diff --git a/services/wallet/transfer/transaction_manager_multitransaction.go b/services/wallet/transfer/transaction_manager_multitransaction.go index 62593e06b..1d8096e48 100644 --- a/services/wallet/transfer/transaction_manager_multitransaction.go +++ b/services/wallet/transfer/transaction_manager_multitransaction.go @@ -68,7 +68,7 @@ func (tm *TransactionManager) SendTransactionForSigningToKeycard(ctx context.Con return err } - signal.SendTransactionsForSigningEvent(hashes) + signal.SendWalletEvent(signal.SignTransactions, hashes) return nil } diff --git a/services/wallet/walletevent/transmitter.go b/services/wallet/walletevent/transmitter.go index fd848eee4..46d2d558a 100644 --- a/services/wallet/walletevent/transmitter.go +++ b/services/wallet/walletevent/transmitter.go @@ -48,7 +48,7 @@ func (tmr *SignalsTransmitter) Start() error { return case event := <-events: if !event.Type.IsInternal() { - signal.SendWalletEvent(event) + signal.SendWalletEvent(signal.Wallet, event) } } } diff --git a/signal/events_wallet.go b/signal/events_wallet.go index dac4ee1a1..528652b53 100644 --- a/signal/events_wallet.go +++ b/signal/events_wallet.go @@ -1,19 +1,13 @@ package signal +type SignalType string + const ( - walletEvent = "wallet" + Wallet = SignalType("wallet") + SignTransactions = SignalType("wallet.sign.transactions") ) -type UnsignedTransactions struct { - Type string `json:"type"` - Transactions []string `json:"transactions"` -} - // SendWalletEvent sends event from services/wallet/events. -func SendWalletEvent(event interface{}) { - send(walletEvent, event) -} - -func SendTransactionsForSigningEvent(transactions []string) { - send(walletEvent, UnsignedTransactions{Type: "sing-transactions", Transactions: transactions}) +func SendWalletEvent(signalType SignalType, event interface{}) { + send(string(signalType), event) }