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]>
69 lines
1.8 KiB
Go
69 lines
1.8 KiB
Go
package client
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/http"
|
|
"strconv"
|
|
)
|
|
|
|
// Timeline tracks the pagination state for fetching transactions
|
|
type Timeline struct {
|
|
// Cursors encountered while scanning backwards to find oldest records
|
|
// These will be used in reverse order to fetch forward chronologically
|
|
Cursors []string `json:"cursors"`
|
|
// Whether we've found the oldest records
|
|
FoundOldest bool `json:"found_oldest"`
|
|
}
|
|
|
|
func (t Timeline) IsCaughtUp() bool {
|
|
return t.FoundOldest
|
|
}
|
|
|
|
func (c *client) scanForOldest(
|
|
ctx context.Context,
|
|
timeline Timeline,
|
|
endpoint string,
|
|
pageSize int,
|
|
) ([]*Transaction, Timeline, bool, error) {
|
|
req, err := c.newRequest(ctx, http.MethodGet, endpoint, http.NoBody)
|
|
if err != nil {
|
|
return nil, timeline, false, fmt.Errorf("failed to create timeline transactions request: %w", err)
|
|
}
|
|
|
|
q := req.URL.Query()
|
|
q.Add("limit", strconv.Itoa(pageSize))
|
|
|
|
// Use the last cursor if we have any
|
|
if len(timeline.Cursors) > 0 {
|
|
q.Add("cursor", timeline.Cursors[len(timeline.Cursors)-1])
|
|
}
|
|
req.URL.RawQuery = q.Encode()
|
|
|
|
var res ResponseWrapper[[]*Transaction]
|
|
var errRes increaseError
|
|
_, err = c.httpClient.Do(ctx, req, &res, &errRes)
|
|
if err != nil {
|
|
return nil, timeline, false, fmt.Errorf("failed to get %s for timeline: %w %w", endpoint, err, errRes.Error())
|
|
}
|
|
|
|
// If we got no data, we're done scanning
|
|
if len(res.Data) == 0 {
|
|
timeline.FoundOldest = true
|
|
return nil, timeline, false, nil
|
|
}
|
|
|
|
// If there's no next cursor, we've found the oldest data
|
|
if res.NextCursor == "" {
|
|
timeline.FoundOldest = true
|
|
if len(timeline.Cursors) > 0 {
|
|
timeline.Cursors = timeline.Cursors[:len(timeline.Cursors)-1]
|
|
}
|
|
return res.Data, timeline, len(timeline.Cursors) > 0, nil
|
|
}
|
|
|
|
// Store the next cursor and continue scanning
|
|
timeline.Cursors = append(timeline.Cursors, res.NextCursor)
|
|
return nil, timeline, true, nil
|
|
}
|