From 17ebdbf04e0b53f324d138b050536c284f0f6e06 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jo=C3=A3o=20Bordalo?= Date: Thu, 6 Feb 2025 15:33:04 +0000 Subject: [PATCH] rename round to batch in log messages --- pkg/client-sdk/covenant_client.go | 8 ++++---- pkg/client-sdk/covenantless_client.go | 14 +++++++------- 2 files changed, 11 insertions(+), 11 deletions(-) diff --git a/pkg/client-sdk/covenant_client.go b/pkg/client-sdk/covenant_client.go index f5efbfe1..26719314 100644 --- a/pkg/client-sdk/covenant_client.go +++ b/pkg/client-sdk/covenant_client.go @@ -1146,10 +1146,10 @@ func (a *covenantArkClient) handleRoundStream( case client.RoundFinalizedEvent: return event.(client.RoundFinalizedEvent).Txid, nil case client.RoundFailedEvent: - return "", fmt.Errorf("round failed: %s", event.(client.RoundFailedEvent).Reason) + return "", fmt.Errorf("batch failed: %s", event.(client.RoundFailedEvent).Reason) case client.RoundFinalizationEvent: pingStop() - log.Info("a round finalization started") + log.Info("a batch finalization started") signedForfeitTxs, signedRoundTx, err := a.handleRoundFinalization( ctx, event.(client.RoundFinalizationEvent), vtxosToSign, boardingUtxos, receivers, @@ -1159,7 +1159,7 @@ func (a *covenantArkClient) handleRoundStream( } if len(signedForfeitTxs) <= 0 && len(vtxosToSign) > 0 { - log.Info("no forfeit txs to sign, waiting for the next round") + log.Info("no forfeit txs to sign, waiting for the next batch") continue } @@ -1169,7 +1169,7 @@ func (a *covenantArkClient) handleRoundStream( } log.Info("done.") - log.Info("waiting for round finalization...") + log.Info("waiting for batch finalization...") } } } diff --git a/pkg/client-sdk/covenantless_client.go b/pkg/client-sdk/covenantless_client.go index 2f8542f9..12b86040 100644 --- a/pkg/client-sdk/covenantless_client.go +++ b/pkg/client-sdk/covenantless_client.go @@ -1712,11 +1712,11 @@ func (a *covenantlessArkClient) handleRoundStream( if step != roundFinalization { continue } - log.Infof("round completed %s", event.(client.RoundFinalizedEvent).Txid) + log.Infof("batch completed %s", event.(client.RoundFinalizedEvent).Txid) return event.(client.RoundFinalizedEvent).Txid, nil case client.RoundFailedEvent: if event.(client.RoundFailedEvent).ID == round.ID { - return "", fmt.Errorf("round failed: %s", event.(client.RoundFailedEvent).Reason) + return "", fmt.Errorf("batch failed: %s", event.(client.RoundFailedEvent).Reason) } continue case client.RoundSigningStartedEvent: @@ -1724,7 +1724,7 @@ func (a *covenantlessArkClient) handleRoundStream( if step != start { continue } - log.Info("a round signing started") + log.Info("a batch signing started") skipped, err := a.handleRoundSigningStarted( ctx, signerSessions, event.(client.RoundSigningStartedEvent), ) @@ -1740,7 +1740,7 @@ func (a *covenantlessArkClient) handleRoundStream( continue } pingStop() - log.Info("round combined nonces generated") + log.Info("batch combined nonces generated") if err := a.handleRoundSigningNoncesGenerated( ctx, event.(client.RoundSigningNoncesGeneratedEvent), signerSessions, ); err != nil { @@ -1753,7 +1753,7 @@ func (a *covenantlessArkClient) handleRoundStream( continue } pingStop() - log.Info("a round finalization started") + log.Info("a batch finalization started") signedForfeitTxs, signedRoundTx, err := a.handleRoundFinalization( ctx, event.(client.RoundFinalizationEvent), vtxosToSign, boardingUtxos, receivers, @@ -1763,7 +1763,7 @@ func (a *covenantlessArkClient) handleRoundStream( } if len(signedForfeitTxs) <= 0 && len(vtxosToSign) > 0 { - log.Info("no forfeit txs to sign, waiting for the next round") + log.Info("no forfeit txs to sign, waiting for the next batch") continue } @@ -1773,7 +1773,7 @@ func (a *covenantlessArkClient) handleRoundStream( } log.Info("done.") - log.Info("waiting for round finalization...") + log.Info("waiting for batch finalization...") step++ continue }