diff --git a/bridge/tfchain_bridge/pkg/bridge/bridge.go b/bridge/tfchain_bridge/pkg/bridge/bridge.go index 92c9d48d7..7428f3713 100644 --- a/bridge/tfchain_bridge/pkg/bridge/bridge.go +++ b/bridge/tfchain_bridge/pkg/bridge/bridge.go @@ -146,7 +146,7 @@ func (bridge *Bridge) Start(ctx context.Context) error { select { case data := <-tfchainSub: if data.Err != nil { - return errors.Wrap(err, "failed to get tfchain events") + return errors.Wrap(data.Err, "failed to get tfchain events") } for _, withdrawCreatedEvent := range data.Events.WithdrawCreatedEvents { err := bridge.handleWithdrawCreated(ctx, withdrawCreatedEvent) @@ -190,7 +190,7 @@ func (bridge *Bridge) Start(ctx context.Context) error { } case data := <-stellarSub: if data.Err != nil { - return errors.Wrap(err, "failed to get stellar payments") + return errors.Wrap(data.Err, "failed to get stellar payments") } for _, mEvent := range data.Events { diff --git a/bridge/tfchain_bridge/pkg/stellar/stellar.go b/bridge/tfchain_bridge/pkg/stellar/stellar.go index 7f923744e..fd4e19b33 100644 --- a/bridge/tfchain_bridge/pkg/stellar/stellar.go +++ b/bridge/tfchain_bridge/pkg/stellar/stellar.go @@ -368,7 +368,7 @@ func (w *StellarWallet) submitTransaction(ctx context.Context, txn *txnbuild.Tra return errors.Wrap(err, "an error occurred while submitting the transaction") } log.Info(). - Str("trace_id", fmt.Sprint(ctx.Value("trace_id"))). + Str("trace_id", fmt.Sprint(ctx.Value(TraceIdKey{}))). Str("event_action", "stellar_transaction_submitted"). Str("event_kind", "event"). Str("category", "vault"). diff --git a/bridge/tfchain_bridge/pkg/substrate/client.go b/bridge/tfchain_bridge/pkg/substrate/client.go index d3461b458..eb61c9f4d 100644 --- a/bridge/tfchain_bridge/pkg/substrate/client.go +++ b/bridge/tfchain_bridge/pkg/substrate/client.go @@ -63,7 +63,7 @@ func NewSubstrateClient(url string, seed string) (*SubstrateClient, error) { func (s *SubstrateClient) RetrySetWithdrawExecuted(ctx context.Context, tixd uint64) error { err := s.SetBurnTransactionExecuted(s.identity, tixd) for err != nil { - log.Err(err).Msg("error while setting refund transaction as executed") + log.Err(err).Msg("error while setting burn transaction as executed") select { case <-ctx.Done():