From 518f62f571c3b1914d99ddf6f5fba12e59ed65ff Mon Sep 17 00:00:00 2001 From: mpetrun5 Date: Mon, 18 May 2026 18:04:09 +0200 Subject: [PATCH 1/2] fix: remove silent coordination errors --- tss/coordinator.go | 17 ++++++++++++++--- 1 file changed, 14 insertions(+), 3 deletions(-) diff --git a/tss/coordinator.go b/tss/coordinator.go index 390dba4d..1f31c0ab 100644 --- a/tss/coordinator.go +++ b/tss/coordinator.go @@ -187,9 +187,13 @@ func (c *Coordinator) start( // broadcastInitiateMsg sends TssInitiateMsg to all peers func (c *Coordinator) broadcastInitiateMsg(sessionID string, peers peer.IDSlice) { log.Debug().Str("SessionID", sessionID).Msgf("broadcasted initiate message") - _ = c.communication.Broadcast( + err := c.communication.Broadcast( peers, []byte{}, comm.TssInitiateMsg, sessionID, ) + if err != nil { + log.Err(err).Str("SessionID", sessionID).Msgf( + "Failed broadcasting initiate message") + } } // initiate sends initiate message to all peers and waits @@ -238,7 +242,11 @@ func (c *Coordinator) initiate( } go func() { - _ = c.communication.Broadcast(c.host.Peerstore().Peers(), startMsgBytes, comm.TssStartMsg, tssProcess.SessionID()) + err = c.communication.Broadcast(c.host.Peerstore().Peers(), startMsgBytes, comm.TssStartMsg, tssProcess.SessionID()) + if err != nil { + log.Err(err).Str("SessionID", tssProcess.SessionID()).Msgf( + "Failed broadcasting start message") + } }() c.metrics.RecordInitiateDuration(time.Since(initiateStart)) ticker.Stop() @@ -293,9 +301,12 @@ func (c *Coordinator) waitForStart( log.Debug().Str("SessionID", tssProcess.SessionID()).Msgf("sent ready message to %s", wMsg.From) go func() { - _ = c.communication.Broadcast( + err := c.communication.Broadcast( peer.IDSlice{wMsg.From}, []byte{}, comm.TssReadyMsg, tssProcess.SessionID(), ) + if err != nil { + log.Err(err).Msgf("Failed sending ready message to peer %s. %w", wMsg.From.String(), err) + } }() } case err := <-errChn: From 96a604e309333faeb67a8c474ab4afc83aa85b28 Mon Sep 17 00:00:00 2001 From: mpetrun5 Date: Mon, 18 May 2026 18:08:10 +0200 Subject: [PATCH 2/2] Lint --- tss/coordinator.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tss/coordinator.go b/tss/coordinator.go index 1f31c0ab..540f0e9f 100644 --- a/tss/coordinator.go +++ b/tss/coordinator.go @@ -305,7 +305,8 @@ func (c *Coordinator) waitForStart( peer.IDSlice{wMsg.From}, []byte{}, comm.TssReadyMsg, tssProcess.SessionID(), ) if err != nil { - log.Err(err).Msgf("Failed sending ready message to peer %s. %w", wMsg.From.String(), err) + log.Err(err).Str("SessionID", tssProcess.SessionID()).Msgf( + "Failed sending ready message") } }() }