hdp 0.9.0

All Herodotus Data Processor
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

use crate::primitives::task::{datalake::DatalakeCompute, module::Module};
use serde::{Deserialize, Serialize};

use super::ChainId;

#[derive(Debug, Serialize, Deserialize)]
#[serde(tag = "type")]
pub enum Task {
    DatalakeCompute(DatalakeCompute),
    Module(Module),
}

#[derive(Debug, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct SubmitBatchQuery {
    pub destination_chain_id: ChainId,
    pub tasks: Vec<Task>,
}

#[test]
fn test_serialize_submit_batch_query_datalake() {
    let json_data = r#"
    {
      "destinationChainId": "ETHEREUM_SEPOLIA",
      "tasks": [
        {
          "type": "DatalakeCompute",
          "datalake": {
            "type": "BlockSampled",
            "chainId": "ETHEREUM_SEPOLIA",
            "blockRangeStart": 5515020,
            "blockRangeEnd": 5515039,
            "increment": 10,
            "sampledProperty": "header.base_fee_per_gas"
          },
          "compute": {
            "aggregateFnId": "avg"
          }
        },
        {
          "type": "DatalakeCompute",
          "datalake": {
            "type": "TransactionsInBlock",
            "chainId": "ETHEREUM_SEPOLIA",
            "targetBlock": 5409986,
            "startIndex": 10,
            "endIndex": 40,
            "increment": 10,
            "includedTypes": {
              "legacy": true,
              "eip2930": true,
              "eip1559": true,
              "eip4844": true
            },
            "sampledProperty": "tx_receipt.success"
          },
          "compute": {
            "aggregateFnId": "count",
            "aggregateFnCtx": {
              "operator": "gt",
              "valueToCompare": "1000000000000000000"
            }
          }
        }
      ]
    }
    "#;

    let parsed: SubmitBatchQuery = serde_json::from_str(json_data).unwrap();
    println!("{:?}", parsed);
}

#[test]
fn test_serialize_submit_batch_query_module() {
    let json_data = r#"
   {
    "destinationChainId": "ETHEREUM_SEPOLIA",
    "tasks": [
        {
        "type": "Module",
        "programHash": "0x64041a339b1edd10de83cf031cfa938645450f971d2527c90d4c2ce68d7d412",
        "inputs": [
            {
            "visibility": "private",
            "value": "0x5222a4"
            },
            {
            "visibility": "public",
            "value": "0x00000000000000000000000013cb6ae34a13a0977f4d7101ebc24b87bb23f0d5"
            }
        ]
        }
    ]
    }

    "#;

    let parsed: SubmitBatchQuery = serde_json::from_str(json_data).unwrap();
    println!("{:?}", parsed);
}