feat: feishu connect

bun.lock

@@ -21,6 +21,7 @@
         "@azure/identity": "^4.13.1",
         "@commander-js/extra-typings": "^14.0.0",
         "@growthbook/growthbook": "^1.6.5",
+        "@larksuiteoapi/node-sdk": "^1.60.0",
         "@modelcontextprotocol/sdk": "^1.29.0",
         "@opentelemetry/api": "^1.9.1",
         "@opentelemetry/api-logs": "^0.214.0",
@@ -324,6 +325,8 @@
 
     "@js-sdsl/ordered-map": ["@js-sdsl/ordered-map@4.4.2", "", {}, "sha512-iUKgm52T8HOE/makSxjqoWhe95ZJA1/G1sYsGev2JDKUSS14KAgg1LHb+Ba+IPow0xflbnSkOsZcO08C7w1gYw=="],
 
+    "@larksuiteoapi/node-sdk": ["@larksuiteoapi/node-sdk@1.66.1", "", { "dependencies": { "axios": "~1.13.3", "lodash.identity": "^3.0.0", "lodash.merge": "^4.6.2", "lodash.pickby": "^4.6.0", "protobufjs": "^7.2.6", "qs": "^6.14.2", "ws": "^8.19.0" } }, "sha512-W1rIAs/8Oc/rEYuWc0sxGvR8iLwd8p5D2RS4ODMqs8htIxK8yIa8sb22EDv/OEBqUpKXZaNLydTz7Oq8HOQROg=="],
+
     "@mixmark-io/domino": ["@mixmark-io/domino@2.2.0", "", {}, "sha512-Y28PR25bHXUg88kCV7nivXrP2Nj2RueZ3/l/jdx6J9f8J4nsEGcgX0Qe6lt7Pa+J79+kPiJU3LguR6O/6zrLOw=="],
 
     "@modelcontextprotocol/sdk": ["@modelcontextprotocol/sdk@1.29.0", "", { "dependencies": { "@hono/node-server": "^1.19.9", "ajv": "^8.17.1", "ajv-formats": "^3.0.1", "content-type": "^1.0.5", "cors": "^2.8.5", "cross-spawn": "^7.0.5", "eventsource": "^3.0.2", "eventsource-parser": "^3.0.0", "express": "^5.2.1", "express-rate-limit": "^8.2.1", "hono": "^4.11.4", "jose": "^6.1.3", "json-schema-typed": "^8.0.2", "pkce-challenge": "^5.0.0", "raw-body": "^3.0.0", "zod": "^3.25 || ^4.0", "zod-to-json-schema": "^3.25.1" }, "peerDependencies": { "@cfworker/json-schema": "^4.1.1" }, "optionalPeers": ["@cfworker/json-schema"] }, "sha512-zo37mZA9hJWpULgkRpowewez1y6ML5GsXJPY8FI0tBBCd77HEvza4jDqRKOXgHNn867PVGCyTdzqpz0izu5ZjQ=="],
@@ -810,6 +813,8 @@
 
     "lodash.debounce": ["lodash.debounce@4.0.8", "", {}, "sha512-FT1yDzDYEoYWhnSGnpE/4Kj1fLZkDFyqRb7fNt6FdYOSxlUWAtp42Eh6Wb0rGIv/m9Bgo7x4GhQbm5Ys4SG5ow=="],
 
+    "lodash.identity": ["lodash.identity@3.0.0", "", {}, "sha512-AupTIzdLQxJS5wIYUQlgGyk2XRTfGXA+MCghDHqZk0pzUNYvd3EESS6dkChNauNYVIutcb0dfHw1ri9Q1yPV8Q=="],
+
     "lodash.includes": ["lodash.includes@4.3.0", "", {}, "sha512-W3Bx6mdkRTGtlJISOvVD/lbqjTlPPUDTMnlXZFnVwi9NKJ6tiAk6LVdlhZMm17VZisqhKcgzpO5Wz91PCt5b0w=="],
 
     "lodash.isboolean": ["lodash.isboolean@3.0.3", "", {}, "sha512-Bz5mupy2SVbPHURB98VAcw+aHh4vRV5IPNhILUCsOzRmsTmSQ17jIuqopAentWoehktxGd9e/hbIXq980/1QJg=="],
@@ -822,8 +827,12 @@
 
     "lodash.isstring": ["lodash.isstring@4.0.1", "", {}, "sha512-0wJxfxH1wgO3GrbuP+dTTk7op+6L41QCXbGINEmD+ny/G/eCqGzxyCsh7159S+mgDDcoarnBw6PC1PS5+wUGgw=="],
 
+    "lodash.merge": ["lodash.merge@4.6.2", "", {}, "sha512-0KpjqXRVvrYyCsX1swR/XTK0va6VQkQM6MNo7PqW77ByjAhoARA8EfrP1N4+KlKj8YS0ZUCtRT/YUuhyYDujIQ=="],
+
     "lodash.once": ["lodash.once@4.1.1", "", {}, "sha512-Sb487aTOCr9drQVL8pIxOzVhafOjZN9UU54hiN8PU3uAiSV7lx1yYNpbNmex2PK6dSJoNTSJUUswT651yww3Mg=="],
 
+    "lodash.pickby": ["lodash.pickby@4.6.0", "", {}, "sha512-AZV+GsS/6ckvPOVQPXSiFFacKvKB4kOQu6ynt9wz0F3LO4R9Ij4K1ddYsIytDpSgLz88JHd9P+oaLeej5/Sl7Q=="],
+
     "long": ["long@5.3.2", "", {}, "sha512-mNAgZ1GmyNhD7AuqnTG3/VQ26o760+ZYBPKjPvugO8+nLbYfX6TVpJPseBvopbdY+qpZ/lKUnmEc1LeZYS3QAA=="],
 
     "lru-cache": ["lru-cache@11.5.1", "", {}, "sha512-RPimw/7aMdv2oqRrxKwvZXcPfwBrn/JZ2xYcY9Hus/6LaS3VOAKVWKWgNLCFSiOm1ESXinjsDlidVU7JlnCN2A=="],
@@ -926,7 +935,7 @@
 
     "proper-lockfile": ["proper-lockfile@4.1.2", "", { "dependencies": { "graceful-fs": "^4.2.4", "retry": "^0.12.0", "signal-exit": "^3.0.2" } }, "sha512-TjNPblN4BwAWMXU8s9AEz4JmQxnD1NNL7bNOY/AKUzyamc379FWASUhc/K1pL2noVb+XmZKLL68cjzLsiOAMaA=="],
 
