diff --git a/signal/events_shhext.go b/signal/events_shhext.go index 1021af94c..c093921e5 100644 --- a/signal/events_shhext.go +++ b/signal/events_shhext.go @@ -45,9 +45,6 @@ const ( // EventHistoryRequestFailed is triggered when requesting history messages fails EventHistoryRequestFailed = "history.request.failed" - // EventHistoryRequestFailed is triggered when requesting history messages succeeds - EventHistoryRequestSuccess = "history.request.success" - // EventBackupPerformed is triggered when a backup has been performed EventBackupPerformed = "backup.performed" @@ -158,10 +155,6 @@ func SendHistoricMessagesRequestFailed(requestID []byte, peerID peer.ID, err err send(EventHistoryRequestFailed, HistoryMessagesSignal{RequestID: hex.EncodeToString(requestID), PeerID: peerID.String(), ErrorMsg: err.Error()}) } -func SendHistoricMessagesRequestSuccess(requestID []byte, peerID peer.ID) { - send(EventHistoryRequestSuccess, HistoryMessagesSignal{RequestID: hex.EncodeToString(requestID), PeerID: peerID.String()}) -} - func SendHistoricMessagesRequestCompleted() { send(EventHistoryRequestCompleted, HistoryMessagesSignal{}) } diff --git a/wakuv2/waku.go b/wakuv2/waku.go index dac726588..c38cc5054 100644 --- a/wakuv2/waku.go +++ b/wakuv2/waku.go @@ -1067,8 +1067,6 @@ func (w *Waku) Query(peerID peer.ID, topics []common.TopicType, from uint64, to return nil, err } - signal.SendHistoricMessagesRequestSuccess(requestID, peerID) - for _, msg := range result.Messages { envelope := protocol.NewEnvelope(msg, msg.Timestamp, relay.DefaultWakuTopic) w.logger.Info("received waku2 store message", zap.Any("envelopeHash", hexutil.Encode(envelope.Hash())))