status-go/signal/events_messenger.go

62 lines
2.1 KiB
Go
Raw Permalink Normal View History

2021-02-23 15:47:45 +00:00
package signal
const (
2022-07-06 11:44:40 +00:00
// EventMediaServerStarted triggers when the media server successfully binds a new port
EventMediaServerStarted = "mediaserver.started"
2021-02-23 15:47:45 +00:00
// EventMesssageDelivered triggered when we got acknowledge from datasync level, that means peer got message
EventMesssageDelivered = "message.delivered"
2022-10-19 10:01:04 +00:00
// EventCommunityInfoFound triggered when user requested info about some community and messenger successfully
// retrieved it from mailserver
EventCommunityInfoFound = "community.found"
2022-10-19 10:01:04 +00:00
// EventStatusUpdatesTimedOut Event Automatic Status Updates Timed out
EventStatusUpdatesTimedOut = "status.updates.timedout"
// EventCuratedCommunitiesUpdate triggered when it is time to refresh the list of curated communities
EventCuratedCommunitiesUpdate = "curated.communities.update"
2021-02-23 15:47:45 +00:00
)
// MessageDeliveredSignal specifies chat and message that was delivered
type MessageDeliveredSignal struct {
ChatID string `json:"chatID"`
MessageID string `json:"messageID"`
}
2022-07-06 11:44:40 +00:00
// MediaServerStarted specifies chat and message that was delivered
type MediaServerStarted struct {
Port int `json:"port"`
2022-07-06 11:44:40 +00:00
}
// MessageDeliveredSignal specifies chat and message that was delivered
type CommunityInfoFoundSignal struct {
Name string `json:"name"`
Description string `json:"description"`
MembersCount int `json:"membersCount"`
Verified bool `json:"verified"`
}
2021-02-23 15:47:45 +00:00
// SendMessageDelivered notifies about delivered message
func SendMessageDelivered(chatID string, messageID string) {
send(EventMesssageDelivered, MessageDeliveredSignal{ChatID: chatID, MessageID: messageID})
}
2022-07-06 11:44:40 +00:00
// SendMediaServerStarted notifies about restarts of the media server
func SendMediaServerStarted(port int) {
send(EventMediaServerStarted, MediaServerStarted{Port: port})
}
// SendMessageDelivered notifies about delivered message
func SendCommunityInfoFound(community interface{}) {
send(EventCommunityInfoFound, community)
}
func SendStatusUpdatesTimedOut(statusUpdates interface{}) {
send(EventStatusUpdatesTimedOut, statusUpdates)
}
func SendCuratedCommunitiesUpdate(curatedCommunitiesUpdate interface{}) {
send(EventCuratedCommunitiesUpdate, curatedCommunitiesUpdate)
}