-    "protobufjs": ["protobufjs@8.6.3", "", { "dependencies": { "long": "^5.3.2" } }, "sha512-alQyzT0j401LGBtwsqu6uprjR6pfNH1UJf9N6GBFMjIcd+HzTe0/HrjAbFCqun+zvnfLarrxAtMM2xvZ+kFZ5A=="],
+    "protobufjs": ["protobufjs@7.6.3", "", { "dependencies": { "@protobufjs/aspromise": "^1.1.2", "@protobufjs/base64": "^1.1.2", "@protobufjs/codegen": "^2.0.5", "@protobufjs/eventemitter": "^1.1.1", "@protobufjs/fetch": "^1.1.1", "@protobufjs/float": "^1.0.2", "@protobufjs/inquire": "^1.1.2", "@protobufjs/path": "^1.1.2", "@protobufjs/pool": "^1.1.0", "@protobufjs/utf8": "^1.1.1", "@types/node": ">=13.7.0", "long": "^5.3.2" } }, "sha512-+k0vdJKNdW+Vu+dYe8tZA/VvQb6XKNWexC6URwBFXxNnjLJz9nQJCemGyNgRAWD+B7+nGNc9qMPGwcD7s4nzUw=="],
 
     "proxy-addr": ["proxy-addr@2.0.7", "", { "dependencies": { "forwarded": "0.2.0", "ipaddr.js": "1.9.1" } }, "sha512-llQsMLSUDUPT44jdrU/O37qlnifitDP+ZwrmmZcoSKyLKvtZxpyV0n2/bD/N4tBAAZ/gJEdZU7KMraoK1+XYAg=="],
 
@@ -1202,8 +1211,6 @@
 
     "@aws-sdk/xml-builder/@smithy/types": ["@smithy/types@4.14.3", "", { "dependencies": { "tslib": "^2.6.2" } }, "sha512-YupL0ZWmFtJexUN2cHzkvvF/b9pKrtAIfT1o7/oY/Ppu8IYeZ+lDPM5vZdQJaSeA132dJCqojjGC9NhXeF71VQ=="],
 
-    "@grpc/proto-loader/protobufjs": ["protobufjs@7.6.3", "", { "dependencies": { "@protobufjs/aspromise": "^1.1.2", "@protobufjs/base64": "^1.1.2", "@protobufjs/codegen": "^2.0.5", "@protobufjs/eventemitter": "^1.1.1", "@protobufjs/fetch": "^1.1.1", "@protobufjs/float": "^1.0.2", "@protobufjs/inquire": "^1.1.2", "@protobufjs/path": "^1.1.2", "@protobufjs/pool": "^1.1.0", "@protobufjs/utf8": "^1.1.1", "@types/node": ">=13.7.0", "long": "^5.3.2" } }, "sha512-+k0vdJKNdW+Vu+dYe8tZA/VvQb6XKNWexC6URwBFXxNnjLJz9nQJCemGyNgRAWD+B7+nGNc9qMPGwcD7s4nzUw=="],
-
     "@grpc/proto-loader/yargs": ["yargs@17.7.2", "", { "dependencies": { "cliui": "^8.0.1", "escalade": "^3.1.1", "get-caller-file": "^2.0.5", "require-directory": "^2.1.1", "string-width": "^4.2.3", "y18n": "^5.0.5", "yargs-parser": "^21.1.1" } }, "sha512-7dSzzRQ++CKnNI/krKnYRV7JKKPUXMEh61soaHKg9mrWEhzFWhFnxPxGl+69cD1Ou63C13NUPCnmIcrvqCuM6w=="],
 
     "@inquirer/checkbox/ansi-escapes": ["ansi-escapes@4.3.2", "", { "dependencies": { "type-fest": "^0.21.3" } }, "sha512-gKXj5ALrKWQLsYG9jlTRmR/xKluxHV+Z9QEwNIgCfM1/uwPMCuzVVnh5mwTd+OuBZcwSIMbqssNWRm1lE51QaQ=="],
@@ -1220,6 +1227,8 @@
 
     "@inquirer/select/ansi-escapes": ["ansi-escapes@4.3.2", "", { "dependencies": { "type-fest": "^0.21.3" } }, "sha512-gKXj5ALrKWQLsYG9jlTRmR/xKluxHV+Z9QEwNIgCfM1/uwPMCuzVVnh5mwTd+OuBZcwSIMbqssNWRm1lE51QaQ=="],
 
+    "@larksuiteoapi/node-sdk/axios": ["axios@1.13.6", "", { "dependencies": { "follow-redirects": "^1.15.11", "form-data": "^4.0.5", "proxy-from-env": "^1.1.0" } }, "sha512-ChTCHMouEe2kn713WHbQGcuYrr6fXTBiu460OTwWrWob16g1bXn4vtz07Ope7ewMozJAnEquLk5lWQWtBig9DQ=="],
+
     "@opentelemetry/exporter-logs-otlp-grpc/@opentelemetry/core": ["@opentelemetry/core@2.6.1", "", { "dependencies": { "@opentelemetry/semantic-conventions": "^1.29.0" }, "peerDependencies": { "@opentelemetry/api": ">=1.0.0 <1.10.0" } }, "sha512-8xHSGWpJP9wBxgBpnqGL0R3PbdWQndL1Qp50qrg71+B28zK5OQmUgcDKLJgzyAAV38t4tOyLMGDD60LneR5W8g=="],
 
     "@opentelemetry/exporter-logs-otlp-http/@opentelemetry/core": ["@opentelemetry/core@2.6.1", "", { "dependencies": { "@opentelemetry/semantic-conventions": "^1.29.0" }, "peerDependencies": { "@opentelemetry/api": ">=1.0.0 <1.10.0" } }, "sha512-8xHSGWpJP9wBxgBpnqGL0R3PbdWQndL1Qp50qrg71+B28zK5OQmUgcDKLJgzyAAV38t4tOyLMGDD60LneR5W8g=="],
@@ -1284,8 +1293,6 @@
 
     "@opentelemetry/otlp-transformer/@opentelemetry/sdk-trace-base": ["@opentelemetry/sdk-trace-base@2.6.1", "", { "dependencies": { "@opentelemetry/core": "2.6.1", "@opentelemetry/resources": "2.6.1", "@opentelemetry/semantic-conventions": "^1.29.0" }, "peerDependencies": { "@opentelemetry/api": ">=1.3.0 <1.10.0" } }, "sha512-r86ut4T1e8vNwB35CqCcKd45yzqH6/6Wzvpk2/cZB8PsPLlZFTvrh8yfOS3CYZYcUmAx4hHTZJ8AO8Dj8nrdhw=="],
 
