72 lines
2.4 KiB
TypeScript
72 lines
2.4 KiB
TypeScript
import type { Context } from '@deepseek-ai/cordis'
|
|
import Schema from '@deepseek-ai/schemastery'
|
|
import { TelegramBridge } from './bridge.js'
|
|
|
|
export const name = 'dsh-telegram-channel'
|
|
/** agents: followup; apiProxy and userQuestions are optional runtime services. */
|
|
export const inject = ['agents']
|
|
|
|
export interface TelegramChannelConfig {
|
|
token?: string
|
|
allowedUserIds?: number[]
|
|
allowAllUsers?: boolean
|
|
maxMessageLength?: number
|
|
pollingTimeoutSec?: number
|
|
/** 默认 'rich' = Telegram native Rich Messages（需较新客户端）；
|
|
* 显式 'html'/'compat' 等其它值 = 兼容模式，所有客户端可显示。 */
|
|
rendering?: string
|
|
}
|
|
|
|
export const Config: Schema<TelegramChannelConfig> = Schema.object({
|
|
token: Schema.string().default(''),
|
|
allowedUserIds: Schema.array(Schema.number()).default([]),
|
|
allowAllUsers: Schema.boolean().default(false),
|
|
maxMessageLength: Schema.number().default(4096),
|
|
pollingTimeoutSec: Schema.number().default(30),
|
|
rendering: Schema.string().default('rich'),
|
|
})
|
|
|
|
function resolveAllowedUserIds(config: TelegramChannelConfig): number[] {
|
|
if (config.allowedUserIds && config.allowedUserIds.length > 0) {
|
|
return config.allowedUserIds
|
|
}
|
|
const raw = process.env.DSH_TELEGRAM_ALLOWED_USER_IDS ?? ''
|
|
return raw
|
|
.split(/[,;\s]+/)
|
|
.map((part) => part.trim())
|
|
.filter(Boolean)
|
|
.map((part) => Number(part))
|
|
.filter((n) => Number.isFinite(n) && n > 0)
|
|
}
|
|
|
|
export function apply(ctx: Context, config: TelegramChannelConfig): void {
|
|
const token = (config.token && config.token.length > 0)
|
|
? config.token
|
|
: (process.env.DSH_TELEGRAM_TOKEN ?? '')
|
|
if (!token) {
|
|
ctx.logger.error(
|
|
'dsh-telegram-channel: missing bot token (set config.token or DSH_TELEGRAM_TOKEN); polling not started',
|
|
)
|
|
return
|
|
}
|
|
const bridge = new TelegramBridge(ctx, {
|
|
token,
|
|
allowedUserIds: resolveAllowedUserIds(config),
|
|
allowAllUsers: config.allowAllUsers ?? false,
|
|
maxMessageLength: config.maxMessageLength ?? 4096,
|
|
pollingTimeoutSec: config.pollingTimeoutSec ?? 30,
|
|
rendering: config.rendering === 'rich' ? 'rich' : 'html',
|
|
})
|
|
ctx.effect(() => {
|
|
bridge.start()
|
|
return () => { void bridge.stop() }
|
|
}, 'dsh-telegram-channel.serve')
|
|
}
|
|
|
|
export * from './format.js'
|
|
export * from './client.js'
|
|
export * from './auth.js'
|
|
export * from './commands.js'
|
|
export * from './label.js'
|
|
export * from './bridge.js'
|