ton_lib 0.0.38

A collection of types and utilities for interacting with the TON network
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

use crate::clients::tl_client::tl::request::TLRequest;
use crate::clients::tl_client::tl::response::TLResponse;
use crate::error::TLError;
use tonlib_sys::*;
// Wrapper around ton client with support for TL data types

pub(crate) struct TonlibjsonWrapper {
    ptr: *mut std::os::raw::c_void,
    tag: String,
}

impl TonlibjsonWrapper {
    pub fn new(tag: String) -> Result<TonlibjsonWrapper, TLError> {
        let client_ptr = unsafe { tonlib_client_json_create() };
        if client_ptr.is_null() {
            return Err(TLError::TLClientCreationFailed);
        }
        Ok(TonlibjsonWrapper { ptr: client_ptr, tag })
    }

    pub fn tag(&self) -> &str { self.tag.as_str() }

    pub fn send(&self, req: &TLRequest, extra: &str) -> Result<(), TLError> {
        let c_str = req.to_c_str_json(extra)?;
        log::trace!("[{}] send: {c_str:?}", self.tag);
        unsafe { tonlib_client_json_send(self.ptr, c_str.as_ptr()) };
        Ok(())
    }

    pub fn receive(&self, timeout: f64) -> Option<Result<(TLResponse, Option<String>), TLError>> {
        let c_str = unsafe { tonlib_client_json_receive(self.ptr, timeout) };
        if c_str.is_null() {
            return None;
        }
        unsafe { Some(TLResponse::from_c_str_json(c_str)) }
    }
}

impl Drop for TonlibjsonWrapper {
    fn drop(&mut self) { unsafe { tonlib_client_json_destroy(self.ptr) } }
}

unsafe impl Send for TonlibjsonWrapper {}
unsafe impl Sync for TonlibjsonWrapper {}

#[cfg(test)]
mod tests {
    use crate::clients::tl_client::tl::{request::TLRequest, tonlibjson_wrapper::TonlibjsonWrapper};
    use crate::sys_utils::sys_tonlib_set_verbosity_level;

    #[test]
    fn it_executes_functions() -> anyhow::Result<()> {
        sys_tonlib_set_verbosity_level(1);
        let client = TonlibjsonWrapper::new("test".to_string())?;
        client.send(&TLRequest::GetLogVerbosityLevel {}, "test2")?;
        Ok(())
    }
}