payments/internal/api/v3/handler_schedules_list_test.go

package v3

import (
	"fmt"
	"net/http"
	"net/http/httptest"

	"github.com/hanzo-fi/go-libs/v5/pkg/storage/bun/paginate"
	"github.com/hanzo-fi/payments/internal/api/backend"
	"github.com/hanzo-fi/payments/pkg/domain/models"
	"github.com/google/uuid"
	. "github.com/onsi/ginkgo/v2"
	"go.uber.org/mock/gomock"
)

var _ = Describe("API v3 Schedules List", func() {
	var (
		handlerFn http.HandlerFunc
	)

	Context("list schedules", func() {
		var (
			w *httptest.ResponseRecorder
			m *backend.MockBackend
		)
		BeforeEach(func() {
			w = httptest.NewRecorder()
			ctrl := gomock.NewController(GinkgoT())
			m = backend.NewMockBackend(ctrl)
			handlerFn = schedulesList(m)
		})

		It("should return an validation error when connector ID is invalid", func(ctx SpecContext) {
			req := prepareQueryRequest(http.MethodGet, "connectorID", "invalidvalue")
			handlerFn(w, req)

			assertExpectedResponse(w.Result(), http.StatusBadRequest, "INVALID")
		})

		It("should return an internal server error when backend returns error", func(ctx SpecContext) {
			connectorID := models.ConnectorID{Provider: "psp", Reference: uuid.New()}
			req := prepareQueryRequest(http.MethodGet, "connectorID", connectorID.String())
			m.EXPECT().SchedulesList(gomock.Any(), gomock.Any()).Return(
				&paginate.Cursor[models.Schedule]{}, fmt.Errorf("schedules list error"),
			)
			handlerFn(w, req)

			assertExpectedResponse(w.Result(), http.StatusInternalServerError, "INTERNAL")
		})

		It("should return a cursor object", func(ctx SpecContext) {
			connectorID := models.ConnectorID{Provider: "psp", Reference: uuid.New()}
			req := prepareQueryRequest(http.MethodGet, "connectorID", connectorID.String())
			m.EXPECT().SchedulesList(gomock.Any(), gomock.Any()).Return(
				&paginate.Cursor[models.Schedule]{}, nil,
			)
			handlerFn(w, req)

			assertExpectedResponse(w.Result(), http.StatusOK, "cursor")
		})
	})
})