payments/ce/plugins/mangopay/payouts.go

package mangopay

import (
	"context"
	"encoding/json"
	"fmt"
	"math/big"
	"regexp"
	"time"

	"github.com/hanzo-fi/go-libs/v5/pkg/types/currency"
	"github.com/hanzo-fi/payments/ce/plugins/mangopay/client"
	"github.com/hanzo-fi/payments/pkg/domain/models"
	errorsutils "github.com/hanzo-fi/payments/pkg/domain/errors"
	"github.com/google/uuid"
)

var (
	bankWireRefPatternRegexp = regexp.MustCompile("[a-zA-Z0-9 ]*")
)

func (p *Plugin) validatePayoutRequest(pi models.PSPPaymentInitiation) error {
	_, err := uuid.Parse(pi.Reference)
	if err != nil {
		return errorsutils.NewWrappedError(
			fmt.Errorf("reference %s is required to be an uuid in payout request", pi.Reference),
			models.ErrInvalidRequest,
		)
	}

	if pi.SourceAccount == nil {
		return errorsutils.NewWrappedError(
			fmt.Errorf("source account is required in payout request"),
			models.ErrInvalidRequest,
		)
	}

	if pi.DestinationAccount == nil {
		return errorsutils.NewWrappedError(
			fmt.Errorf("destination account is required in payout request"),
			models.ErrInvalidRequest,
		)
	}

	_, ok := pi.SourceAccount.Metadata[userIDMetadataKey]
	if !ok {
		return errorsutils.NewWrappedError(
			fmt.Errorf("source account metadata with user id is required in payout request"),
			models.ErrInvalidRequest,
		)
	}

	if len(pi.Description) > 12 || !bankWireRefPatternRegexp.MatchString(pi.Description) {
		return errorsutils.NewWrappedError(
			fmt.Errorf("description must be alphanumeric and less than 12 characters in payout request"),
			models.ErrInvalidRequest,
		)
	}

	return nil
}

func (p *Plugin) createPayout(ctx context.Context, pi models.PSPPaymentInitiation) (models.PSPPayment, error) {
	if err := p.validatePayoutRequest(pi); err != nil {
		return models.PSPPayment{}, err
	}

	userID := pi.SourceAccount.Metadata[userIDMetadataKey]

	curr, _, err := currency.GetCurrencyAndPrecisionFromAsset(supportedCurrenciesWithDecimal, pi.Asset)
	if err != nil {
		return models.PSPPayment{}, errorsutils.NewWrappedError(
			fmt.Errorf("failed to get currency and precision from asset: %w", err),
			models.ErrInvalidRequest,
		)
	}

	resp, err := p.client.InitiatePayout(ctx, &client.PayoutRequest{
		Reference: pi.Reference,
		AuthorID:  userID,
		DebitedFunds: client.Funds{
			Currency: curr,
			Amount:   json.Number(pi.Amount.String()),
		},
		Fees: client.Funds{
			Currency: curr,
			Amount:   json.Number("0"),
		},
		DebitedWalletID: pi.SourceAccount.Reference,
		BankAccountID:   pi.DestinationAccount.Reference,
		BankWireRef:     pi.Description,
	})
	if err != nil {
		return models.PSPPayment{}, err
	}

	payment, err := FromPayoutToPayment(resp, pi.DestinationAccount.Reference)
	if err != nil {
		return models.PSPPayment{}, err
	}

	return payment, nil
}

func FromPayoutToPayment(from *client.PayoutResponse, destinationAccountReference string) (models.PSPPayment, error) {
	raw, err := json.Marshal(from)
	if err != nil {
		return models.PSPPayment{}, err
	}

	var amount big.Int
	_, ok := amount.SetString(from.DebitedFunds.Amount.String(), 10)
	if !ok {
		return models.PSPPayment{}, fmt.Errorf("failed to parse amount %s", from.DebitedFunds.Amount.String())
	}

	return models.PSPPayment{
		Reference:                   from.ID,
		CreatedAt:                   time.Unix(from.CreationDate, 0),
		Type:                        models.PAYMENT_TYPE_PAYOUT,
		Amount:                      &amount,
		Asset:                       currency.FormatAsset(supportedCurrenciesWithDecimal, from.DebitedFunds.Currency),
		Scheme:                      models.PAYMENT_SCHEME_OTHER,
		Status:                      matchPaymentStatus(from.Status),
		SourceAccountReference:      &from.DebitedWalletID,
		DestinationAccountReference: &destinationAccountReference,
		Raw:                         raw,
	}, nil
}