zenops 0.12.0

Declarative system configuration management for shell config and dotfiles.
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

//! Newline-delimited JSON renderer.
//!
//! One event per line with the `event` tag set by [`super::Event`]'s serde
//! attributes (e.g. `{"event": "status", "kind": "...", ...}`). Streams as it
//! goes — `finalize()` is a no-op.

use std::io::Write;

use super::{DoctorCheck, Event, Output, OutputError};

/// Newline-delimited JSON output. One event per line:
/// `{"event": "status", "kind": "...", ...}` or
/// `{"event": "applied_action", "kind": "...", ...}`.
pub struct JsonOutput<'w> {
    out: &'w mut dyn Write,
}

impl<'w> JsonOutput<'w> {
    /// Wrap a writer (typically a locked stdout). Each event is flushed as
    /// a single line on `push`; the writer is not buffered internally.
    pub fn new(out: &'w mut dyn Write) -> Self {
        Self { out }
    }
}

impl Output for JsonOutput<'_> {
    fn push(&mut self, event: Event) -> Result<(), OutputError> {
        // Bare section headers are a human-rendering construct — JSON
        // consumers reconstruct sections from `Check { section, ... }`
        // events directly.
        if matches!(event, Event::DoctorCheck(DoctorCheck::SectionHeader { .. })) {
            return Ok(());
        }
        serde_json::to_writer(&mut *self.out, &event)?;
        writeln!(self.out)?;
        Ok(())
    }
}