payments/internal/api/v2/handler_transfer_initiations_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/go-libs/v5/pkg/types/pointer"
	"github.com/hanzo-fi/payments/internal/api/backend"
	"github.com/hanzo-fi/payments/internal/api/common"
	"github.com/hanzo-fi/payments/pkg/domain/models"
	"github.com/hanzo-fi/payments/internal/otel"
	"github.com/hanzo-fi/payments/internal/storage"
)

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

		query, err := paginate.Extract[storage.ListPaymentInitiationsQuery](r, func() (*storage.ListPaymentInitiationsQuery, error) {
			options, err := getPagination(span, r, storage.PaymentInitiationQuery{})
			if err != nil {
				return nil, err
			}
			return pointer.For(storage.NewListPaymentInitiationsQuery(*options)), nil
		})
		if err != nil {
			otel.RecordError(span, err)
			api.BadRequest(w, ErrValidation, err)
			return
		}

		cursor, err := backend.PaymentInitiationsList(ctx, *query)
		if err != nil {
			otel.RecordError(span, err)
			handleServiceErrors(w, r, err)
			return
		}

		data := make([]transferInitiationResponse, len(cursor.Data))
		for i := range cursor.Data {
			data[i] = translatePaymentInitiationToResponse(&cursor.Data[i])

			lastAdjustment, err := backend.PaymentInitiationAdjustmentsGetLast(ctx, cursor.Data[i].ID)
			if err != nil {
				otel.RecordError(span, err)
				handleServiceErrors(w, r, err)
				return
			}

			status := ""
			switch lastAdjustment.Status {
			case models.PAYMENT_INITIATION_ADJUSTMENT_STATUS_SCHEDULED_FOR_PROCESSING:
				// PAYMENT_INITIATION_ADJUSTMENT_STATUS_SCHEDULED_FOR_PROCESSING is not supported
				// in v2 as it is introduced in v3. We map it to PROCESSING for backward compatibility.
				status = models.PAYMENT_INITIATION_ADJUSTMENT_STATUS_PROCESSING.String()
			default:
				status = lastAdjustment.Status.String()
			}

			if lastAdjustment != nil {
				data[i].Status = status
				data[i].Error = func() string {
					if lastAdjustment.Error == nil {
						return ""
					}
					return lastAdjustment.Error.Error()
				}()
			}
		}

		err = json.NewEncoder(w).Encode(api.BaseResponse[transferInitiationResponse]{
			Cursor: &paginate.Cursor[transferInitiationResponse]{
				PageSize: cursor.PageSize,
				HasMore:  cursor.HasMore,
				Previous: cursor.Previous,
				Next:     cursor.Next,
				Data:     data,
			},
		})
		if err != nil {
			otel.RecordError(span, err)
			common.InternalServerError(w, r, err)
			return
		}
	}
}