updates

type Config struct {
	RawClient RawClient
	Handler   Handler
	SelfID    int
	IsBot     bool

	// Storage is the place whether the state is stored.
	// In-mem by default.
	Storage Storage
	// Number of workers which handles updates.
	// Min is 5.
	Concurrency int
	Forget      bool
	Logger      *zap.Logger
}

type DiffUpdate struct {
	NewMessages          []tg.MessageClass
	NewEncryptedMessages []tg.EncryptedMessageClass
	OtherUpdates         []tg.UpdateClass
	Users                []tg.UserClass
	Chats                []tg.ChatClass

	Pending     []tg.UpdateClass
	PendingEnts *Entities
}

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

type Entities struct {
	Users    map[int]*tg.User
	Chats    map[int]*tg.Chat
	Channels map[int]*tg.Channel
}

type Handler interface {
	HandleDiff(DiffUpdate) error
	HandleUpdates(Updates) error
	ChannelTooLong(channelID int)
}

type RawClient interface {
	UpdatesGetState(ctx context.Context) (*tg.UpdatesState, error)
	UpdatesGetDifference(ctx context.Context, request *tg.UpdatesGetDifferenceRequest) (tg.UpdatesDifferenceClass, error)
	UpdatesGetChannelDifference(ctx context.Context, request *tg.UpdatesGetChannelDifferenceRequest) (tg.UpdatesChannelDifferenceClass, error)
}

type State struct {
	Pts  int
	Qts  int
	Date int
	Seq  int
}

type Storage interface {
	GetState() (State, error)
	SetState(s State) error
	SetPts(pts int) error
	SetQts(qts int) error
	SetDateSeq(date, seq int) error

	SetChannelPts(channelID, pts int) error
	Channels(iter func(channelID, pts int)) error
	ForgetAll() error
}

type Updates struct {
	Updates []tg.UpdateClass
	Ents    *Entities
}