refactor: 将 server.ts 迁入 packages/weixin，彻底移除 src/services/weixin/

通过依赖注入（WeixinServerDeps）解耦 src/ 依赖（analytics、config、
MCP channel schema），server.ts 完全移入包内。cli.tsx 入口处一次性
注入所有依赖。

src/services/weixin/ 目录已完全删除。

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: claude-code-best

packages/weixin/src/cli.ts

@@ -1,6 +1,8 @@
 import { clearAccount, DEFAULT_BASE_URL, loadAccount, saveAccount } from './accounts.js'
 import { startLogin, waitForLogin } from './login.js'
 import { confirmPairing } from './pairing.js'
+import { runWeixinMcpServer } from './server.js'
+import type { WeixinServerDeps } from './server.js'
 
 function printUsage(): void {
   process.stdout.write(
@@ -92,18 +94,18 @@ function runAccess(args: string[]): void {
 
 export async function handleWeixinCli(
   args: string[],
-  serveHandler?: () => Promise<void>,
+  serverDeps?: WeixinServerDeps,
+  version?: string,
 ): Promise<void> {
   const [subcommand, ...rest] = args
 
   switch (subcommand) {
     case 'serve':
-      if (serveHandler) {
-        await serveHandler()
-      } else {
+      if (!serverDeps) {
         process.stderr.write('[weixin] serve handler not available in this context.\n')
         process.exit(1)
       }
+      await runWeixinMcpServer(version ?? '0.0.0', serverDeps)
       return
     case 'login':
       await runLogin(rest[0] === 'clear')

packages/weixin/src/index.ts

@@ -107,5 +107,9 @@ export type {
   ActivePermissionChat,
 } from './permissions.js'
 
+// Server (MCP)
+export { createWeixinMcpServer, runWeixinMcpServer } from './server.js'
+export type { WeixinServerDeps } from './server.js'
+
 // CLI
 export { handleWeixinCli } from './cli.js'

src/services/weixin/server.ts packages/weixin/src/server.tssrc/services/weixin/server.ts renamed to packages/weixin/src/server.ts

@@ -5,15 +5,6 @@ import {
   CallToolRequestSchema,
   ListToolsRequestSchema,
 } from '@modelcontextprotocol/sdk/types.js'
-import {
-  ChannelPermissionRequestNotificationSchema,
-  type ChannelPermissionRequestParams,
-} from '../mcp/channelNotification.js'
-import { initializeAnalyticsSink } from '../analytics/sink.js'
-import { shutdownDatadog } from '../analytics/datadog.js'
-import { shutdown1PEventLogging } from '../analytics/firstPartyEventLogger.js'
-import { enableConfigs } from '../../utils/config.js'
-import { logForDebugging } from '../../utils/debug.js'
 import {
   CDN_BASE_URL,
   DEFAULT_BASE_URL,
@@ -27,8 +18,21 @@ import {
   sendMediaFile,
   sendText,
   TypingStatus,
-} from '@claude-code-best/weixin'
-import type { ParsedMessage } from '@claude-code-best/weixin'
+} from './index.js'
+import type { ParsedMessage } from './monitor.js'
+import type { ChannelPermissionRequestParams } from './permissions.js'
+
+export interface WeixinServerDeps {
+  enableConfigs(): void
+  initializeAnalyticsSink(): void
+  shutdownDatadog(): Promise<void>
+  shutdown1PEventLogging(): Promise<void>
+  logForDebugging(message: string): void
+  registerPermissionHandler(
+    server: Server,
+    handler: (request: ChannelPermissionRequestParams) => Promise<void>,
+  ): void
+}
 
 function formatPermissionRequestMessage(
   request: ChannelPermissionRequestParams,
@@ -45,9 +49,9 @@ function formatPermissionRequestMessage(
   ].join('\n')
 }
 
-export function createWeixinMcpServer(): Server {
+export function createWeixinMcpServer(version: string): Server {
   const server = new Server(
-    { name: 'weixin', version: MACRO.VERSION },
+    { name: 'weixin', version },
     {
       capabilities: {
         experimental: {
@@ -224,61 +228,60 @@ export function createWeixinMcpServer(): Server {
   return server
 }
 
-export async function runWeixinMcpServer(): Promise<void> {
-  enableConfigs()
-  initializeAnalyticsSink()
+export async function runWeixinMcpServer(
+  version: string,
+  deps: WeixinServerDeps,
+): Promise<void> {
+  deps.enableConfigs()
+  deps.initializeAnalyticsSink()
 
   const account = loadAccount()
   if (!account) {
     process.stderr.write(
       '[weixin] No account configured. Run `ccb weixin login` to connect your WeChat account.\n',
     )
-    await Promise.all([shutdown1PEventLogging(), shutdownDatadog()])
+    await Promise.all([deps.shutdown1PEventLogging(), deps.shutdownDatadog()])
     process.exit(1)
   }
 
-  const server = createWeixinMcpServer()
+  const server = createWeixinMcpServer(version)
   const transport = new StdioServerTransport()
 
-  server.setNotificationHandler(
-    ChannelPermissionRequestNotificationSchema(),
-    async notification => {
-      const request = notification.params
-      const targetChatId = request.channel_context?.chat_id
-      const targetChat = targetChatId
-        ? {
-            chatId: targetChatId,
-            contextToken: getContextToken(targetChatId),
-          }
-        : getActivePermissionChat()
+  deps.registerPermissionHandler(server, async request => {
+    const targetChatId = request.channel_context?.chat_id
+    const targetChat = targetChatId
+      ? {
+          chatId: targetChatId,
+          contextToken: getContextToken(targetChatId),
+        }
+      : getActivePermissionChat()
 
-      if (!targetChat) {
-        logForDebugging(
-          `[Weixin MCP] No active chat available for permission request ${request.request_id}`,
-        )
-        return
-      }
+    if (!targetChat) {
+      deps.logForDebugging(
+        `[Weixin MCP] No active chat available for permission request ${request.request_id}`,
+      )
+      return
+    }
 
-      try {
-        savePendingPermission(
-          request,
-          targetChat.chatId,
-          targetChat.contextToken,
-        )
-        await sendText({
-          to: targetChat.chatId,
-          text: formatPermissionRequestMessage(request),
-          baseUrl,
-          token: account.token,
-          contextToken: targetChat.contextToken || '',
-        })
-      } catch (error) {
-        process.stderr.write(
-          `[weixin] Failed to relay permission request ${request.request_id}: ${error}\n`,
-        )
-      }
-    },
-  )
+    try {
+      savePendingPermission(
+        request,
+        targetChat.chatId,
+        targetChat.contextToken,
+      )
+      await sendText({
+        to: targetChat.chatId,
+        text: formatPermissionRequestMessage(request),
+        baseUrl,
+        token: account.token,
+        contextToken: targetChat.contextToken || '',
+      })
+    } catch (error) {
+      process.stderr.write(
+        `[weixin] Failed to relay permission request ${request.request_id}: ${error}\n`,
+      )
+    }
+  })
 
   await server.connect(transport)
 
@@ -292,7 +295,7 @@ export async function runWeixinMcpServer(): Promise<void> {
     if (!controller.signal.aborted) {
       controller.abort()
     }
-    await Promise.all([shutdown1PEventLogging(), shutdownDatadog()])
+    await Promise.all([deps.shutdown1PEventLogging(), deps.shutdownDatadog()])
     process.exit(0)
   }
 
@@ -313,7 +316,7 @@ export async function runWeixinMcpServer(): Promise<void> {
     }
   }, 5000)
 
-  logForDebugging('[Weixin MCP] Starting poll loop')
+  deps.logForDebugging('[Weixin MCP] Starting poll loop')
   await startPollLoop({
     baseUrl,
     cdnBaseUrl: CDN_BASE_URL,

src/entrypoints/cli.tsx

@@ -143,8 +143,25 @@ async function main(): Promise<void> {
   if (args[0] === 'weixin') {
     profileCheckpoint('cli_weixin_path')
     const { handleWeixinCli } = await import('@claude-code-best/weixin')
-    const { runWeixinMcpServer } = await import('../services/weixin/cli-serve.js')
-    await handleWeixinCli(args.slice(1), runWeixinMcpServer)
+    const { enableConfigs } = await import('../utils/config.js')
+    const { initializeAnalyticsSink } = await import('../services/analytics/sink.js')
+    const { shutdownDatadog } = await import('../services/analytics/datadog.js')
+    const { shutdown1PEventLogging } = await import('../services/analytics/firstPartyEventLogger.js')
+    const { logForDebugging } = await import('../utils/debug.js')
+    const { ChannelPermissionRequestNotificationSchema } = await import('../services/mcp/channelNotification.js')
+    await handleWeixinCli(args.slice(1), {
+      enableConfigs,
+      initializeAnalyticsSink,
+      shutdownDatadog,
+      shutdown1PEventLogging,
+      logForDebugging,
+      registerPermissionHandler(server, handler) {
+        server.setNotificationHandler(
+          ChannelPermissionRequestNotificationSchema(),
+          async notification => handler(notification.params),
+        )
+      },
+    }, MACRO.VERSION)
     return
   }