use std::{thread, time::Duration};

use radicle_ci_broker::msg::{Request, Response, RunId, RunResult};

fn main() {

    let _req = Request::from_reader(std::io::stdin()).unwrap();

    let pid = std::process::id();

    let run_id = format!("xyzzy-{}", pid);

    let first = Response::triggered(RunId::from(run_id.as_str()));

    first.to_writer(std::io::stdout()).unwrap();

    thread::sleep(Duration::from_millis(3000));

    let second = if pid % 2 == 0 {

        Response::finished(RunResult::Success)

    } else {

        Response::finished(RunResult::Failure)

    };

    second.to_writer(std::io::stdout()).unwrap();

}