balius-runtime 0.5.1

Runtime for run Headless dApps on UTxO-based blockchains
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87

#![cfg(test)]

use std::{
    path::{Path, PathBuf},
    process::Command,
};

use balius_runtime::{ledgers, Runtime, Store};
use serde_json::json;
use wit_component::ComponentEncoder;

fn build_module(src_dir: impl AsRef<Path>, module_name: &str, target: impl AsRef<Path>) {
    let output = Command::new("cargo")
        .arg("build")
        .arg("--target")
        .arg("wasm32-unknown-unknown")
        .current_dir(src_dir.as_ref())
        .output()
        .unwrap();
    if !output.stderr.is_empty() {
        eprintln!("{}", std::str::from_utf8(&output.stderr).unwrap());
    }
    if !output.status.success() {
        panic!("command failed: {}", output.status);
    }

    let wasm_path =
        PathBuf::from("../target/wasm32-unknown-unknown/debug").join(format!("{module_name}.wasm"));
    let module = wat::Parser::new().parse_file(wasm_path).unwrap();
    let component = ComponentEncoder::default()
        .validate(true)
        .module(&module)
        .unwrap()
        .encode()
        .unwrap();

    std::fs::write(target.as_ref(), component).unwrap();
}

#[tokio::test]
async fn faucet_claim() {
    build_module("../examples/minter/offchain", "minter", "tests/faucet.wasm");

    let store = Store::open("tests/balius.db", None).unwrap();

    let mut runtime = Runtime::builder(store)
        .with_ledger(ledgers::mock::Ledger.into())
        .build()
        .unwrap();

    let config = json!({
      "validator": {
        "ref_txo": {
          "transaction_id": "f7d3837715680f3a170e99cd202b726842d97f82c05af8fcd18053c64e33ec4f",
          "index": 0
        },
        "hash": "ef7a1cebb2dc7de884ddf82f8fcbc91fe9750dcd8c12ec7643a99bbe",
        "address": "addr1qx2fxv2umyhttkxyxp8x0dlpdt3k6cwng5pxj3jhsydzer3n0d3vllmyqwsx5wktcd8cc3sq835lu7drv2xwl2wywfgse35a3x"
      }
    });

    runtime
        .register_worker_from_file("faucet", "tests/faucet.wasm", config)
        .await
        .unwrap();

    let req = json!({
      "token": "54455354",
      "quantity": 1,
      "recipient": "addr1qx2fxv2umyhttkxyxp8x0dlpdt3k6cwng5pxj3jhsydzer3n0d3vllmyqwsx5wktcd8cc3sq835lu7drv2xwl2wywfgse35a3x",
      "fuel": {
        "Refs": [
          {
            "hash": "f7d3837715680f3a170e99cd202b726842d97f82c05af8fcd18053c64e33ec4f",
            "index": 0
          }
        ]
      }
    });

    let res = runtime
        .handle_request("faucet", "claim", serde_json::to_vec(&req).unwrap())
        .await
        .unwrap();

    println!("{:?}", res);
}