Openclaw lark stream plus

Skill sadjjk/public-agent-skills-plugins/skills/openclaw-lark-stream-plus

公开的 AI Agent Skills 合集

Install

npx -y skills add sadjjk/public-agent-skills-plugins --skill openclaw-lark-stream-plus

Assembled from the repository path, not quoted from the project. Check it against their README if it does not work.

One thing to look at

3 stars3 stars. Stars are a popularity signal and not a quality one, but at this level it is likely that nobody has read this closely except its author, and you would be relying on your own review.

What its author says it does

Copied from the file, not written here

OpenClaw 飞书/Lark 插件流式增强配置。触发词：开启/关闭飞书流式输出、开启/关闭飞书流式跨插件通信

SKILL.md

11.1 KB, as published. Nobody here has run it

OpenClaw Lark/Feishu 插件流式增强配置

功能 1：安装飞书插件

其他功能的前置依赖。未安装时，开启流式输出或跨插件通信会回退引导至此功能。

# 动态检测
OC_LARK_INSTALLED=$(openclaw plugins list 2>/dev/null | grep "openclaw-lark" | grep -c "enabled")

已安装

提示"飞书插件已安装"，无需操作。

未安装

建议用户参考文档：https://bytedance.larkoffice.com/docx/MFK7dDFLFoVlOGxWCv5cTXKmnMh 并自行使用以下命令安装

npx -y @larksuite/openclaw-lark install

功能 2：流式输出

包含单聊流式 + 群聊流式。支持开启和关闭。

# 动态检测
OC_LARK_DIR=$(eval echo "$(openclaw plugins inspect openclaw-lark 2>/dev/null | grep 'Install path:' | sed 's/Install path: *//')")
OC_LARK_STREAMING=$(grep -c "OC_LARK_PLUS:STREAMING:START" "$OC_LARK_DIR/src/card/reply-mode.js" 2>/dev/null)

开启

已开启（OC_LARK_STREAMING=1）→ 提示"流式输出已开启，无需重复操作"
未开启 → 检测 OC_LARK_INSTALLED，未安装则引导先执行功能 1
解析 OC_LARK_DIR 为实际路径，风险提示中的 $OC_LARK_DIR 替换为实际值展示
提示风险，用户确认后再执行：

⚠️ 风险提示

群聊流式更新频率可能触发飞书 API 限流

多人同时对话时卡片更新可能互相干扰

将执行以下修改：

openclaw config set channels.feishu.streaming true（单聊流式配置）

修改 {OC_LARK_DIR实际路径}/src/card/reply-mode.js 的 expandAutoMode 函数：

原始：return streaming === true ? (chatType === 'group' ? 'static' : 'streaming') : 'static';

改为：return streaming === true ? 'streaming' : 'static';（用 OC_LARK_PLUS:STREAMING 标记包裹）

openclaw gateway restart

确认开启？

用户确认后执行：

单聊流式：

openclaw config set channels.feishu.streaming true

群聊流式（修改源码 + 标记包裹）：

文件：$OC_LARK_DIR/src/card/reply-mode.js

定位 expandAutoMode 函数，找到：

return streaming === true ? (chatType === 'group' ? 'static' : 'streaming') : 'static';

替换为：

// <!-- OC_LARK_PLUS:STREAMING:START -->
// ⚠️ 原始逻辑 group → static（硬编码降级），现已改为 group 也走 streaming。
return streaming === true ? 'streaming' : 'static';
// <!-- OC_LARK_PLUS:STREAMING:END -->

重启生效：

openclaw gateway restart

关闭

已关闭（OC_LARK_STREAMING=0）→ 提示"流式输出已关闭，无需重复操作"
已开启 → 解析 OC_LARK_DIR 为实际路径，风险提示中的 $OC_LARK_DIR 替换为实际值展示
提示影响，用户确认后再执行：

⚠️ 风险提示

将恢复群聊为 static 模式（非流式）

单聊流式配置也将关闭

将执行以下修改：

删除 {OC_LARK_DIR实际路径}/src/card/reply-mode.js 中 OC_LARK_PLUS:STREAMING:START/END 之间的内容，恢复原始代码：

