payments/internal/api/v2/handler_connectors_list.go

package v2

import (
	"encoding/json"
	"net/http"

	"github.com/hanzo-fi/go-libs/v5/pkg/storage/bun/paginate"
	"github.com/hanzo-fi/go-libs/v5/pkg/transport/api"
	"github.com/hanzo-fi/payments/internal/api/backend"
	"github.com/hanzo-fi/payments/internal/api/common"
	"github.com/hanzo-fi/payments/internal/otel"
	"github.com/hanzo-fi/payments/internal/storage"
)

// NOTE: in order to maintain previous version compatibility, we need to keep the
// same response structure as the previous version of the API
type connectorsListElement struct {
	Provider             string `json:"provider"`
	ConnectorID          string `json:"connectorID"`
	Name                 string `json:"name"`
	Enabled              bool   `json:"enabled"`
	ScheduledForDeletion bool   `json:"scheduledForDeletion"`
}

func connectorsList(backend backend.Backend) http.HandlerFunc {
	return func(w http.ResponseWriter, r *http.Request) {
		ctx, span := otel.Tracer().Start(r.Context(), "v2_connectorsList")
		defer span.End()

		connectors, err := backend.ConnectorsList(
			ctx,
			storage.NewListConnectorsQuery(
				paginate.NewPaginatedQueryOptions(storage.ConnectorQuery{}).
					// NOTE: previous version of payments did not have pagination, so
					// fetch everything and return it all
					WithPageSize(1000),
			),
		)
		if err != nil {
			otel.RecordError(span, err)
			handleServiceErrors(w, r, err)
			return
		}

		data := make([]*connectorsListElement, len(connectors.Data))
		for i := range connectors.Data {
			data[i] = &connectorsListElement{
				Provider:             toV2Provider(connectors.Data[i].Provider),
				ConnectorID:          connectors.Data[i].ID.String(),
				Name:                 connectors.Data[i].Name,
				ScheduledForDeletion: connectors.Data[i].ScheduledForDeletion,
				Enabled:              true,
			}
		}

		err = json.NewEncoder(w).Encode(
			api.BaseResponse[[]*connectorsListElement]{
				Data: &data,
			})
		if err != nil {
			otel.RecordError(span, err)
			common.InternalServerError(w, r, err)
			return
		}
	}
}