channels: migrate providers to tinychannels + generic ChannelHost boundary (whatsapp_web, telegram)

Cargo.toml

@@ -246,16 +246,10 @@ coins-bip39 = "0.8"
 curve25519-dalek = { version = "4", default-features = false, features = ["alloc"] }
 
 fantoccini = { version = "0.22.0", optional = true, default-features = false, features = ["rustls-tls"] }
-serde-big-array = { version = "0.5", optional = true }
 pdf-extract = "0.10"
-# WhatsApp Web — upstream `whatsapp-rust` 0.5. Its Diesel-backed sqlite-storage
-# feature links sqlite3 separately from rusqlite 0.40, so the TinyAgents 1.5
-# baseline compiles this provider against wacore's in-memory Backend until a
-# rusqlite-backed durable store lands.
-whatsapp-rust = { version = "0.5", optional = true, default-features = false, features = ["tokio-runtime"] }
-whatsapp-rust-tokio-transport = { version = "0.5", optional = true, default-features = false }
-whatsapp-rust-ureq-http-client = { version = "0.5", optional = true }
-wacore = { version = "0.5", optional = true, default-features = false }
+# The WhatsApp Web provider (and its `whatsapp-rust` / `wacore` / `serde-big-array`
+# stack) now lives in the tinychannels crate; the `whatsapp-web` feature forwards
+# to `tinychannels/whatsapp-web`.
 ppt-rs = "0.2.14"
 
 [target.'cfg(windows)'.dependencies]
@@ -335,7 +329,8 @@ peripheral-rpi = ["dep:rppal"]
 browser-native = ["dep:fantoccini"]
 fantoccini = ["browser-native"]
 landlock = ["sandbox-landlock"]
-whatsapp-web = ["dep:whatsapp-rust", "dep:whatsapp-rust-tokio-transport", "dep:whatsapp-rust-ureq-http-client", "dep:wacore", "serde-big-array"]
+# The WhatsApp Web provider now lives in tinychannels; forward to its feature.
+whatsapp-web = ["tinychannels/whatsapp-web"]
 # Exposes the destructive `openhuman.test_reset` RPC. Off by default; the E2E
 # build (app/scripts/e2e-build.sh) flips it on. Shipped binaries never have
 # this feature so the wipe RPC isn't even registered, let alone reachable.

src/openhuman/agent/task_dispatcher/executor.rs

@@ -227,7 +227,7 @@ pub(super) async fn run_autonomous(
     if let Some(thread_id) = session_thread_id.as_deref() {
         match &result {
             Ok(response) => {
-                crate::openhuman::channels::providers::presentation::deliver_response(
+                crate::openhuman::channels::providers::web::presentation::deliver_response(
                     "system",
                     thread_id,
                     run_id,

src/openhuman/channels/commands.rs

@@ -64,13 +64,14 @@ pub async fn doctor_channels(config: Config) -> Result<()> {
     if let Some(ref dc) = config.channels_config.discord {
         channels.push((
             "Discord",
-            Arc::new(DiscordChannel::new(
+            Arc::new(DiscordChannel::with_http_client(
                 dc.bot_token.clone(),
                 dc.guild_id.clone(),
                 dc.channel_id.clone(),
                 dc.allowed_users.clone(),
                 dc.listen_to_bots,
                 dc.mention_only,
+                crate::openhuman::config::build_runtime_proxy_client("channel.discord"),
             )),
         ));
     }
@@ -209,21 +210,23 @@ pub async fn doctor_channels(config: Config) -> Result<()> {
     if let Some(ref dt) = config.channels_config.dingtalk {
         channels.push((
             "DingTalk",
-            Arc::new(DingTalkChannel::new(
+            Arc::new(DingTalkChannel::with_http_client(
                 dt.client_id.clone(),
                 dt.client_secret.clone(),
                 dt.allowed_users.clone(),
+                crate::openhuman::config::build_runtime_proxy_client("channel.dingtalk"),
             )),
         ));
     }
 
     if let Some(ref qq) = config.channels_config.qq {
         channels.push((
             "QQ",
-            Arc::new(QQChannel::new(
+            Arc::new(QQChannel::with_http_client(
                 qq.app_id.clone(),
                 qq.app_secret.clone(),
                 qq.allowed_users.clone(),
+                crate::openhuman::config::build_runtime_proxy_client("channel.qq"),
             )),
         ));
     }