pubsub

type Listener interface {
	// Begin listening on this channel with this callback starting from this position. Blocks until Close() is called.
	Listen(chanName string, start int64, fn func(p PartialWrapper)) 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
}

type PartialWrapper struct {
	PayloadType string          `json:"t"`
	Payload     json.RawMessage `json:"p"`
}

type Payload interface {
	Type() string
}

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

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

type V2DeviceData struct {
	Pos int64
}

type V2InitialSyncComplete struct {
	UserID   string
	DeviceID string
}

type V2Initialise struct {
	RoomID      string
	SnapshotNID int64
}

type V2InviteRoom struct {
	UserID string
	RoomID string
}

type V2LeaveRoom struct {
	UserID string
	RoomID string
}

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

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

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

type V2SubReceiver interface {
	Initialise(p *V2Initialise)
	Accumulate(p *V2Accumulate)
	OnAccountData(p *V2AccountData)
	OnInvite(p *V2InviteRoom)
	OnLeftRoom(p *V2LeaveRoom)
	OnUnreadCounts(p *V2UnreadCounts)
	OnInitialSyncComplete(p *V2InitialSyncComplete)
	OnDeviceData(p *V2DeviceData)
	OnTyping(p *V2Typing)
	OnReceipt(p *V2Receipt)
}

type V2Typing struct {
	RoomID         string
	EphemeralEvent json.RawMessage
}

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

type V3EnsurePolling struct {
	UserID   string
	DeviceID string
}

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

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

type V3SubReceiver interface {
	EnsurePolling(p *V3EnsurePolling)
}

type Wrapper struct {
	Type    string      `json:"t"`
	Payload interface{} `json:"p"`
}