diff --git a/node/pkg/watchers/algorand/watcher.go b/node/pkg/watchers/algorand/watcher.go index 0c19ce477..e72e893a9 100644 --- a/node/pkg/watchers/algorand/watcher.go +++ b/node/pkg/watchers/algorand/watcher.go @@ -151,6 +151,15 @@ func (e *Watcher) Run(ctx context.Context) error { logger := supervisor.Logger(ctx) + logger.Info("Starting watcher", + zap.String("watcher_name", "algorand"), + zap.String("indexerRPC", e.indexerRPC), + zap.String("indexerToken", e.indexerToken), + zap.String("algodRPC", e.algodRPC), + zap.String("algodToken", e.algodToken), + zap.Uint64("appid", e.appid), + ) + logger.Info("Algorand watcher connecting to indexer ", zap.String("url", e.indexerRPC)) logger.Info("Algorand watcher connecting to RPC node ", zap.String("url", e.algodRPC)) diff --git a/node/pkg/watchers/aptos/watcher.go b/node/pkg/watchers/aptos/watcher.go index 689b619c7..467191d98 100644 --- a/node/pkg/watchers/aptos/watcher.go +++ b/node/pkg/watchers/aptos/watcher.go @@ -73,6 +73,13 @@ func (e *Watcher) Run(ctx context.Context) error { logger := supervisor.Logger(ctx) + logger.Info("Starting watcher", + zap.String("watcher_name", "aptos"), + zap.String("aptosRPC", e.aptosRPC), + zap.String("aptosAccount", e.aptosAccount), + zap.String("aptosHandle", e.aptosHandle), + ) + logger.Info("Aptos watcher connecting to RPC node ", zap.String("url", e.aptosRPC)) // SECURITY: the API guarantees that we only get the events from the right diff --git a/node/pkg/watchers/cosmwasm/watcher.go b/node/pkg/watchers/cosmwasm/watcher.go index bb00e6a6d..2edff7bb4 100644 --- a/node/pkg/watchers/cosmwasm/watcher.go +++ b/node/pkg/watchers/cosmwasm/watcher.go @@ -145,6 +145,14 @@ func (e *Watcher) Run(ctx context.Context) error { errC := make(chan error) logger := supervisor.Logger(ctx) + logger.Info("Starting watcher", + zap.String("watcher_name", "cosmwasm"), + zap.String("urlWS", e.urlWS), + zap.String("urlLCD", e.urlLCD), + zap.String("contract", e.contract), + zap.String("chainID", e.chainID.String()), + ) + logger.Info("connecting to websocket", zap.String("network", networkName), zap.String("url", e.urlWS)) c, _, err := websocket.Dial(ctx, e.urlWS, nil) diff --git a/node/pkg/watchers/evm/watcher.go b/node/pkg/watchers/evm/watcher.go index 67245ca9d..978662920 100644 --- a/node/pkg/watchers/evm/watcher.go +++ b/node/pkg/watchers/evm/watcher.go @@ -165,6 +165,15 @@ func NewEthWatcher( func (w *Watcher) Run(parentCtx context.Context) error { logger := supervisor.Logger(parentCtx) + logger.Info("Starting watcher", + zap.String("watcher_name", "evm"), + zap.String("url", w.url), + zap.String("contract", w.contract.String()), + zap.String("networkName", w.networkName), + zap.String("chainID", w.chainID.String()), + zap.Bool("unsafeDevMode", w.unsafeDevMode), + ) + // later on we will spawn multiple go-routines through `RunWithScissors`, i.e. catching panics. // If any of them panic, this function will return, causing this child context to be canceled // such that the other go-routines can free up resources diff --git a/node/pkg/watchers/ibc/watcher.go b/node/pkg/watchers/ibc/watcher.go index 65e546c2b..071b081c2 100644 --- a/node/pkg/watchers/ibc/watcher.go +++ b/node/pkg/watchers/ibc/watcher.go @@ -168,6 +168,14 @@ type ibcReceivePublishEvent struct { // Run is the runnable for monitoring the IBC contract on wormchain. func (w *Watcher) Run(ctx context.Context) error { w.logger = supervisor.Logger(ctx) + + w.logger.Info("Starting watcher", + zap.String("watcher_name", "ibc"), + zap.String("wsUrl", w.wsUrl), + zap.String("lcdUrl", w.lcdUrl), + zap.String("contractAddress", w.contractAddress), + ) + errC := make(chan error) w.logger.Info("creating watcher", diff --git a/node/pkg/watchers/near/watcher.go b/node/pkg/watchers/near/watcher.go index 6ccfbe6fc..ed1fbf769 100644 --- a/node/pkg/watchers/near/watcher.go +++ b/node/pkg/watchers/near/watcher.go @@ -265,6 +265,13 @@ func (e *Watcher) runTxProcessor(ctx context.Context) error { func (e *Watcher) Run(ctx context.Context) error { logger := supervisor.Logger(ctx) + logger.Info("Starting watcher", + zap.String("watcher_name", "near"), + zap.Bool("mainnet", e.mainnet), + zap.String("wormholeAccount", e.wormholeAccount), + zap.String("nearRPC", e.nearRPC), + ) + e.errC = make(chan error) e.nearAPI = nearapi.NewNearApiImpl(nearapi.NewHttpNearRpc(e.nearRPC)) diff --git a/node/pkg/watchers/solana/client.go b/node/pkg/watchers/solana/client.go index a8ed8fe52..c6d2658ea 100644 --- a/node/pkg/watchers/solana/client.go +++ b/node/pkg/watchers/solana/client.go @@ -273,6 +273,19 @@ func (s *SolanaWatcher) Run(ctx context.Context) error { logger := supervisor.Logger(ctx) + wsUrl := "" + if s.wsUrl != nil { + wsUrl = *s.wsUrl + } + + logger.Info("Starting watcher", + zap.String("watcher_name", "solana"), + zap.String("rpcUrl", s.rpcUrl), + zap.String("wsUrl", wsUrl), + zap.String("contract", contractAddr), + zap.String("rawContract", s.rawContract), + ) + logger.Info("Solana watcher connecting to RPC node ", zap.String("url", s.rpcUrl)) s.errC = make(chan error) diff --git a/node/pkg/watchers/sui/watcher.go b/node/pkg/watchers/sui/watcher.go index 934cc4e91..eb849c8ae 100644 --- a/node/pkg/watchers/sui/watcher.go +++ b/node/pkg/watchers/sui/watcher.go @@ -267,6 +267,14 @@ func (e *Watcher) Run(ctx context.Context) error { logger := supervisor.Logger(ctx) + logger.Info("Starting watcher", + zap.String("watcher_name", "sui"), + zap.String("suiRPC", e.suiRPC), + zap.String("suiWS", e.suiWS), + zap.String("suiMoveEventType", e.suiMoveEventType), + zap.Bool("unsafeDevMode", e.unsafeDevMode), + ) + u := url.URL{Scheme: "ws", Host: e.suiWS} logger.Info("Sui watcher connecting to WS node ", zap.String("url", u.String()))