chore: some minor non-critical issues

RSS3-Network · Dec 1, 2023 · c881a90 · c881a90
1 parent 97a0012
commit c881a90
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/internal/database/dialer/cockroachdb/client.go b/internal/database/dialer/cockroachdb/client.go
@@ -96,7 +96,7 @@ func (c *client) Commit() error {
 func (c *client) LoadCheckpoint(ctx context.Context, id string, chain filter.Chain, worker string) (*engine.Checkpoint, error) {
 	var value table.Checkpoint
 
-	fmt.Println("checkpoint", id, chain.FullName(), worker)
+	zap.L().Info("load checkpoint", zap.String("id", id), zap.String("fullname", chain.FullName()), zap.String("worker", worker))
 
 	if err := c.database.WithContext(ctx).
 		Where("id = ? AND chain = ? AND worker = ?", id, chain.FullName(), worker).

diff --git a/internal/engine/source/ethereum/source.go b/internal/engine/source/ethereum/source.go
@@ -51,10 +51,6 @@ func (s *source) Start(ctx context.Context, tasksChan chan<- []engine.Task, erro
 }
 
 func (s *source) initialize(ctx context.Context) (err error) {
-	if s.ethereumClient, err = ethclient.Dial(s.config.Endpoint); err != nil {
-		return fmt.Errorf("dial rpc endpoint: %w", err)
-	}
-
 	if s.ethereumClient, err = ethclient.Dial(s.config.Endpoint); err != nil {
 		return fmt.Errorf("dial ethereum endpoint: %w", err)
 	}