opencrabs 0.3.75

The autonomous, self-improving AI agent. Single Rust binary. Every channel. Install with: cargo install opencrabs
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
45
46
47

//! Background-task resume producer for Discord (#731).
//!
//! Mirrors Telegram's `build_enqueue_callback`: when a detached long command
//! finishes, resume the originating session and deliver the result to its
//! Discord channel. Discord has no streaming resume pipeline, so this sends the
//! completed turn's final text (like the crash-recovery path in `cli/ui.rs`).

use super::DiscordState;
use crate::brain::agent::service::MessageEnqueueCallback;
use crate::channels::bg_resume::{self, AgentHolder};
use std::sync::Arc;

pub(crate) fn build_enqueue_callback(
    state: Arc<DiscordState>,
    agent_holder: AgentHolder,
) -> MessageEnqueueCallback {
    Arc::new(move |session_id, msg| {
        let state = state.clone();
        let agent_holder = agent_holder.clone();
        tokio::spawn(async move {
            let Some(channel_id) = state.session_channel(session_id).await else {
                tracing::warn!(
                    "[bg-resume] discord: no channel for session {session_id}; dropping"
                );
                return;
            };
            let Some(http) = state.http().await else {
                tracing::warn!("[bg-resume] discord: http not available; dropping resume");
                return;
            };
            let Some(agent) = bg_resume::upgrade(&agent_holder) else {
                tracing::warn!("[bg-resume] discord: agent gone; dropping resume");
                return;
            };
            let target = channel_id.to_string();
            if let Some(content) =
                bg_resume::run_resume_turn(agent, session_id, msg.context_text, "discord", &target)
                    .await
            {
                let ch = serenity::model::id::ChannelId::new(channel_id);
                if let Err(e) = ch.say(&http, &content).await {
                    tracing::warn!("[bg-resume] discord: say failed: {e}");
                }
            }
        });
    })
}