Add context to MsgEventListener method

abicky · abicky · commit 92c8c5246d27 · 2025-02-10T21:34:26.000+09:00
Signed-off-by: Takeshi Arabiki &lt;takeshi.arabiki@datachain.jp&gt;
diff --git a/chains/tendermint/chain.go b/chains/tendermint/chain.go
@@ -193,7 +193,7 @@ func (c *Chain) sendMsgs(msgs []sdk.Msg) (*sdk.TxResponse, error) {
 
 	// call msgEventListener if needed
 	if c.msgEventListener != nil {
-		if err := c.msgEventListener.OnSentMsg(msgs); err != nil {
+		if err := c.msgEventListener.OnSentMsg(context.TODO(), msgs); err != nil {
 			logger.Error("failed to OnSendMsg call", err)
 			return res, nil
 		}
diff --git a/core/chain.go b/core/chain.go
@@ -113,7 +113,7 @@ type ChainInfo interface {
 // MsgEventListener is a listener that listens a msg send to the chain
 type MsgEventListener interface {
 	// OnSentMsg is a callback functoin that is called when a msg send to the chain
-	OnSentMsg(msgs []sdk.Msg) error
+	OnSentMsg(ctx context.Context, msgs []sdk.Msg) error
 }
 
 // IBCQuerier is an interface to the state of IBC

Original file line number	Diff line number	Diff line change
`@@ -193,7 +193,7 @@ func (c Chain) sendMsgs(msgs []sdk.Msg) (sdk.TxResponse, error) {`
`193`	`193`
`194`	`194`	`// call msgEventListener if needed`
`195`	`195`	`if c.msgEventListener != nil {`
`196`		`- if err := c.msgEventListener.OnSentMsg(msgs); err != nil {`
	`196`	`+ if err := c.msgEventListener.OnSentMsg(context.TODO(), msgs); err != nil {`
`197`	`197`	`logger.Error("failed to OnSendMsg call", err)`
`198`	`198`	`return res, nil`
`199`	`199`	`}`
Original file line number	Diff line number	Diff line change
`@@ -113,7 +113,7 @@ type ChainInfo interface {`
`113`	`113`	`// MsgEventListener is a listener that listens a msg send to the chain`
`114`	`114`	`type MsgEventListener interface {`
`115`	`115`	`// OnSentMsg is a callback functoin that is called when a msg send to the chain`
`116`		`- OnSentMsg(msgs []sdk.Msg) error`
	`116`	`+ OnSentMsg(ctx context.Context, msgs []sdk.Msg) error`
`117`	`117`	`}`
`118`	`118`
`119`	`119`	`// IBCQuerier is an interface to the state of IBC`