openclaw-glance

智能盯盘：OpenClaw 插件连接 openclaw-bridge。

安装与接入文档：

• OpenClaw 插件模式：docs/openclaw-install-guide.md

插件定位

本项目当前以 OpenClaw 插件模式运行（index.js + openclaw.plugin.json），保持长连接并接收 watch.triggered，并对同一 baseWsUrl + token 启用严格单活锁，防止重复实例。

OpenClaw 调用时机（插件模式）

• 用户新建盯盘：调用 submitWatchDemand 或 createWatch
• 用户修改状态：调用 activate / pause
• 用户删除盯盘：调用 remove
• 需要接收触发消息：由插件后台运行时持续接收
• 需要主动通过邮件、短信、电话发送通知时

功能

• 与 openclaw-bridge 建立 WebSocket 长连接
• 支持请求：watch.create / watch.activate / watch.pause / watch.delete / ticker.query / notify.send / ping
• 支持渠道：openclaw / email / call / sms / dingtalk
  • 建议在 channel_configs.openclaw 中携带路由字段（如 channel、session_key、account_id、conversation_id），便于触发后回推到正确会话
• 订阅推送：watch.triggered
• 主动发起通知结果推送：notify.sent
• 自动重连 + 心跳
• 严格单活（同 token 只允许一个活跃进程）
• 断线请求排队（可配置），重连后自动冲刷
• 提供业务适配层 OpenClawPluginAdapter

安装

npm install

测试

npm test

运行示例

OPENCLAW_WS_TOKEN=your_ws_token \
npm start

运行适配层示例：

npm run start:adapter

SDK 使用

import { OpenClawBridgeClient } from './src/index.js';

const client = new OpenClawBridgeClient({
  baseWsUrl: 'wss://glanceup-pre.100credit.cn',
  token: '<JWT_TOKEN>',
  enqueueIfDisconnected: true
});

client.on('triggered', (msg) => {
  console.log(msg);
});

await client.connect();
const res = await client.createWatch({
  product_code: '00700',
  product_type: 'hk_stock',
  operator_type: 'rule',
  operator_parameters: {
    condition: 'price < threshold',
    variables: { threshold: 420 }
  },
  channels: ['openclaw'],
  channel_configs: { openclaw: {} }
});

适配层用法

import { OpenClawPluginAdapter } from './src/index.js';

const adapter = new OpenClawPluginAdapter({
  baseWsUrl: 'wss://glanceup-pre.100credit.cn',
  token: '<JWT_TOKEN>'
});

await adapter.start();
await adapter.submitWatchDemand({
  productCode: '06608',
  productType: 'hk_stock',
  condition: 'price >= threshold',
  variables: { threshold: 8.97 },
  channels: ['openclaw', 'email', 'call', 'sms', 'dingtalk'], // openclaw 必传，其它可选
  emailConfig: {
    to_address: '[email protected]',
    template_id: 4
  },
  callConfig: {
    phone: '13800138000',
    customer_name: 'Demo'
  },
  smsConfig: {
    receiver: '13800138000',
    template_id: 90010,
    content: '测试短信'
  },
  dingtalkConfig: {
    cas_id: 'user.dingtalk',
    template_id: 3,
    msg_type: 'text',
    content: '测试钉钉消息'
  }
});

插件工具（OpenClaw 调用）

• watch_query_ticker
• watch_create
• watch_list
• watch_pause
• watch_activate
• watch_remove
• notify_sms
• notify_call
• notify_email
• notify_dingtalk

notify_* 工具走 bridge notify.send 直连通知链路，发送完成后客户端会收到 notify.sent 回执事件。

客户端事件

• connected
• disconnected
• reconnecting
• warning
• error
• queued（请求入队）
• queueFlushed（重连后队列发送）
• triggered

说明

• 先获取 ws token，然后连接 wss://<host>:8005/openclaw/ws，并在握手 Header 传 Authorization: Bearer <TOKEN>。
• 发布时将导出 src/ 与 README.md（见 package.json 的 files/exports）。