Class FeishuAdapter

src/runtime/adapters/feishu.ts:116–555

  return resource.type === "image" || resource.type === "file";
}

export class FeishuAdapter implements PlatformAdapter, MessageSender {
  readonly name = "feishu";

  private channel: ResilientLarkChannel | null = null;
  private agent: IPackAgent | null = null;
  private ipcBroadcaster: IpcBroadcaster | null = null;
  private rootDir = process.cwd();
  private readonly options: FeishuAdapterOptions;

  constructor(options: FeishuAdapterOptions) {
    this.options = options;
  }

  async start(ctx: AdapterContext): Promise<void> {
    this.agent = ctx.agent;
    this.ipcBroadcaster = ctx.ipcBroadcaster ?? null;
    this.rootDir = ctx.rootDir;
    const domain = normalizeFeishuDomain(this.options.domain);

    this.channel = createResilientLarkChannel({
      appId: this.options.appId,
      appSecret: this.options.appSecret,
      domain: resolveFeishuSdkDomain(domain),
      loggerLevel: Lark.LoggerLevel.info,
      transport: "websocket",
      source: "skillpack",
      policy: {
        dmMode: "open",
        requireMention: false,
      },
    });

    this.channel.on("message", (message) => {
      void this.handleIncomingMessage(message).catch((error) => {
        console.error("[Feishu] Error handling message:", error);
      });
    });

    this.channel.on("error", (error) => {
      console.error("[Feishu] Channel error:", error);
    });

    this.channel.on("reconnecting", () => {
      console.warn("[Feishu] Channel reconnecting");
    });

    this.channel.on("reconnected", () => {
      console.log("[Feishu] Channel reconnected");
    });

    await this.channel.connect();
    const botName = this.channel.botIdentity?.name;
    console.log(
      botName
        ? `[FeishuAdapter] Started as ${botName} (domain=${domain})`
        : `[FeishuAdapter] Started (domain=${domain})`,
    );