updates

type AccessHasher interface {
	GetChannelHash(channelID int) (hash int64, found bool, err error)
	SetChannelHash(channelID int, accessHash int64) error
}

type Config struct {
	RawClient    RawClient
	Handler      Handler
	Storage      Storage
	AccessHasher AccessHasher
	SelfID       int
	IsBot        bool
	Forget       bool
	Logger       *zap.Logger
}

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

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
	ChannelsForbidden map[int]*tg.ChannelForbidden
}

type Handler interface {
	HandleDiff(DiffUpdate) error
	HandleUpdates(*Entities, []tg.UpdateClass) error
	ChannelTooLong(channelID int)
}

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

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
	SetSeq(seq int) error
	SetDate(date int) error

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

	ForgetAll() error
}