@@ -306,19 +306,21 @@ func (r *Relayer) processClusterEvents(ctx context.Context, message *types.Route
306306 switch message .EventType {
307307 case events .EmitMessage :
308308 srcChainProvider , err := r .FindChainRuntime (message .Src )
309- message .DstConnAddress = dst .Provider .Config ().GetConnContract ()
310- message .Message .SrcConnAddress = srcChainProvider .Provider .Config ().GetConnContract ()
311- iconChain := getIconChain (r .chains )
312309 if err != nil {
313- r .log .Error ("wrapped src chain nid not found" , zap .String ("nid" , message .Src ))
310+ r .log .Error ("wrapped src chain runtime not found" , zap .String ("nid" , message .Src ))
314311 r .ClearMessages (ctx , []* types.MessageKey {message .MessageKey ()}, src )
312+ return
315313 }
314+ message .DstConnAddress = dst .Provider .Config ().GetConnContract ()
315+ message .Message .SrcConnAddress = srcChainProvider .Provider .Config ().GetConnContract ()
316+ iconChain := getIconChain (r .chains )
316317 go r .processAcknowledgementMsg (ctx , message , srcChainProvider , dst , iconChain , true )
317318 case events .PacketRegistered :
318319 srcChainProvider , err := r .FindChainRuntime (message .Src )
319320 if err != nil {
320- r .log .Error ("wrapped src chain nid not found" , zap .String ("nid" , message .Src ))
321+ r .log .Error ("wrapped src chain runtime not found" , zap .String ("nid" , message .Src ))
321322 r .ClearMessages (ctx , []* types.MessageKey {message .MessageKey ()}, src )
323+ return
322324 }
323325 iconChain := getIconChain (r .chains )
324326 go r .processAcknowledgementMsg (ctx , message , srcChainProvider , dst , iconChain , false )
0 commit comments