node/watchers: Log each watcher's config on startup

This commit is contained in:
tbjump 2023-06-12 16:56:54 +00:00 committed by Evan Gray
parent 51877302eb
commit e5c8214fa9
8 changed files with 69 additions and 0 deletions

View File

@ -151,6 +151,15 @@ func (e *Watcher) Run(ctx context.Context) error {
logger := supervisor.Logger(ctx) 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 indexer ", zap.String("url", e.indexerRPC))
logger.Info("Algorand watcher connecting to RPC node ", zap.String("url", e.algodRPC)) logger.Info("Algorand watcher connecting to RPC node ", zap.String("url", e.algodRPC))

View File

@ -73,6 +73,13 @@ func (e *Watcher) Run(ctx context.Context) error {
logger := supervisor.Logger(ctx) 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)) 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 // SECURITY: the API guarantees that we only get the events from the right

View File

@ -145,6 +145,14 @@ func (e *Watcher) Run(ctx context.Context) error {
errC := make(chan error) errC := make(chan error)
logger := supervisor.Logger(ctx) 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)) logger.Info("connecting to websocket", zap.String("network", networkName), zap.String("url", e.urlWS))
c, _, err := websocket.Dial(ctx, e.urlWS, nil) c, _, err := websocket.Dial(ctx, e.urlWS, nil)

View File

@ -165,6 +165,15 @@ func NewEthWatcher(
func (w *Watcher) Run(parentCtx context.Context) error { func (w *Watcher) Run(parentCtx context.Context) error {
logger := supervisor.Logger(parentCtx) 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. // 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 // 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 // such that the other go-routines can free up resources

View File

@ -168,6 +168,14 @@ type ibcReceivePublishEvent struct {
// Run is the runnable for monitoring the IBC contract on wormchain. // Run is the runnable for monitoring the IBC contract on wormchain.
func (w *Watcher) Run(ctx context.Context) error { func (w *Watcher) Run(ctx context.Context) error {
w.logger = supervisor.Logger(ctx) 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) errC := make(chan error)
w.logger.Info("creating watcher", w.logger.Info("creating watcher",

View File

@ -265,6 +265,13 @@ func (e *Watcher) runTxProcessor(ctx context.Context) error {
func (e *Watcher) Run(ctx context.Context) error { func (e *Watcher) Run(ctx context.Context) error {
logger := supervisor.Logger(ctx) 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.errC = make(chan error)
e.nearAPI = nearapi.NewNearApiImpl(nearapi.NewHttpNearRpc(e.nearRPC)) e.nearAPI = nearapi.NewNearApiImpl(nearapi.NewHttpNearRpc(e.nearRPC))

View File

@ -273,6 +273,19 @@ func (s *SolanaWatcher) Run(ctx context.Context) error {
logger := supervisor.Logger(ctx) 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)) logger.Info("Solana watcher connecting to RPC node ", zap.String("url", s.rpcUrl))
s.errC = make(chan error) s.errC = make(chan error)

View File

@ -267,6 +267,14 @@ func (e *Watcher) Run(ctx context.Context) error {
logger := supervisor.Logger(ctx) 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} u := url.URL{Scheme: "ws", Host: e.suiWS}
logger.Info("Sui watcher connecting to WS node ", zap.String("url", u.String())) logger.Info("Sui watcher connecting to WS node ", zap.String("url", u.String()))