rsclaw-watch 0.1.0

Watch crate for RsClaw — internal workspace crate, not for direct use
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

//! Chat delivery wrapper.

use std::sync::Arc;

use anyhow::{Result, anyhow};

use rsclaw_channel::{ChannelManager, OutboundMessage};

/// Push `body` to (channel, account, peer) using the same ChannelManager
/// that /loop / cron use.
///
/// When `account` is `Some`, we first try the account-keyed channel name
/// (`feishu/main`, `wechat/biz1`, …) so multi-account chat channels route
/// the delivery through the SAME app that received the originating
/// `/watch` command — open IDs are per-app in feishu, so cross-app sends
/// fail with 99992361 "open_id cross app". If the account-keyed channel
/// isn't registered we fall back to the bare name.
///
/// Re-maps the legacy `ws` channel name to `desktop` (same hack as cron's
/// send_delivery at src/cron/mod.rs:1884).
pub async fn deliver(
    channels: &Arc<ChannelManager>,
    channel: &str,
    account: Option<&str>,
    peer: &str,
    body: String,
) -> Result<()> {
    let resolved = if channel == "ws" { "desktop" } else { channel };
    let ch = match account {
        Some(acct) => {
            let keyed = format!("{resolved}/{acct}");
            channels.get(&keyed).or_else(|| channels.get(resolved))
        }
        None => channels.get(resolved),
    };
    let ch = ch.ok_or_else(|| anyhow!("watch: channel `{channel}` not registered"))?;
    let msg = OutboundMessage {
        target_id: peer.to_owned(),
        text: body,
        account: account.map(str::to_owned),
        ..Default::default()
    };
    ch.send(msg).await
}