parallel_compare.rs

#![recursion_limit = "512"]

use hypershell::prelude::*;
use hypershell_examples::dsl::Compare;
use hypershell_examples::presets::HypershellComparePreset;
use hypershell_hash_components::dsl::{BytesToHex, Checksum};
use reqwest::Client;
use sha2::Sha256;

pub type GetChecksumOf<Url> = hypershell! {
    StreamingHttpRequest<
        GetMethod,
        Url,
        WithHeaders[ ],
    >
    | Checksum<Sha256>
    | BytesToHex
};

pub type Program = hypershell! {
    Compare<
        GetChecksumOf<FieldArg<"url_a">>,
        GetChecksumOf<FieldArg<"url_b">>,
    >
};

#[cgp_inherit(HypershellComparePreset)]
#[derive(HasField)]
pub struct MyApp {
    pub http_client: Client,
    pub url_a: String,
    pub url_b: String,
}

#[tokio::main]
async fn main() -> Result<(), Error> {
    let app = MyApp {
        http_client: Client::new(),
        url_a: "https://nixos.org/manual/nixpkgs/unstable/".to_owned(),
        url_b: "https://nixos.org/manual/nixpkgs/unstable".to_owned(),
    };

    let res = app
        .handle(PhantomData::<Program>, (<Vec<u8>>::new(), <Vec<u8>>::new()))
        .await?;

    println!("equals: {res}");

    Ok(())
}