opencrabs 0.5.1

The autonomous, self-improving AI agent. Single Rust binary. Every channel. Recommended: the 40MB prebuilt binary for macOS, Linux and Windows: https://github.com/adolfousier/opencrabs/releases
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

//! Session to channel-id map so approvals and resumed background results
//! route back to the channel the session was last handled in.

use uuid::Uuid;

use super::DiscordState;

impl DiscordState {
    /// Record which channel_id corresponds to a given session.
    pub async fn register_session_channel(&self, session_id: Uuid, channel_id: u64) {
        self.session_channels
            .lock()
            .await
            .insert(session_id, channel_id);
        // Reverse ownership map (#148): written beside the forward map so the
        // two cannot drift. Last writer wins — a channel re-registers to its
        // newest owning session.
        self.channel_sessions
            .lock()
            .await
            .insert(channel_id, session_id);
    }

    /// Look up the channel_id for a session.
    pub async fn session_channel(&self, session_id: Uuid) -> Option<u64> {
        self.session_channels.lock().await.get(&session_id).copied()
    }

    /// Reverse lookup (#148): the session currently bound to a Discord channel
    /// id, for `oc://discord/<id>` resolution. Reads the reverse map kept in
    /// lockstep with the forward map at `register_session_channel`.
    pub async fn session_owner_by_channel(&self, channel_id: u64) -> Option<Uuid> {
        self.channel_sessions.lock().await.get(&channel_id).copied()
    }
}