Skip to content

Commit 4b417fa

Browse files
committed
refactor: avoid conflict
1 parent 71062e6 commit 4b417fa

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

pkg/eventconsumer/event_consumer.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -223,7 +223,6 @@ func (ec *eventConsumer) handleKeyGenEvent(natMsg *nats.Msg) {
223223
doneEddsa()
224224
}
225225
}()
226-
227226
go func() {
228227
defer wg.Done()
229228
data, err := taurusSession.Keygen(ctxTaurus)
@@ -233,7 +232,7 @@ func (ec *eventConsumer) handleKeyGenEvent(natMsg *nats.Msg) {
233232
return
234233
}
235234

236-
logger.Info("Keygen completed successfully", "walletID", walletID, "payloadLength", len(data.Payload))
235+
logger.Info("CMP Keygen completed successfully", "walletID", walletID, "payloadLength", len(data.Payload))
237236
successEvent.TaurusCMPPubKey = data.PubKeyBytes
238237
doneTaurus()
239238
}()
@@ -253,7 +252,6 @@ func (ec *eventConsumer) handleKeyGenEvent(natMsg *nats.Msg) {
253252
close(doneAll)
254253
}()
255254

256-
// Check for errors
257255
select {
258256
case <-doneAll:
259257
// Check if any errors occurred during execution
@@ -277,6 +275,7 @@ func (ec *eventConsumer) handleKeyGenEvent(natMsg *nats.Msg) {
277275
ec.handleKeygenSessionError(walletID, err, "Failed to marshal keygen success event", natMsg)
278276
return
279277
}
278+
280279
key := fmt.Sprintf(mpc.TypeGenerateWalletResultFmt, walletID)
281280
if err := ec.genKeyResultQueue.Enqueue(
282281
key,

0 commit comments

Comments
 (0)