cerc-io/ipld-eth-server
18
0
Fork 1
Code Issues 10 Pull Requests 1 Actions Packages Projects Releases 37 Wiki Activity

Add logging to watched addresses gap filler service

Browse Source
This commit is contained in:
Prathamesh Musale 2022-01-20 13:28:03 +05:30
parent b9af16ad99
commit b7c6b56a11
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/serve.go
View File

@ -325,6 +325,10 @@ func startWatchedAddressGapFiller(config *s.Config) {
// Get the block number to end fill at // Get the block number to end fill at
fillWatchedAddresses, minStartBlock, maxEndBlock := getFillAddresses(config) fillWatchedAddresses, minStartBlock, maxEndBlock := getFillAddresses(config)
if len(fillWatchedAddresses) > 0 {
log.Infof("running watched address gap filler for block range: (%d, %d)", minStartBlock, maxEndBlock)
}
// Fill the missing diffs // Fill the missing diffs
for blockNumber := minStartBlock; blockNumber <= maxEndBlock; blockNumber++ { for blockNumber := minStartBlock; blockNumber <= maxEndBlock; blockNumber++ {
params := statediff.Params{ params := statediff.Params{
@ -362,6 +366,7 @@ func startWatchedAddressGapFiller(config *s.Config) {
func getFillAddresses(config *s.Config) ([]WatchedAddress, uint64, uint64) { func getFillAddresses(config *s.Config) ([]WatchedAddress, uint64, uint64) {
rows := []WatchedAddress{} rows := []WatchedAddress{}
pgStr := "SELECT * FROM eth.watched_addresses" pgStr := "SELECT * FROM eth.watched_addresses"
err := config.DB.Select(&rows, pgStr) err := config.DB.Select(&rows, pgStr)
if err != nil { if err != nil {
log.Fatalf("Error fetching watched addreesses:", err.Error()) log.Fatalf("Error fetching watched addreesses:", err.Error())
@ -373,6 +378,7 @@ func getFillAddresses(config *s.Config) ([]WatchedAddress, uint64, uint64) {
for _, row := range rows { for _, row := range rows {
// Check for a gap between created_at and watched_at // Check for a gap between created_at and watched_at
// CreatedAt and WatchedAt being equal is considered a gap
if row.CreatedAt > row.WatchedAt { if row.CreatedAt > row.WatchedAt {
continue continue
} }
@ -420,8 +426,10 @@ func fillWatchedAddressGap(config *s.Config, blockNumber uint64, params statedif
// Update the db // Update the db
query := "UPDATE eth.watched_addresses SET last_filled_at=? WHERE address IN (?" + strings.Repeat(",?", len(fillAddresses)-1) + ")" query := "UPDATE eth.watched_addresses SET last_filled_at=? WHERE address IN (?" + strings.Repeat(",?", len(fillAddresses)-1) + ")"
query = config.DB.Rebind(query) query = config.DB.Rebind(query)
args := []interface{}{blockNumber} args := []interface{}{blockNumber}
args = append(args, fillAddresses...) args = append(args, fillAddresses...)
_, err = config.DB.Exec(query, args...) _, err = config.DB.Exec(query, args...)
if err != nil { if err != nil {
log.Fatalf(err.Error()) log.Fatalf(err.Error())