恢复为：return streaming === true ? (chatType === 'group' ? 'static' : 'streaming') : 'static';

openclaw config set channels.feishu.streaming false

openclaw gateway restart

确认关闭？

用户确认后执行：

删除 $OC_LARK_DIR/src/card/reply-mode.js 中 OC_LARK_PLUS:STREAMING:START 与 OC_LARK_PLUS:STREAMING:END 之间的内容，恢复原始代码：
```
return streaming === true ? (chatType === 'group' ? 'static' : 'streaming') : 'static';
```

关闭单聊流式配置：

openclaw config set channels.feishu.streaming false

重启：
```
openclaw gateway restart
```

功能 3：流式跨插件通信

飞书流式卡片在 finalize 前会读取 global.__ocCardAppend 中对应 session 的文本，追加到卡片内容中。其他插件只需往这个 Map 写入数据，即可将自定义内容注入飞书卡片。

支持开启和关闭。

# 动态检测
OC_LARK_DIR=$(eval echo "$(openclaw plugins inspect openclaw-lark 2>/dev/null | grep 'Install path:' | sed 's/Install path: *//')")
OC_LARK_CROSS_PLUGIN=$(grep -c "OC_LARK_PLUS:CROSS_PLUGIN:START" "$OC_LARK_DIR/src/card/streaming-card-controller.js" 2>/dev/null)

开启

已开启（OC_LARK_CROSS_PLUGIN=1）→ 提示"跨插件通信已开启，无需重复操作"
未开启 → 检测 OC_LARK_INSTALLED，未安装则引导先执行功能 1
解析 OC_LARK_DIR 为实际路径，风险提示中的 $OC_LARK_DIR 替换为实际值展示
提示说明，用户确认后再执行：

⚠️ 风险提示

其他插件可通过 global.__ocCardAppend 注入内容到飞书流式卡片终态

注入内容会追加到卡片 displayText 末尾，以 --- 分隔

将执行以下修改：

修改 {OC_LARK_DIR实际路径}/src/card/streaming-card-controller.js，在 onIdle 方法中：

将 const displayText 改为 let displayText

在 if (!this.text.completedText && !this.text.accumulatedText) { ... } 块之后、const resolvedDisplayText = ... 行之前，插入跨插件通信代码（用 OC_LARK_PLUS:CROSS_PLUGIN 标记包裹）

openclaw gateway restart

其他插件使用方式： 推荐使用 appendToMessage 已封装的函数（飞书渠道自动追加到卡片，其他渠道写入 msg.content）。

确认开启？

用户确认后执行：

文件：$OC_LARK_DIR/src/card/streaming-card-controller.js

在 onIdle 方法中执行以下 三步修改（按顺序）：

步骤 1：将 const displayText 改为 let displayText（跨插件代码需要 += 修改此变量）

定位：

const displayText = this.text.completedText || (isNoReplyLeak ? '' : this.text.accumulatedText) || reply_dispatcher_types_1.EMPTY_REPLY_FALLBACK_TEXT;

替换为：

let displayText = this.text.completedText || (isNoReplyLeak ? '' : this.text.accumulatedText) || reply_dispatcher_types_1.EMPTY_REPLY_FALLBACK_TEXT;

步骤 2：在 if (!this.text.completedText && !this.text.accumulatedText) { ... } 块之后、const resolvedDisplayText = await this.imageResolver.resolveImagesAwait(displayText, ...) 行之前，插入跨插件通信代码块（用标记包裹）

插入位置的特征锚点：

上方紧邻：} （if 块的闭合花括号）
下方紧邻：const resolvedDisplayText = await this.imageResolver.resolveImagesAwait(displayText, 15_000);

⚠️ 关键：插入的代码是独立语句，必须位于两个完整语句之间，绝不能嵌在任何变量赋值表达式中间

