kudu 0.2.0

Library for interacting with Antelope 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

// SPDX-FileCopyrightText: 2026 DigiGaia SCCL
// SPDX-License-Identifier: AGPL-3.0-or-later

use std::collections::HashMap;
use std::sync::{Arc, LazyLock, Mutex};

use snafu::OptionExt;

use crate::{
    ABI, ABIError, abi,
    abi::error::{NoMatchingABISnafu, UnknownABISnafu}
};

//
// see tests and more: https://github.com/wharfkit/abicache/blob/master/test/tests/abi.ts
//

// TODO: make abi name a kudu::Name instead of a String
//       at the very least, we should be able to query using either a kudu::Name or a &str
// TODO: could we get rid of the `Arc` here since we have a 'static lifetime?
static REGISTRY: LazyLock<Mutex<HashMap<String, Arc<ABI>>>> = LazyLock::new(|| {
    let mut reg = HashMap::new();
    reg.insert("eosio".to_string(), Arc::new(ABI::from_str(abi::data::EOSIO_ABI).unwrap()));
    reg.insert("eosio.token".to_string(), Arc::new(ABI::from_str(abi::data::EOSIO_TOKEN_ABI).unwrap()));
    reg.insert("core.vaulta".to_string(), Arc::new(ABI::from_str(abi::data::CORE_VAULTA_ABI).unwrap()));
    reg.insert("transaction".to_string(), Arc::new(ABI::from_str(abi::data::TRANSACTION_ABI).unwrap()));
    Mutex::new(reg)
});

pub fn load_abi(abi_name: &str, abi: &str) -> Result<(), ABIError> {
    let mut reg = REGISTRY.lock().unwrap();
    reg.insert(abi_name.to_string(), Arc::new(ABI::from_str(abi)?));
    Ok(())
}

pub fn get_abi(abi_name: &str) -> Result<Arc<ABI>, ABIError> {
    REGISTRY.lock().unwrap().get(abi_name).cloned().context(UnknownABISnafu { name: abi_name.to_string() })
}

pub fn find_abi_for(typename: &str) -> Result<Arc<ABI>, ABIError> {
    for (_name, abi) in REGISTRY.lock().unwrap().iter() {
        if abi.has_struct(typename) { return Ok(abi.clone()); }
    }
    NoMatchingABISnafu { name: typename }.fail()
}

// -----------------------------------------------------------------------------
//     static ABI definitions for tests
// -----------------------------------------------------------------------------

// FIXME: replace this with actual ABIs from the networks

// static EOSIO_ABI: &str  = r#"{
//     "version": "eosio::abi/1.2",
//     "structs": [
//         {
//             "name": "voteproducer",
//             "base": "",
//             "fields": [
//                 { "name": "voter", "type": "name" },
//                 { "name": "proxy", "type": "name" },
//                 { "name": "producers", "type": "name[]" }
//             ]
//         }
//     ]
// }
// "#;

// static EOSIO_TOKEN_ABI: &str  = r#"{
//     "version": "eosio::abi/1.2",
//     "structs": [
//         {
//             "name": "transfer",
//             "base": "",
//             "fields": [
//                 { "name": "from", "type": "name" },
//                 { "name": "to", "type": "name" },
//                 { "name": "quantity", "type": "asset" },
//                 { "name": "memo", "type": "string" }
//             ]
//         }
//     ]
// }
// "#;