mirror of
https://github.com/hanzo-fi/payments.git
synced 2026-10-30 20:31:20 +00:00
d045ece673
* Reflect new amount for returned/reverted transaction. * Enhance payout and transfer response structures with transaction IDs and pending transaction IDs; * Update payment creation logic to utilize new fields. * Remove periodic execution of fetch_payments * Update ParentReference and Reference fields in payment model for transfer creation * Update pkg/client/ * Set return payment to SUCCEEDED, remove adjustment update * trigger ready for review * retrigger CI * Reuse Refund functionality instead of created Returned upsert operation * fix: ensure PendingTimeline and DeclinedTimeline are preserved in payments state test: add unit test to preserve timeline states in FetchNextPayments * Retrigger CI --------- Co-authored-by: gitstart_bot <[email protected]>
46 lines
1.2 KiB
Go
46 lines
1.2 KiB
Go
package increase
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"fmt"
|
|
"math/big"
|
|
|
|
"github.com/formancehq/payments/internal/models"
|
|
)
|
|
|
|
func (p *Plugin) fetchNextBalances(ctx context.Context, req models.FetchNextBalancesRequest) (models.FetchNextBalancesResponse, error) {
|
|
var from models.PSPAccount
|
|
if req.FromPayload == nil {
|
|
return models.FetchNextBalancesResponse{}, models.ErrMissingFromPayloadInRequest
|
|
}
|
|
if err := json.Unmarshal(req.FromPayload, &from); err != nil {
|
|
return models.FetchNextBalancesResponse{}, err
|
|
}
|
|
|
|
balance, atTime, err := p.client.GetAccountBalance(ctx, from.Reference)
|
|
if err != nil {
|
|
return models.FetchNextBalancesResponse{}, err
|
|
}
|
|
|
|
var amount big.Int
|
|
_, ok := amount.SetString(balance.AvailableBalance.String(), 10)
|
|
if !ok {
|
|
return models.FetchNextBalancesResponse{}, fmt.Errorf("failed to parse amount: %s", balance.AvailableBalance.String())
|
|
}
|
|
|
|
accountBalances := models.PSPBalance{
|
|
AccountReference: balance.AccountID,
|
|
Amount: &amount,
|
|
CreatedAt: atTime,
|
|
}
|
|
if from.DefaultAsset != nil {
|
|
accountBalances.Asset = *from.DefaultAsset
|
|
}
|
|
|
|
return models.FetchNextBalancesResponse{
|
|
Balances: []models.PSPBalance{accountBalances},
|
|
HasMore: false,
|
|
}, nil
|
|
}
|