telegram

type Command struct {
	Command     string
	Description string
}

type TelegramAdmin struct {
	logger.Logger
	// contains filtered or unexported fields
}

type TelegramAdminActionStore interface {
	Get(ctx context.Context, key string) (string, error)
	Set(ctx context.Context, key, value string, ttl time.Duration) error
	Delete(ctx context.Context, key string) error
}

type TelegramAdminDependencies struct {
	Messenger TelegramMessenger
	Actions   TelegramAdminActionStore
	// MirrorTicketStatus and MirrorTicketReply keep the ticket's forum
	// topic in step with ticket mutations done through bot commands
	// (/close, /reopen, /rp), which bypass the support module's notifier.
	// Optional and best-effort.
	MirrorTicketStatus func(ticketID int64, status uint8)
	MirrorTicketReply  func(ticketID int64, content string)
	Tickets            repository.TicketRepo
	Orders             repository.OrderRepo
	Users              repository.UserRepo
	UserAuth           repository.UserAuthRepo
	Subscriptions      repository.UserSubscriptionRepo
	UserCache          repository.UserCacheRepo
	Plans              repository.SubscribeRepo
	Logs               repository.LogRepo
	// Wallet is the billing-domain read port for balance display.
	Wallet repository.WalletRepo
}

type TelegramAdminHandler interface {
	Handle(msg *models.Message)
}

type TelegramCommandRegistrar interface {
	SetCommands(chatID int64, commands []Command) error
	SetGroupAdminCommands(chatID int64, commands []Command) error
}

type TelegramLogic struct {
	logger.Logger
	// contains filtered or unexported fields
}

type TelegramLogicDependencies struct {
	Messenger TelegramMessenger
	Sessions  TelegramSessionStore
	UserAuth  repository.UserAuthRepo
	UserCache repository.UserCacheRepo
	Admin     TelegramAdminHandler

	// GroupChatID returns the validated admin group; zero disables group
	// routing. Read per call because re-initialisation may change it.
	GroupChatID func() int64
	Topics      repository.TelegramTopicRepo
	TopicClient TelegramTopicClient
	Tickets     repository.TicketRepo
	Users       repository.UserRepo
	Limiter     TelegramRelayLimiter
}

type TelegramMessenger interface {
	Send(chatID, threadID int64, message string) error
	SendMarkdown(chatID, threadID int64, message string) error
}

type TelegramRedisStore interface {
	TelegramSessionStore
	TelegramAdminActionStore
	TelegramRelayLimiter
}

type TelegramRelayLimiter interface {
	// Allow reports whether the chat may relay another message right now.
	// shouldNotify is true only for the first rejection of a window, so a
	// flood is answered with one notice instead of one per message.
	Allow(ctx context.Context, chatID int64) (allowed, shouldNotify bool)
}

type TelegramSessionStore interface {
	Get(ctx context.Context, key string) (string, error)
	Delete(ctx context.Context, key string) error
}

type TelegramTopicClient interface {
	// ValidateAdminGroup confirms the chat is a forum-enabled supergroup
	// where the bot may manage topics.
	ValidateAdminGroup(ctx context.Context, chatID int64) error
	CreateTopic(ctx context.Context, chatID int64, name string) (int64, error)
	DeleteTopic(ctx context.Context, chatID, threadID int64) error
	CloseTopic(ctx context.Context, chatID, threadID int64) error
	ReopenTopic(ctx context.Context, chatID, threadID int64) error
	// ForwardToThread relays a user's message into a group topic keeping
	// the sender identity visible to the support staff.
	ForwardToThread(ctx context.Context, chatID, threadID, fromChatID int64, messageID int) error
	// CopyTo relays a group message to a private chat without exposing
	// which administrator wrote it.
	CopyTo(ctx context.Context, toChatID, fromChatID int64, messageID int) error
}

type TopicService struct {
	logger.Logger
	// contains filtered or unexported fields
}