Add shopify webhook routes

Author: toddkazakov

auth/service/service/service.go

@@ -8,6 +8,7 @@ import (
 	"github.com/tidepool-org/platform/mailer"
 	"github.com/tidepool-org/platform/oura/customerio"
 	"github.com/tidepool-org/platform/oura/jotform"
+	"github.com/tidepool-org/platform/oura/shopify"
 
 	userClient "github.com/tidepool-org/platform/user/client"
 
@@ -40,6 +41,8 @@ import (
 	"github.com/tidepool-org/platform/errors"
 	"github.com/tidepool-org/platform/events"
 	jotformAPI "github.com/tidepool-org/platform/oura/jotform/api"
+	shopifyAPI "github.com/tidepool-org/platform/oura/shopify/api"
+	shopifyClient "github.com/tidepool-org/platform/oura/shopify/client"
 
 	"github.com/tidepool-org/platform/log"
 	oauthProvider "github.com/tidepool-org/platform/oauth/provider"
@@ -305,7 +308,17 @@ func (s *Service) initializeRouter() error {
 		return errors.Wrap(err, "unable to create user client")
 	}
 
-	webhookProcessor, err := jotform.NewWebhookProcessor(jotformConfig, s.Logger(), s.consentService, customerIOClient, usrClient)
+	shopifyConfig := shopify.ClientConfig{}
+	if err := envconfig.Process("", &shopifyConfig); err != nil {
+		return errors.Wrap(err, "unable to load shopify config")
+	}
+
+	shopifyClnt, err := shopifyClient.New(context.Background(), shopifyConfig)
+	if err != nil {
+		return errors.Wrap(err, "unable to create shopify client")
+	}
+
+	webhookProcessor, err := jotform.NewWebhookProcessor(jotformConfig, s.Logger(), s.consentService, customerIOClient, usrClient, shopifyClnt)
 	if err != nil {
 		return errors.Wrap(err, "unable to create jotform webhook processor")
 	}
@@ -315,9 +328,19 @@ func (s *Service) initializeRouter() error {
 		return errors.Wrap(err, "unable to create jotform router")
 	}
 
+	fulfillmentEventCreatedProcessor, err := shopify.NewFulfillmentCreatedEventProcessor(s.Logger(), customerIOClient, shopifyClnt)
+	if err != nil {
+		return errors.Wrap(err, "unable to create fulfillment created event processor")
+	}
+
+	shopifyRouter, err := shopifyAPI.NewRouter(fulfillmentEventCreatedProcessor)
+	if err != nil {
+		return errors.Wrap(err, "unable to create shopify router")
+	}
+
 	s.Logger().Debug("Initializing routers")
 
-	if err = s.API().InitializeRouters(apiRouter, v1Router, consentV1Router, jotformRouter); err != nil {
+	if err = s.API().InitializeRouters(apiRouter, v1Router, consentV1Router, jotformRouter, shopifyRouter); err != nil {
 		return errors.Wrap(err, "unable to initialize routers")
 	}
 

oura/shopify/api/router.go

@@ -13,8 +13,10 @@ type Router struct {
 	fulfillmentCreatedEventProcessor *shopify.FulfillmentCreatedEventProcessor
 }
 
-func NewRouter() (*Router, error) {
-	return &Router{}, nil
+func NewRouter(fulfillmentCreatedEventProcessor *shopify.FulfillmentCreatedEventProcessor) (*Router, error) {
+	return &Router{
+		fulfillmentCreatedEventProcessor: fulfillmentCreatedEventProcessor,
+	}, nil
 }
 
 func (r *Router) Routes() []*rest.Route {

oura/shopify/client.go

@@ -3,9 +3,9 @@ package shopify
 import "context"
 
 type ClientConfig struct {
-	StoreID      string `envconfig:"TIDEPOOL_SHOPIFY_STORE_ID" required:"true"`
-	ClientID     string `envconfig:"TIDEPOOL_SHOPIFY_CLIENT_ID" required:"true"`
-	ClientSecret string `envconfig:"TIDEPOOL_SHOPIFY_CLIENT_SECRET" required:"true"`
+	StoreID      string `envconfig:"TIDEPOOL_SHOPIFY_STORE_ID"`
+	ClientID     string `envconfig:"TIDEPOOL_SHOPIFY_CLIENT_ID"`
+	ClientSecret string `envconfig:"TIDEPOOL_SHOPIFY_CLIENT_SECRET"`
 }
 
 //go:generate mockgen -source=client.go -destination=./test/client.go -package=test Client

oura/shopify/client/client.go

@@ -15,7 +15,7 @@ type defaultClient struct {
 	gql graphql.Client
 }
 
-func NewClient(ctx context.Context, cfg shopify.ClientConfig) (shopify.Client, error) {
+func New(ctx context.Context, cfg shopify.ClientConfig) (shopify.Client, error) {
 	oauthConfig := clientcredentials.Config{
 		ClientID:     cfg.ClientID,
 		ClientSecret: cfg.ClientSecret,