import * as _$ylib_openclaw_plugin_sdk0 from "ylib-openclaw/plugin-sdk"; import { ChannelMessageActionAdapter, ChannelPlugin, ClawdbotConfig, HistoryEntry, OpenClawConfig, OpenClawPluginApi, PluginRuntime, RuntimeEnv } from "ylib-openclaw/plugin-sdk"; import * as Lark from "@larksuiteoapi/node-sdk"; import { z } from "zod"; //#region src/core/config-schema.d.ts declare const FeishuConfigSchema: z.ZodObject<{ appId: z.ZodOptional; appSecret: z.ZodOptional; encryptKey: z.ZodOptional; verificationToken: z.ZodOptional; name: z.ZodOptional; nickname: z.ZodOptional; enabled: z.ZodOptional; domain: z.ZodOptional, z.ZodLiteral<"lark">, z.ZodString]>>; connectionMode: z.ZodOptional>; webhookPath: z.ZodOptional; webhookPort: z.ZodOptional; dmPolicy: z.ZodDefault>>; allowFrom: z.ZodDefault>>; groupPolicy: z.ZodDefault>>; groupAllowFrom: z.ZodPipe>, z.ZodTransform>; requireMention: z.ZodDefault>; groups: z.ZodOptional>; requireMention: z.ZodOptional; tools: z.ZodOptional>; deny: z.ZodOptional>; }, z.core.$strip>>; skills: z.ZodOptional>; enabled: z.ZodOptional; allowFrom: z.ZodPipe>, z.ZodTransform>; systemPrompt: z.ZodOptional; }, z.core.$strip>>>; historyLimit: z.ZodOptional; dmHistoryLimit: z.ZodOptional; dms: z.ZodOptional; }, z.core.$strip>>; textChunkLimit: z.ZodOptional; chunkMode: z.ZodOptional>; blockStreamingCoalesce: z.ZodOptional; maxChars: z.ZodOptional; idleMs: z.ZodOptional; }, z.core.$strip>>; mediaMaxMb: z.ZodOptional; heartbeat: z.ZodOptional; activeHours: z.ZodOptional; end: z.ZodOptional; timezone: z.ZodOptional; }, z.core.$strip>>; target: z.ZodOptional; to: z.ZodOptional; prompt: z.ZodOptional; accountId: z.ZodOptional; }, z.core.$strip>>; replyMode: z.ZodOptional, z.ZodObject<{ default: z.ZodOptional>; group: z.ZodOptional>; direct: z.ZodOptional>; }, z.core.$strip>]>>; streaming: z.ZodDefault>; blockStreaming: z.ZodOptional; tools: z.ZodOptional; wiki: z.ZodOptional; drive: z.ZodOptional; perm: z.ZodOptional; scopes: z.ZodOptional; }, z.core.$strip>>; footer: z.ZodOptional; elapsed: z.ZodOptional; }, z.core.$strip>>; markdown: z.ZodOptional>; }, z.core.$strip>>; configWrites: z.ZodOptional; capabilities: z.ZodOptional; audio: z.ZodOptional; video: z.ZodOptional; }, z.core.$strip>>; dedup: z.ZodOptional; maxEntries: z.ZodOptional; }, z.core.$strip>>; reactionNotifications: z.ZodOptional>; threadSession: z.ZodOptional; uat: z.ZodOptional; allowedScopes: z.ZodOptional>; blockedScopes: z.ZodOptional>; }, z.core.$strip>>; gatewayBaseUrl: z.ZodOptional; gatewayToken: z.ZodOptional; uploadHost: z.ZodOptional; injectSenderContextToPrompt: z.ZodDefault>; showFinalAnswerOnly: z.ZodDefault>; yuceImageCookieStrictOrigin: z.ZodOptional; modelName: z.ZodOptional; scopeType: z.ZodOptional>; workspaceId: z.ZodOptional; projectId: z.ZodOptional; scope_type: z.ZodOptional>; workspace_id: z.ZodOptional; project_id: z.ZodOptional; separateSessionByConversation: z.ZodDefault>; groupSessionScope: z.ZodDefault>>; accounts: z.ZodOptional; appSecret: z.ZodOptional; encryptKey: z.ZodOptional; verificationToken: z.ZodOptional; name: z.ZodOptional; nickname: z.ZodOptional; enabled: z.ZodOptional; domain: z.ZodOptional, z.ZodLiteral<"lark">, z.ZodString]>>; connectionMode: z.ZodOptional>; webhookPath: z.ZodOptional; webhookPort: z.ZodOptional; dmPolicy: z.ZodDefault>>; allowFrom: z.ZodDefault>>; groupPolicy: z.ZodDefault>>; groupAllowFrom: z.ZodPipe>, z.ZodTransform>; requireMention: z.ZodDefault>; groups: z.ZodOptional>; requireMention: z.ZodOptional; tools: z.ZodOptional>; deny: z.ZodOptional>; }, z.core.$strip>>; skills: z.ZodOptional>; enabled: z.ZodOptional; allowFrom: z.ZodPipe>, z.ZodTransform>; systemPrompt: z.ZodOptional; }, z.core.$strip>>>; historyLimit: z.ZodOptional; dmHistoryLimit: z.ZodOptional; dms: z.ZodOptional; }, z.core.$strip>>; textChunkLimit: z.ZodOptional; chunkMode: z.ZodOptional>; blockStreamingCoalesce: z.ZodOptional; maxChars: z.ZodOptional; idleMs: z.ZodOptional; }, z.core.$strip>>; mediaMaxMb: z.ZodOptional; heartbeat: z.ZodOptional; activeHours: z.ZodOptional; end: z.ZodOptional; timezone: z.ZodOptional; }, z.core.$strip>>; target: z.ZodOptional; to: z.ZodOptional; prompt: z.ZodOptional; accountId: z.ZodOptional; }, z.core.$strip>>; replyMode: z.ZodOptional, z.ZodObject<{ default: z.ZodOptional>; group: z.ZodOptional>; direct: z.ZodOptional>; }, z.core.$strip>]>>; streaming: z.ZodDefault>; blockStreaming: z.ZodOptional; tools: z.ZodOptional; wiki: z.ZodOptional; drive: z.ZodOptional; perm: z.ZodOptional; scopes: z.ZodOptional; }, z.core.$strip>>; footer: z.ZodOptional; elapsed: z.ZodOptional; }, z.core.$strip>>; markdown: z.ZodOptional>; }, z.core.$strip>>; configWrites: z.ZodOptional; capabilities: z.ZodOptional; audio: z.ZodOptional; video: z.ZodOptional; }, z.core.$strip>>; dedup: z.ZodOptional; maxEntries: z.ZodOptional; }, z.core.$strip>>; reactionNotifications: z.ZodOptional>; threadSession: z.ZodOptional; uat: z.ZodOptional; allowedScopes: z.ZodOptional>; blockedScopes: z.ZodOptional>; }, z.core.$strip>>; gatewayBaseUrl: z.ZodOptional; gatewayToken: z.ZodOptional; uploadHost: z.ZodOptional; injectSenderContextToPrompt: z.ZodDefault>; showFinalAnswerOnly: z.ZodDefault>; yuceImageCookieStrictOrigin: z.ZodOptional; modelName: z.ZodOptional; scopeType: z.ZodOptional>; workspaceId: z.ZodOptional; projectId: z.ZodOptional; scope_type: z.ZodOptional>; workspace_id: z.ZodOptional; project_id: z.ZodOptional; separateSessionByConversation: z.ZodDefault>; groupSessionScope: z.ZodDefault>>; }, z.core.$strip>>>; }, z.core.$strip>; //#endregion //#region src/core/types.d.ts /** Fully resolved top-level Feishu channel configuration. */ type FeishuConfig = z.infer; /** * The Lark platform brand. * - `"feishu"` targets the China-mainland Feishu service. * - `"lark"` targets the international Lark service. * - Any other string is treated as a custom base URL. */ type LarkBrand = 'feishu' | 'lark' | (string & {}); /** Common fields shared by all resolved account states. */ interface LarkAccountBase { accountId: string; enabled: boolean; name?: string; encryptKey?: string; verificationToken?: string; brand: LarkBrand; config: FeishuConfig; } /** An account with both `appId` and `appSecret` present. */ type ConfiguredLarkAccount = LarkAccountBase & { configured: true; appId: string; appSecret: string; }; /** An account that is missing `appId` and/or `appSecret`. */ type UnconfiguredLarkAccount = LarkAccountBase & { configured: false; appId?: string; appSecret?: string; }; /** A resolved Lark account — either fully configured or not. */ type LarkAccount = ConfiguredLarkAccount | UnconfiguredLarkAccount; /** Result of probing an app's connectivity / permissions. */ interface FeishuProbeResult { ok: boolean; error?: string; appId?: string; botName?: string; botOpenId?: string; } //#endregion //#region src/messaging/inbound/dedup.d.ts /** * Copyright (c) 2026 ByteDance Ltd. and/or its affiliates * SPDX-License-Identifier: MIT * * FIFO-based message deduplication. * * Feishu WebSocket connections may redeliver messages on reconnect. * This module tracks recently-seen message IDs and filters duplicates. * * Design choices: * - FIFO eviction (not LRU) — message IDs are write-once/check-once, * no hot/cold access pattern. FIFO naturally expires the oldest entry * first, which matches the dedup semantics. * - ES2015 `Map` preserves insertion order, giving us FIFO for free. * - Periodic sweep leverages FIFO ordering: iterate from oldest and * `break` at the first non-expired entry → O(expired), not O(n). */ interface MessageDedupOpts { /** Time-to-live for each entry in milliseconds (default: 5 min). */ ttlMs?: number; /** Maximum number of tracked entries (default: 10 000). */ maxEntries?: number; } /** * Check whether a message is too old to process. * * Feishu message `create_time` is a millisecond Unix timestamp encoded * as a string. When a WebSocket reconnects after a long outage, stale * messages may be redelivered — this function lets callers discard them * before entering the full handling pipeline. */ declare function isMessageExpired(createTimeStr: string | undefined, expiryMs?: number): boolean; declare class MessageDedup { private readonly store; private readonly ttlMs; private readonly maxEntries; private readonly sweepTimer; constructor(opts?: MessageDedupOpts); /** * Try to record a message ID. * * @param id Unique message identifier (e.g. Feishu `message_id`). * @param scope Optional scope prefix (e.g. accountId) to namespace IDs. * @returns `true` if the message is **new**; `false` if it is a duplicate. */ tryRecord(id: string, scope?: string): boolean; /** Current number of tracked entries (for diagnostics). */ get size(): number; /** Remove all entries and stop the periodic sweep. */ clear(): void; /** Stop the periodic sweep timer and clear all tracked entries. */ dispose(): void; /** * Sweep expired entries from the front of the map. * Because entries are in insertion order (FIFO), we can stop as soon as * we hit one that hasn't expired yet. */ private sweep; } //#endregion //#region src/core/lark-client.d.ts /** Credential set accepted by the ephemeral `fromCredentials` factory. */ interface LarkClientCredentials { accountId?: string; appId?: string; appSecret?: string; brand?: LarkBrand; } declare class LarkClient { readonly account: LarkAccount; private _sdk; private _wsClient; private _botOpenId; private _botName; private _lastProbeResult; private _lastProbeAt; private _runtimeStatusKeepaliveTimer; /** Attached message deduplicator — disposed together with the client. */ messageDedup: MessageDedup | null; private static _runtime; /** Persist the runtime instance for later retrieval (activate 阶段调用一次). */ static setRuntime(runtime: PluginRuntime): void; /** Retrieve the stored runtime instance. Throws if not yet initialised. */ static get runtime(): PluginRuntime; private static _globalConfig; /** Store the original global config (called during monitor startup). */ static setGlobalConfig(cfg: ClawdbotConfig): void; /** Retrieve the stored global config, or `null` if not yet set. */ static get globalConfig(): ClawdbotConfig | null; private constructor(); /** Shorthand for `this.account.accountId`. */ get accountId(): string; /** Resolve account from config and return a cached `LarkClient`. */ static fromCfg(cfg: ClawdbotConfig, accountId?: string): LarkClient; /** * Get (or create) a cached `LarkClient` for the given account. * If the cached instance has stale credentials it is replaced. */ static fromAccount(account: LarkAccount): LarkClient; /** * Create an ephemeral `LarkClient` from bare credentials. * The instance is **not** added to the global cache — suitable for * one-off probe / diagnose calls that should not pollute account state. */ static fromCredentials(credentials: LarkClientCredentials): LarkClient; /** Look up a cached instance by accountId. */ static get(accountId: string): LarkClient | null; /** * Dispose one or all cached instances. * With `accountId` — dispose that single instance. * Without — dispose every cached instance and clear the cache. */ static clearCache(accountId?: string): void; /** Lazily-created Lark SDK client. */ get sdk(): Lark.Client; /** * Probe bot identity via the `bot/v3/info` API. * Results are cached on the instance for subsequent access via * `botOpenId` / `botName`. */ probe(opts?: { maxAgeMs?: number; }): Promise; /** Cached bot open_id (available after `probe()` or `startWS()`). */ get botOpenId(): string | undefined; /** Cached bot name (available after `probe()` or `startWS()`). */ get botName(): string | undefined; private clearRuntimeStatusKeepaliveTimer; private startRuntimeStatusKeepaliveTimer; /** * Start WebSocket event monitoring. * * Flow: probe bot identity → EventDispatcher → WSClient → start. * The returned Promise resolves when `abortSignal` fires. */ startWS(opts: { handlers: Record Promise>; abortSignal?: AbortSignal; autoProbe?: boolean; }): Promise; /** Whether a WebSocket client is currently active. */ get wsConnected(): boolean; /** Disconnect WebSocket but keep instance in cache. */ disconnect(): void; /** Disconnect + remove from cache. */ dispose(): void; /** Assert credentials exist or throw. */ private requireCredentials; /** * Start the WSClient and return a promise that resolves when the * abort signal fires (or immediately if already aborted). */ private waitForAbort; } //#endregion //#region src/channel/types.d.ts interface MonitorFeishuOpts { config?: ClawdbotConfig; runtime?: RuntimeEnv; abortSignal?: AbortSignal; accountId?: string; } //#endregion //#region src/channel/monitor.d.ts /** * Start monitoring for all enabled Feishu accounts (or a single * account when `opts.accountId` is specified). */ declare function monitorFeishuProvider(opts?: MonitorFeishuOpts): Promise; //#endregion //#region src/messaging/types.d.ts /** * Copyright (c) 2026 ByteDance Ltd. and/or its affiliates * SPDX-License-Identifier: MIT * * Messaging type definitions for the Lark/Feishu channel plugin. * * Pure shape types for inbound message events, normalised message context, * mention targets, and media metadata. */ interface FeishuMessageEvent { sender: { sender_id: { open_id?: string; user_id?: string; union_id?: string; }; sender_type?: string; tenant_key?: string; }; message: { message_id: string; root_id?: string; parent_id?: string; create_time?: string; update_time?: string; chat_id: string; thread_id?: string; chat_type: 'p2p' | 'group'; message_type: string; content: string; mentions?: Array<{ key: string; id: { open_id?: string; user_id?: string; union_id?: string; }; name: string; tenant_key?: string; }>; user_agent?: string; }; } interface FeishuReactionCreatedEvent { message_id: string; chat_id?: string; chat_type?: 'p2p' | 'group' | 'private'; reaction_type?: { emoji_type?: string; }; operator_type?: string; user_id?: { open_id?: string; user_id?: string; union_id?: string; }; action_time?: string; } /** Metadata describing a media resource in a message (no binary data). */ interface ResourceDescriptor { type: 'image' | 'file' | 'audio' | 'video' | 'sticker'; /** image_key or file_key from the raw message content. */ fileKey: string; /** Original file name (file/video messages). */ fileName?: string; /** Duration in milliseconds (audio/video messages). */ duration?: number; /** Video cover image key. */ coverImageKey?: string; } /** Structured @mention information from a message. */ interface MentionInfo { /** Placeholder key in raw content (e.g. "@_user_1"). */ key: string; /** Feishu Open ID of the mentioned user. */ openId: string; /** Display name. */ name: string; /** Whether this mention targets the bot itself. */ isBot: boolean; } /** Raw message body, directly mapped from FeishuMessageEvent.message. */ interface RawMessage { message_id: string; root_id?: string; parent_id?: string; create_time?: string; update_time?: string; chat_id: string; thread_id?: string; chat_type: 'p2p' | 'group'; message_type: string; content: string; mentions?: Array<{ key: string; id: { open_id?: string; user_id?: string; union_id?: string; }; name: string; tenant_key?: string; }>; user_agent?: string; } /** Raw sender data, directly mapped from FeishuMessageEvent.sender. */ interface RawSender { sender_id: { open_id?: string; user_id?: string; union_id?: string; }; sender_type?: string; tenant_key?: string; } /** Normalised representation of an inbound Feishu message. */ interface MessageContext { chatId: string; messageId: string; senderId: string; senderName?: string; chatType: 'p2p' | 'group'; content: string; contentType: string; /** Media resource descriptors extracted during parsing. */ resources: ResourceDescriptor[]; /** All @mentions in the message (including bot). */ mentions: MentionInfo[]; rootId?: string; parentId?: string; threadId?: string; createTime?: number; rawMessage: RawMessage; rawSender: RawSender; } /** @deprecated Use {@link MessageContext} instead. */ type FeishuMessageContext = MessageContext; /** Metadata about a media attachment received in or sent through Feishu. */ interface FeishuMediaInfo { path: string; contentType?: string; placeholder: string; /** Original Feishu file_key / image_key that was downloaded. */ fileKey: string; /** Best-effort original file name from upstream metadata. */ fileName?: string; /** Resource type from the original descriptor. */ resourceType: ResourceDescriptor['type']; } /** Result of sending a message via the Feishu API. */ interface FeishuSendResult { messageId: string; chatId: string; /** * Human-readable warning when the send succeeded but with degradation * (e.g. media upload failed, fell back to a text link). * * Populated so upstream callers (and the AI) can detect that the * delivery was not fully as intended and take corrective action. */ warning?: string; } //#endregion //#region src/messaging/shared/value-format.d.ts declare function toDisplayText(value: unknown, seen?: WeakSet