payments/internal/connectors/plugins/public/mangopay/client/payout.go

package client

import (
	"bytes"
	"context"
	"encoding/json"
	"fmt"
	"net/http"

	"github.com/formancehq/payments/internal/connectors/metrics"
	errorsutils "github.com/formancehq/payments/internal/utils/errors"
)

type PayoutRequest struct {
	Reference           string `json:"-"` // Needed for idempotency
	AuthorID            string `json:"AuthorId"`
	DebitedFunds        Funds  `json:"DebitedFunds"`
	Fees                Funds  `json:"Fees"`
	DebitedWalletID     string `json:"DebitedWalletId"`
	BankAccountID       string `json:"BankAccountId"`
	BankWireRef         string `json:"BankWireRef,omitempty"`
	PayoutModeRequested string `json:"PayoutModeRequested,omitempty"`
}

type PayoutResponse struct {
	ID              string `json:"Id"`
	ModeRequest     string `json:"ModeRequested"`
	ModeApplied     string `json:"ModeApplied"`
	FallbackReason  string `json:"FallbackReason"`
	CreationDate    int64  `json:"CreationDate"`
	AuthorID        string `json:"AuthorId"`
	DebitedFunds    Funds  `json:"DebitedFunds"`
	Fees            Funds  `json:"Fees"`
	CreditedFunds   Funds  `json:"CreditedFunds"`
	Status          string `json:"Status"`
	ResultCode      string `json:"ResultCode"`
	ResultMessage   string `json:"ResultMessage"`
	Type            string `json:"Type"`
	Nature          string `json:"Nature"`
	ExecutionDate   int64  `json:"ExecutionDate"`
	BankAccountID   string `json:"BankAccountId"`
	DebitedWalletID string `json:"DebitedWalletId"`
	PaymentType     string `json:"PaymentType"`
	BankWireRef     string `json:"BankWireRef"`
}

func (c *client) InitiatePayout(ctx context.Context, payoutRequest *PayoutRequest) (*PayoutResponse, error) {
	ctx = context.WithValue(ctx, metrics.MetricOperationContextKey, "initiate_payout")

	endpoint := fmt.Sprintf("%s/v2.01/%s/payouts/bankwire", c.endpoint, c.clientID)

	body, err := json.Marshal(payoutRequest)
	if err != nil {
		return nil, fmt.Errorf("failed to marshal transfer request: %w", err)
	}

	req, err := http.NewRequestWithContext(ctx, http.MethodPost, endpoint, bytes.NewBuffer(body))
	if err != nil {
		return nil, fmt.Errorf("failed to create login request: %w", err)
	}
	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("Idempotency-Key", payoutRequest.Reference)

	var payoutResponse PayoutResponse
	var errRes mangopayError
	_, err = c.httpClient.Do(ctx, req, &payoutResponse, &errRes)
	if err != nil {
		return nil, errorsutils.NewWrappedError(
			fmt.Errorf("failed to initiate payout: %v", errRes.Error()),
			err,
		)
	}
	return &payoutResponse, nil
}

func (c *client) GetPayout(ctx context.Context, payoutID string) (*PayoutResponse, error) {
	ctx = context.WithValue(ctx, metrics.MetricOperationContextKey, "get_payout")

	endpoint := fmt.Sprintf("%s/v2.01/%s/payouts/%s", c.endpoint, c.clientID, payoutID)

	req, err := http.NewRequestWithContext(ctx, http.MethodGet, endpoint, nil)
	if err != nil {
		return nil, fmt.Errorf("failed to create get payout request: %w", err)
	}

	var payoutResponse PayoutResponse
	statusCode, err := c.httpClient.Do(ctx, req, &payoutResponse, nil)
	if err != nil {
		return nil, errorsutils.NewWrappedError(
			fmt.Errorf("failed to get payout: status code %d", statusCode),
			err,
		)
	}
	return &payoutResponse, nil
}