fix: interop-node startup bug (#144)

settlus · Apr 1, 2024 · bd1544e · bd1544e
1 parent 324e62e
commit bd1544e
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/tools/interop-node/cmd/start.go b/tools/interop-node/cmd/start.go
@@ -3,6 +3,9 @@ package cmd
 import (
 	"context"
 	"fmt"
+	"os"
+	"os/signal"
+	"syscall"
 
 	"github.com/tendermint/tendermint/libs/cli/flags"
 
@@ -40,6 +43,11 @@ func startCmd() *cobra.Command {
 				interopServer.Close()
 			}()
 
+			cancelChan := make(chan os.Signal, 1)
+			signal.Notify(cancelChan, syscall.SIGTERM, syscall.SIGINT)
+
+			<-cancelChan
+
 			return nil
 		},
 	}

diff --git a/tools/interop-node/subscriber/ethereum_subscriber.go b/tools/interop-node/subscriber/ethereum_subscriber.go
@@ -204,6 +204,7 @@ func (sub *EthereumSubscriber) dbLoop(ctx context.Context) {
 
 		case <-ctx.Done():
 			close(sub.dbCh)
+			return
 		}
 	}
 }
@@ -235,7 +236,6 @@ func (sub *EthereumSubscriber) fetchLoop(ctx context.Context) {
 			sub.dbCh <- event
 		case <-ctx.Done():
 			sub.logger.Info("fetchLoop stopped")
-			close(sub.dbCh)
 			return
 		}
 	}