mirror of
https://github.com/hanzo-fi/payments.git
synced 2026-10-30 20:31:20 +00:00
CrimsonandGitHub
61cae8af0a
* Move all public connectors to ce/plugins * Update tooling to account for new go modules under ce * Ensure we test all CE plugins in CI * Move Dummypay to ce/plugins for simplicity's sake in the generation scripts * Use versioned pkg/domain in plugins * Ensure that renovate updates all CE plugins in a single PR when pkg/domain tags are pushed to github * Ensure Justfile commands work over all CE plugins * Copy ce plugin go.mods in dev.Dockerfile * Only add a go.mod for new plugins if they are ce * Ensure generated generic client structs are named correctly for submodule * Add coverprofile for each ce plugin * Add set -e for Justfile for loops over plugins * Infer go version from flake.nix in connector template tool
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
|
|
}
|