feat(payments): add payments accounts pool system (#939)

components/payments/cmd/api/internal/api/backend/backend.go

@@ -3,6 +3,7 @@ package backend
 import (
 	"context"
 
+	"github.com/formancehq/payments/cmd/api/internal/api/service"
 	"github.com/formancehq/payments/cmd/api/internal/storage"
 	"github.com/formancehq/payments/internal/models"
 	"github.com/google/uuid"
@@ -21,6 +22,13 @@ type Service interface {
 	ListPayments(ctx context.Context, pagination storage.PaginatorQuery) ([]*models.Payment, storage.PaginationDetails, error)
 	GetPayment(ctx context.Context, id string) (*models.Payment, error)
 	UpdatePaymentMetadata(ctx context.Context, paymentID models.PaymentID, metadata map[string]string) error
+	CreatePool(ctx context.Context, req *service.CreatePoolRequest) (*models.Pool, error)
+	AddAccountToPool(ctx context.Context, poolID string, req *service.AddAccountToPoolRequest) error
+	RemoveAccountFromPool(ctx context.Context, poolID string, accountID string) error
+	ListPools(ctx context.Context, pagination storage.PaginatorQuery) ([]*models.Pool, storage.PaginationDetails, error)
+	GetPool(ctx context.Context, poolID string) (*models.Pool, error)
+	GetPoolBalance(ctx context.Context, poolID string, atTime string) (*service.GetPoolBalanceResponse, error)
+	DeletePool(ctx context.Context, poolID string) error
 }
 
 type Backend interface {

components/payments/cmd/api/internal/api/metadata.go

@@ -23,13 +23,13 @@ func updateMetadataHandler(b backend.Backend) http.HandlerFunc {
 
 		var metadata service.UpdateMetadataRequest
 		if r.ContentLength == 0 {
-			api.BadRequest(w, ErrMissingBody, errors.New("body is required"))
+			api.BadRequest(w, ErrMissingOrInvalidBody, errors.New("body is required"))
 			return
 		}
 
 		err = json.NewDecoder(r.Body).Decode(&metadata)
 		if err != nil {
-			api.BadRequest(w, ErrInvalidBody, err)
+			api.BadRequest(w, ErrMissingOrInvalidBody, err)
 			return
 		}
 

components/payments/cmd/api/internal/api/metadata_test.go

@@ -53,14 +53,14 @@ func TestMetadata(t *testing.T) {
 			name:               "missing body",
 			paymentID:          paymentID.String(),
 			expectedStatusCode: http.StatusBadRequest,
-			expectedErrorCode:  ErrMissingBody,
+			expectedErrorCode:  ErrMissingOrInvalidBody,
 		},
 		{
 			name:               "invalid body",
 			paymentID:          paymentID.String(),
 			body:               "invalid",
 			expectedStatusCode: http.StatusBadRequest,
-			expectedErrorCode:  ErrInvalidBody,
+			expectedErrorCode:  ErrMissingOrInvalidBody,
 		},
 		{
 			name:               "invalid paymentID",

components/payments/cmd/api/internal/api/module.go

@@ -24,12 +24,11 @@ const (
 	otelTracesFlag = "otel-traces"
 	serviceName    = "Payments"
 
-	ErrUniqueReference = "CONFLICT"
-	ErrNotFound        = "NOT_FOUND"
-	ErrInvalidID       = "INVALID_ID"
-	ErrMissingBody     = "MISSING_BODY"
-	ErrInvalidBody     = "INVALID_BODY"
-	ErrValidation      = "VALIDATION"
+	ErrUniqueReference      = "CONFLICT"
+	ErrNotFound             = "NOT_FOUND"
+	ErrInvalidID            = "INVALID_ID"
+	ErrMissingOrInvalidBody = "MISSING_OR_INVALID_BODY"
+	ErrValidation           = "VALIDATION"
 )
 
 func HTTPModule(serviceInfo api.ServiceInfo, bind string) fx.Option {