-    "@opentelemetry/otlp-transformer/protobufjs": ["protobufjs@7.6.3", "", { "dependencies": { "@protobufjs/aspromise": "^1.1.2", "@protobufjs/base64": "^1.1.2", "@protobufjs/codegen": "^2.0.5", "@protobufjs/eventemitter": "^1.1.1", "@protobufjs/fetch": "^1.1.1", "@protobufjs/float": "^1.0.2", "@protobufjs/inquire": "^1.1.2", "@protobufjs/path": "^1.1.2", "@protobufjs/pool": "^1.1.0", "@protobufjs/utf8": "^1.1.1", "@types/node": ">=13.7.0", "long": "^5.3.2" } }, "sha512-+k0vdJKNdW+Vu+dYe8tZA/VvQb6XKNWexC6URwBFXxNnjLJz9nQJCemGyNgRAWD+B7+nGNc9qMPGwcD7s4nzUw=="],
-
     "@opentelemetry/sdk-logs/@opentelemetry/core": ["@opentelemetry/core@2.6.1", "", { "dependencies": { "@opentelemetry/semantic-conventions": "^1.29.0" }, "peerDependencies": { "@opentelemetry/api": ">=1.0.0 <1.10.0" } }, "sha512-8xHSGWpJP9wBxgBpnqGL0R3PbdWQndL1Qp50qrg71+B28zK5OQmUgcDKLJgzyAAV38t4tOyLMGDD60LneR5W8g=="],
 
     "@opentelemetry/sdk-logs/@opentelemetry/resources": ["@opentelemetry/resources@2.6.1", "", { "dependencies": { "@opentelemetry/core": "2.6.1", "@opentelemetry/semantic-conventions": "^1.29.0" }, "peerDependencies": { "@opentelemetry/api": ">=1.3.0 <1.10.0" } }, "sha512-lID/vxSuKWXM55XhAKNoYXu9Cutoq5hFdkbTdI/zDKQktXzcWBVhNsOkiZFTMU9UtEWuGRNe0HUgmsFldIdxVA=="],
@@ -1340,6 +1347,8 @@
 
     "cliui/wrap-ansi": ["wrap-ansi@7.0.0", "", { "dependencies": { "ansi-styles": "^4.0.0", "string-width": "^4.1.0", "strip-ansi": "^6.0.0" } }, "sha512-YVGIj2kamLSTxw6NsZjoBxfSwsn0ycdesmc4p+Q21c5zPuZ1pl+NfxVdxPtdHvmNVOQ6XSYG4AUtyt/Fi7D16Q=="],
 
+    "doubaoime-asr/protobufjs": ["protobufjs@8.6.3", "", { "dependencies": { "long": "^5.3.2" } }, "sha512-alQyzT0j401LGBtwsqu6uprjR6pfNH1UJf9N6GBFMjIcd+HzTe0/HrjAbFCqun+zvnfLarrxAtMM2xvZ+kFZ5A=="],
+
     "external-editor/iconv-lite": ["iconv-lite@0.4.24", "", { "dependencies": { "safer-buffer": ">= 2.1.2 < 3" } }, "sha512-v3MXnZAcvnywkTUEZomIActle7RXXeedOR31wwl7VlyoXO4Qi9arvSenNQWne1TcRwhCL1HwLI21bEqdpj8/rA=="],
 
     "form-data/mime-types": ["mime-types@2.1.35", "", { "dependencies": { "mime-db": "1.52.0" } }, "sha512-ZDY+bPm5zTTF+YpCrAU9nK0UgICYPT0QtT1NZWFv4s++TNkcgVaT0g6+4R2uI4MjQjzysHB1zxuWL50hzaeXiw=="],
@@ -1418,6 +1427,8 @@
 
     "@inquirer/select/ansi-escapes/type-fest": ["type-fest@0.21.3", "", {}, "sha512-t0rzBq87m3fVcduHDUFhKmyyX+9eo6WQjZvf51Ea/M0Q7+T374Jp1aUiyUl0GKxp8M/OETVHSDvmkyPgvX+X2w=="],
 
+    "@larksuiteoapi/node-sdk/axios/proxy-from-env": ["proxy-from-env@1.1.0", "", {}, "sha512-D+zkORCbA9f1tdWRK0RaCR3GPv50cMxcrz4X8k5LTSUD1Dkw47mKJEZQNunItRTkWwgtaUSo1RVFRIG9ZXiFYg=="],
+
     "@smithy/eventstream-codec/@aws-crypto/crc32/@aws-crypto/util": ["@aws-crypto/util@3.0.0", "", { "dependencies": { "@aws-sdk/types": "^3.222.0", "@aws-sdk/util-utf8-browser": "^3.0.0", "tslib": "^1.11.1" } }, "sha512-2OJlpeJpCR48CC8r+uKVChzs9Iungj9wkZrl8Z041DWEWvyIHILYKCPNzJghKsivj+S3mLo6BVc7mBNzdxA46w=="],
 
     "@smithy/eventstream-codec/@aws-crypto/crc32/tslib": ["tslib@1.14.1", "", {}, "sha512-Xni35NKzjgMrwevysHTCArtLDpPvye8zV/0E4EyYn43P7/7qvQwPh9BGkHewbMulVntbigmcT7rdX3BNo9wRJg=="],

package.json

@@ -39,6 +39,7 @@
     "@azure/identity": "^4.13.1",
     "@commander-js/extra-typings": "^14.0.0",
     "@growthbook/growthbook": "^1.6.5",
+    "@larksuiteoapi/node-sdk": "^1.60.0",
     "@modelcontextprotocol/sdk": "^1.29.0",
     "@opentelemetry/api": "^1.9.1",
     "@opentelemetry/api-logs": "^0.214.0",

src/commands.ts

@@ -43,6 +43,7 @@ import share from './commands/share/index.js'
 import skills from './commands/skills/index.js'
 import status from './commands/status/index.js'
 import tasks from './commands/tasks/index.js'
+import feishu from './commands/feishu/index.js'
 import telegram from './commands/telegram/index.js'
 import teleport from './commands/teleport/index.js'
 /* eslint-disable @typescript-eslint/no-require-imports */
