status-im/status-go

package signal

const (

    // EventHistoryArchivesEnabled triggered when the community history archive protocol
    // was enabled via the RPC API
    EventHistoryArchivesProtocolEnabled = "community.historyArchivesProtocolEnabled"
    // EventHistoryArchivesDisabled triggered when the community history archive protocol
    // was disabled via the RPC API
    EventHistoryArchivesProtocolDisabled = "community.historyArchivesProtocolDisabled"
    // EventCreatingHistoryArchives is triggered when the community owner node
    // starts to create archives torrents
    EventCreatingHistoryArchives = "community.creatingHistoryArchives"
    // EventHistoryArchivesCreated is triggered when the community owner node
    // has finished to create archives torrents
    EventHistoryArchivesCreated = "community.historyArchivesCreated"
    // EventNoHistoryArchivesCreated is triggered when the community owner node
    // tried to create archives but haven't because there were no new messages
    // to archive
    EventNoHistoryArchivesCreated = "community.noHistoryArchivesCreated"
    // EventHistoryArchivesSeeding is triggered when the community owner node
    // started seeding archives torrents
    EventHistoryArchivesSeeding = "community.historyArchivesSeeding"
    // EventHistoryArchivesUnseeded is triggered when the community owner node
    // drops a torrent for a particular community
    EventHistoryArchivesUnseeded = "community.historyArchivesUnseeded"
    // EventDownloadingHistoryArchivesFinished is triggered when the community member node
    // has downloaded all archives
    EventDownloadingHistoryArchivesStarted = "community.downloadingHistoryArchivesStarted"
    // EventHistoryArchiveDownloaded is triggered when the community member node
    // has downloaded an individual community archive
    EventHistoryArchiveDownloaded = "community.historyArchiveDownloaded"
    // EventImportingHistoryArchiveMessages is triggered when the community member node
    // has starts importing downloaded archive messages into the database
    EventImportingHistoryArchiveMessages = "community.importingHistoryArchiveMessages"
    // EventDownloadingHistoryArchivesFinished is triggered when the community member node
    // has downloaded all archives
    EventDownloadingHistoryArchivesFinished = "community.downloadingHistoryArchivesFinished"
)

type CreatingHistoryArchivesSignal struct {
    CommunityID string `json:"communityId"`
}

type NoHistoryArchivesCreatedSignal struct {
    CommunityID string `json:"communityId"`
    From        int    `json:"from"`
    To          int    `json:"to"`
}

type HistoryArchivesCreatedSignal struct {
    CommunityID string `json:"communityId"`
    From        int    `json:"from"`
    To          int    `json:"to"`
}

type HistoryArchivesSeedingSignal struct {
    CommunityID string `json:"communityId"`
}

type HistoryArchivesUnseededSignal struct {
    CommunityID string `json:"communityId"`
}

type HistoryArchiveDownloadedSignal struct {
    CommunityID string `json:"communityId"`
    From        int    `json:"from"`
    To          int    `json:"to"`
}

type DownloadingHistoryArchivesStartedSignal struct {
    CommunityID string `json:"communityId"`
}

type ImportingHistoryArchiveMessagesSignal struct {
    CommunityID string `json:"communityId"`
}

type DownloadingHistoryArchivesFinishedSignal struct {
    CommunityID string `json:"communityId"`
}

func SendHistoryArchivesProtocolEnabled() {
    send(EventHistoryArchivesProtocolEnabled, nil)
}

func SendHistoryArchivesProtocolDisabled() {
    send(EventHistoryArchivesProtocolDisabled, nil)
}

func SendCreatingHistoryArchives(communityID string) {
    send(EventCreatingHistoryArchives, CreatingHistoryArchivesSignal{CommunityID: communityID})
}

func SendNoHistoryArchivesCreated(communityID string, from int, to int) {
    send(EventNoHistoryArchivesCreated, NoHistoryArchivesCreatedSignal{
        CommunityID: communityID,
        From:        from,
        To:          to,
    })
}

func SendHistoryArchivesCreated(communityID string, from int, to int) {
    send(EventHistoryArchivesCreated, HistoryArchivesCreatedSignal{
        CommunityID: communityID,
        From:        from,
        To:          to,
    })
}

func SendHistoryArchivesSeeding(communityID string) {
    send(EventHistoryArchivesSeeding, HistoryArchivesSeedingSignal{CommunityID: communityID})
}

func SendHistoryArchivesUnseeded(communityID string) {
    send(EventHistoryArchivesUnseeded, HistoryArchivesUnseededSignal{CommunityID: communityID})
}

func SendHistoryArchiveDownloaded(communityID string, from int, to int) {
    send(EventHistoryArchiveDownloaded, HistoryArchiveDownloadedSignal{
        CommunityID: communityID,
        From:        from,
        To:          to,
    })
}

func SendDownloadingHistoryArchivesStarted(communityID string) {
    send(EventDownloadingHistoryArchivesStarted, DownloadingHistoryArchivesStartedSignal{
        CommunityID: communityID,
    })
}

func SendImportingHistoryArchiveMessages(communityID string) {
    send(EventImportingHistoryArchiveMessages, ImportingHistoryArchiveMessagesSignal{
        CommunityID: communityID,
    })
}

func SendDownloadingHistoryArchivesFinished(communityID string) {
    send(EventDownloadingHistoryArchivesFinished, DownloadingHistoryArchivesFinishedSignal{
        CommunityID: communityID,
    })
}