channels

type TelegramChannel ¶

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

TelegramChannel implements domain.Channel for the Telegram Bot API using the go-telegram/bot SDK with long-polling.

func NewTelegramChannel(cfg config.TelegramChannelConfig, transcriber VoiceTranscriber, retention *VoiceRetention) *TelegramChannel

func (t *TelegramChannel) Name() string

func (t *TelegramChannel) Send(ctx context.Context, msg domain.OutboundMessage) error

func (t *TelegramChannel) SendApproval(ctx context.Context, recipientID string, req *domain.ApprovalRequest) error

func (t *TelegramChannel) Start(ctx context.Context, inbox chan<- domain.InboundMessage) error

func (t *TelegramChannel) Stop() error

type VoiceRetention ¶ added in v0.125.0

type VoiceRetention struct {
	Dir  string
	Keep int
	// contains filtered or unexported fields
}

VoiceRetention persists a bounded number of inbound voice/audio recordings to a local directory, pruning the oldest once the count exceeds Keep. A nil *VoiceRetention or a Keep <= 0 disables retention (the default behavior).

save serializes on mu because the channel manager may process voice messages concurrently and they all share one directory.

type VoiceTranscriber ¶ added in v0.116.0

type VoiceTranscriber interface {
	TranscribeFile(ctx context.Context, audioPath string) (string, error)
}

VoiceTranscriber transcribes a downloaded audio file (any format ffmpeg can decode) into text. It is defined here so the channel can be wired with a concrete speech-to-text implementation only when the feature is enabled, while remaining nil (and a no-op) otherwise.