Skip to content

Commit

Permalink
chore(exporter): improve logging when fetching relays-data (#990)
Browse files Browse the repository at this point in the history
BEDS-90
  • Loading branch information
guybrush authored Oct 18, 2024
1 parent 123d0c0 commit ea224ae
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions backend/pkg/exporter/modules/relays.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,16 +113,15 @@ func fetchDeliveredPayloads(r types.Relay, offset uint64) ([]BidTrace, error) {
resp, err := client.Get(url)

if err != nil {
log.Error(err, "error retrieving delivered payloads", 0, map[string]interface{}{"relay": r.ID})
return nil, fmt.Errorf("error retrieving delivered payloads for cursor: %v, url: %v: %v", offset, url, err)
log.Error(err, "error retrieving delivered payloads", 0, map[string]interface{}{"relay": r.ID, "offset": offset, "url": url})
return nil, fmt.Errorf("error retrieving delivered payloads for relay: %v, offset: %v, url: %v: %w", r.ID, offset, url, err)
}

defer resp.Body.Close()

err = json.NewDecoder(resp.Body).Decode(&payloads)

if err != nil {
return nil, fmt.Errorf("error decoding json for delivered payloads for cursor: %v, url: %v: %v", offset, url, err)
return nil, fmt.Errorf("error decoding json for delivered payloads for relay: %v, offset: %v, url: %v: %w", r.ID, offset, url, err)
}

return payloads, nil
Expand Down Expand Up @@ -176,7 +175,7 @@ func retrieveAndInsertPayloadsFromRelay(r types.Relay, low_bound uint64, high_bo
for {
resp, err := fetchDeliveredPayloads(r, offset)
if err != nil {
return fmt.Errorf("error calling fetchDeliveredPayloads with offset: %v for relay: %v", r.ID, err)
return fmt.Errorf("error calling fetchDeliveredPayloads with offset: %v for relay: %v: %w", offset, r.ID, err)
}

if resp == nil {
Expand Down

0 comments on commit ea224ae

Please sign in to comment.