[WIP] Add Oura functionality

Makefile

@@ -263,38 +263,32 @@ ci-test: ci-test-go
 test-ginkgo: ginkgo
 	@echo "ginkgo $(GINKGO_FLAGS) $(TEST)"
 	@cd $(ROOT_DIRECTORY) && \
-		{ [ -z `go env GOWORK` ] || GOWORK_FLAGS=-mod=readonly; } && \
-		. ./env.test.sh && $(TIMING_CMD) ginkgo $(GINKGO_FLAGS) $${GOWORK_FLAGS:-} $(TEST)
+		. ./env.test.sh && GOWORK=off $(TIMING_CMD) ginkgo $(GINKGO_FLAGS) $${GOWORK_FLAGS:-} $(TEST)
 
 test-ginkgo-until-failure: ginkgo
 	@echo "ginkgo $(GINKGO_FLAGS) -untilItFails $(TEST)"
 	@cd $(ROOT_DIRECTORY) && \
-		{ [ -z `go env GOWORK` ] || GOWORK_FLAGS=-mod=readonly; } && \
-		. ./env.test.sh && ginkgo $(GINKGO_FLAGS) -untilItFails $${GOWORK_FLAGS:-} $(TEST)
+		. ./env.test.sh && GOWORK=off ginkgo $(GINKGO_FLAGS) -untilItFails $${GOWORK_FLAGS:-} $(TEST)
 
 test-ginkgo-watch: ginkgo
 	@echo "ginkgo watch $(GINKGO_FLAGS) $(TEST)"
 	@cd $(ROOT_DIRECTORY) && \
-		{ [ -z `go env GOWORK` ] || GOWORK_FLAGS=-mod=readonly; } && \
-		. ./env.test.sh && ginkgo watch $(GINKGO_FLAGS) $${GOWORK_FLAGS:-} $(TEST)
+		. ./env.test.sh && GOWORK=off ginkgo watch $(GINKGO_FLAGS) $${GOWORK_FLAGS:-} $(TEST)
 
 ci-test-ginkgo: ginkgo
 	@echo "ginkgo $(GINKGO_FLAGS) $(GINKGO_CI_FLAGS) $(TEST)"
 	@cd $(ROOT_DIRECTORY) && \
-		{ [ -z `go env GOWORK` ] || GOWORK_FLAGS=-mod=readonly; } && \
-		. ./env.test.sh && $(TIMING_CMD) ginkgo $(GINKGO_FLAGS) $(GINKGO_CI_FLAGS) $${GOWORK_FLAGS:-} $(TEST)
+		. ./env.test.sh && GOWORK=off $(TIMING_CMD) ginkgo $(GINKGO_FLAGS) $(GINKGO_CI_FLAGS) $${GOWORK_FLAGS:-} $(TEST)
 
 ci-test-ginkgo-until-failure: ginkgo
 	@echo "ginkgo $(GINKGO_FLAGS) $(GINKGO_CI_FLAGS) -untilItFails $(TEST)"
 	@cd $(ROOT_DIRECTORY) && \
-		{ [ -z `go env GOWORK` ] || GOWORK_FLAGS=-mod=readonly; } && \
-		. ./env.test.sh && ginkgo $(GINKGO_FLAGS) $(GINKGO_CI_FLAGS) -untilItFails $${GOWORK_FLAGS:-} $(TEST)
+		. ./env.test.sh && GOWORK=off ginkgo $(GINKGO_FLAGS) $(GINKGO_CI_FLAGS) -untilItFails $${GOWORK_FLAGS:-} $(TEST)
 
 ci-test-ginkgo-watch: ginkgo
 	@echo "ginkgo watch $(GINKGO_FLAGS) $(GINKGO_CI_WATCH_FLAGS) $(TEST)"
 	@cd $(ROOT_DIRECTORY) && \
