codetether-agent 4.7.0-a-002.4

A2A-native AI coding agent for the CodeTether ecosystem
Documentation 
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

//! Background RLM worker jobs.

use std::sync::Arc;

use crate::provider::Provider;
use crate::rlm::RlmConfig;

use super::{cache, render, status, summary};

pub(super) struct Job {
    pub key: u64,
    pub content: String,
    pub tool: String,
    pub input: serde_json::Value,
    pub session_id: String,
    pub model: String,
    pub provider: Arc<dyn Provider>,
    pub config: RlmConfig,
    pub reason: String,
    pub original_bytes: usize,
    pub notify: Option<status::Notify>,
}

pub(super) async fn run(job: Job) {
    status::progress(&job.notify, "background started", 1, 1);
    tracing::info!(tool = %job.tool, bytes = job.original_bytes, "RLM background summary started");
    match summary::summarize(&job).await {
        Ok(body) => {
            let summary = render::summary(&job.tool, job.original_bytes, &job.reason, &body);
            cache::complete(job.key, summary);
            status::complete(&job.notify, true, None);
            tracing::info!(tool = %job.tool, "RLM background summary cached");
        }
        Err(e) => {
            cache::fail(job.key);
            status::complete(&job.notify, false, Some(e.to_string()));
            tracing::warn!(tool = %job.tool, error = %e, "RLM background summary failed");
        }
    }
}