fix: changed to not start from 0 (#166)

* fix: changed to not start from 0 * fix: increased timeout
primev · Jun 21, 2024 · c80ebad · c80ebad
1 parent 5bc56cb
commit c80ebad
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/oracle/pkg/l1Listener/l1Listener.go b/oracle/pkg/l1Listener/l1Listener.go
@@ -130,7 +130,12 @@ func (l *L1Listener) watchL1Block(ctx context.Context) error {
 	ticker := time.NewTicker(checkInterval)
 	defer ticker.Stop()
 
-	currentBlockNo := 0
+	// TODO: change it to the store to not miss blocks, if oracle is down
+	currentBlockNo, err := l.l1Client.BlockNumber(ctx)
+	if err != nil {
+		l.logger.Error("failed to get block number", "error", err)
+		return err
+	}
 	for {
 		select {
 		case <-ctx.Done():
@@ -181,7 +186,7 @@ func (l *L1Listener) watchL1Block(ctx context.Context) error {
 				)
 			}
 
-			currentBlockNo = int(blockNum)
+			currentBlockNo = blockNum
 		}
 	}
 }
diff --git a/oracle/pkg/l1Listener/l1Listener_test.go b/oracle/pkg/l1Listener/l1Listener_test.go
@@ -93,7 +93,7 @@ func TestL1Listener(t *testing.T) {
 
 	// ensure no winner is sent for the previous block
 	select {
-	case <-time.After(5 * time.Second):
+	case <-time.After(10 * time.Second):
 		t.Fatal("timeout waiting for winner")
 	case update := <-rec.updates:
 		if update.blockNum.Int64() != 11 {