timegraph-client 0.1.10

Timegraph Client
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

use graphql_client::{GraphQLQuery, QueryBody};
use serde::{Deserialize, Serialize};

pub const OPERATION_NAME: &str = "CollectData";
pub const QUERY: &str = r#"
mutation CollectData(
    $feed: String!,
    $timechainBlock: Int!,
    $targetBlock: Int!,
    $taskCycle: Int!,
    $taskId: Int!,
    $signature: String!,
    $shardId: Int!
    $data: [String!]!
    $eventId: Int
    ) {
        collect(
            feed: $feed,
            timechainBlock: $timechainBlock,
            targetBlock: $targetBlock,
            taskCycle: $taskCycle,
            taskId: $taskId,
            signature: $signature,
            shardId: $shardId,
            data: $data,
            eventId: $eventId) { status }
    }"#;

type Int = i64;

#[derive(Serialize, Debug)]
pub struct Variables {
    pub feed: String,
    #[serde(rename = "taskId")]
    pub task_id: Int,
    #[serde(rename = "taskCycle")]
    pub task_cycle: Int,
    #[serde(rename = "targetBlock")]
    pub target_block: Int,
    #[serde(rename = "timechainBlock")]
    pub timechain_block: Int,
    #[serde(rename = "shardId")]
    pub shard_id: Int,
    pub signature: String,
    pub data: Vec<String>,
}

#[derive(Deserialize, Debug)]
pub struct ResponseData {
    pub collect: CollectDataCollect,
}

#[derive(Deserialize, Debug)]
pub struct CollectDataCollect {
    pub status: String,
}

pub struct CollectData;

impl GraphQLQuery for CollectData {
    type Variables = Variables;
    type ResponseData = ResponseData;
    fn build_query(variables: Self::Variables) -> QueryBody<Self::Variables> {
        QueryBody {
            variables,
            query: QUERY,
            operation_name: OPERATION_NAME,
        }
    }
}