@@ -306,6 +307,7 @@ const COMMANDS = memoize((): Command[] => [
   telegram,
   theme,
   feedback,
+  feishu,
   review,
   ultrareview,
   rewind,

src/commands/feishu/feishu.tsx

@@ -0,0 +1,551 @@
+import * as React from 'react'
+import { Box, Text, useInput } from '../../ink.js'
+import { Dialog } from '../../components/design-system/Dialog.js'
+import { ListItem } from '../../components/design-system/ListItem.js'
+import type { LocalJSXCommandContext } from '../../commands.js'
+import type { LocalJSXCommandOnDone } from '../../types/command.js'
+import { feishuService } from '../../services/feishu/FeishuService.js'
+import {
+  clearFeishuConfig,
+  getFeishuConfig,
+  maskFeishuAppId,
+  maskFeishuAppSecret,
+  saveFeishuConfig,
+} from '../../services/feishu/feishuConfig.js'
+
+type Step =
+  | { type: 'menu' }
+  | { type: 'edit-app-id' }
+  | { type: 'edit-app-secret' }
+  | { type: 'edit-encrypt-key' }
+  | { type: 'edit-verification-token' }
+  | { type: 'edit-allowed-users' }
+  | { type: 'confirm-clear' }
+
+type Notice = {
+  text: string
+  tone: 'success' | 'error' | 'info'
+}
+
+function TextInput({
+  title,
+  hint,
+  initialValue,
+  masked = false,
+  onSubmit,
+  onCancel,
+}: {
+  title: string
+  hint: string
+  initialValue?: string
+  masked?: boolean
+  onSubmit: (value: string) => void
+  onCancel: () => void
+}) {
+  const [value, setValue] = React.useState(initialValue ?? '')
+  const [cursorOffset, setCursorOffset] = React.useState(
+    (initialValue ?? '').length,
+  )
+
+  useInput((input, key) => {
+    if (key.escape) {
+      onCancel()
+      return
+    }
+
+    if (key.return) {
+      onSubmit(value.trim())
+      return
+    }
+
+    if (key.leftArrow) {
+      setCursorOffset(current => Math.max(0, current - 1))
+      return
+    }
+
+    if (key.rightArrow) {
+      setCursorOffset(current => Math.min(value.length, current + 1))
+      return
+    }
+
+    if (key.backspace || key.delete) {
+      if (cursorOffset === 0) return
+      const nextValue =
+        value.slice(0, cursorOffset - 1) + value.slice(cursorOffset)
+      setValue(nextValue)
+      setCursorOffset(current => Math.max(0, current - 1))
+      return
+    }
+
+    if (input) {
+      const nextValue =
+        value.slice(0, cursorOffset) + input + value.slice(cursorOffset)
+      setValue(nextValue)
+      setCursorOffset(current => current + input.length)
+    }
+  })
+
+  const displayValue = masked ? '*'.repeat(value.length) : value
+  const cursorChar =
+    cursorOffset < displayValue.length ? displayValue[cursorOffset] : ' '
+
+  return (
+    <Box flexDirection="column" gap={1}>
+      <Text bold>{title}</Text>
+      <Text dimColor>{hint}</Text>
+      <Box flexDirection="column" marginTop={1}>
+        <Text dimColor>Value:</Text>
+        <Box>
+          <Text>{displayValue.slice(0, cursorOffset)}</Text>
+          <Text backgroundColor="white" color="black">
+            {cursorChar}
+          </Text>
+          <Text>{displayValue.slice(cursorOffset + 1)}</Text>
+        </Box>
+      </Box>
+      <Text dimColor>[Enter] 保存 · [Esc] 返回</Text>
+    </Box>
+  )
+}
+
+function ConfirmClear({
+  onConfirm,
+  onCancel,
+}: {
+  onConfirm: () => void
+  onCancel: () => void
+}) {
+  useInput((_, key) => {
+    if (key.escape) {
+      onCancel()
+      return
+    }
+
+    if (key.return) {
+      onConfirm()
+    }
+  })
+
+  return (
+    <Box flexDirection="column" gap={1}>
+      <Text color="yellow">这会清空飞书 App ID / App Secret 以及所有白名单配置。</Text>
+      <Text dimColor>
+        如果当前 bot 正在运行，会一并停止。按 Enter 确认，Esc 返回。
+      </Text>
+    </Box>
+  )
+}
+
+function FeishuDialog({
+  onDone,
+}: {
+  onDone: LocalJSXCommandOnDone
+}) {
+  const serviceState = React.useSyncExternalStore(
+    feishuService.subscribe,
+    feishuService.getStateSnapshot,
+  )
+  const [config, setConfig] = React.useState(() => getFeishuConfig())
+  const [step, setStep] = React.useState<Step>({ type: 'menu' })
+  const [notice, setNotice] = React.useState<Notice | null>(null)
+  const [focusIndex, setFocusIndex] = React.useState(0)
+  const [busy, setBusy] = React.useState(false)
+
+  const refreshConfig = React.useCallback(() => {
+    setConfig(getFeishuConfig())
+  }, [])
+
+  const menuItems = React.useMemo(
+    () => [
+      {
+        label: '设置 App ID',
+        action: () => setStep({ type: 'edit-app-id' }),
+      },
+      {
+        label: '设置 App Secret',
+        action: () => setStep({ type: 'edit-app-secret' }),
+      },
+      {
+        label: '设置加密密钥（可选）',
+        action: () => setStep({ type: 'edit-encrypt-key' }),
+      },
+      {
+        label: '设置验证 Token（可选）',
+        action: () => setStep({ type: 'edit-verification-token' }),
+      },
+      {
+        label: '设置允许访问的用户',
+        action: () => setStep({ type: 'edit-allowed-users' }),
+      },
+      {
+        label:
+          serviceState.status === 'running' ? '停止当前飞书 Bot' : '启动当前飞书 Bot',
+        action: async () => {
+          setBusy(true)
+          try {
+            if (serviceState.status === 'running') {
+              await feishuService.stop()
+              setNotice({ text: '飞书 Bot 已停止。', tone: 'success' })
+            } else {
+              await feishuService.startFromSavedConfig()
+              setNotice({
+                text: '飞书 Bot 已启动，请在飞书中私聊机器人验证连接。',
+                tone: 'success',
+              })
+            }
+          } catch (error) {
+            setNotice({
+              text: error instanceof Error ? error.message : '启动飞书 Bot 失败',
+              tone: 'error',
+            })
+          } finally {
+            setBusy(false)
+          }
+        },
+      },
+      {
+        label: '清空飞书配置',
+        action: () => setStep({ type: 'confirm-clear' }),
+      },
+      {
+        label: '关闭',
+        action: () => onDone(undefined, { display: 'skip' }),
+      },
+    ],
+    [onDone, serviceState.status],
+  )
+
+  React.useEffect(() => {
+    setFocusIndex(current => Math.min(current, menuItems.length - 1))
+  }, [menuItems.length])
+
+  const saveAppId = React.useCallback(
+    async (value: string) => {
+      if (!value) {
+        setNotice({ text: 'App ID 不能为空。', tone: 'error' })
+        setStep({ type: 'menu' })
+        return
+      }
+
+      setBusy(true)
+      try {
+        const current = getFeishuConfig()
+        saveFeishuConfig({ ...current, appId: value })
+        refreshConfig()
+        if (serviceState.status === 'running') {
+          await feishuService.stop()
+          await feishuService.startFromSavedConfig()
+        }
+        setNotice({ text: 'App ID 已保存。', tone: 'success' })
+      } catch (error) {
+        setNotice({
+          text: error instanceof Error ? error.message : '保存 App ID 失败',
+          tone: 'error',
+        })
+      } finally {
+        setBusy(false)
+        setStep({ type: 'menu' })
+      }
+    },
+    [refreshConfig, serviceState.status],
+  )
+
+  const saveAppSecret = React.useCallback(
+    async (value: string) => {
+      if (!value) {
+        setNotice({ text: 'App Secret 不能为空。', tone: 'error' })
+        setStep({ type: 'menu' })
+        return
+      }
+
+      setBusy(true)
+      try {
+        const current = getFeishuConfig()
+        saveFeishuConfig({ ...current, appSecret: value })
+        refreshConfig()
+        if (serviceState.status === 'running') {
+          await feishuService.stop()
+          await feishuService.startFromSavedConfig()
+        }
+        setNotice({ text: 'App Secret 已保存。', tone: 'success' })
+      } catch (error) {
+        setNotice({
+          text: error instanceof Error ? error.message : '保存 App Secret 失败',
+          tone: 'error',
+        })
+      } finally {
+        setBusy(false)
+        setStep({ type: 'menu' })
+      }
+    },
+    [refreshConfig, serviceState.status],
+  )
+
+  const saveEncryptKey = React.useCallback(
+    async (value: string) => {
+      setBusy(true)
+      try {
+        const current = getFeishuConfig()
+        saveFeishuConfig({ ...current, encryptKey: value || undefined })
+        refreshConfig()
+        if (serviceState.status === 'running') {
+          await feishuService.stop()
+          await feishuService.startFromSavedConfig()
+        }
+        setNotice({ text: '加密密钥已保存。', tone: 'success' })
+      } catch (error) {
+        setNotice({
+          text: error instanceof Error ? error.message : '保存失败',
+          tone: 'error',
+        })
+      } finally {
+        setBusy(false)
+        setStep({ type: 'menu' })
+      }
+    },
+    [refreshConfig, serviceState.status],
+  )
+
+  const saveVerificationToken = React.useCallback(
+    async (value: string) => {
+      setBusy(true)
+      try {
+        const current = getFeishuConfig()
+        saveFeishuConfig({ ...current, verificationToken: value || undefined })
+        refreshConfig()
+        if (serviceState.status === 'running') {
+          await feishuService.stop()
+          await feishuService.startFromSavedConfig()
+        }
+        setNotice({ text: '验证 Token 已保存。', tone: 'success' })
+      } catch (error) {
+        setNotice({
+          text: error instanceof Error ? error.message : '保存失败',
+          tone: 'error',
+        })
+      } finally {
+        setBusy(false)
+        setStep({ type: 'menu' })
+      }
+    },
+    [refreshConfig, serviceState.status],
+  )
+
+  const saveAllowedUsers = React.useCallback(
+    async (value: string) => {
+      const users = value.split(/[,\s]+/).map(s => s.trim()).filter(Boolean)
+      setBusy(true)
+      try {
+        const current = getFeishuConfig()
+        saveFeishuConfig({ ...current, allowedUsers: users.length > 0 ? users : undefined })
+        refreshConfig()
+        setNotice({ text: '允许用户列表已保存。', tone: 'success' })
+      } catch (error) {
+        setNotice({
+          text: error instanceof Error ? error.message : '保存失败',
+          tone: 'error',
+        })
+      } finally {
+        setBusy(false)
+        setStep({ type: 'menu' })
+      }
+    },
+    [refreshConfig],
+  )
+
+  const clearConfigAndStop = React.useCallback(async () => {
+    setBusy(true)
+    try {
+      await feishuService.stop()
+      clearFeishuConfig()
+      refreshConfig()
+      setNotice({ text: '飞书配置已清空。', tone: 'success' })
+    } catch (error) {
+      setNotice({
+        text: error instanceof Error ? error.message : '清空配置失败',
+        tone: 'error',
+      })
+    } finally {
+      setBusy(false)
+      setStep({ type: 'menu' })
+    }
+  }, [refreshConfig])
+
+  useInput((_, key) => {
+    if (step.type !== 'menu' || busy) return
+
+    if (key.escape) {
+      onDone(undefined, { display: 'skip' })
+      return
+    }
+
+    if (key.upArrow) {
+      setFocusIndex(current => (current - 1 + menuItems.length) % menuItems.length)
+      return
+    }
+
+    if (key.downArrow) {
+      setFocusIndex(current => (current + 1) % menuItems.length)
+      return
+    }
+
+    if (key.return) {
+      void menuItems[focusIndex]?.action()
+    }
+  })
+
+  const noticeColor =
+    notice?.tone === 'error'
+      ? 'red'
+      : notice?.tone === 'success'
+        ? 'green'
+        : 'cyan'
+
+  // Step rendering
+  if (step.type === 'edit-app-id') {
+    return (
+      <Dialog title="飞书 App ID" onCancel={() => setStep({ type: 'menu' })}>
+        <TextInput
+          title="App ID"
+          hint="从飞书开放平台 > 凭证与基础信息 获取。"
+          initialValue={config?.appId}
+          onSubmit={value => { void saveAppId(value) }}
+          onCancel={() => setStep({ type: 'menu' })}
+        />
+      </Dialog>
+    )
+  }
+
+  if (step.type === 'edit-app-secret') {
+    return (
+      <Dialog title="飞书 App Secret" onCancel={() => setStep({ type: 'menu' })}>
+        <TextInput
+          title="App Secret"
+          hint="从飞书开放平台 > 凭证与基础信息 获取。"
+          initialValue={config?.appSecret}
+          masked={true}
+          onSubmit={value => { void saveAppSecret(value) }}
+          onCancel={() => setStep({ type: 'menu' })}
+        />
+      </Dialog>
+    )
+  }
+
+  if (step.type === 'edit-encrypt-key') {
+    return (
+      <Dialog title="飞书加密密钥" onCancel={() => setStep({ type: 'menu' })}>
+        <TextInput
+          title="加密密钥（可选）"
+          hint="如果启用了「订阅事件请求 URL 加密模式」才需要填写。"
+          initialValue={config?.encryptKey}
+          masked={true}
+          onSubmit={value => { void saveEncryptKey(value) }}
+          onCancel={() => setStep({ type: 'menu' })}
+        />
+      </Dialog>
+    )
+  }
+
+  if (step.type === 'edit-verification-token') {
+    return (
+      <Dialog title="飞书验证 Token" onCancel={() => setStep({ type: 'menu' })}>
+        <TextInput
+          title="验证 Token（可选）"
+          hint="如果启用了「订阅事件请求 URL 验证」才需要填写。"
+          initialValue={config?.verificationToken}
+          masked={true}
+          onSubmit={value => { void saveVerificationToken(value) }}
+          onCancel={() => setStep({ type: 'menu' })}
+        />
+      </Dialog>
+    )
+  }
+
+  if (step.type === 'edit-allowed-users') {
+    return (
+      <Dialog title="允许访问的用户" onCancel={() => setStep({ type: 'menu' })}>
+        <TextInput
+          title="允许访问的飞书用户 open_id"
+          hint="可输入一个或多个 open_id，支持空格或逗号分隔。配对成功后可发送配对码完成授权。"
+          initialValue={config?.allowedUsers?.join(', ')}
+          onSubmit={value => { void saveAllowedUsers(value) }}
+          onCancel={() => setStep({ type: 'menu' })}
+        />
+      </Dialog>
+    )
+  }
+
+  if (step.type === 'confirm-clear') {
+    return (
+      <Dialog title="清空飞书配置" onCancel={() => setStep({ type: 'menu' })}>
+        <ConfirmClear
+          onConfirm={() => { void clearConfigAndStop() }}
+          onCancel={() => setStep({ type: 'menu' })}
+        />
+      </Dialog>
+    )
+  }
+
+  return (
+    <Dialog title="飞书 (Feishu)" onCancel={() => onDone(undefined, { display: 'skip' })}>
+      <Box flexDirection="column" gap={1}>
+        <Text dimColor>
+          启动飞书长连接机器人，并把私聊消息接入当前会话。
+        </Text>
+        <Text>
+          状态:
+          {' '}
+          <Text color={serviceState.status === 'running' ? 'green' : 'yellow'}>
+            {serviceState.status === 'running'
+              ? '运行中'
+              : serviceState.status === 'starting'
+                ? '启动中'
+                : '未启动'}
+          </Text>
+        </Text>
+        <Text>App ID: {maskFeishuAppId(config?.appId)}</Text>
+        <Text>App Secret: {maskFeishuAppSecret(config?.appSecret)}</Text>
+        <Text>
+          加密密钥: {config?.encryptKey ? '已配置' : '未配置'}
+        </Text>
+        <Text>
+          验证 Token: {config?.verificationToken ? '已配置' : '未配置'}
+        </Text>
+        <Text>
+          允许用户:
+          {' '}
+          {config?.allowedUsers?.length
+            ? config.allowedUsers.join(', ')
+            : '未配置（使用配对码授权）'}
+        </Text>
+        {config?.pairedUsers?.length ? (
+          <Text>
+            已配对用户: {config.pairedUsers.map(u => u.displayName || u.userId).join(', ')}
+          </Text>
+        ) : null}
+        {serviceState.lastError ? (
+          <Text color="red">最近错误: {serviceState.lastError}</Text>
+        ) : null}
+        {notice ? <Text color={noticeColor}>{notice.text}</Text> : null}
+        {busy ? <Text dimColor>处理中，请稍候...</Text> : null}
+        <Box flexDirection="column" marginTop={1}>
+          {menuItems.map((item, index) => (
+            <ListItem key={item.label} isFocused={focusIndex === index}>
+              <Text>{item.label}</Text>
+            </ListItem>
+          ))}
+        </Box>
+        <Text dimColor>上下箭头选择，Enter 执行，Esc 关闭</Text>
+      </Box>
+    </Dialog>
+  )
+}
+
+export async function call(
+  onDone: LocalJSXCommandOnDone,
+  _context: LocalJSXCommandContext,
+): Promise<React.ReactNode> {
+  return <FeishuDialog onDone={onDone} />
+}
+
+export default call

src/commands/feishu/index.ts

@@ -0,0 +1,10 @@
+import type { Command } from '../../commands.js'
+
+const feishu = {
+  type: 'local-jsx',
+  name: 'feishu',
+  description: 'Connect a Feishu bot to this session',
+  load: () => import('./feishu.js'),
+} satisfies Command
+
+export default feishu

src/components/PromptInput/PromptInputFooter.tsx

@@ -11,6 +11,7 @@ import { useTerminalSize } from '../../hooks/useTerminalSize.js';
 import { Box, Text } from '../../ink.js';
 import type { MCPServerConnection } from '../../services/mcp/types.js';
 import { telegramService } from '../../services/telegram/TelegramService.js';
+import { feishuService } from '../../services/feishu/FeishuService.js';
 import { useAppState } from '../../state/AppState.js';
 import type { ToolPermissionContext } from '../../Tool.js';
 import type { Message } from '../../types/message.js';
@@ -146,6 +147,7 @@ function PromptInputFooter({
           {isFullscreen ? null : <Notifications apiKeyStatus={apiKeyStatus} autoUpdaterResult={autoUpdaterResult} debug={debug} isAutoUpdating={isAutoUpdating} verbose={verbose} messages={messages} onAutoUpdaterResult={onAutoUpdaterResult} onChangeIsUpdating={onChangeIsUpdating} ideSelection={ideSelection} mcpClients={mcpClients} isInputWrapped={isInputWrapped} isNarrow={isNarrow} />}
           {"external" === 'ant' && isUndercover() && <Text dimColor>undercover</Text>}
           <TelegramStatusIndicator />
+          <FeishuStatusIndicator />
           <BridgeStatusIndicator bridgeSelected={bridgeSelected} />
         </Box>
       </Box>
@@ -170,6 +172,22 @@ function TelegramStatusIndicator(): React.ReactNode {
     </Text>;
 }
 
+function FeishuStatusIndicator(): React.ReactNode {
+  const state = React.useSyncExternalStore(
+    feishuService.subscribe,
+    feishuService.getStateSnapshot,
+    feishuService.getStateSnapshot,
+  );
+
+  if (state.status !== 'running' && state.status !== 'starting') {
+    return null;
+  }
+
+  return <Text color={state.status === 'running' ? 'notice' : 'warning'}>
+      ✉
+    </Text>;
+}
+
 type BridgeStatusProps = {
   bridgeSelected: boolean;
 };

src/hooks/useFeishuBridge.ts

@@ -0,0 +1,23 @@
+/**
+ * useFeishuBridge — auto-starts Feishu service if configured.
+ */
+
+import { useEffect, useRef } from 'react'
+import { feishuService } from '../services/feishu/FeishuService.js'
+import { getFeishuConfig } from '../services/feishu/feishuConfig.js'
+
+export function useFeishuBridge(): void {
+  const attempted = useRef(false)
+
+  useEffect(() => {
+    if (attempted.current) return
+    attempted.current = true
+
+    const config = getFeishuConfig()
+    if (!config.appId || !config.appSecret) return
+
+    void feishuService.startFromSavedConfig().catch((e) => {
+      console.warn('[feishu] auto-start failed:', e instanceof Error ? e.message : String(e))
+    })
+  }, [])
+}

src/services/feishu/FeishuService.ts

@@ -0,0 +1,194 @@
+/**
+ * FeishuService — in-process Feishu bot using @larksuiteoapi/node-sdk
+ *
+ * Uses Lark.WSClient to receive events, enqueues messages to REPL,
+ * collects responses via polling AppState, sends back to Feishu.
+ */
+
+import * as Lark from '@larksuiteoapi/node-sdk'
+import { getFeishuConfig, type FeishuRuntimeConfig } from './feishuConfig.js'
+import { logForDebugging } from '../../utils/debug.js'
+
+type FeishuServiceState = {
+  status: 'stopped' | 'starting' | 'running' | 'error'
+  appId?: string
+  lastError?: string
+}
+
+type Listener = () => void
+
+function normalizeError(error: unknown): string {
+  if (error instanceof Error) return error.message
+  return String(error)
+}
+
+class FeishuService {
+  private listeners = new Set<Listener>()
+  private state: FeishuServiceState = { status: 'stopped' }
+  private config?: FeishuRuntimeConfig
+  private client?: Lark.Client
+  private wsClient?: { stop?: () => void }
+  private runId = 0
+
+  subscribe = (listener: Listener): (() => void) => {
+    this.listeners.add(listener)
+    return () => this.listeners.delete(listener)
+  }
+
+  getStateSnapshot = (): FeishuServiceState => this.state
+
+  async start(config: FeishuRuntimeConfig): Promise<void> {
+    if (this.state.status === 'running' &&
+        this.config?.appId === config.appId &&
+        this.config?.appSecret === config.appSecret) {
+      return
+    }
+
+    await this.stop()
+    const runId = ++this.runId
+    this.config = config
+    this.client = new Lark.Client({
+      appId: config.appId,
+      appSecret: config.appSecret,
+      appType: Lark.AppType.SelfBuild,
+      domain: Lark.Domain.Feishu,
+    })
+
+    this.setState({ status: 'starting', appId: config.appId, lastError: undefined })
+
+    try {
+      // Verify credentials
+      await this.client.request({
+        method: 'GET',
+        url: '/open-apis/bot/v3/info',
+      })
+      if (runId !== this.runId) return
+
+      logForDebugging('[feishu] connected successfully')
+
+      const dispatcher = new Lark.EventDispatcher({
+        encryptKey: config.encryptKey,
+        verificationToken: config.verificationToken,
+      })
+
+      dispatcher.register({
+        'im.message.receive_v1': async (data: any) => {
+          if (runId !== this.runId) return
+          try {
+            await this.handleInbound(data)
+          } catch (err) {
+            logForDebugging(`[feishu] inbound error: ${normalizeError(err)}`)
+          }
+        },
+      } as any)
+
+      // @ts-ignore - WSClient instance type varies
+      this.wsClient = new Lark.WSClient({
+        appId: config.appId,
+        appSecret: config.appSecret,
+        domain: Lark.Domain.Feishu,
+        loggerLevel: Lark.LoggerLevel.warn,
+      })
+
+      await this.wsClient.start?.({ eventDispatcher: dispatcher })
+      if (runId !== this.runId) return
+
+      this.setState({ status: 'running', appId: config.appId })
+    } catch (err) {
+      if (runId !== this.runId) return
+      this.setState({ status: 'error', appId: config.appId, lastError: normalizeError(err) })
+      throw err
+    }
+  }
+
+  async startFromSavedConfig(): Promise<void> {
+    const config = getFeishuConfig()
+    if (!config.appId || !config.appSecret) {
+      throw new Error('飞书 App ID 或 App Secret 未配置。')
+    }
+    await this.start(config)
+  }
+
+  async stop(): Promise<void> {
+    this.runId++
+    try { this.wsClient?.stop?.() } catch {}
+    this.wsClient = undefined
+    this.client = undefined
+    this.config = undefined
+    if (this.state.status !== 'stopped') {
+      this.setState({ ...this.state, status: 'stopped' })
+    }
+  }
+
+  async sendText(chatId: string, text: string): Promise<void> {
+    if (!this.client) return
+    const MAX = 4000
+    for (let i = 0; i < text.length; i += MAX) {
+      const chunk = text.slice(i, i + MAX)
+      await this.client.im.message.create({
+        data: {
+          receive_id: chatId,
+          receive_id_type: 'open_id',
+          msg_type: 'text',
+          content: JSON.stringify({ text: chunk }),
+        },
+      }).catch((e) => logForDebugging(`[feishu] send error: ${e}`))
+    }
+  }
+
+  /** Called from useFeishuBridge with REPL message state */
+  onMessagesChange(messages: any[], isLoading: boolean): void {
+    // Currently a no-op — responses are handled by the bridge pattern
+    // where messages go through enqueue → REPL → AppState → back to Feishu
+  }
+
+  private async handleInbound(data: any): Promise<void> {
+    // Debug: log what we receive
+    console.log('[feishu] raw inbound:', JSON.stringify(data).slice(0, 500))
+
+    const event = data.event as any
+    const sender = event?.sender as any
+    const message = event?.message as any
+    console.log('[feishu] event:', JSON.stringify(event)?.slice(0,200))
+    console.log('[feishu] sender:', JSON.stringify(sender)?.slice(0,200))
+    console.log('[feishu] message:', JSON.stringify(message)?.slice(0,200))
+
+    const chatId = sender?.sender_id?.open_id
+    const userId = sender?.sender_id?.open_id
+    let text = ''
+    try {
+      if (message.content) {
+        text = JSON.parse(message.content).text?.trim() ?? ''
+      }
+    } catch {}
+
+    if (!text || !chatId || !userId) return
+
+    // Check allowed users
+    if (this.config?.allowedUsers?.length && !this.config.allowedUsers.includes(userId)) {
+      await this.sendText(chatId, '你没有权限使用此飞书机器人。')
+      return
+    }
+
+    logForDebugging(`[feishu] inbound: ${text.slice(0, 50)}`)
+    console.log('[feishu] enqueueing:', text.slice(0, 50))
+
+    // Enqueue to REPL — will be picked up by the command queue
+    const { enqueue } = await import('../../utils/messageQueueManager.js')
+    enqueue({
+      value: text,
+      mode: 'prompt',
+      skipSlashCommands: true,
+      bridgeOrigin: true,
+      origin: { kind: 'channel', server: 'feishu' },
+    })
+    console.log('[feishu] enqueued, queue length now:', (await import('../../utils/messageQueueManager.js')).getCommandQueueSnapshot().length)
+  }
+
+  private setState(next: FeishuServiceState): void {
+    this.state = { ...this.state, ...next }
+    for (const listener of this.listeners) listener()
+  }
+}
+
+export const feishuService = new FeishuService()

src/services/feishu/feishuConfig.ts

@@ -0,0 +1,98 @@
+/**
+ * Feishu Config — read/write ~/.claude/adapters.json feishu section
+ */
+
+import * as fs from 'node:fs'
+import * as path from 'node:path'
+import * as os from 'node:os'
+
+export type PairedUser = {
+  userId: string | number
+  displayName: string
+  pairedAt: number
+}
+
+export type FeishuRuntimeConfig = {
+  appId?: string
+  appSecret?: string
+  encryptKey?: string
+  verificationToken?: string
+  allowedUsers?: string[]
+  pairedUsers?: PairedUser[]
+  streamingCard?: boolean
+}
+
+function getConfigPath(): string {
+  const configDir = process.env.CLAUDE_CONFIG_DIR || path.join(os.homedir(), '.claude')
+  return path.join(configDir, 'adapters.json')
+}
+
+function maskSecret(value: string | undefined): string | undefined {
+  if (!value) return value
+  if (value.length <= 4) return '****'
+  return '****' + value.slice(-4)
+}
+
+export function getFeishuConfig(): FeishuRuntimeConfig {
+  try {
+    const raw = fs.readFileSync(getConfigPath(), 'utf-8')
+    const config = JSON.parse(raw) as { feishu?: FeishuRuntimeConfig }
+    return config.feishu ?? {}
+  } catch {
+    return {}
+  }
+}
+
+export function saveFeishuConfig(patch: Partial<FeishuRuntimeConfig>): void {
+  const filePath = getConfigPath()
+  const dir = path.dirname(filePath)
+  fs.mkdirSync(dir, { recursive: true, mode: 0o700 })
+
+  let existing: Record<string, unknown> = {}
+  try {
+    const raw = fs.readFileSync(filePath, 'utf-8')
+    existing = JSON.parse(raw)
+  } catch {
+    // File doesn't exist yet
+  }
+
+  const current = ((existing.feishu as Record<string, unknown> | undefined) ?? {}) as Record<string, unknown>
+  // Don't overwrite masked secrets (frontend sends back masked values for unchanged fields)
+  const merged: Record<string, unknown> = { ...current, ...patch }
+  for (const key of Object.keys(merged)) {
+    const val = merged[key]
+    if (typeof val === 'string' && val.startsWith('****')) {
+      merged[key] = current[key]
+    }
+  }
+
+  const finalConfig = { ...existing, feishu: merged }
+  fs.writeFileSync(filePath, JSON.stringify(finalConfig, null, 2) + '\n', { mode: 0o600 })
+}
+
+export function clearFeishuConfig(): void {
+  try {
+    const filePath = getConfigPath()
+    const raw = fs.readFileSync(filePath, 'utf-8')
+    const config = JSON.parse(raw) as Record<string, unknown>
+    delete config.feishu
+    fs.writeFileSync(filePath, JSON.stringify(config, null, 2) + '\n', { mode: 0o600 })
+  } catch {
+    // ignore
+  }
+}
+
+export function maskFeishuAppId(appId?: string): string {
+  if (!appId) return '未配置'
+  if (appId.length <= 6) return '****'
+  return appId.slice(0, 3) + '****' + appId.slice(-3)
+}
+
+export function maskFeishuAppSecret(secret?: string): string {
+  return maskSecret(secret) ?? '未配置'
+}
+
+export function isFeishuConfigured(): boolean {
+  const config = getFeishuConfig()
+  return Boolean(config.appId && config.appSecret)
+}

test_feishu_ws.ts

@@ -0,0 +1,44 @@
+import * as Lark from '@larksuiteoapi/node-sdk'
+
+const appId = 'cli_aaa6659174b85bec'
+const appSecret = 'nMV7WvGm9Pbvtf0PA3RVLbqNujzeqP7I'
+
+const client = new Lark.Client({
+  appId,
+  appSecret,
+  appType: Lark.AppType.SelfBuild,
+  domain: Lark.Domain.Feishu,
+})
+
+// Test bot info
+try {
+  const info = await client.request({
+    method: 'GET',
+    url: '/open-apis/bot/v3/info',
+  })
+  console.log('Bot info:', JSON.stringify(info, null, 2))
+} catch (e) {
+  console.error('Bot info failed:', e)
+}
+
+// Test WSClient
+const dispatcher = new Lark.EventDispatcher({})
+
+dispatcher.register({
+  'im.message.receive_v1': async (data: any) => {
+    console.log('Received message:', JSON.stringify(data, null, 2))
+  },
+} as any)
+
+const ws = new Lark.WSClient({
+  appId,
+  appSecret,
+  domain: Lark.Domain.Feishu,
+  loggerLevel: Lark.LoggerLevel.debug,
+})
+
+await ws.start({ eventDispatcher: dispatcher })
+console.log('[WS] started, waiting 10s...')
+await new Promise(r => setTimeout(r, 10000))
+console.log('[WS] done')
+ws.stop?.()