-		{ [ -z `go env GOWORK` ] || GOWORK_FLAGS=-mod=readonly; } && \
-		. ./env.test.sh && ginkgo watch $(GINKGO_FLAGS) $(GINKGO_CI_WATCH_FLAGS) $${GOWORK_FLAGS:-} $(TEST)
+		. ./env.test.sh && GOWORK=off ginkgo watch $(GINKGO_FLAGS) $(GINKGO_CI_WATCH_FLAGS) $${GOWORK_FLAGS:-} $(TEST)
 
 test-go:
 	@echo "go test $(GOTEST_FLAGS) $(GOTEST_PKGS)"

auth/providersession/provider_session.go

@@ -0,0 +1,6 @@
+package providersession
+
+import "github.com/tidepool-org/platform/auth"
+
+//go:generate mockgen -destination=test/provider_session_mocks.go -package=test --mock_names=ProviderSessionAccessor=MockClient github.com/tidepool-org/platform/auth ProviderSessionAccessor
+type Client auth.ProviderSessionAccessor

auth/providersession/work/mixin.go

@@ -0,0 +1,80 @@
+package work
+
+import (
+	"context"
+
+	"github.com/tidepool-org/platform/auth"
+	providerSession "github.com/tidepool-org/platform/auth/providersession"
+	"github.com/tidepool-org/platform/errors"
+	"github.com/tidepool-org/platform/log"
+	"github.com/tidepool-org/platform/work"
+	workBase "github.com/tidepool-org/platform/work/base"
+)
+
+const MetadataKeyID = "providerSessionId"
+
+type Mixin struct {
+	*workBase.Processor
+	Client          providerSession.Client
+	ProviderSession *auth.ProviderSession
+}
+
+func NewMixin(processor *workBase.Processor, client providerSession.Client) (*Mixin, error) {
+	if processor == nil {
+		return nil, errors.New("processor is missing")
+	}
+	if client == nil {
+		return nil, errors.New("client is missing")
+	}
+	return &Mixin{
+		Processor: processor,
+		Client:    client,
+	}, nil
+}
+
+func (m *Mixin) ProviderSessionIDFromMetadata() (*string, error) {
+	parser := m.MetadataParser()
+	providerSessionID := parser.String(MetadataKeyID)
+	if err := parser.Error(); err != nil {
+		return nil, errors.Wrap(err, "unable to parse provider session id from metadata")
+	}
+	return providerSessionID, nil
+}
+
+func (m *Mixin) FetchProviderSessionFromMetadata() *work.ProcessResult {
+	providerSessionID, err := m.ProviderSessionIDFromMetadata()
+	if err != nil || providerSessionID == nil {
+		return m.Failed(errors.Wrap(err, "unable to get provider session id from metadata"))
+	}
+	return m.FetchProviderSession(*providerSessionID)
+}
+
+func (m *Mixin) FetchProviderSession(providerSessionID string) *work.ProcessResult {
+	providerSession, err := m.Client.GetProviderSession(m.Context(), providerSessionID)
+	if err != nil {
+		return m.Failing(errors.Wrap(err, "unable to fetch provider session"))
+	} else if providerSession == nil {
+		return m.Failed(errors.New("provider session is missing"))
+	}
+	m.ProviderSession = providerSession
+
+	m.AddFieldToContext("providerSession", log.Fields{"id": m.ProviderSession.ID, "userId": m.ProviderSession.UserID})
+
+	return nil
+}
+
+func (m *Mixin) UpdateProviderSession(providerSessionUpdate auth.ProviderSessionUpdate) *work.ProcessResult {
+	if m.ProviderSession == nil {
+		return m.Failed(errors.New("provider session is missing"))
+	}
+
+	providerSession, err := m.Client.UpdateProviderSession(context.WithoutCancel(m.Context()), m.ProviderSession.ID, &providerSessionUpdate)
+	if err != nil {
+		return m.Failing(errors.Wrap(err, "unable to update provider session"))
+	} else if providerSession == nil {
+		return m.Failed(errors.New("provider session is missing"))
+	}
+	m.ProviderSession = providerSession
+
+	return nil
+}