fixing farcaster bug with error

vocdoni · Apr 17, 2024 · 4007680 · 4007680
1 parent e037e63
commit 4007680
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/cmd/census3/main.go b/cmd/census3/main.go
@@ -147,7 +147,7 @@ func main() {
 	}
 	for _, uri := range config.listOfWeb3Providers {
 		if err := w3p.AddEndpoint(uri); err != nil {
-			log.Warnw("error adding web3 provider (%s): %w", uri, err)
+			log.Warnf("error adding web3 provider (%s): %w", uri, err)
 		}
 	}
 	// init the database

diff --git a/scanner/providers/farcaster/provider.go b/scanner/providers/farcaster/provider.go
@@ -354,6 +354,11 @@ func (p *FarcasterProvider) keyRegistryCreationBlock() uint64 {
 // before the next iteration. It also updates the last block scanned and the
 // sync vars of the provider.
 func (p *FarcasterProvider) initInternalScanner() {
+	defer func() {
+		if err := p.Close(); err != nil {
+			log.Warnf("error closing provider: %s", err.Error())
+		}
+	}()
 	for {
 		select {
 		case <-p.scannerCtx.Done():
@@ -363,8 +368,8 @@ func (p *FarcasterProvider) initInternalScanner() {
 			defer downloading.Store(false)
 			lastBlock, idrSynced, krSynced, err := p.scanIteration(p.scannerCtx)
 			if err != nil {
-				log.Errorf("error scanning iteration: %s", err.Error())
-				continue
+				log.Warnf("error scanning iteration: %s", err.Error())
+				return
 			}
 			p.contracts.lastBlock.Store(lastBlock)
 			log.Debugw("scanning iteration finished, sleeping...",