[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_220":221,"_222":223},"routes/_app.x.$handle.$name",{"_99":98,"_32":46,"_108":89,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":126,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":-5,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",8,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","src/app/serverless/mainWebhookApp.ts","latestPath","fileId","655e66c6-5b66-11f1-ba8d-ee650bb23af1","name","mainWebhookApp.ts","fileType","script","content","import { type Hono } from \"@hono/hono\";\n\nimport { PostgresAdminDataService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/adminDataService.ts\";\nimport { RedisAdminSessionStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/adminSessionStore.ts\";\nimport { AdminTotpManager } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/adminTotpManager.ts\";\nimport {\n createAdminApp,\n type CreateAdminAppOptions,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/createAdminApp.ts\";\nimport { AivenPostgresControlPlaneService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/aivenPostgresControlPlane.ts\";\nimport { CloudflareScheduledAutomationService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/cloudflareScheduledAutomationService.ts\";\nimport { InfrastructureTargetRepository } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/infrastructureTargetRepository.ts\";\nimport { QStashCronAutomationService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/qstashCronAutomationService.ts\";\nimport { TelegramWebhookAdminService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/telegramWebhookAdminService.ts\";\nimport { UpstashRedisControlPlaneService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/upstashRedisControlPlane.ts\";\nimport { ValTownCronAutomationService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/valTownCronAutomationService.ts\";\nimport {\n initializeMerchantAssetStore,\n releaseDueMerchantSettlements,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/billing/merchantAssetStore.ts\";\nimport { createBot } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/bot/createBot.ts\";\nimport {\n createRedisRuntimeClient,\n PostgresRedisRuntimeCutoverRepository,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/bot/storage/redisRuntimeCutover.ts\";\nimport { registerTelegramWebhookRoutes } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/bot/telegramWebhook.ts\";\nimport { type AppEnv, loadEnv } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/config/env.ts\";\nimport { type RuntimeConfig } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/config/runtimeConfig.ts\";\nimport { RuntimeConfigRepository } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/config/runtimeConfigRepository.ts\";\nimport {\n type AdminBootstrapRuntimeConfig,\n RuntimeConfigService,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/config/runtimeConfigService.ts\";\nimport { buildGroupPaidAccessControlsFromRuntimeConfig } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/groupPaidAccessConfig.ts\";\nimport {\n type GroupAutoKickSweepOptions,\n runGroupAutoKickSweep,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/groupAutoKickWorker.ts\";\nimport { runGroupPaymentConfirmationSweep } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/groupPaymentConfirmationSweepWorker.ts\";\nimport { runGroupPaymentRefundAutoApprove } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/groupPaymentRefundAutoApproveWorker.ts\";\nimport { runGroupPaymentRefundReconcile } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/groupPaymentRefundReconcileWorker.ts\";\nimport { initializeGroupStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/store.ts\";\nimport { initializeMerchantAccountStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/merchantAccount/store.ts\";\nimport { initializeVirtualDeliveryStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/virtualDelivery/store.ts\";\nimport {\n PostgresSystemHealthRegistry,\n recordRuntimeIssue,\n type SystemHealthSnapshot,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/ops/systemHealth.ts\";\nimport { buildLocalTestPaymentProviderPolicy } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/paymentProviders/localTestSafety.ts\";\nimport { PaymentProviderRuntimeStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/paymentProviders/runtimeStore.ts\";\nimport { initializeTelegramUserStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/user/store.ts\";\nimport { initializeUserAccessControlStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/user/accessControlStore.ts\";\n\nexport interface MainWebhookAppAssetLoaders {\n loadAdminWebIndexHtml?: CreateAdminAppOptions[\"loadAdminWebIndexHtml\"];\n loadAdminWebAsset?: CreateAdminAppOptions[\"loadAdminWebAsset\"];\n}\n\nexport interface CreateMainWebhookAppOptions\n extends MainWebhookAppAssetLoaders {\n env?: AppEnv;\n devAuthBypassEnabled?: boolean;\n}\n\ninterface MainControlPlane {\n adminTotpManager: AdminTotpManager;\n aivenPostgresControlPlaneService: AivenPostgresControlPlaneService;\n cloudflareScheduledAutomationService: CloudflareScheduledAutomationService;\n infrastructureTargetRepository: InfrastructureTargetRepository;\n qstashCronAutomationService: QStashCronAutomationService;\n runtimeConfigRepository: RuntimeConfigRepository;\n runtimeConfigService: RuntimeConfigService;\n systemHealthRegistry: PostgresSystemHealthRegistry;\n telegramWebhookAdminService: TelegramWebhookAdminService;\n upstashRedisControlPlaneService: UpstashRedisControlPlaneService;\n valTownCronAutomationService: ValTownCronAutomationService;\n}\n\nfunction createMainControlPlane(env: AppEnv): MainControlPlane {\n const runtimeConfigRepository = new RuntimeConfigRepository(\n env.controlDatabaseUrl,\n );\n const runtimeConfigService = new RuntimeConfigService(\n runtimeConfigRepository,\n );\n const adminTotpManager = new AdminTotpManager({\n databaseUrl: env.controlDatabaseUrl,\n });\n const valTownCronAutomationService = new ValTownCronAutomationService({\n databaseUrl: env.controlDatabaseUrl,\n encryptionSecret: env.controlDatabaseUrl,\n });\n const qstashCronAutomationService = new QStashCronAutomationService();\n const cloudflareScheduledAutomationService =\n new CloudflareScheduledAutomationService({\n controlDatabaseUrl: env.controlDatabaseUrl,\n });\n const telegramWebhookAdminService = new TelegramWebhookAdminService();\n const infrastructureTargetRepository = new InfrastructureTargetRepository(\n env.controlDatabaseUrl,\n );\n const upstashRedisControlPlaneService = new UpstashRedisControlPlaneService({\n controlDatabaseUrl: env.controlDatabaseUrl,\n encryptionSecret: env.controlDatabaseUrl,\n infrastructureTargetRepository,\n });\n const aivenPostgresControlPlaneService = new AivenPostgresControlPlaneService(\n {\n controlDatabaseUrl: env.controlDatabaseUrl,\n encryptionSecret: env.controlDatabaseUrl,\n infrastructureTargetRepository,\n },\n );\n const systemHealthRegistry = new PostgresSystemHealthRegistry(\n env.controlDatabaseUrl,\n );\n\n return {\n adminTotpManager,\n aivenPostgresControlPlaneService,\n cloudflareScheduledAutomationService,\n infrastructureTargetRepository,\n qstashCronAutomationService,\n runtimeConfigRepository,\n runtimeConfigService,\n systemHealthRegistry,\n telegramWebhookAdminService,\n upstashRedisControlPlaneService,\n valTownCronAutomationService,\n };\n}\n\nasync function seedStartupConfig(\n controlPlane: MainControlPlane,\n env: AppEnv,\n): Promise {\n await controlPlane.runtimeConfigService.seedMissingConfigsFromBuiltinDefaults(\n {\n actorId: \"system:valtown-main-startup\",\n reason: \"Val Town 主服务启动时补齐内建配置\",\n },\n );\n await controlPlane.runtimeConfigService.seedMissingBootstrapConfigsFromEnv({\n botToken: env.bootstrapBotToken,\n superAdminIds: env.bootstrapSuperAdminIds,\n actorId: \"system:valtown-main-bootstrap-env\",\n reason: \"Val Town 主服务启动时从环境变量引导配置\",\n });\n return await controlPlane.runtimeConfigService.getAdminBootstrapConfig();\n}\n\nfunction createBootstrapAdminApp(input: {\n assetLoaders: MainWebhookAppAssetLoaders;\n controlPlane: MainControlPlane;\n devAuthBypassEnabled: boolean;\n}): Hono {\n const app = createAdminApp(input.controlPlane.runtimeConfigService, {\n adminTotpManager: input.controlPlane.adminTotpManager,\n cloudflareScheduledAutomationService:\n input.controlPlane.cloudflareScheduledAutomationService,\n qstashCronAutomationService: input.controlPlane.qstashCronAutomationService,\n telegramWebhookAdminService: input.controlPlane.telegramWebhookAdminService,\n valTownCronAutomationService:\n input.controlPlane.valTownCronAutomationService,\n adminWebAppEnabled: true,\n devAuthBypassEnabled: input.devAuthBypassEnabled,\n healthRegistry: input.controlPlane.systemHealthRegistry,\n loadAdminWebAsset: input.assetLoaders.loadAdminWebAsset,\n loadAdminWebIndexHtml: input.assetLoaders.loadAdminWebIndexHtml,\n });\n registerServerlessHealthRoute(app, \"bootstrap\");\n return app;\n}\n\nfunction buildGroupAutoKickSweepOptions(\n runtimeConfig: RuntimeConfig,\n): Omit {\n return {\n batchSize: runtimeConfig.GROUP_AUTO_KICK_SWEEP_BATCH_SIZE,\n maxBatchesPerSweep: runtimeConfig.GROUP_AUTO_KICK_SWEEP_MAX_BATCHES,\n maxSweepRuntimeMs: runtimeConfig.GROUP_AUTO_KICK_SWEEP_MAX_RUNTIME_SECONDS *\n 1000,\n };\n}\n\nfunction buildPaymentConfirmationSweepOptions(runtimeConfig: RuntimeConfig) {\n return {\n batchSize: runtimeConfig.GROUP_PAYMENT_CONFIRMATION_SWEEP_BATCH_SIZE,\n maxBatchesPerSweep:\n runtimeConfig.GROUP_PAYMENT_CONFIRMATION_SWEEP_MAX_BATCHES,\n maxSweepRuntimeMs:\n runtimeConfig.GROUP_PAYMENT_CONFIRMATION_SWEEP_MAX_RUNTIME_SECONDS * 1000,\n pendingGraceMs:\n runtimeConfig.GROUP_PAYMENT_CONFIRMATION_SWEEP_PENDING_GRACE_SECONDS *\n 1000,\n };\n}\n\nfunction buildPaymentRefundReconcileOptions(runtimeConfig: RuntimeConfig) {\n return {\n batchSize: runtimeConfig.GROUP_PAYMENT_REFUND_RECONCILE_BATCH_SIZE,\n maxBatchesPerSweep:\n runtimeConfig.GROUP_PAYMENT_REFUND_RECONCILE_MAX_BATCHES,\n maxSweepRuntimeMs:\n runtimeConfig.GROUP_PAYMENT_REFUND_RECONCILE_MAX_RUNTIME_SECONDS * 1000,\n pendingGraceMs:\n runtimeConfig.GROUP_PAYMENT_REFUND_RECONCILE_PENDING_GRACE_SECONDS * 1000,\n };\n}\n\nfunction buildPaymentRefundAutoApproveOptions(runtimeConfig: RuntimeConfig) {\n return {\n batchSize: runtimeConfig.GROUP_PAYMENT_REFUND_AUTO_APPROVE_SWEEP_BATCH_SIZE,\n maxBatchesPerSweep:\n runtimeConfig.GROUP_PAYMENT_REFUND_AUTO_APPROVE_SWEEP_MAX_BATCHES,\n maxSweepRuntimeMs: runtimeConfig\n .GROUP_PAYMENT_REFUND_AUTO_APPROVE_SWEEP_MAX_RUNTIME_SECONDS *\n 1000,\n };\n}\n\nfunction createPaymentProviderRuntimeStore(input: {\n controlDatabaseUrl: string;\n runtimeConfig: RuntimeConfig;\n}): PaymentProviderRuntimeStore {\n const localTestPaymentProviderPolicy = buildLocalTestPaymentProviderPolicy({\n appEnvironment: input.runtimeConfig.APP_ENVIRONMENT,\n localTestProviderEnabled:\n input.runtimeConfig.PAYMENT_LOCAL_TEST_PROVIDER_ENABLED,\n controlDatabaseUrl: input.controlDatabaseUrl,\n mainDatabaseUrl: input.runtimeConfig.MAIN_DATABASE_URL,\n });\n\n return new PaymentProviderRuntimeStore(\n input.runtimeConfig.MAIN_DATABASE_URL,\n {\n allowLocalTestProvider:\n localTestPaymentProviderPolicy.allowLocalTestProvider,\n localTestProviderDisabledReason:\n localTestPaymentProviderPolicy.disabledReason,\n },\n );\n}\n\nfunction formatRuntimeIssueDetail(error: unknown): string {\n if (error instanceof Error) {\n return [error.message, error.stack].filter(Boolean).join(\"\\n\").slice(\n 0,\n 2000,\n );\n }\n return String(error).slice(0, 2000);\n}\n\nfunction createRuntimeIssuePublisher(\n registry: PostgresSystemHealthRegistry,\n) {\n return (input: {\n id: string;\n name: string;\n category: SystemHealthSnapshot[\"category\"];\n message: string;\n error: unknown;\n }) => {\n const snapshot = recordRuntimeIssue(registry, {\n id: input.id,\n name: input.name,\n category: input.category,\n message: input.message,\n detail: formatRuntimeIssueDetail(input.error),\n });\n void registry.upsert(snapshot).catch((error) => {\n console.error(\"记录 Val Town 主服务运行异常失败：\", error);\n });\n };\n}\n\nfunction registerServerlessHealthRoute(\n app: Hono,\n mode: \"bootstrap\" | \"webhook\",\n): void {\n app.get(\"/health\", (c) =>\n c.json({\n ok: true,\n runtime: \"valtown-main\",\n mode,\n }));\n}\n\nfunction initializePersistentStores(input: {\n controlDatabaseUrl: string;\n runtimeConfig: RuntimeConfig;\n}): void {\n initializeGroupStore(input.runtimeConfig.MAIN_DATABASE_URL);\n initializeVirtualDeliveryStore(input.runtimeConfig.MAIN_DATABASE_URL);\n initializeTelegramUserStore(input.runtimeConfig.MAIN_DATABASE_URL);\n initializeUserAccessControlStore(input.runtimeConfig.MAIN_DATABASE_URL);\n initializeMerchantAccountStore({\n databaseUrl: input.runtimeConfig.MAIN_DATABASE_URL,\n totpSecretEncryptionSecret: input.controlDatabaseUrl,\n });\n initializeMerchantAssetStore(input.runtimeConfig.MAIN_DATABASE_URL);\n}\n\nexport async function createMainWebhookApp(\n options: CreateMainWebhookAppOptions = {},\n): Promise {\n const env = options.env ?? loadEnv();\n const devAuthBypassEnabled = options.devAuthBypassEnabled ??\n Deno.env.get(\"WEB_ADMIN_DEV_AUTH_BYPASS\") === \"true\";\n const assetLoaders: MainWebhookAppAssetLoaders = {\n loadAdminWebAsset: options.loadAdminWebAsset,\n loadAdminWebIndexHtml: options.loadAdminWebIndexHtml,\n };\n const controlPlane = createMainControlPlane(env);\n\n await seedStartupConfig(controlPlane, env);\n\n let runtimeConfig: RuntimeConfig;\n try {\n runtimeConfig = await controlPlane.runtimeConfigService\n .getEffectiveRuntimeConfig();\n } catch (error) {\n console.error(\n \"Val Town 主服务缺少完整运行配置，已进入管理台初始化模式：\",\n error,\n );\n return createBootstrapAdminApp({\n assetLoaders,\n controlPlane,\n devAuthBypassEnabled,\n });\n }\n\n initializePersistentStores({\n controlDatabaseUrl: env.controlDatabaseUrl,\n runtimeConfig,\n });\n\n const paymentProviderRuntimeStore = createPaymentProviderRuntimeStore({\n controlDatabaseUrl: env.controlDatabaseUrl,\n runtimeConfig,\n });\n const adminDataService = new PostgresAdminDataService(\n runtimeConfig.MAIN_DATABASE_URL,\n {\n tenantDataSourceSecret: env.controlDatabaseUrl,\n paymentProviderRuntimeStore,\n refundPlatformFeeRateBps:\n runtimeConfig.GROUP_PAYMENT_REFUND_PLATFORM_FEE_RATE_BPS,\n },\n );\n\n const publishRuntimeIssue = createRuntimeIssuePublisher(\n controlPlane.systemHealthRegistry,\n );\n const redisHealthReporter = {\n reportRedisFailure: (input: {\n id: string;\n name: string;\n message: string;\n error: unknown;\n }) => {\n publishRuntimeIssue({\n id: input.id,\n name: input.name,\n category: \"redis\",\n message: input.message,\n error: input.error,\n });\n },\n };\n const redisRuntimeCutoverRepository =\n new PostgresRedisRuntimeCutoverRepository({\n controlDatabaseUrl: env.controlDatabaseUrl,\n encryptionSecret: env.controlDatabaseUrl,\n });\n const [mainRedisClient, conversationRedisClient, adminSessionRedis] =\n await Promise.all([\n createRedisRuntimeClient({\n cutoverRepository: redisRuntimeCutoverRepository,\n defaultRedisUrl: runtimeConfig.MAIN_REDIS_URL,\n displayName: \"主 Redis\",\n healthId: \"main-redis\",\n reporter: redisHealthReporter,\n role: \"MAIN\",\n }),\n createRedisRuntimeClient({\n cutoverRepository: redisRuntimeCutoverRepository,\n defaultRedisUrl: runtimeConfig.CONVERSATION_REDIS_URL,\n displayName: \"会话 Redis\",\n healthId: \"conversation-redis\",\n reporter: redisHealthReporter,\n role: \"CONVERSATION\",\n }),\n createRedisRuntimeClient({\n cutoverRepository: redisRuntimeCutoverRepository,\n defaultRedisUrl: runtimeConfig.WEB_ADMIN_SESSION_REDIS_URL,\n displayName: \"管理台会话 Redis\",\n healthId: \"web-admin-session-redis\",\n reporter: redisHealthReporter,\n role: \"ADMIN_SESSION\",\n }),\n ]);\n\n const bot = createBot(runtimeConfig, {\n conversationRedisClient,\n mainRedisClient,\n redisHealthReporter,\n onRuntimeError: (error) => {\n publishRuntimeIssue({\n id: \"telegram-bot-runtime\",\n name: \"Telegram Bot 运行时\",\n category: \"bot\",\n message: \"Bot 处理 update 时发生异常。\",\n error,\n });\n },\n paymentProviderRuntimeStore,\n refundPlatformFeeRateBps:\n runtimeConfig.GROUP_PAYMENT_REFUND_PLATFORM_FEE_RATE_BPS,\n loadPaidAccessControls: async () =>\n buildGroupPaidAccessControlsFromRuntimeConfig(\n await controlPlane.runtimeConfigService.getEffectiveRuntimeConfig(),\n ),\n loadPlatformSupportUrl: async () =>\n (await controlPlane.runtimeConfigService.getEffectiveRuntimeConfig())\n .PLATFORM_SUPPORT_URL,\n loadMiniAppWebAppUrl: async () =>\n (await controlPlane.runtimeConfigService.getEffectiveRuntimeConfig())\n .MINIAPP_WEB_APP_URL,\n loadWebAdminBaseUrl: async () => {\n const currentConfig = await controlPlane.runtimeConfigService\n .getEffectiveRuntimeConfig();\n return currentConfig.WEB_ADMIN_PUBLIC_BASE_URL ??\n `http://127.0.0.1:${currentConfig.WEB_ADMIN_PORT}`;\n },\n loadMerchantAccountRuntimeControls: async () => {\n const currentConfig = await controlPlane.runtimeConfigService\n .getEffectiveRuntimeConfig();\n return {\n selfRegistrationEnabled:\n currentConfig.MERCHANT_TELEGRAM_SELF_REGISTRATION_ENABLED,\n telegramMultiMerchantAccountBindingEnabled:\n currentConfig.MERCHANT_TELEGRAM_MULTI_ACCOUNT_BINDING_ENABLED,\n merchantAccountMultiTelegramBindingEnabled:\n currentConfig.MERCHANT_ACCOUNT_MULTI_TELEGRAM_BINDING_ENABLED,\n manualCnyPayoutEnabled:\n currentConfig.MERCHANT_PAYOUT_MANUAL_CNY_ENABLED,\n manualUsdtPayoutEnabled:\n currentConfig.MERCHANT_PAYOUT_MANUAL_USDT_ENABLED,\n };\n },\n onPaymentProviderIssue: (issue) => {\n publishRuntimeIssue({\n id: `payment-provider-${issue.issueCode}`,\n name: \"支付服务商链路\",\n category: \"runtime\",\n message: issue.message,\n error: issue.detail ?? issue.issueCode,\n });\n return Promise.resolve();\n },\n });\n\n const app = createAdminApp(controlPlane.runtimeConfigService, {\n adminTotpManager: controlPlane.adminTotpManager,\n adminDataService,\n cloudflareScheduledAutomationService:\n controlPlane.cloudflareScheduledAutomationService,\n qstashCronAutomationService: controlPlane.qstashCronAutomationService,\n telegramWebhookAdminService: controlPlane.telegramWebhookAdminService,\n valTownCronAutomationService: controlPlane.valTownCronAutomationService,\n infrastructureTargetRepository: controlPlane.infrastructureTargetRepository,\n upstashRedisControlPlaneService:\n controlPlane.upstashRedisControlPlaneService,\n aivenPostgresControlPlaneService:\n controlPlane.aivenPostgresControlPlaneService,\n adminSessionStore: new RedisAdminSessionStore(adminSessionRedis, {\n keyPrefix: \"web_admin:sessions:\",\n }),\n adminWebAppEnabled: true,\n devAuthBypassEnabled,\n paymentProviderRuntimeStore,\n healthRegistry: controlPlane.systemHealthRegistry,\n loadAdminWebAsset: assetLoaders.loadAdminWebAsset,\n loadAdminWebIndexHtml: assetLoaders.loadAdminWebIndexHtml,\n onTriggerGroupAutoKick: () =>\n runGroupAutoKickSweep(bot, {\n trigger: \"http_trigger\",\n ...buildGroupAutoKickSweepOptions(runtimeConfig),\n }),\n onTriggerGroupPaymentConfirmationSweep: () =>\n runGroupPaymentConfirmationSweep({\n trigger: \"http_trigger\",\n paymentProviderRuntimeStore,\n ...buildPaymentConfirmationSweepOptions(runtimeConfig),\n }),\n onTriggerGroupPaymentRefundReconcile: () =>\n runGroupPaymentRefundReconcile({\n trigger: \"http_trigger\",\n paymentProviderRuntimeStore,\n ...buildPaymentRefundReconcileOptions(runtimeConfig),\n }),\n onTriggerGroupPaymentRefundAutoApprove: () =>\n runGroupPaymentRefundAutoApprove({\n trigger: \"http_trigger\",\n paymentProviderRuntimeStore,\n refundPlatformFeeRateBps:\n runtimeConfig.GROUP_PAYMENT_REFUND_PLATFORM_FEE_RATE_BPS,\n ...buildPaymentRefundAutoApproveOptions(runtimeConfig),\n }),\n onTriggerMerchantSettlementRelease: () => releaseDueMerchantSettlements(),\n });\n\n registerTelegramWebhookRoutes(app, {\n bot,\n runtimeConfigService: controlPlane.runtimeConfigService,\n onUpdateReceived: () => {\n controlPlane.telegramWebhookAdminService.recordReceivedUpdate();\n },\n onError: (error) => {\n publishRuntimeIssue({\n id: \"telegram-bot-webhook-runtime\",\n name: \"Telegram Webhook 处理\",\n category: \"bot\",\n message: \"Bot webhook 处理 update 时发生异常。\",\n error,\n });\n },\n });\n registerServerlessHealthRoute(app, \"webhook\");\n\n return app;\n}\n","import { type Hono } from \"https://esm.sh/jsr/@hono/hono@4.10.1\";\n\nimport { PostgresAdminDataService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/adminDataService.ts\";\nimport { RedisAdminSessionStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/adminSessionStore.ts\";\nimport { AdminTotpManager } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/adminTotpManager.ts\";\nimport {\n createAdminApp,\n type CreateAdminAppOptions,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/createAdminApp.ts\";\nimport { AivenPostgresControlPlaneService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/aivenPostgresControlPlane.ts\";\nimport { CloudflareScheduledAutomationService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/cloudflareScheduledAutomationService.ts\";\nimport { InfrastructureTargetRepository } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/infrastructureTargetRepository.ts\";\nimport { QStashCronAutomationService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/qstashCronAutomationService.ts\";\nimport { TelegramWebhookAdminService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/telegramWebhookAdminService.ts\";\nimport { UpstashRedisControlPlaneService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/upstashRedisControlPlane.ts\";\nimport { ValTownCronAutomationService } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/admin/valTownCronAutomationService.ts\";\nimport {\n initializeMerchantAssetStore,\n releaseDueMerchantSettlements,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/billing/merchantAssetStore.ts\";\nimport { createBot } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/bot/createBot.ts\";\nimport {\n createRedisRuntimeClient,\n PostgresRedisRuntimeCutoverRepository,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/bot/storage/redisRuntimeCutover.ts\";\nimport { registerTelegramWebhookRoutes } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/bot/telegramWebhook.ts\";\nimport { type AppEnv, loadEnv } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/config/env.ts\";\nimport { type RuntimeConfig } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/config/runtimeConfig.ts\";\nimport { RuntimeConfigRepository } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/config/runtimeConfigRepository.ts\";\nimport {\n type AdminBootstrapRuntimeConfig,\n RuntimeConfigService,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/config/runtimeConfigService.ts\";\nimport { buildGroupPaidAccessControlsFromRuntimeConfig } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/groupPaidAccessConfig.ts\";\nimport {\n type GroupAutoKickSweepOptions,\n runGroupAutoKickSweep,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/groupAutoKickWorker.ts\";\nimport { runGroupPaymentConfirmationSweep } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/groupPaymentConfirmationSweepWorker.ts\";\nimport { runGroupPaymentRefundAutoApprove } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/groupPaymentRefundAutoApproveWorker.ts\";\nimport { runGroupPaymentRefundReconcile } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/groupPaymentRefundReconcileWorker.ts\";\nimport { initializeGroupStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/group/store.ts\";\nimport { initializeMerchantAccountStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/merchantAccount/store.ts\";\nimport { initializeVirtualDeliveryStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/features/virtualDelivery/store.ts\";\nimport {\n PostgresSystemHealthRegistry,\n recordRuntimeIssue,\n type SystemHealthSnapshot,\n} from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/ops/systemHealth.ts\";\nimport { buildLocalTestPaymentProviderPolicy } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/paymentProviders/localTestSafety.ts\";\nimport { PaymentProviderRuntimeStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/paymentProviders/runtimeStore.ts\";\nimport { initializeTelegramUserStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/user/store.ts\";\nimport { initializeUserAccessControlStore } from \"https://raw.githubusercontent.com/toocutetop/baohuangtian/541686af27095ca15ddf382e57a20874958b4a12/src/app/user/accessControlStore.ts\";\n\nexport interface MainWebhookAppAssetLoaders {\n loadAdminWebIndexHtml?: CreateAdminAppOptions[\"loadAdminWebIndexHtml\"];\n loadAdminWebAsset?: CreateAdminAppOptions[\"loadAdminWebAsset\"];\n}\n\nexport interface CreateMainWebhookAppOptions\n extends MainWebhookAppAssetLoaders {\n env?: AppEnv;\n devAuthBypassEnabled?: boolean;\n}\n\ninterface MainControlPlane {\n adminTotpManager: AdminTotpManager;\n aivenPostgresControlPlaneService: AivenPostgresControlPlaneService;\n cloudflareScheduledAutomationService: CloudflareScheduledAutomationService;\n infrastructureTargetRepository: InfrastructureTargetRepository;\n qstashCronAutomationService: QStashCronAutomationService;\n runtimeConfigRepository: RuntimeConfigRepository;\n runtimeConfigService: RuntimeConfigService;\n systemHealthRegistry: PostgresSystemHealthRegistry;\n telegramWebhookAdminService: TelegramWebhookAdminService;\n upstashRedisControlPlaneService: UpstashRedisControlPlaneService;\n valTownCronAutomationService: ValTownCronAutomationService;\n}\n\nfunction createMainControlPlane(env: AppEnv): MainControlPlane {\n const runtimeConfigRepository = new RuntimeConfigRepository(\n env.controlDatabaseUrl,\n );\n const runtimeConfigService = new RuntimeConfigService(\n runtimeConfigRepository,\n );\n const adminTotpManager = new AdminTotpManager({\n databaseUrl: env.controlDatabaseUrl,\n });\n const valTownCronAutomationService = new ValTownCronAutomationService({\n databaseUrl: env.controlDatabaseUrl,\n encryptionSecret: env.controlDatabaseUrl,\n });\n const qstashCronAutomationService = new QStashCronAutomationService();\n const cloudflareScheduledAutomationService =\n new CloudflareScheduledAutomationService({\n controlDatabaseUrl: env.controlDatabaseUrl,\n });\n const telegramWebhookAdminService = new TelegramWebhookAdminService();\n const infrastructureTargetRepository = new InfrastructureTargetRepository(\n env.controlDatabaseUrl,\n );\n const upstashRedisControlPlaneService = new UpstashRedisControlPlaneService({\n controlDatabaseUrl: env.controlDatabaseUrl,\n encryptionSecret: env.controlDatabaseUrl,\n infrastructureTargetRepository,\n });\n const aivenPostgresControlPlaneService = new AivenPostgresControlPlaneService(\n {\n controlDatabaseUrl: env.controlDatabaseUrl,\n encryptionSecret: env.controlDatabaseUrl,\n infrastructureTargetRepository,\n },\n );\n const systemHealthRegistry = new PostgresSystemHealthRegistry(\n env.controlDatabaseUrl,\n );\n\n return {\n adminTotpManager,\n aivenPostgresControlPlaneService,\n cloudflareScheduledAutomationService,\n infrastructureTargetRepository,\n qstashCronAutomationService,\n runtimeConfigRepository,\n runtimeConfigService,\n systemHealthRegistry,\n telegramWebhookAdminService,\n upstashRedisControlPlaneService,\n valTownCronAutomationService,\n };\n}\n\nasync function seedStartupConfig(\n controlPlane: MainControlPlane,\n env: AppEnv,\n): Promise {\n await controlPlane.runtimeConfigService.seedMissingConfigsFromBuiltinDefaults(\n {\n actorId: \"system:valtown-main-startup\",\n reason: \"Val Town 主服务启动时补齐内建配置\",\n },\n );\n await controlPlane.runtimeConfigService.seedMissingBootstrapConfigsFromEnv({\n botToken: env.bootstrapBotToken,\n superAdminIds: env.bootstrapSuperAdminIds,\n actorId: \"system:valtown-main-bootstrap-env\",\n reason: \"Val Town 主服务启动时从环境变量引导配置\",\n });\n return await controlPlane.runtimeConfigService.getAdminBootstrapConfig();\n}\n\nfunction createBootstrapAdminApp(input: {\n assetLoaders: MainWebhookAppAssetLoaders;\n controlPlane: MainControlPlane;\n devAuthBypassEnabled: boolean;\n}): Hono {\n const app = createAdminApp(input.controlPlane.runtimeConfigService, {\n adminTotpManager: input.controlPlane.adminTotpManager,\n cloudflareScheduledAutomationService:\n input.controlPlane.cloudflareScheduledAutomationService,\n qstashCronAutomationService: input.controlPlane.qstashCronAutomationService,\n telegramWebhookAdminService: input.controlPlane.telegramWebhookAdminService,\n valTownCronAutomationService:\n input.controlPlane.valTownCronAutomationService,\n adminWebAppEnabled: true,\n devAuthBypassEnabled: input.devAuthBypassEnabled,\n healthRegistry: input.controlPlane.systemHealthRegistry,\n loadAdminWebAsset: input.assetLoaders.loadAdminWebAsset,\n loadAdminWebIndexHtml: input.assetLoaders.loadAdminWebIndexHtml,\n });\n registerServerlessHealthRoute(app, \"bootstrap\");\n return app;\n}\n\nfunction buildGroupAutoKickSweepOptions(\n runtimeConfig: RuntimeConfig,\n): Omit {\n return {\n batchSize: runtimeConfig.GROUP_AUTO_KICK_SWEEP_BATCH_SIZE,\n maxBatchesPerSweep: runtimeConfig.GROUP_AUTO_KICK_SWEEP_MAX_BATCHES,\n maxSweepRuntimeMs: runtimeConfig.GROUP_AUTO_KICK_SWEEP_MAX_RUNTIME_SECONDS *\n 1000,\n };\n}\n\nfunction buildPaymentConfirmationSweepOptions(runtimeConfig: RuntimeConfig) {\n return {\n batchSize: runtimeConfig.GROUP_PAYMENT_CONFIRMATION_SWEEP_BATCH_SIZE,\n maxBatchesPerSweep:\n runtimeConfig.GROUP_PAYMENT_CONFIRMATION_SWEEP_MAX_BATCHES,\n maxSweepRuntimeMs:\n runtimeConfig.GROUP_PAYMENT_CONFIRMATION_SWEEP_MAX_RUNTIME_SECONDS * 1000,\n pendingGraceMs:\n runtimeConfig.GROUP_PAYMENT_CONFIRMATION_SWEEP_PENDING_GRACE_SECONDS *\n 1000,\n };\n}\n\nfunction buildPaymentRefundReconcileOptions(runtimeConfig: RuntimeConfig) {\n return {\n batchSize: runtimeConfig.GROUP_PAYMENT_REFUND_RECONCILE_BATCH_SIZE,\n maxBatchesPerSweep:\n runtimeConfig.GROUP_PAYMENT_REFUND_RECONCILE_MAX_BATCHES,\n maxSweepRuntimeMs:\n runtimeConfig.GROUP_PAYMENT_REFUND_RECONCILE_MAX_RUNTIME_SECONDS * 1000,\n pendingGraceMs:\n runtimeConfig.GROUP_PAYMENT_REFUND_RECONCILE_PENDING_GRACE_SECONDS * 1000,\n };\n}\n\nfunction buildPaymentRefundAutoApproveOptions(runtimeConfig: RuntimeConfig) {\n return {\n batchSize: runtimeConfig.GROUP_PAYMENT_REFUND_AUTO_APPROVE_SWEEP_BATCH_SIZE,\n maxBatchesPerSweep:\n runtimeConfig.GROUP_PAYMENT_REFUND_AUTO_APPROVE_SWEEP_MAX_BATCHES,\n maxSweepRuntimeMs: runtimeConfig\n .GROUP_PAYMENT_REFUND_AUTO_APPROVE_SWEEP_MAX_RUNTIME_SECONDS *\n 1000,\n };\n}\n\nfunction createPaymentProviderRuntimeStore(input: {\n controlDatabaseUrl: string;\n runtimeConfig: RuntimeConfig;\n}): PaymentProviderRuntimeStore {\n const localTestPaymentProviderPolicy = buildLocalTestPaymentProviderPolicy({\n appEnvironment: input.runtimeConfig.APP_ENVIRONMENT,\n localTestProviderEnabled:\n input.runtimeConfig.PAYMENT_LOCAL_TEST_PROVIDER_ENABLED,\n controlDatabaseUrl: input.controlDatabaseUrl,\n mainDatabaseUrl: input.runtimeConfig.MAIN_DATABASE_URL,\n });\n\n return new PaymentProviderRuntimeStore(\n input.runtimeConfig.MAIN_DATABASE_URL,\n {\n allowLocalTestProvider:\n localTestPaymentProviderPolicy.allowLocalTestProvider,\n localTestProviderDisabledReason:\n localTestPaymentProviderPolicy.disabledReason,\n },\n );\n}\n\nfunction formatRuntimeIssueDetail(error: unknown): string {\n if (error instanceof Error) {\n return [error.message, error.stack].filter(Boolean).join(\"\\n\").slice(\n 0,\n 2000,\n );\n }\n return String(error).slice(0, 2000);\n}\n\nfunction createRuntimeIssuePublisher(\n registry: PostgresSystemHealthRegistry,\n) {\n return (input: {\n id: string;\n name: string;\n category: SystemHealthSnapshot[\"category\"];\n message: string;\n error: unknown;\n }) => {\n const snapshot = recordRuntimeIssue(registry, {\n id: input.id,\n name: input.name,\n category: input.category,\n message: input.message,\n detail: formatRuntimeIssueDetail(input.error),\n });\n void registry.upsert(snapshot).catch((error) => {\n console.error(\"记录 Val Town 主服务运行异常失败：\", error);\n });\n };\n}\n\nfunction registerServerlessHealthRoute(\n app: Hono,\n mode: \"bootstrap\" | \"webhook\",\n): void {\n app.get(\"/health\", (c) =>\n c.json({\n ok: true,\n runtime: \"valtown-main\",\n mode,\n }));\n}\n\nfunction initializePersistentStores(input: {\n controlDatabaseUrl: string;\n runtimeConfig: RuntimeConfig;\n}): void {\n initializeGroupStore(input.runtimeConfig.MAIN_DATABASE_URL);\n initializeVirtualDeliveryStore(input.runtimeConfig.MAIN_DATABASE_URL);\n initializeTelegramUserStore(input.runtimeConfig.MAIN_DATABASE_URL);\n initializeUserAccessControlStore(input.runtimeConfig.MAIN_DATABASE_URL);\n initializeMerchantAccountStore({\n databaseUrl: input.runtimeConfig.MAIN_DATABASE_URL,\n totpSecretEncryptionSecret: input.controlDatabaseUrl,\n });\n initializeMerchantAssetStore(input.runtimeConfig.MAIN_DATABASE_URL);\n}\n\nexport async function createMainWebhookApp(\n options: CreateMainWebhookAppOptions = {},\n): Promise {\n const env = options.env ?? loadEnv();\n const devAuthBypassEnabled = options.devAuthBypassEnabled ??\n Deno.env.get(\"WEB_ADMIN_DEV_AUTH_BYPASS\") === \"true\";\n const assetLoaders: MainWebhookAppAssetLoaders = {\n loadAdminWebAsset: options.loadAdminWebAsset,\n loadAdminWebIndexHtml: options.loadAdminWebIndexHtml,\n };\n const controlPlane = createMainControlPlane(env);\n\n await seedStartupConfig(controlPlane, env);\n\n let runtimeConfig: RuntimeConfig;\n try {\n runtimeConfig = await controlPlane.runtimeConfigService\n .getEffectiveRuntimeConfig();\n } catch (error) {\n console.error(\n \"Val Town 主服务缺少完整运行配置，已进入管理台初始化模式：\",\n error,\n );\n return createBootstrapAdminApp({\n assetLoaders,\n controlPlane,\n devAuthBypassEnabled,\n });\n }\n\n initializePersistentStores({\n controlDatabaseUrl: env.controlDatabaseUrl,\n runtimeConfig,\n });\n\n const paymentProviderRuntimeStore = createPaymentProviderRuntimeStore({\n controlDatabaseUrl: env.controlDatabaseUrl,\n runtimeConfig,\n });\n const adminDataService = new PostgresAdminDataService(\n runtimeConfig.MAIN_DATABASE_URL,\n {\n tenantDataSourceSecret: env.controlDatabaseUrl,\n paymentProviderRuntimeStore,\n refundPlatformFeeRateBps:\n runtimeConfig.GROUP_PAYMENT_REFUND_PLATFORM_FEE_RATE_BPS,\n },\n );\n\n const publishRuntimeIssue = createRuntimeIssuePublisher(\n controlPlane.systemHealthRegistry,\n );\n const redisHealthReporter = {\n reportRedisFailure: (input: {\n id: string;\n name: string;\n message: string;\n error: unknown;\n }) => {\n publishRuntimeIssue({\n id: input.id,\n name: input.name,\n category: \"redis\",\n message: input.message,\n error: input.error,\n });\n },\n };\n const redisRuntimeCutoverRepository =\n new PostgresRedisRuntimeCutoverRepository({\n controlDatabaseUrl: env.controlDatabaseUrl,\n encryptionSecret: env.controlDatabaseUrl,\n });\n const [mainRedisClient, conversationRedisClient, adminSessionRedis] =\n await Promise.all([\n createRedisRuntimeClient({\n cutoverRepository: redisRuntimeCutoverRepository,\n defaultRedisUrl: runtimeConfig.MAIN_REDIS_URL,\n displayName: \"主 Redis\",\n healthId: \"main-redis\",\n reporter: redisHealthReporter,\n role: \"MAIN\",\n }),\n createRedisRuntimeClient({\n cutoverRepository: redisRuntimeCutoverRepository,\n defaultRedisUrl: runtimeConfig.CONVERSATION_REDIS_URL,\n displayName: \"会话 Redis\",\n healthId: \"conversation-redis\",\n reporter: redisHealthReporter,\n role: \"CONVERSATION\",\n }),\n createRedisRuntimeClient({\n cutoverRepository: redisRuntimeCutoverRepository,\n defaultRedisUrl: runtimeConfig.WEB_ADMIN_SESSION_REDIS_URL,\n displayName: \"管理台会话 Redis\",\n healthId: \"web-admin-session-redis\",\n reporter: redisHealthReporter,\n role: \"ADMIN_SESSION\",\n }),\n ]);\n\n const bot = createBot(runtimeConfig, {\n conversationRedisClient,\n mainRedisClient,\n redisHealthReporter,\n onRuntimeError: (error) => {\n publishRuntimeIssue({\n id: \"telegram-bot-runtime\",\n name: \"Telegram Bot 运行时\",\n category: \"bot\",\n message: \"Bot 处理 update 时发生异常。\",\n error,\n });\n },\n paymentProviderRuntimeStore,\n refundPlatformFeeRateBps:\n runtimeConfig.GROUP_PAYMENT_REFUND_PLATFORM_FEE_RATE_BPS,\n loadPaidAccessControls: async () =>\n buildGroupPaidAccessControlsFromRuntimeConfig(\n await controlPlane.runtimeConfigService.getEffectiveRuntimeConfig(),\n ),\n loadPlatformSupportUrl: async () =>\n (await controlPlane.runtimeConfigService.getEffectiveRuntimeConfig())\n .PLATFORM_SUPPORT_URL,\n loadMiniAppWebAppUrl: async () =>\n (await controlPlane.runtimeConfigService.getEffectiveRuntimeConfig())\n .MINIAPP_WEB_APP_URL,\n loadWebAdminBaseUrl: async () => {\n const currentConfig = await controlPlane.runtimeConfigService\n .getEffectiveRuntimeConfig();\n return currentConfig.WEB_ADMIN_PUBLIC_BASE_URL ??\n `http://127.0.0.1:${currentConfig.WEB_ADMIN_PORT}`;\n },\n loadMerchantAccountRuntimeControls: async () => {\n const currentConfig = await controlPlane.runtimeConfigService\n .getEffectiveRuntimeConfig();\n return {\n selfRegistrationEnabled:\n currentConfig.MERCHANT_TELEGRAM_SELF_REGISTRATION_ENABLED,\n telegramMultiMerchantAccountBindingEnabled:\n currentConfig.MERCHANT_TELEGRAM_MULTI_ACCOUNT_BINDING_ENABLED,\n merchantAccountMultiTelegramBindingEnabled:\n currentConfig.MERCHANT_ACCOUNT_MULTI_TELEGRAM_BINDING_ENABLED,\n manualCnyPayoutEnabled:\n currentConfig.MERCHANT_PAYOUT_MANUAL_CNY_ENABLED,\n manualUsdtPayoutEnabled:\n currentConfig.MERCHANT_PAYOUT_MANUAL_USDT_ENABLED,\n };\n },\n onPaymentProviderIssue: (issue) => {\n publishRuntimeIssue({\n id: `payment-provider-${issue.issueCode}`,\n name: \"支付服务商链路\",\n category: \"runtime\",\n message: issue.message,\n error: issue.detail ?? issue.issueCode,\n });\n return Promise.resolve();\n },\n });\n\n const app = createAdminApp(controlPlane.runtimeConfigService, {\n adminTotpManager: controlPlane.adminTotpManager,\n adminDataService,\n cloudflareScheduledAutomationService:\n controlPlane.cloudflareScheduledAutomationService,\n qstashCronAutomationService: controlPlane.qstashCronAutomationService,\n telegramWebhookAdminService: controlPlane.telegramWebhookAdminService,\n valTownCronAutomationService: controlPlane.valTownCronAutomationService,\n infrastructureTargetRepository: controlPlane.infrastructureTargetRepository,\n upstashRedisControlPlaneService:\n controlPlane.upstashRedisControlPlaneService,\n aivenPostgresControlPlaneService:\n controlPlane.aivenPostgresControlPlaneService,\n adminSessionStore: new RedisAdminSessionStore(adminSessionRedis, {\n keyPrefix: \"web_admin:sessions:\",\n }),\n adminWebAppEnabled: true,\n devAuthBypassEnabled,\n paymentProviderRuntimeStore,\n healthRegistry: controlPlane.systemHealthRegistry,\n loadAdminWebAsset: assetLoaders.loadAdminWebAsset,\n loadAdminWebIndexHtml: assetLoaders.loadAdminWebIndexHtml,\n onTriggerGroupAutoKick: () =>\n runGroupAutoKickSweep(bot, {\n trigger: \"http_trigger\",\n ...buildGroupAutoKickSweepOptions(runtimeConfig),\n }),\n onTriggerGroupPaymentConfirmationSweep: () =>\n runGroupPaymentConfirmationSweep({\n trigger: \"http_trigger\",\n paymentProviderRuntimeStore,\n ...buildPaymentConfirmationSweepOptions(runtimeConfig),\n }),\n onTriggerGroupPaymentRefundReconcile: () =>\n runGroupPaymentRefundReconcile({\n trigger: \"http_trigger\",\n paymentProviderRuntimeStore,\n ...buildPaymentRefundReconcileOptions(runtimeConfig),\n }),\n onTriggerGroupPaymentRefundAutoApprove: () =>\n runGroupPaymentRefundAutoApprove({\n trigger: \"http_trigger\",\n paymentProviderRuntimeStore,\n refundPlatformFeeRateBps:\n runtimeConfig.GROUP_PAYMENT_REFUND_PLATFORM_FEE_RATE_BPS,\n ...buildPaymentRefundAutoApproveOptions(runtimeConfig),\n }),\n onTriggerMerchantSettlementRelease: () => releaseDueMerchantSettlements(),\n });\n\n registerTelegramWebhookRoutes(app, {\n bot,\n runtimeConfigService: controlPlane.runtimeConfigService,\n onUpdateReceived: () => {\n controlPlane.telegramWebhookAdminService.recordReceivedUpdate();\n },\n onError: (error) => {\n publishRuntimeIssue({\n id: \"telegram-bot-webhook-runtime\",\n name: \"Telegram Webhook 处理\",\n category: \"bot\",\n message: \"Bot webhook 处理 update 时发生异常。\",\n error,\n });\n },\n });\n registerServerlessHealthRoute(app, \"webhook\");\n\n return app;\n}\n","createdAt",["D",1780063139878],"branchVersion","branchId","ee973778-5b62-11f1-bc6a-ee650bb23af1","id","ee966f78-5b62-11f1-bc6a-ee650bb23af1","baohuangtian-main",["D",1780061589295],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","baohuangtian 主服务 Val Town webhook 入口","imageUrl","1b06fec8-ebc5-4a87-9c5e-c5d4ab16c0e6","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e1a35-373c-751f-ac7a-32ad31701ae9","tursoName","ee966f785b6211f1bc6aee650bb23af1","tursoHostname","ee966f785b6211f1bc6aee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789492855745],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":56,"_104":105,"_106":25},"branch",{"_13":88,"_32":89,"_44":43,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":46,"_97":98},"isOwned",10,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","KqEmL35T8y1YDcjzi9gRZ2SOe4P73","handle","displayName","迪迦","avatar","https://lh3.googleusercontent.com/a/ACg8ocLqxrq95dl6q1ky9ObFN7sAiEcqwhjvlRIB1o8-snquCPIuoH06=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_32":46,"_39":215,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":-5,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":216,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":217,"_83":218,"_85":219,"_87":25},"tree",[178,182,183,184],"files",[178,179,180,181,182,183,184],"counts",{"_167":62,"_168":149,"_169":62,"_170":171,"_172":173},"contents",[131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_44":160,"_32":161,"_30":162,"_138":-5,"_42":43,"_41":163,"_140":126,"_39":164,"_13":62,"_34":165,"_36":-5,"_24":25,"_144":-5,"_27":166},{"_44":153,"_32":154,"_30":155,"_138":-5,"_42":43,"_41":156,"_140":126,"_39":157,"_13":62,"_34":20,"_36":158,"_24":25,"_144":-5,"_27":159},{"_44":146,"_32":147,"_30":148,"_138":-5,"_42":43,"_41":149,"_140":126,"_39":150,"_13":62,"_34":20,"_36":151,"_24":25,"_144":-5,"_27":152},{"_44":135,"_32":136,"_30":137,"_138":-5,"_42":43,"_41":139,"_140":25,"_39":141,"_13":62,"_34":142,"_36":143,"_24":25,"_144":-5,"_27":145},"641072f0-5b66-11f1-bab1-ee650bb23af1","valtown-main.http.ts","641073b8-5b66-11f1-bab1-ee650bb23af1","parentId",2,"latest",["D",1780063074865],"http","import { createMainWebhookApp } from \"./src/app/serverless/mainWebhookApp.ts\";\nimport type { MainWebhookAppAssetLoaders } from \"./src/app/serverless/mainWebhookApp.ts\";\n\nconst ADMIN_WEB_DIST_ROOT = \"/apps/admin-web/dist\";\nconst ADMIN_WEB_ASSET_NAME_PATTERN = /^[A-Za-z0-9._-]+$/;\n\nfunction joinValTownPath(...parts: string[]): string {\n return parts\n .map((part, index) =>\n index === 0 ? part.replace(/\\/+$/, \"\") : part.replace(/^\\/+|\\/+$/g, \"\")\n )\n .filter((part) => part.length > 0)\n .join(\"/\");\n}\n\nfunction getAdminWebAssetContentType(assetName: string): string {\n if (assetName.endsWith(\".js\")) {\n return \"text/javascript; charset=utf-8\";\n }\n if (assetName.endsWith(\".css\")) {\n return \"text/css; charset=utf-8\";\n }\n if (assetName.endsWith(\".svg\")) {\n return \"image/svg+xml\";\n }\n if (assetName.endsWith(\".png\")) {\n return \"image/png\";\n }\n if (assetName.endsWith(\".jpg\") || assetName.endsWith(\".jpeg\")) {\n return \"image/jpeg\";\n }\n if (assetName.endsWith(\".woff2\")) {\n return \"font/woff2\";\n }\n return \"application/octet-stream\";\n}\n\nfunction isMissingValTownFileError(error: unknown): boolean {\n if (!(error instanceof Error)) {\n return false;\n }\n const message = error.message.toLowerCase();\n return message.includes(\"not found\") ||\n message.includes(\"failed to fetch file\");\n}\n\nasync function readValTownTextFile(path: string): Promise {\n const utilsModuleUrl = \"https://esm.town/v/std/utils/index.ts\";\n const utilsModule = await import(utilsModuleUrl) as {\n readFile(path: string, moduleUrl?: string): Promise;\n };\n try {\n return await utilsModule.readFile(path, import.meta.url);\n } catch (error) {\n if (isMissingValTownFileError(error)) {\n return null;\n }\n throw error;\n }\n}\n\nfunction createValTownAdminWebAssetLoaders(\n rootPath = ADMIN_WEB_DIST_ROOT,\n): MainWebhookAppAssetLoaders {\n return {\n loadAdminWebIndexHtml: () =>\n readValTownTextFile(joinValTownPath(rootPath, \"index.html\")),\n loadAdminWebAsset: async (assetName) => {\n if (!ADMIN_WEB_ASSET_NAME_PATTERN.test(assetName)) {\n return null;\n }\n\n const assetPath = joinValTownPath(rootPath, \"assets\", assetName);\n const content = await readValTownTextFile(assetPath);\n if (content === null) {\n return null;\n }\n\n return {\n bytes: new TextEncoder().encode(content),\n contentType: getAdminWebAssetContentType(assetName),\n };\n },\n };\n}\n\nlet appPromise: ReturnType | null = null;\n\nfunction getApp() {\n if (!appPromise) {\n appPromise = createMainWebhookApp(createValTownAdminWebAssetLoaders())\n .catch((error) => {\n appPromise = null;\n throw error;\n });\n }\n return appPromise;\n}\n\nexport default async function handler(request: Request): Promise {\n try {\n const app = await getApp();\n return await app.fetch(request);\n } catch (error) {\n console.error(\"Val Town 主服务启动失败：\", error);\n return Response.json({\n ok: false,\n error: \"main_service_unavailable\",\n message: error instanceof Error ? error.message : String(error),\n }, { status: 503 });\n }\n}\n","label",[136],"515ebbb2-5b66-11f1-83e1-ee650bb23af1","test.txt","515ebc84-5b66-11f1-83e1-ee650bb23af1",1,["D",1780063043494],"hello",[147],"65a40c30-5b66-11f1-9d88-ee650bb23af1","deno.jsonc","65a40cf8-5b66-11f1-9d88-ee650bb23af1",7,["D",1780063077510],"{\n \"nodeModulesDir\": \"auto\",\n \"compilerOptions\": {\n \"strict\": true,\n \"lib\": [\"deno.ns\", \"dom\", \"node\"]\n },\n \"imports\": {\n \"@db/postgres\": \"jsr:@db/postgres@^0.19.5\",\n \"@db/redis\": \"jsr:@db/redis@^0.41.0\",\n \"@cliffy/command\": \"jsr:@cliffy/command@1.0.1\",\n \"@cliffy/prompt/confirm\": \"jsr:@cliffy/prompt@1.0.1/confirm\",\n \"@cliffy/prompt/input\": \"jsr:@cliffy/prompt@1.0.1/input\",\n \"@cliffy/prompt/select\": \"jsr:@cliffy/prompt@1.0.1/select\",\n \"@cliffy/table\": \"jsr:@cliffy/table@1.0.1\",\n \"@hono/hono\": \"jsr:@hono/hono@^4.10.1\",\n \"@grammyjs/auto-retry\": \"npm:@grammyjs/auto-retry@^2.0.2\",\n \"@grammyjs/chat-members\": \"npm:@grammyjs/chat-members@^1.2.0\",\n \"@grammyjs/commands\": \"npm:@grammyjs/commands@^1.3.2\",\n \"@grammyjs/conversations\": \"npm:@grammyjs/conversations@^2.1.1\",\n \"@grammyjs/hydrate\": \"npm:@grammyjs/hydrate@^1.6.0\",\n \"@grammyjs/menu\": \"npm:@grammyjs/menu@^1.3.1\",\n \"@grammyjs/ratelimiter\": \"npm:@grammyjs/ratelimiter@^1.2.1\",\n \"@grammyjs/stateless-question\": \"npm:@grammyjs/stateless-question@^4.0.0\",\n \"@std/assert\": \"jsr:@std/assert@^1.0.14\",\n \"@std/async\": \"jsr:@std/async@^1.2.0\",\n \"@std/dotenv\": \"jsr:@std/dotenv@^0.225.6\",\n \"@std/fmt/colors\": \"jsr:@std/fmt@^1.0.7/colors\",\n \"@upstash/redis\": \"npm:@upstash/redis@^1.37.0\",\n \"grammy\": \"npm:grammy@^1.42.0\",\n \"prisma/config\": \"npm:prisma@7.7.0/config\",\n \"qrcode\": \"npm:qrcode@^1.5.4\",\n \"pg\": \"npm:pg@8.20.0\",\n \"@std/path\": \"jsr:@std/path@^1.1.2\"\n },\n \"fmt\": {\n \"exclude\": [\"**/*.md\", \"node_modules/\", \"tmp/\"]\n },\n \"lint\": {\n \"exclude\": [\"node_modules/\", \"tmp/\"]\n },\n \"tasks\": {\n // ===== 本地热更新入口 =====\n // 本地开发一键热更新：并行启动 Bot 主后端 watch 和管理台 Web Vite。\n \"dev\": \"deno run --allow-run --allow-env --allow-read scripts/dev.ts\",\n // Bot 项目热重载：监听 Deno 模块图变更，代码变化后自动重启进程。\n \"bot:dev\": \"deno run --env-file=.env --watch -A src/main.ts\",\n // 管理台前端热更新：Vite 开发服务器，本地默认 5175，代理 /admin/* 到 Bot 后端。\n \"admin:web:start\": \"npm --prefix apps/admin-web run dev\",\n\n // ===== 最常用入口 =====\n // 第一次拉起本地环境：启动开发容器，并把三套 schema 推到本地开发库。\n \"dev:setup\": \"deno task dev:docker:up && deno task dev:db:push\",\n // 构建并启动 Bot 主后端；同时承载新版管理台、后台任务和内部接口。\n \"bot:start\": \"deno task admin:web:build && deno task bot:start:backend\",\n // 仅启动 Bot 主后端，不刷新管理台前端构建；只用于后端调试或前端 dev server 并行开发。\n \"bot:start:backend\": \"deno run --env-file=.env -A src/main.ts\",\n // 启动 Mini App API（本地默认 8788）。\n \"miniapp:api:start\": \"deno run --env-file=.env -A apps/miniapp-api/src/main.ts\",\n // 启动独立 Job API（本地默认 8790），供外部 scheduler 触发后台任务。\n \"job:api:start\": \"deno run --env-file=.env -A apps/job-api/src/main.ts\",\n // Cloudflare Worker 构建预检，不发布线上版本。\n \"job:api:deploy:dry-run\": \"npm --prefix apps/job-api run deploy:dry-run\",\n // 发布独立 Job API Cloudflare Worker；执行前先配置 CONTROL_DATABASE_URL secret。\n \"job:api:deploy\": \"npm --prefix apps/job-api run deploy\",\n \"valtown:main:deploy\": \"deno run --allow-env --allow-read --allow-write=tmp --allow-run=git --allow-net=api.val.town,raw.githubusercontent.com scripts/deploy_valtown_main.ts\",\n // 启动 Mini App 前端开发服务器（本地默认 5174）。\n \"miniapp:web:start\": \"npm --prefix apps/miniapp-web run dev\",\n // 管理台首次动态码私聊不可用时，在受控终端人工查看待绑定密钥。\n \"admin:totp:bootstrap\": \"deno run --env-file=.env -A scripts/admin_totp_bootstrap.ts\",\n\n // ===== 日常质量检查 =====\n // 改 TypeScript 代码后优先跑它；覆盖后端、脚本、共享包和测试源码。\n \"check\": \"deno check --all prisma.config.ts prisma.main.config.ts prisma.tenant.config.ts prisma.control.config.ts prisma.config.shared.ts packages/shared/src/**/*.ts apps/miniapp-api/src/**/*.ts apps/job-api/src/**/*.ts scripts/**/*.ts src/main.ts src/app/**/*.ts tests/**/*.ts\",\n // 静态风格检查；提交前和 code review 前都建议执行。\n \"lint\": \"deno lint prisma.config.ts prisma.main.config.ts prisma.tenant.config.ts prisma.control.config.ts prisma.config.shared.ts apps/miniapp-api/src apps/job-api/src scripts src tests\",\n // 统一格式化仓库里的可格式化文件。\n \"fmt\": \"deno fmt\",\n // 轻量提交前检查：格式化 + 类型检查 + lint；不包含数据库集成测试。\n \"ci\": \"deno task fmt && deno task check && deno task lint\",\n \"test:quick\": \"deno task check && deno task lint && deno task test:unit:config && deno task test:unit:admin && deno task job:api:test && deno task test:unit:ops && deno task test:unit:payments && deno task test:unit:bot && deno task test:unit:group && deno task telegram:e2e:unit\",\n // 完整回归：启动测试依赖、重置测试库、运行单元和集成测试。\n \"test\": \"deno task test:setup && deno task test:unit && deno task test:integration\",\n\n // ===== 管理台 Web =====\n \"admin:web:check\": \"npm --prefix apps/admin-web run check\",\n \"admin:web:build\": \"npm --prefix apps/admin-web run build\",\n \"admin:web:preview\": \"npm --prefix apps/admin-web run preview\",\n\n // ===== Mini App 开发 =====\n \"miniapp:web:check\": \"npm --prefix apps/miniapp-web run check\",\n \"miniapp:web:build\": \"npm --prefix apps/miniapp-web run build\",\n \"miniapp:web:test\": \"npm --prefix apps/miniapp-web run test\",\n \"miniapp:web:preview\": \"npm --prefix apps/miniapp-web run preview\",\n \"miniapp:api:test\": \"deno test tests/unit/miniappApi_test.ts\",\n \"miniapp:test\": \"deno task miniapp:api:test && deno task miniapp:web:test\",\n \"miniapp:check\": \"deno check --all packages/shared/src/mod.ts apps/miniapp-api/src/main.ts tests/unit/miniappApi_test.ts && deno task miniapp:web:check\",\n \"job:api:test\": \"deno test --env-file=.env.test --allow-env tests/unit/createJobApp_test.ts tests/unit/jobApiApp_test.ts tests/unit/cloudflareScheduledJobs_test.ts\",\n \"job:api:check\": \"deno check --all apps/job-api/src/**/*.ts tests/unit/createJobApp_test.ts tests/unit/jobApiApp_test.ts tests/unit/cloudflareScheduledJobs_test.ts && npm --prefix apps/job-api run check\",\n\n // ===== 本地开发依赖与数据库 =====\n // up 只启动容器；down 会同时删除本地开发库卷，执行前先确认不需要保留数据。\n \"dev:docker:up\": \"docker compose -p baohuangtian_dev -f docker-compose.dev.yml up -d --wait\",\n \"dev:docker:down\": \"docker compose -p baohuangtian_dev -f docker-compose.dev.yml down -v --remove-orphans\",\n \"dev:db:push:main\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 db push --config prisma.main.config.ts\",\n \"dev:db:push:tenant\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 db push --config prisma.tenant.config.ts\",\n \"dev:db:push:control\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 db push --config prisma.control.config.ts\",\n \"dev:db:push\": \"deno task dev:db:push:main && deno task dev:db:push:tenant && deno task dev:db:push:control\",\n \"dev:db:reset:control\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 migrate reset --force --config prisma.control.config.ts\",\n \"dev:db:reset:main\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 migrate reset --force --config prisma.main.config.ts\",\n \"dev:db:reset:tenant\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 migrate reset --force --config prisma.tenant.config.ts\",\n \"dev:db:reset\": \"deno task dev:db:reset:control && deno task dev:db:reset:main && deno task dev:db:reset:tenant\",\n\n // ===== Prisma schema / migration =====\n // app:* 只覆盖主服务上线必需的 control + main；tenant 库按商家单独迁移。\n \"prisma:main:validate\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 validate --config prisma.main.config.ts\",\n \"prisma:tenant:validate\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 validate --config prisma.tenant.config.ts\",\n \"prisma:control:validate\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 validate --config prisma.control.config.ts\",\n \"prisma:app:validate\": \"deno task prisma:control:validate && deno task prisma:main:validate\",\n \"prisma:all:validate\": \"deno task prisma:app:validate && deno task prisma:tenant:validate\",\n \"prisma:validate\": \"deno task prisma:app:validate\",\n \"prisma:main:migrate:dev\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 migrate dev --config prisma.main.config.ts\",\n \"prisma:tenant:migrate:dev\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 migrate dev --config prisma.tenant.config.ts\",\n \"prisma:control:migrate:dev\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 migrate dev --config prisma.control.config.ts\",\n \"prisma:migrate:dev\": \"deno task prisma:main:migrate:dev\",\n \"prisma:main:migrate:deploy\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 migrate deploy --config prisma.main.config.ts\",\n \"prisma:tenant:migrate:deploy\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 migrate deploy --config prisma.tenant.config.ts\",\n \"prisma:control:migrate:deploy\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 migrate deploy --config prisma.control.config.ts\",\n \"prisma:app:migrate:deploy\": \"deno task prisma:control:migrate:deploy && deno task prisma:main:migrate:deploy\",\n \"prisma:all:migrate:deploy\": \"deno task prisma:app:migrate:deploy && deno task prisma:tenant:migrate:deploy\",\n \"prisma:migrate:deploy\": \"deno task prisma:app:migrate:deploy\",\n \"prisma:main:generate\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 generate --config prisma.main.config.ts\",\n \"prisma:tenant:generate\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 generate --config prisma.tenant.config.ts\",\n \"prisma:control:generate\": \"deno run --env-file=.env.prisma -A npm:prisma@7.7.0 generate --config prisma.control.config.ts\",\n \"prisma:app:generate\": \"deno task prisma:control:generate && deno task prisma:main:generate\",\n \"prisma:all:generate\": \"deno task prisma:app:generate && deno task prisma:tenant:generate\",\n \"prisma:generate\": \"deno task prisma:app:generate\",\n\n // ===== 商家库运维 =====\n // tenant:* 默认只操作一个商家库；正式执行迁移前先看 status。\n \"tenant:schema\": \"deno run --env-file=.env -A scripts/tenant_db_cli/main.ts\",\n \"tenant:status\": \"deno run --env-file=.env -A scripts/tenant_db_cli/main.ts status\",\n \"tenant:migrate\": \"deno run --env-file=.env -A scripts/tenant_db_cli/main.ts migrate\",\n \"tenant:init\": \"deno run --env-file=.env -A scripts/tenant_db_cli/main.ts migrate\",\n\n // ===== 测试依赖与细分测试 =====\n // test:setup 会重置测试库；所有 test:* 只应配合 .env.test 使用。\n \"test:docker:up\": \"docker compose -p baohuangtian_test -f docker-compose.test.yml up -d --wait\",\n \"test:docker:down\": \"docker compose -p baohuangtian_test -f docker-compose.test.yml down -v --remove-orphans\",\n \"test:db:push:main\": \"deno run --env-file=.env.test -A npm:prisma@7.7.0 db push --config prisma.main.config.ts --force-reset\",\n \"test:db:push:tenant\": \"deno run --env-file=.env.test -A npm:prisma@7.7.0 db push --config prisma.tenant.config.ts --force-reset\",\n \"test:db:push:control\": \"deno run --env-file=.env.test -A npm:prisma@7.7.0 db push --config prisma.control.config.ts --force-reset\",\n \"test:db:push\": \"deno task test:db:push:main && deno task test:db:push:tenant && deno task test:db:push:control\",\n \"test:setup\": \"deno task test:docker:up && deno task test:db:push\",\n \"test:unit:admin\": \"deno test --env-file=.env.test --allow-env --allow-read --allow-write tests/unit/adminTotpManager_test.ts tests/unit/createAdminApp_test.ts tests/unit/infrastructureTargetRepository_test.ts tests/unit/qstashCronAutomationService_test.ts tests/unit/cloudflareScheduledAutomationService_test.ts\",\n \"test:unit:bot\": \"deno test --env-file=.env.test --allow-env --allow-read=src tests/unit/conversationControl_test.ts tests/unit/menuMessage_test.ts tests/unit/replyKeyboardIntent_test.ts tests/unit/slashCommands_test.ts tests/unit/telegramCommandRouter_test.ts tests/unit/telegramDateTime_test.ts tests/unit/telegramHtml_test.ts tests/unit/telegramSupportUser_test.ts tests/unit/telegramTimeSourceGuard_test.ts tests/unit/telegramUserSync_test.ts tests/unit/telegramWebhook_test.ts tests/unit/telegramWebhookAdminService_test.ts tests/unit/userAccessGuard_test.ts tests/unit/mainMenu_test.ts tests/unit/userCenterMenu_test.ts tests/unit/merchantAccountConversations_test.ts\",\n \"test:unit:config\": \"deno test --env-file=.env.test --allow-env tests/unit/loadEnv_test.ts tests/unit/runtimeConfig_test.ts\",\n \"test:unit:group\": \"deno test --env-file=.env.test --allow-env tests/unit/groupCardRedeemAction_test.ts tests/unit/groupCenterMenu_test.ts tests/unit/groupJoinEntrySupport_test.ts tests/unit/groupOrderMemberMenu_test.ts tests/unit/groupPaymentConfirmationService_test.ts tests/unit/groupPaymentConfirmationSweepWorker_test.ts tests/unit/groupPaymentRefundService_test.ts tests/unit/groupShareLinkCommon_test.ts tests/unit/groupShareRepository_test.ts tests/unit/groupShareRuntime_test.ts tests/unit/groupShareLinkSetupConversation_test.ts tests/unit/groupShareLinkSetPriceConversation_test.ts tests/unit/groupShareManagementMenu_test.ts tests/unit/groupShareProfileMenu_test.ts tests/unit/groupStoreCardKey_test.ts tests/unit/groupTelegramPermissions_test.ts tests/unit/managedGroupRepository_test.ts tests/unit/merchantBuyerAccess_test.ts tests/unit/slashCommands_test.ts tests/unit/telegramHtml_test.ts tests/unit/userCenterMenu_test.ts\",\n \"test:unit:payments\": \"deno test --env-file=.env.test --allow-env tests/unit/checkoutPricing_test.ts tests/unit/refundPricing_test.ts tests/unit/groupPaymentConfirmationService_test.ts tests/unit/groupPaymentRefundService_test.ts tests/unit/paidOrderRepository_test.ts tests/unit/paymentProviders/localTestClient_test.ts tests/unit/paymentProviders/ymxhClient_test.ts tests/unit/paymentProviders/ymxhSignature_test.ts\",\n \"test:unit:miniapp\": \"deno test tests/unit/miniappApi_test.ts\",\n \"test:unit:ops\": \"deno test --env-file=.env.test --allow-env tests/unit/systemHealth_test.ts\",\n \"test:unit\": \"deno test --env-file=.env.test --allow-env --allow-read --allow-write tests/unit\",\n \"test:integration:redis\": \"deno test --env-file=.env.test -A tests/integration/resilientRedis_test.ts\",\n \"test:integration:config\": \"deno test --env-file=.env.test -A tests/integration/runtimeConfigRepository_test.ts tests/integration/runtimeConfigService_test.ts\",\n \"test:integration\": \"deno test --env-file=.env.test -A tests/integration\",\n \"telegram:e2e:install\": \"python -m pip install -r tests/e2e/telegram/requirements.txt\",\n \"telegram:e2e:unit\": \"python -m unittest tests.e2e.telegram.telegram_e2e_test\",\n \"telegram:e2e:login\": \"python tests/e2e/telegram/telegram_e2e.py login\",\n \"telegram:e2e:whoami\": \"python tests/e2e/telegram/telegram_e2e.py whoami\",\n \"telegram:e2e:reset-session\": \"python tests/e2e/telegram/telegram_e2e.py reset-session\",\n \"telegram:e2e:ensure-group\": \"python tests/e2e/telegram/telegram_e2e.py ensure-group\",\n \"telegram:e2e:selftest\": \"python tests/e2e/telegram/telegram_e2e.py selftest\",\n \"telegram:e2e:prepare-data\": \"deno run --env-file=.env --allow-env --allow-net --allow-read=.env,tests/e2e/telegram tests/e2e/telegram/prepare_data.ts\",\n \"telegram:e2e:paid-flow\": \"python tests/e2e/telegram/telegram_e2e.py --env-file tests/e2e/telegram/.env.buyer paid-flow\",\n \"telegram:e2e:assert-paid\": \"deno run --env-file=.env --allow-env --allow-net --allow-read=.env,tests/e2e/telegram tests/e2e/telegram/assert_paid_order.ts\",\n \"telegram:e2e:refund-flow\": \"python tests/e2e/telegram/telegram_e2e.py refund-flow\",\n \"telegram:e2e:refund-data\": \"deno run --env-file=.env --allow-env --allow-net --allow-read=.env,tests/e2e/telegram tests/e2e/telegram/refund_data.ts\",\n \"telegram:e2e:assert-refund\": \"deno run --env-file=.env --allow-env --allow-net --allow-read=.env,tests/e2e/telegram tests/e2e/telegram/assert_refund_data.ts\",\n \"telegram:e2e:full\": \"python tests/e2e/telegram/telegram_e2e.py suite\",\n \"test:telegram:e2e\": \"python tests/e2e/telegram/telegram_e2e.py smoke\",\n\n // ===== 调试 / 联调工具 =====\n // debug:* 面向开发排查；test:ymxh:cli 用于人工联调支付商接口，不属于自动化测试。\n \"debug:admin-totp:caption\": \"deno run --env-file=.env -A scripts/debug_admin_totp_caption_probe.ts\",\n \"test:ymxh:cli\": \"deno run --allow-env --allow-net --allow-read scripts/ymxh_cli/main.ts\"\n }\n}\n",[154],"645733f2-5b66-11f1-ba44-ee650bb23af1","src","645734c4-5b66-11f1-ba44-ee650bb23af1",3,["D",1780063075304],"directory",[161],"pulls","branches","forks","envVars",{"_174":176,"_177":62},"connections",{"_174":62,"_175":62},"count","unfilledCount",4,"emptyCount",{"_44":160,"_32":161,"_30":162,"_138":-5,"_42":43,"_41":163,"_140":126,"_39":212,"_13":62,"_34":165,"_36":-5,"_24":25,"_144":-5,"_186":213,"_27":214},{"_44":208,"_32":200,"_30":203,"_138":162,"_42":43,"_41":176,"_140":126,"_39":209,"_13":62,"_34":165,"_36":-5,"_24":25,"_144":-5,"_186":210,"_27":211},{"_44":202,"_32":201,"_30":196,"_138":203,"_42":43,"_41":204,"_140":126,"_39":205,"_13":62,"_34":165,"_36":-5,"_24":25,"_144":-5,"_186":206,"_27":207},{"_44":195,"_32":33,"_30":31,"_138":196,"_42":43,"_41":14,"_140":25,"_39":197,"_13":149,"_34":35,"_36":38,"_24":25,"_144":-5,"_186":198,"_27":199},{"_44":153,"_32":154,"_30":155,"_138":-5,"_42":43,"_41":156,"_140":126,"_39":192,"_13":62,"_34":20,"_36":158,"_24":25,"_144":-5,"_186":193,"_27":194},{"_44":146,"_32":147,"_30":148,"_138":-5,"_42":43,"_41":149,"_140":126,"_39":189,"_13":62,"_34":20,"_36":151,"_24":25,"_144":-5,"_186":190,"_27":191},{"_44":135,"_32":136,"_30":137,"_138":-5,"_42":43,"_41":139,"_140":25,"_39":185,"_13":62,"_34":142,"_36":143,"_24":25,"_144":-5,"_186":187,"_27":188},["D",1780063074865],"children",[],[136],["D",1780063043494],[],[147],["D",1780063077510],[],[154],"8ad1720e-5b66-11f1-9180-ee650bb23af1","64ceafb8-5b66-11f1-b552-ee650bb23af1",["D",1780063139878],[],[161,200,201,33],"app","serverless","64ceaedc-5b66-11f1-b552-ee650bb23af1","649404f8-5b66-11f1-ba44-ee650bb23af1",5,["D",1780063076114],[181],[161,200,201],"649403fe-5b66-11f1-ba44-ee650bb23af1",["D",1780063075734],[180],[161,200],["D",1780063075304],[179],[161],["D",1780061589295],["D",1789492855745],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":56,"_104":105,"_106":25},{"_13":88,"_32":89,"_44":43,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":46,"_97":98},"ctx",{"_81":-5,"_128":253,"_254":255,"_256":257,"_258":25,"_259":25,"_260":25,"_261":126,"_262":-5,"_263":-7,"_264":-7,"_265":62,"_266":25,"_267":25,"_268":-5,"_269":25,"_270":25,"_271":25,"_272":-5},"ENV",{"_224":225,"_226":227,"_228":89,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v8