daat-locus 0.4.0

A long-running local agent runtime with memory, workflows, apps, and sleep-time self-improvement.
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89

use serde::{Deserialize, Serialize};

use crate::activity_event::{
    BrowserActivityAction, BrowserActivityDescriptor, WebSearchActivityAction,
    WebSearchActivityDescriptor,
};

#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq)]
pub struct BrowserActivityData {
    pub title: String,
    pub body_lines: Vec<String>,
    pub url: Option<String>,
    pub line_count: Option<usize>,
    pub ref_count: Option<usize>,
}

#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq)]
pub struct LiveBrowserActivityData {
    pub title: String,
    pub body_lines: Vec<String>,
    pub url: Option<String>,
}

#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq)]
pub struct WebSearchActivityData {
    pub action: WebSearchActivityAction,
    pub query: String,
    pub url: Option<String>,
    pub body_lines: Vec<String>,
}

impl From<BrowserActivityDescriptor> for BrowserActivityData {
    fn from(data: BrowserActivityDescriptor) -> Self {
        Self {
            title: data.title,
            body_lines: data.body_lines,
            url: data.url,
            line_count: data.line_count,
            ref_count: data.ref_count,
        }
    }
}

impl From<BrowserActivityDescriptor> for LiveBrowserActivityData {
    fn from(data: BrowserActivityDescriptor) -> Self {
        let title = match data.action {
            BrowserActivityAction::OpenPage => data.url.as_deref().map_or_else(
                || "Opening Page".to_string(),
                |url| format!("Opening URL: {}", compact_browser_url(url)),
            ),
            BrowserActivityAction::Wait => "Waiting for Page".to_string(),
            BrowserActivityAction::Click => "Clicking Element".to_string(),
            BrowserActivityAction::Fill => "Filling Element".to_string(),
            BrowserActivityAction::Back => "Going Back".to_string(),
            BrowserActivityAction::Forward => "Going Forward".to_string(),
            BrowserActivityAction::Reload => "Reloading Page".to_string(),
            BrowserActivityAction::ClosePage => "Closing Page".to_string(),
            BrowserActivityAction::Snapshot => "Capturing Page".to_string(),
        };
        Self {
            title,
            body_lines: data.body_lines,
            url: data.url,
        }
    }
}

impl From<WebSearchActivityDescriptor> for WebSearchActivityData {
    fn from(data: WebSearchActivityDescriptor) -> Self {
        Self {
            action: data.action,
            query: data.query,
            url: data.url,
            body_lines: data.body_lines,
        }
    }
}

fn compact_browser_url(url: &str) -> String {
    const MAX_CHARS: usize = 88;
    let compact = url.trim().replace('\n', "");
    let mut chars = compact.chars();
    let head = chars.by_ref().take(MAX_CHARS).collect::<String>();
    if chars.next().is_some() {
        format!("{head}...")
    } else {
        head
    }
}