chainparser 0.3.0

Parses Solana account data using provided IDL
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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

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

use borsh::BorshSerialize;
pub use chainparser::json::{
    JsonIdlTypeDefinitionDeserializer, JsonSerializationOpts,
};
use serde::Deserialize;
use solana_idl::{IdlField, IdlType, IdlTypeDefinition};

pub fn to_if(name: &str, ty: IdlType) -> IdlField {
    IdlField {
        name: name.to_string(),
        ty,
        attrs: None,
    }
}

pub fn process_test_case_json<'de, 'a, T>(
    label: &str,
    idl_type_defs: &[&IdlTypeDefinition],
    instance: T,
    deser_key: &str,
    writer: &'de mut String,
    opts: Option<JsonSerializationOpts>,
    buf: Option<Vec<u8>>,
) where
    T: Deserialize<'de> + BorshSerialize + std::fmt::Debug + Eq + PartialEq,
{
    let type_map = Arc::new(Mutex::new(HashMap::new()));
    let opts = opts.unwrap_or_default();

    // 1. process all idl type defs to populate the type map and then use
    for idl_type_def in idl_type_defs {
        let deser = JsonIdlTypeDefinitionDeserializer::new(
            idl_type_def,
            type_map.clone(),
            &opts,
        );
        type_map
            .lock()
            .unwrap()
            .insert(idl_type_def.name.clone(), deser);
    }

    // 2. deserialize the instance with the requested json
    let buf = buf.unwrap_or_else(|| instance.try_to_vec().unwrap());

    let deser = {
        type_map
            .lock()
            .unwrap()
            .get(deser_key)
            .cloned()
            .unwrap_or_else(|| panic!("Unable to find json {deser_key}"))
    };
    let de = chainparser::borsh::BorshDeserializer;
    deser
        .deserialize(&de, writer, &mut &buf[..])
        .expect("Failed to deserialize");

    let res = match serde_json::from_str::<T>(writer) {
        Ok(res) => res,
        Err(e) => {
            eprintln!("JSON: {writer}");
            panic!("Failed to deserialize: {e}")
        }
    };
    if res != instance {
        eprintln!("JSON: {writer}");
    }
    assert_eq!(res, instance, "{label}");
}

pub fn process_test_case_json_compare_str(
    label: &str,
    idl_type_defs: &[&IdlTypeDefinition],
    deser_key: &str,
    writer: &mut String,
    opts: Option<JsonSerializationOpts>,
    buf: Vec<u8>,
    expected: &str,
) {
    let type_map = Arc::new(Mutex::new(HashMap::new()));
    let opts = opts.unwrap_or_default();

    // 1. process all idl type defs to populate the type map and then use
    for idl_type_def in idl_type_defs {
        let deser = JsonIdlTypeDefinitionDeserializer::new(
            idl_type_def,
            type_map.clone(),
            &opts,
        );
        type_map
            .lock()
            .unwrap()
            .insert(idl_type_def.name.clone(), deser);
    }

    let deser = {
        type_map
            .lock()
            .unwrap()
            .get(deser_key)
            .cloned()
            .unwrap_or_else(|| panic!("Unable to find json {deser_key}"))
    };
    let de = chainparser::borsh::BorshDeserializer;
    deser
        .deserialize(&de, writer, &mut &buf[..])
        .expect("Failed to deserialize");

    assert_eq!(writer, expected, "{label}");
}