diff --git a/protocol/messenger_config.go b/protocol/messenger_config.go
index daf3fe7d7..e76e9466c 100644
--- a/protocol/messenger_config.go
+++ b/protocol/messenger_config.go
@@ -22,6 +22,9 @@ type MessengerSignalsHandler interface {
 	MessageDelivered(chatID string, messageID string)
 	CommunityInfoFound(community *communities.Community)
 	MessengerResponse(response *MessengerResponse)
+	HistoryRequestStarted()
+	HistoryRequestCompleted()
+	HistoryRequestFailed(err error)
 }
 
 type config struct {
diff --git a/protocol/messenger_mailserver.go b/protocol/messenger_mailserver.go
index 8b4897de3..8c32020ce 100644
--- a/protocol/messenger_mailserver.go
+++ b/protocol/messenger_mailserver.go
@@ -262,13 +262,27 @@ func (m *Messenger) syncFilters(filters []*transport.Filter) (*MessengerResponse
 	}
 
 	m.logger.Info("syncing topics", zap.Any("batches", batches))
+
+	if m.config.messengerSignalsHandler != nil {
+		m.config.messengerSignalsHandler.HistoryRequestStarted()
+	}
+
 	for _, batch := range batches {
 		err := m.processMailserverBatch(batch)
 		if err != nil {
+			m.logger.Info("error syncing topics", zap.Any("error", err))
+			if m.config.messengerSignalsHandler != nil {
+				m.config.messengerSignalsHandler.HistoryRequestFailed(err)
+			}
 			return nil, err
 		}
 	}
 
+	m.logger.Info("topics synced")
+	if m.config.messengerSignalsHandler != nil {
+		m.config.messengerSignalsHandler.HistoryRequestCompleted()
+	}
+
 	err = m.mailserversDatabase.AddTopics(syncedTopics)
 	if err != nil {
 		return nil, err
diff --git a/services/ext/signal.go b/services/ext/signal.go
index 9d6234773..944a1427d 100644
--- a/services/ext/signal.go
+++ b/services/ext/signal.go
@@ -65,3 +65,15 @@ func (m MessengerSignalsHandler) CommunityInfoFound(community *communities.Commu
 func (m *MessengerSignalsHandler) MessengerResponse(response *protocol.MessengerResponse) {
 	PublisherSignalHandler{}.NewMessages(response)
 }
+
+func (m *MessengerSignalsHandler) HistoryRequestStarted() {
+	signal.SendHistoricMessagesRequestStarted()
+}
+
+func (m *MessengerSignalsHandler) HistoryRequestFailed(err error) {
+	signal.SendHistoricMessagesRequestFailed(err)
+}
+
+func (m *MessengerSignalsHandler) HistoryRequestCompleted() {
+	signal.SendHistoricMessagesRequestCompleted()
+}
diff --git a/signal/events_shhext.go b/signal/events_shhext.go
index 0c1518383..d99565384 100644
--- a/signal/events_shhext.go
+++ b/signal/events_shhext.go
@@ -34,6 +34,15 @@ const (
 
 	// EventNewMessages is triggered when we receive new messages
 	EventNewMessages = "messages.new"
+
+	// EventHistoryRequestStarted is triggered before processing a mailserver batch
+	EventHistoryRequestStarted = "history.request.started"
+
+	// EventHistoryRequestCompleted is triggered after processing a mailserver batch
+	EventHistoryRequestCompleted = "history.request.completed"
+
+	// EventHistoryRequestFailed is triggered when requesting history messages fails
+	EventHistoryRequestFailed = "history.request.failed"
 )
 
 // EnvelopeSignal includes hash of the envelope.
@@ -51,6 +60,10 @@ type MailServerResponseSignal struct {
 	ErrorMsg         string     `json:"errorMessage"`
 }
 
+type HistoryMessagesSignal struct {
+	ErrorMsg string `json:"errorMessage,omitempty"`
+}
+
 // DecryptMessageFailedSignal holds the sender of the message that could not be decrypted
 type DecryptMessageFailedSignal struct {
 	Sender string `json:"sender"`
@@ -103,6 +116,18 @@ func SendEnvelopeExpired(identifiers [][]byte, err error) {
 	send(EventEnvelopeExpired, EnvelopeSignal{IDs: hexIdentifiers, Message: message})
 }
 
+func SendHistoricMessagesRequestStarted() {
+	send(EventHistoryRequestStarted, HistoryMessagesSignal{})
+}
+
+func SendHistoricMessagesRequestFailed(err error) {
+	send(EventHistoryRequestFailed, HistoryMessagesSignal{ErrorMsg: err.Error()})
+}
+
+func SendHistoricMessagesRequestCompleted() {
+	send(EventHistoryRequestCompleted, HistoryMessagesSignal{})
+}
+
 // SendMailServerRequestCompleted triggered when mail server response has been received
 func SendMailServerRequestCompleted(requestID types.Hash, lastEnvelopeHash types.Hash, cursor []byte, err error) {
 	errorMsg := ""