corpora-engine 0.1.0

Bus orchestrator and IO edges (parser, fs walk, writer, git oracle) for corpora.
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

//! Persists `Report` artifacts to disk under `out_dir`. The only place report bytes
//! touch the filesystem — adapters themselves stay pure.

use std::fs;
use std::path::PathBuf;

use corpora_core::subscriber::ek;
use corpora_core::{Context, Diagnostic, Event, Interest, Subscriber};

pub struct Writer {
    out_dir: PathBuf,
}

impl Writer {
    pub fn new(out_dir: impl Into<PathBuf>) -> Self {
        Writer {
            out_dir: out_dir.into(),
        }
    }
}

impl Subscriber for Writer {
    fn name(&self) -> &'static str {
        "writer"
    }

    fn interest(&self) -> Interest {
        Interest::only(ek::REPORT)
    }

    fn handle(&mut self, ev: &Event, cx: &mut Context<'_>) {
        let Event::Report(a) = ev else { return };
        let dest = self.out_dir.join(&a.path.0);
        if let Some(parent) = dest.parent() {
            let _ = fs::create_dir_all(parent);
        }
        if let Err(e) = fs::write(&dest, &a.bytes) {
            cx.error(Diagnostic::error("WRITE", &a.path, e.to_string()));
        }
    }
}