mirror of
https://github.com/hanzo-fi/payments.git
synced 2026-10-30 20:31:20 +00:00
CrimsonandGitHub
db0561d07e
* Set webhook ID as payment adjustment ID when adjustment created via webhook * Fetch Column payments oldest to newest * Ensure that webhook secrets are fetched when containers restart * Regenerate plugin code for tests * Add paging to fetch webhook request * Add WorkerPool unit test to increase test coverage * Guard against unhandled webhooks in Column plugin initiation * Rename Timeline.LatestID to Timeline.LastSeenID for clarity * Add metadata column to webhooks_configs table * Persist webhook_configs.metadata * Persist Column webhook secrets as metadata in webhooks_configs * Remove PSPWebhookConfig from InstallResponse * Stop passing context to initWebhookConfig() * Don't pass context to RegisterPlugin func * Don't pass context to plugins.RegisterPlugin
60 lines
1.6 KiB
Go
60 lines
1.6 KiB
Go
package client
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/http"
|
|
"strconv"
|
|
)
|
|
|
|
// Timeline allows the client to navigate the backlog and decide whether to fetch
|
|
// historical or recently added data
|
|
type Timeline struct {
|
|
LastSeenID string `json:"last_seen_id"`
|
|
BacklogCursor string `json:"backlog_cursor"`
|
|
}
|
|
|
|
func (t Timeline) IsCaughtUp() bool {
|
|
return t.LastSeenID != ""
|
|
}
|
|
|
|
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))
|
|
if timeline.BacklogCursor != "" {
|
|
q.Add("starting_after", timeline.BacklogCursor)
|
|
}
|
|
req.URL.RawQuery = q.Encode()
|
|
|
|
var res TransactionResponseWrapper[[]*Transaction]
|
|
var errRes columnError
|
|
_, err = c.httpClient.Do(ctx, req, &res, &errRes)
|
|
if err != nil {
|
|
return nil, timeline, false, fmt.Errorf("failed to get transactions for timeline: %w %w", err, errRes.Error())
|
|
}
|
|
|
|
if len(res.Transfers) == 0 {
|
|
return nil, timeline, res.HasMore, nil
|
|
}
|
|
|
|
oldest := res.Transfers[len(res.Transfers)-1]
|
|
if !res.HasMore {
|
|
// we've reached the beginning of time: we can return the oldest entry as the starting point for subsequent searches
|
|
timeline.LastSeenID = oldest.ID
|
|
return oldest, timeline, res.HasMore, nil
|
|
}
|
|
// we still haven't found the beginning of time: set the cursor and keep going
|
|
timeline.BacklogCursor = oldest.ID
|
|
return oldest, timeline, res.HasMore, nil
|
|
}
|