Add tests for shopify orders

Author: toddkazakov

auth/service/service/service.go

@@ -333,7 +333,7 @@ func (s *Service) initializeRouter() error {
 		return errors.Wrap(err, "unable to create fulfillment event processor")
 	}
 
-	ordersCreateEventProcessor, err := shopify.NewOrdersCreateEventProcessor(s.Logger(), customerIOClient, shopifyClnt)
+	ordersCreateEventProcessor, err := shopify.NewOrdersCreateEventProcessor(s.Logger(), customerIOClient)
 	if err != nil {
 		return errors.Wrap(err, "unable to create orders create event processor")
 	}

oura/jotform/webhook_test.go

@@ -23,7 +23,6 @@ import (
 	logTest "github.com/tidepool-org/platform/log/test"
 	"github.com/tidepool-org/platform/oura/customerio"
 	"github.com/tidepool-org/platform/oura/jotform"
-	jotformTest "github.com/tidepool-org/platform/oura/jotform/test"
 	shopfiyTest "github.com/tidepool-org/platform/oura/shopify/test"
 	userTest "github.com/tidepool-org/platform/user/test"
 )
@@ -101,15 +100,15 @@ var _ = Describe("WebhookProcessor", func() {
 			submissionID := "6410095903544943563"
 			userID := "1aacb960-430c-4081-8b3b-a32688807dc5"
 
-			submission, err := jotformTest.LoadFixture("./test/fixtures/submission.json")
+			submission, err := ouraTest.LoadFixture("./test/fixtures/submission.json")
 			Expect(err).ToNot(HaveOccurred())
 
 			jotformResponses.AddResponse(
 				[]ouraTest.RequestMatcher{ouraTest.NewRequestMethodAndPathMatcher(http.MethodGet, "/v1/submission/"+submissionID)},
 				ouraTest.Response{StatusCode: http.StatusOK, Body: submission},
 			)
 
-			customer, err := jotformTest.LoadFixture("./test/fixtures/customer.json")
+			customer, err := ouraTest.LoadFixture("./test/fixtures/customer.json")
 			Expect(err).ToNot(HaveOccurred())
 
 			appAPIResponses.AddResponse(
@@ -171,15 +170,15 @@ var _ = Describe("WebhookProcessor", func() {
 			submissionID := "6410095903544943563"
 			userID := "1aacb960-430c-4081-8b3b-a32688807dc5"
 
-			submission, err := jotformTest.LoadFixture("./test/fixtures/submission.json")
+			submission, err := ouraTest.LoadFixture("./test/fixtures/submission.json")
 			Expect(err).ToNot(HaveOccurred())
 
 			jotformResponses.AddResponse(
 				[]ouraTest.RequestMatcher{ouraTest.NewRequestMethodAndPathMatcher(http.MethodGet, "/v1/submission/"+submissionID)},
 				ouraTest.Response{StatusCode: http.StatusOK, Body: submission},
 			)
 
-			customer, err := jotformTest.LoadFixture("./test/fixtures/customer.json")
+			customer, err := ouraTest.LoadFixture("./test/fixtures/customer.json")
 			Expect(err).ToNot(HaveOccurred())
 
 			appAPIResponses.AddResponse(
@@ -231,7 +230,7 @@ var _ = Describe("WebhookProcessor", func() {
 			submissionID := "6410095903544943563"
 			userID := "1aacb960-430c-4081-8b3b-a32688807dc5"
 
-			submission, err := jotformTest.LoadFixture("./test/fixtures/submission.json")
+			submission, err := ouraTest.LoadFixture("./test/fixtures/submission.json")
 			Expect(err).ToNot(HaveOccurred())
 
 			jotformResponses.AddResponse(
@@ -252,7 +251,7 @@ var _ = Describe("WebhookProcessor", func() {
 			submissionID := "6410095903544943563"
 			userID := "1aacb960-430c-4081-8b3b-a32688807dc5"
 
-			submission, err := jotformTest.LoadFixture("./test/fixtures/submission_participant_mismatch.json")
+			submission, err := ouraTest.LoadFixture("./test/fixtures/submission_participant_mismatch.json")
 			Expect(err).ToNot(HaveOccurred())
 
 			jotformResponses.AddResponse(
@@ -273,15 +272,15 @@ var _ = Describe("WebhookProcessor", func() {
 			submissionID := "6410095903544943563"
 			userID := "1aacb960-430c-4081-8b3b-a32688807dc5"
 
-			submission, err := jotformTest.LoadFixture("./test/fixtures/submission.json")
+			submission, err := ouraTest.LoadFixture("./test/fixtures/submission.json")
 			Expect(err).ToNot(HaveOccurred())
 
 			jotformResponses.AddResponse(
 				[]ouraTest.RequestMatcher{ouraTest.NewRequestMethodAndPathMatcher(http.MethodGet, "/v1/submission/"+submissionID)},
 				ouraTest.Response{StatusCode: http.StatusOK, Body: submission},
 			)
 
-			customer, err := jotformTest.LoadFixture("./test/fixtures/customer.json")
+			customer, err := ouraTest.LoadFixture("./test/fixtures/customer.json")
 			Expect(err).ToNot(HaveOccurred())
 
 			appAPIResponses.AddResponse(

oura/shopify/api/api_suite_test.go

@@ -0,0 +1,11 @@
+package api_test
+
+import (
+	"testing"
+
+	"github.com/tidepool-org/platform/test"
+)
+
+func TestSuite(t *testing.T) {
+	test.Test(t)
+}

oura/shopify/api/router_test.go

@@ -0,0 +1,64 @@
+package api_test
+
+import (
+	"bytes"
+	"context"
+	"net/http"
+
+	"github.com/ant0ine/go-json-rest/rest"
+	. "github.com/onsi/ginkgo/v2"
+	. "github.com/onsi/gomega"
+	"github.com/tidepool-org/platform/log"
+	"github.com/tidepool-org/platform/log/null"
+
+	"github.com/tidepool-org/platform/oura/test"
+
+	"github.com/tidepool-org/platform/oura/shopify/api"
+	"github.com/tidepool-org/platform/request"
+
+	serviceTest "github.com/tidepool-org/platform/service/test"
+)
+
+var _ = Describe("Router", func() {
+	Context("NewRouter", func() {
+		It("returns successfully", func() {
+			rtr, err := api.NewRouter(nil, nil)
+			Expect(err).ToNot(HaveOccurred())
+			Expect(rtr).ToNot(BeNil())
+		})
+	})
+
+	Context("with new router", func() {
+		var rtr *api.Router
+
+		BeforeEach(func() {
+			var err error
+			rtr, err = api.NewRouter(nil, nil)
+			Expect(err).ToNot(HaveOccurred())
+			Expect(rtr).ToNot(BeNil())
+		})
+
+		Context("Routes", func() {
+			It("returns the expected routes", func() {
+				Expect(rtr.Routes()).ToNot(BeEmpty())
+			})
+		})
+
+		Context("HandleOrdersCreateEvent", func() {
+			It("returns successfully", func() {
+				ctx := log.NewContextWithLogger(request.NewContextWithAuthDetails(context.Background(), nil), null.NewLogger())
+				body, err := test.LoadFixture("./test/fixtures/orders_create.json")
+				Expect(err).ToNot(HaveOccurred())
+
+				httpReq, err := http.NewRequestWithContext(ctx, http.MethodPost, "", bytes.NewBuffer([]byte(body)))
+				Expect(err).ToNot(HaveOccurred())
+
+				req := &rest.Request{
+					Request: httpReq,
+				}
+				res := serviceTest.NewMockRestResponseWriter()
+				rtr.HandleOrdersCreateEvent(res, req)
+			})
+		})
+	})
+})