mirror of
https://github.com/status-im/status-go.git
synced 2025-01-09 22:26:30 +00:00
9b458c63e0
I've removed any mention or dependency of TorrentManager from Manager. There is still more work to do, but Messenger now communicates directly with a TorrentManager rather than asking the communities Manager to handle it. I've ensured that LogStdout() is only called from TorrentManager and removed entirely from Manager, this functionality seems to be some kind of debug tool specifically for torrent related functionality. Next I need to focus on functions within Messenger that call a TorrentManager and see how to isolate these from the main flows, following that I also need fix the tests that are broken. I will also need to refactor torrentClientReady() so that it is a function of TorrentManager, this may allow for pushing more functions into TorrentManager which will lead to better torrent encapsulation.
187 lines
6.8 KiB
Go
187 lines
6.8 KiB
Go
package ext
|
|
|
|
import (
|
|
"github.com/status-im/status-go/eth-node/types"
|
|
"github.com/status-im/status-go/protocol"
|
|
"github.com/status-im/status-go/protocol/communities"
|
|
"github.com/status-im/status-go/protocol/discord"
|
|
"github.com/status-im/status-go/protocol/wakusync"
|
|
"github.com/status-im/status-go/signal"
|
|
)
|
|
|
|
// EnvelopeSignalHandler sends signals when envelope is sent or expired.
|
|
type EnvelopeSignalHandler struct{}
|
|
|
|
// EnvelopeSent triggered when envelope delivered at least to 1 peer.
|
|
func (h EnvelopeSignalHandler) EnvelopeSent(identifiers [][]byte) {
|
|
signal.SendEnvelopeSent(identifiers)
|
|
}
|
|
|
|
// EnvelopeExpired triggered when envelope is expired but wasn't delivered to any peer.
|
|
func (h EnvelopeSignalHandler) EnvelopeExpired(identifiers [][]byte, err error) {
|
|
signal.SendEnvelopeExpired(identifiers, err)
|
|
}
|
|
|
|
// MailServerRequestCompleted triggered when the mailserver sends a message to notify that the request has been completed
|
|
func (h EnvelopeSignalHandler) MailServerRequestCompleted(requestID types.Hash, lastEnvelopeHash types.Hash, cursor []byte, err error) {
|
|
signal.SendMailServerRequestCompleted(requestID, lastEnvelopeHash, cursor, err)
|
|
}
|
|
|
|
// MailServerRequestExpired triggered when the mailserver request expires
|
|
func (h EnvelopeSignalHandler) MailServerRequestExpired(hash types.Hash) {
|
|
signal.SendMailServerRequestExpired(hash)
|
|
}
|
|
|
|
// PublisherSignalHandler sends signals on protocol events
|
|
type PublisherSignalHandler struct{}
|
|
|
|
func (h PublisherSignalHandler) DecryptMessageFailed(pubKey string) {
|
|
signal.SendDecryptMessageFailed(pubKey)
|
|
}
|
|
|
|
func (h PublisherSignalHandler) BundleAdded(identity string, installationID string) {
|
|
signal.SendBundleAdded(identity, installationID)
|
|
}
|
|
|
|
func (h PublisherSignalHandler) NewMessages(response *protocol.MessengerResponse) {
|
|
signal.SendNewMessages(response)
|
|
}
|
|
|
|
func (h PublisherSignalHandler) Stats(stats types.StatsSummary) {
|
|
signal.SendStats(stats)
|
|
}
|
|
|
|
// MessengerSignalsHandler sends signals on messenger events
|
|
type MessengerSignalsHandler struct{}
|
|
|
|
// MessageDelivered passes information that message was delivered
|
|
func (m *MessengerSignalsHandler) MessageDelivered(chatID string, messageID string) {
|
|
signal.SendMessageDelivered(chatID, messageID)
|
|
}
|
|
|
|
// BackupPerformed passes information that a backup was performed
|
|
func (m *MessengerSignalsHandler) BackupPerformed(lastBackup uint64) {
|
|
signal.SendBackupPerformed(lastBackup)
|
|
}
|
|
|
|
// CommunityInfoFound passes info about community that was requested before
|
|
func (m *MessengerSignalsHandler) CommunityInfoFound(community *communities.Community) {
|
|
signal.SendCommunityInfoFound(community)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) MessengerResponse(response *protocol.MessengerResponse) {
|
|
PublisherSignalHandler{}.NewMessages(response)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) HistoryRequestStarted(numBatches int) {
|
|
signal.SendHistoricMessagesRequestStarted(numBatches)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) HistoryRequestCompleted() {
|
|
signal.SendHistoricMessagesRequestCompleted()
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) HistoryArchivesProtocolEnabled() {
|
|
signal.SendHistoryArchivesProtocolEnabled()
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) HistoryArchivesProtocolDisabled() {
|
|
signal.SendHistoryArchivesProtocolDisabled()
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) CreatingHistoryArchives(communityID string) {
|
|
signal.SendCreatingHistoryArchives(communityID)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) NoHistoryArchivesCreated(communityID string, from int, to int) {
|
|
signal.SendNoHistoryArchivesCreated(communityID, from, to)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) HistoryArchivesCreated(communityID string, from int, to int) {
|
|
signal.SendHistoryArchivesCreated(communityID, from, to)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) HistoryArchivesSeeding(communityID string) {
|
|
signal.SendHistoryArchivesSeeding(communityID)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) HistoryArchivesUnseeded(communityID string) {
|
|
signal.SendHistoryArchivesUnseeded(communityID)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) HistoryArchiveDownloaded(communityID string, from int, to int) {
|
|
signal.SendHistoryArchiveDownloaded(communityID, from, to)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) DownloadingHistoryArchivesStarted(communityID string) {
|
|
signal.SendDownloadingHistoryArchivesStarted(communityID)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) ImportingHistoryArchiveMessages(communityID string) {
|
|
signal.SendImportingHistoryArchiveMessages(communityID)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) DownloadingHistoryArchivesFinished(communityID string) {
|
|
signal.SendDownloadingHistoryArchivesFinished(communityID)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) StatusUpdatesTimedOut(statusUpdates *[]protocol.UserStatus) {
|
|
signal.SendStatusUpdatesTimedOut(statusUpdates)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) DiscordCategoriesAndChannelsExtracted(categories []*discord.Category, channels []*discord.Channel, oldestMessageTimestamp int64, errors map[string]*discord.ImportError) {
|
|
signal.SendDiscordCategoriesAndChannelsExtracted(categories, channels, oldestMessageTimestamp, errors)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) DiscordCommunityImportProgress(importProgress *discord.ImportProgress) {
|
|
signal.SendDiscordCommunityImportProgress(importProgress)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) DiscordChannelImportProgress(importProgress *discord.ImportProgress) {
|
|
signal.SendDiscordChannelImportProgress(importProgress)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) DiscordCommunityImportFinished(id string) {
|
|
signal.SendDiscordCommunityImportFinished(id)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) DiscordChannelImportFinished(communityID string, channelID string) {
|
|
signal.SendDiscordChannelImportFinished(communityID, channelID)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) DiscordCommunityImportCancelled(id string) {
|
|
signal.SendDiscordCommunityImportCancelled(id)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) DiscordCommunityImportCleanedUp(id string) {
|
|
signal.SendDiscordCommunityImportCleanedUp(id)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) DiscordChannelImportCancelled(id string) {
|
|
signal.SendDiscordChannelImportCancelled(id)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) SendWakuFetchingBackupProgress(response *wakusync.WakuBackedUpDataResponse) {
|
|
signal.SendWakuFetchingBackupProgress(response)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) SendWakuBackedUpProfile(response *wakusync.WakuBackedUpDataResponse) {
|
|
signal.SendWakuBackedUpProfile(response)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) SendWakuBackedUpSettings(response *wakusync.WakuBackedUpDataResponse) {
|
|
signal.SendWakuBackedUpSettings(response)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) SendWakuBackedUpKeypair(response *wakusync.WakuBackedUpDataResponse) {
|
|
signal.SendWakuBackedUpKeypair(response)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) SendWakuBackedUpWatchOnlyAccount(response *wakusync.WakuBackedUpDataResponse) {
|
|
signal.SendWakuBackedUpWatchOnlyAccount(response)
|
|
}
|
|
|
|
func (m *MessengerSignalsHandler) SendCuratedCommunitiesUpdate(response *communities.KnownCommunitiesResponse) {
|
|
signal.SendCuratedCommunitiesUpdate(response)
|
|
}
|