dolphindb 3.3.1

A Rust native API for DolphinDB
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

mod header;
use crate::types::ConstantImpl;
use crate::{
    error::{Error, Result},
    Deserialize,
};

use self::header::ResponseHeader;
use tokio::io::AsyncBufReadExt;

#[derive(Default, Debug)]
struct ExecuteResult {
    res: String,
}

#[derive(Default, Debug)]
pub(crate) struct Response {
    pub(crate) header: ResponseHeader,
    res: ExecuteResult,
    pub(crate) data: Option<ConstantImpl>,
}

impl Deserialize for Response {
    async fn deserialize<R>(&mut self, reader: &mut R) -> Result<()>
    where
        R: AsyncBufReadExt + Unpin,
    {
        self.header.deserialize(reader).await?;

        self.res.deserialize(reader).await?;

        match self.header.counts {
            0 => self.data = None,
            1 => {
                let mut c = ConstantImpl::default();
                c.deserialize(reader).await?;
                self.data = Some(c);
            }
            _ => return Err(Error::BadResponse("unexpected object numbers".to_string())),
        }

        Ok(())
    }

    async fn deserialize_le<R>(&mut self, reader: &mut R) -> Result<()>
    where
        R: AsyncBufReadExt + Unpin,
    {
        self.header.deserialize_le(reader).await?;

        self.res.deserialize_le(reader).await?;

        match self.header.counts {
            0 => self.data = None,
            1 => {
                let mut c = ConstantImpl::default();
                c.deserialize_le(reader).await?;
                self.data = Some(c);
            }
            _ => return Err(Error::BadResponse("unexpected object numbers".to_string())),
        }

        Ok(())
    }
}

impl Deserialize for ExecuteResult {
    async fn deserialize<R>(&mut self, reader: &mut R) -> Result<()>
    where
        R: AsyncBufReadExt + Unpin,
    {
        let mut buf = String::new();
        if reader.read_line(&mut buf).await? == 0 {
            return Err(Error::UnexpectedEof);
        }

        if !buf.ends_with('\n') {
            return Err(Error::UnexpectedEof);
        }
        buf.pop();

        if buf != "OK" {
            return Err(Error::BadResponse(format!("server response: {}", buf)));
        }

        self.res = buf;

        Ok(())
    }
}