pubsub

type Listener interface {
	// Begin listening on this channel with this callback starting from this position. Blocks until Close() is called.
	Listen(chanName string, fn func(p Payload)) error
	// Close the listener. No more callbacks should fire.
	Close() error
}

type Notifier interface {
	// Notify chanName that there is a new payload p. Return an error if we failed to send the notification.
	Notify(chanName string, p Payload) error
	// Close is called when we should stop listening.
	Close() error
}

type Payload interface {
	// The type of payload; used mostly for logging and prometheus metrics
	Type() string
}

type PromNotifier struct {
	Notifier
	// contains filtered or unexported fields
}

type PubSub struct {
	// contains filtered or unexported fields
}

type V2AccountData struct {
	UserID string
	RoomID string
	Types  []string
}

type V2Accumulate struct {
	RoomID    string
	PrevBatch string
	EventNIDs []int64
}

type V2DeviceData struct {
	UserIDToDeviceIDs map[string][]string
}

type V2DeviceMessages struct {
	UserID   string
	DeviceID string
}

type V2ExpiredToken struct {
	UserID   string
	DeviceID string
}

type V2InitialSyncComplete struct {
	UserID   string
	DeviceID string
	Success  bool
}

type V2Initialise struct {
	RoomID      string
	SnapshotNID int64
}

type V2InvalidateRoom struct {
	RoomID string
}

type V2InviteRoom struct {
	UserID string
	RoomID string
}

type V2LeaveRoom struct {
	UserID     string
	RoomID     string
	LeaveEvent json.RawMessage
}

type V2Listener interface {
	Initialise(p *V2Initialise)
	Accumulate(p *V2Accumulate)
	OnTransactionID(p *V2TransactionID)
	OnAccountData(p *V2AccountData)
	OnInvite(p *V2InviteRoom)
	OnLeftRoom(p *V2LeaveRoom)
	OnUnreadCounts(p *V2UnreadCounts)
	OnInitialSyncComplete(p *V2InitialSyncComplete)
	OnDeviceData(p *V2DeviceData)
	OnTyping(p *V2Typing)
	OnReceipt(p *V2Receipt)
	OnDeviceMessages(p *V2DeviceMessages)
	OnExpiredToken(p *V2ExpiredToken)
	OnInvalidateRoom(p *V2InvalidateRoom)
}

type V2Receipt struct {
	RoomID   string
	Receipts []internal.Receipt
}

type V2Sub struct {
	// contains filtered or unexported fields
}

type V2TransactionID struct {
	EventID       string
	RoomID        string
	UserID        string // of the sender
	DeviceID      string
	TransactionID string // Note: an empty transaction ID represents the all-clear.
	NID           int64
}

type V2Typing struct {
	RoomID         string
	EphemeralEvent json.RawMessage
}

type V2UnreadCounts struct {
	UserID            string
	RoomID            string
	HighlightCount    *int
	NotificationCount *int
}

type V3EnsurePolling struct {
	// TODO: we only really need to provide the access token hash here.
	// Passing through a user means we can log something sensible though.
	UserID          string
	DeviceID        string
	AccessTokenHash string
}

type V3Listener interface {
	EnsurePolling(p *V3EnsurePolling)
}

type V3Sub struct {
	// contains filtered or unexported fields
}