Merge pull request #8 from Galactica-corp/feature/indexer-reconnect

Restart indexer service after fail

cmd/galacticad-merkle/cmd/indexer/start.go

@@ -99,8 +99,23 @@ func CreateStartCmd() *cobra.Command {
 				IndexerConfig:         getIndexConfig(),
 			}
 
-			if err := pkgindexer.StartApplication(cmd.Context(), appConfig, logger); err != nil {
-				return fmt.Errorf("start indexer server: %w", err)
+			for {
+				if err := pkgindexer.StartApplication(cmd.Context(), appConfig, logger); err != nil {
+					logger.Error("service produced an error", "error", err)
+				}
+
+				needStop := false
+				select {
+				case <-cmd.Context().Done():
+					needStop = true
+				default:
+				}
+
+				if !needStop {
+					logger.Error("restarting service")
+				} else {
+					break
+				}
 			}
 
 			logger.Info("gracefully stopped indexer server")

pkg/indexer/application.go

@@ -150,8 +150,14 @@ func StartApplication(ctx context.Context, config ApplicationConfig, logger log.
 func (app *Application) Init(ctx context.Context) error {
 	app.logger.Info("connecting to EVM RPC", "evm_rpc", app.config.EvmRpc)
 	if err := backoff.Retry(func() error {
+		ctxWithTimeout, cancel := context.WithTimeout(ctx, time.Second*5)
+		defer cancel()
+
 		var err error
-		app.ethereumClient, err = ethclient.DialContext(ctx, app.config.EvmRpc)
+		app.ethereumClient, err = ethclient.DialContext(ctxWithTimeout, app.config.EvmRpc)
+		if err != nil {
+			app.logger.Error("ethereum node dial", "error", err)
+		}
 
 		return err
 	}, backoff.NewExponentialBackOff()); err != nil {