rspyts-cli 3.0.1

//! Command execution and user-visible reporting.

use std::io::Write;
use std::thread;
use std::time::Duration;

use anyhow::Result;
use serde::Serialize;
use serde_json::json;

use crate::cli::{Command, ProjectArgs};
use crate::config;
use crate::init;
use crate::output::SourceWatcher;
use crate::project::{Project, build, check};

/// Execute one parsed command using explicit output streams.
pub(crate) fn execute(
    command: Command,
    stdout: &mut dyn Write,
    stderr: &mut dyn Write,
) -> Result<()> {
    match command {
        Command::Init(args) => write_json(stdout, &init::create(&args.path, &args.version)?),
        Command::Build(args) => {
            let project = read_project(&args)?;
            write_json(stdout, &build(&project)?)
        }
        Command::Check(args) => {
            let project = read_project(&args)?;
            check(&project)?;
            write_json(
                stdout,
                &json!({
                    "status": "ok",
                    "pythonSource": project.python_source(),
                    "typescriptSource": project.typescript_source(),
                }),
            )
        }
        Command::Watch(args) => watch(config::discover(args.config.as_deref())?, stdout, stderr),
    }
}

fn read_project(args: &ProjectArgs) -> Result<Project> {
    Project::read(&config::discover(args.config.as_deref())?)
}

/// Build once, then rebuild after each observed source change.
///
/// The loop deliberately remains at the process boundary: a fatal watcher
/// error ends the command, while a build error is reported and waits for the
/// next source change.
fn watch(config: std::path::PathBuf, stdout: &mut dyn Write, stderr: &mut dyn Write) -> Result<()> {
    let project = Project::read(&config)?;
    build(&project)?;
    writeln!(
        stdout,
        "rspyts is watching {}",
        project.workspace_root.display()
    )?;
    let mut watcher = SourceWatcher::new(&project.workspace_root, &config)?;
    loop {
        thread::sleep(Duration::from_millis(500));
        if watcher.changed()? {
            match Project::read(&config).and_then(|project| build(&project)) {
                Ok(_) => writeln!(
                    stdout,
                    "rspyts rebuilt {} and {}",
                    project.python_source().display(),
                    project.typescript_source().display()
                )?,
                Err(error) => writeln!(stderr, "rspyts build failed: {error:#}")?,
            }
        }
    }
}

fn write_json(output: &mut dyn Write, value: &impl Serialize) -> Result<()> {
    serde_json::to_writer_pretty(&mut *output, value)?;
    writeln!(output)?;
    Ok(())
}