110 lines
3.6 KiB
TypeScript
110 lines
3.6 KiB
TypeScript
import { NextRequest, NextResponse } from 'next/server'
|
|
import { ConfigManager, reconnectAllPlatforms } from '@/remote-control/config/manager'
|
|
|
|
export async function GET() {
|
|
const configManager = ConfigManager.getInstance()
|
|
await configManager.ensureLoaded()
|
|
const config = configManager.getMasked()
|
|
return NextResponse.json(config)
|
|
}
|
|
|
|
export async function PUT(request: NextRequest) {
|
|
try {
|
|
const body = await request.json()
|
|
const configManager = ConfigManager.getInstance()
|
|
await configManager.ensureLoaded()
|
|
|
|
// Replace masked values with existing real values so we don't overwrite secrets
|
|
const merged = stripMaskedValues(body, configManager.get())
|
|
|
|
const validationError = validateConfig(merged)
|
|
if (validationError) {
|
|
return NextResponse.json(
|
|
{ success: false, error: validationError },
|
|
{ status: 400 }
|
|
)
|
|
}
|
|
|
|
// skipEmit: lifecycle is managed explicitly below, avoid double-triggering
|
|
await configManager.update(merged, { skipEmit: true })
|
|
|
|
// After saving, explicitly manage bot lifecycle:
|
|
// - Stop all disabled bots
|
|
// - Reconnect (stop + start) all enabled bots
|
|
const config = configManager.get()
|
|
const errors: string[] = []
|
|
|
|
await reconnectAllPlatforms(config, errors)
|
|
|
|
return NextResponse.json({
|
|
success: true,
|
|
message: errors.length > 0
|
|
? `配置已保存，部分渠道连接异常: ${errors.join('; ')}`
|
|
: '配置已保存并生效',
|
|
})
|
|
} catch (error) {
|
|
return NextResponse.json(
|
|
{ success: false, error: '保存配置失败' },
|
|
{ status: 500 }
|
|
)
|
|
}
|
|
}
|
|
|
|
const MASK_PREFIX = '••••'
|
|
|
|
/**
|
|
* If the frontend sends back a masked value (e.g. "••••pbYI"), replace it
|
|
* with the real value from the current config so we never overwrite secrets.
|
|
*/
|
|
function stripMaskedValues(
|
|
incoming: Record<string, Record<string, unknown>>,
|
|
current: Record<string, Record<string, unknown>>,
|
|
): Record<string, Record<string, unknown>> {
|
|
const result: Record<string, Record<string, unknown>> = {}
|
|
for (const platform of Object.keys(incoming)) {
|
|
const incomingPlatform = incoming[platform]
|
|
const currentPlatform = current[platform] ?? {}
|
|
const merged: Record<string, unknown> = {}
|
|
for (const key of Object.keys(incomingPlatform)) {
|
|
const val = incomingPlatform[key]
|
|
if (typeof val === 'string' && val.startsWith(MASK_PREFIX)) {
|
|
// Keep the real value
|
|
merged[key] = currentPlatform[key] ?? ''
|
|
} else {
|
|
merged[key] = val
|
|
}
|
|
}
|
|
result[platform] = merged
|
|
}
|
|
return result
|
|
}
|
|
|
|
function validateConfig(config: Record<string, unknown>): string | null {
|
|
const discord = config.discord as Record<string, unknown> | undefined
|
|
const dingtalk = config.dingtalk as Record<string, unknown> | undefined
|
|
const lark = config.lark as Record<string, unknown> | undefined
|
|
|
|
if (discord?.enabled && !discord?.botToken) {
|
|
return 'Discord Bot Token 不能为空'
|
|
}
|
|
if (dingtalk?.enabled && (!dingtalk?.clientId || !dingtalk?.clientSecret)) {
|
|
return '钉钉 Client ID 和 Client Secret 不能为空'
|
|
}
|
|
if (lark?.enabled) {
|
|
if (!lark?.appId || !lark?.appSecret) {
|
|
return '飞书 App ID 和 App Secret 不能为空'
|
|
}
|
|
}
|
|
|
|
const telegram = config.telegram as Record<string, unknown> | undefined
|
|
const slack = config.slack as Record<string, unknown> | undefined
|
|
|
|
if (telegram?.enabled && !telegram?.botToken) {
|
|
return 'Telegram Bot Token 不能为空'
|
|
}
|
|
if (slack?.enabled && (!slack?.botToken || !slack?.appToken)) {
|
|
return 'Slack Bot Token 和 App Token 不能为空'
|
|
}
|
|
return null
|
|
}
|