插入内容：

                // <!-- OC_LARK_PLUS:CROSS_PLUGIN:START -->
                // ── 跨插件通信：读取其他插件通过 global.__ocCardAppend 注入的文本 ──
                let _appendText = global.__ocCardAppend?.get?.(this.deps.sessionKey);
                if (!_appendText) {
                    if (!global.__ocCardAppendReady) global.__ocCardAppendReady = new Map();
                    let resolveReady;
                    const readyPromise = new Promise(r => { resolveReady = r; });
                    global.__ocCardAppendReady.set(this.deps.sessionKey, resolveReady);
                    const pollPromise = (async () => {
                        for (let i = 0; i < 50; i++) {
                            await new Promise(r => setTimeout(r, 100));
                            const v = global.__ocCardAppend?.get?.(this.deps.sessionKey);
                            if (v) return v;
                        }
                        return undefined;
                    })();
                    const raceResult = await Promise.race([
                        readyPromise.then(t => t ? "\n\n---\n\n" + t : undefined),
                        pollPromise,
                        new Promise(r => setTimeout(() => r(undefined), 5000))
                    ]);
                    _appendText = raceResult;
                    global.__ocCardAppendReady.delete(this.deps.sessionKey);
                }
                if (_appendText) {
                    displayText += _appendText;
                    global.__ocCardAppend.delete(this.deps.sessionKey);
                }
                // <!-- OC_LARK_PLUS:CROSS_PLUGIN:END -->

步骤 3：确认 const resolvedDisplayText = await this.imageResolver.resolveImagesAwait(displayText, 15_000); 保持不变（此行在步骤 2 插入的代码之后，此时 displayText 已包含跨插件追加内容）

重启生效：

openclaw gateway restart

appendToMessage 源码参考

function appendToMessage(msg, text, sk) {
  const suffix = "\n\n---\n\n" + text;
  const isFeishuChannel = sk?.includes("feishu");
  if (isFeishuChannel) {
    if (!global.__ocCardAppend) global.__ocCardAppend = new Map();
    const existing = global.__ocCardAppend.get(sk) || "";
    global.__ocCardAppend.set(sk, existing + suffix);
    if (!global.__ocCardAppendReady) global.__ocCardAppendReady = new Map();
    const ready = global.__ocCardAppendReady.get(sk);
    if (ready) ready(text);
    return;
  }
  if (typeof msg.content === "string") {
    msg.content += suffix;
  } else if (Array.isArray(msg.content)) {
    const last = msg.content[msg.content.length - 1];
    if (last?.type === "text" && typeof last.text === "string") {
      last.text += suffix;
    } else {
      msg.content.push({ type: "text", text: suffix });
    }
  }
}

关闭

已关闭（OC_LARK_CROSS_PLUGIN=0）→ 提示"跨插件通信已关闭，无需重复操作"
已开启 → 解析 OC_LARK_DIR 为实际路径，风险提示中的 $OC_LARK_DIR 替换为实际值展示
提示影响，用户确认后再执行：

⚠️ 风险提示

飞书卡片将不再读取其他插件注入的内容

将执行以下修改：

删除 {OC_LARK_DIR实际路径}/src/card/streaming-card-controller.js 中 OC_LARK_PLUS:CROSS_PLUGIN:START/END 之间的代码

将 let displayText 恢复为 const displayText

恢复 onIdle 方法中 if (!this.text.completedText && !this.text.accumulatedText) { ... } 块之后直接跟 const resolvedDisplayText = await this.imageResolver.resolveImagesAwait(displayText, ...) 的原始流程

openclaw gateway restart

确认关闭？

用户确认后执行：

删除 $OC_LARK_DIR/src/card/streaming-card-controller.js 中 OC_LARK_PLUS:CROSS_PLUGIN:START 与 OC_LARK_PLUS:CROSS_PLUGIN:END 之间的代码
将 let displayText = ... 恢复为 const displayText = ...（跨插件代码移除后变量不再被修改）
确认 const resolvedDisplayText = await this.imageResolver.resolveImagesAwait(displayText, 15_000); 紧邻 if (!this.text.completedText && !this.text.accumulatedText) { ... } 块之后，中间无多余空行
重启：
```
openclaw gateway restart
```

One thing to look at

What its author says it does

SKILL.md

OpenClaw Lark/Feishu 插件流式增强配置

功能 1：安装飞书插件

已安装

未安装

功能 2：流式输出

开启

关闭

功能 3：流式跨插件通信

开启

appendToMessage 源码参考

关闭

Keep looking