// cargo run -- modules/hello <did>: runs hello's count entry (after `atlibs add bobvmbuilder.bsky.social/hello`).
use std::sync::Arc;

use atlibs_host::host::{Fetch, HostCall};
use atlibs_host::run::{Ctx, Module, Options, run_module};
use atlibs_host::wasm::{Bound, Wasm};
use serde_json::{Value, json};

#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<(), String> {
    atlibs_host::tls();
    let mut args = std::env::args().skip(1);
    let (path, did) = (args.next().ok_or("a module: modules/hello")?, args.next().ok_or("a DID")?);
    let read = |ext: &str| std::fs::read(format!("{path}.{ext}")).map_err(|e| format!("{path}.{ext}: {e}"));
    let spec: Value = serde_json::from_slice(&read("json")?).map_err(|e| e.to_string())?;
    let module = Module::from_manifest(read("wasm")?, &spec)?;

    let ctx = Ctx { runner: Arc::new(Bound { wasm: Wasm::new(5000), bytes: module.bytes.clone(), sha256: None }), ledger: None, now: None };
    // signed out: public reads only (a Session here acts as an account)
    let fetch: Arc<dyn Fetch> = Arc::new(reqwest::Client::new());
    let call = Arc::new(HostCall { fetch, session: None, attest: None });
    let input = json!({ "did": did, "collection": "com.fedfork.exec.wasm.module" });
    let ran = run_module(&ctx, &module, "count", input.as_object().unwrap(), call, Options::default()).await;
    println!("{}", ran["result"]);
    Ok(())
}