cellix 0.4.2

The AI companion IDE inside your agent: a Claude Code mod, Codex plugin and Gemini CLI extension
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
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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110

//! Checks writing on a thread of its own: starting the checker and reading a long document
//! both take a moment, and typing must never wait for either.

use std::collections::HashSet;
use std::path::{Path, PathBuf};
use std::sync::mpsc::{self, Receiver, Sender};

use cellix_doc::prose::{Checker, Issue, Source};

enum Job {
    Check {
        file: PathBuf,
        revision: u64,
        text: String,
        source: Source,
    },
    Learn(String),
}

/// What came back for one revision of a file.
pub struct Found {
    pub file: PathBuf,
    pub revision: u64,
    pub issues: Vec<Issue>,
}

pub struct Spell {
    jobs: Sender<Job>,
    found: Receiver<Found>,
    words: Option<PathBuf>,
}

/// The words someone has said are right.
fn read_words(file: Option<&Path>) -> HashSet<String> {
    let text = file.and_then(|f| std::fs::read_to_string(f).ok());
    let lines = text.iter().flat_map(|t| t.lines());
    lines.map(|l| l.trim().to_lowercase()).collect()
}

impl Spell {
    pub fn start(words: Option<PathBuf>) -> Self {
        let (jobs, inbox) = mpsc::channel::<Job>();
        let (done, found) = mpsc::channel();
        let known = read_words(words.as_deref());
        std::thread::spawn(move || {
            let mut checker = None;
            while let Ok(job) = inbox.recv() {
                // Only the newest text matters, and whatever it takes to reach it.
                let mut job = job;
                let mut learned = Vec::new();
                while let Job::Learn(word) = job {
                    learned.push(word);
                    match inbox.recv() {
                        Ok(next) => job = next,
                        Err(_) => return,
                    }
                }
                let Job::Check {
                    file,
                    revision,
                    text,
                    source,
                } = job
                else {
                    continue;
                };
                let checker = checker.get_or_insert_with(|| Checker::new(known.clone()));
                checker.known.extend(learned);
                let issues = checker.check(&text, source);
                let found = Found {
                    file,
                    revision,
                    issues,
                };
                if done.send(found).is_err() {
                    return;
                }
            }
        });
        Self { jobs, found, words }
    }

    pub fn check(&self, file: PathBuf, revision: u64, text: String, source: Source) {
        let _ = self.jobs.send(Job::Check {
            file,
            revision,
            text,
            source,
        });
    }

    /// Remembers a word, for this run and the next.
    pub fn learn(&self, word: &str) {
        let word = word.to_lowercase();
        let _ = self.jobs.send(Job::Learn(word.clone()));
        if let Some(file) = &self.words {
            let mut text = std::fs::read_to_string(file).unwrap_or_default();
            text.push_str(&word);
            text.push('\n');
            if let Some(folder) = file.parent() {
                let _ = std::fs::create_dir_all(folder);
            }
            let _ = std::fs::write(file, text);
        }
    }

    pub fn poll(&self) -> Option<Found> {
        self.found.try_recv().ok()
    }
}