eq-sdk 0.1.13

Celestia Equivalence Service SDK to build clients and integrations to for a running instance of the service
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

// Re-export eq-common parts
pub use eq_common::eqs::inclusion_client::InclusionClient;
pub use eq_common::eqs::{get_zk_stack_response, GetZkStackRequest, GetZkStackResponse};
pub use eq_common::{ZKStackEqProofInput, ZKStackEqProofOutput};

use tonic::transport::Channel;
use tonic::Status as TonicStatus;

pub mod types;
pub use types::JobId;

#[derive(Debug)]
pub struct EqClient {
    grpc_channel: Channel,
}

impl EqClient {
    pub fn new(grpc_channel: Channel) -> Self {
        Self { grpc_channel }
    }
    pub fn get_zk_stack<'a>(
        &'a self,
        request: &'a JobId,
    ) -> impl std::future::Future<Output = Result<GetZkStackResponse, TonicStatus>> + Send + 'a
    where
        Self: Sync,
    {
        async {
            let request = GetZkStackRequest {
                commitment: request.blob_id.commitment.hash().to_vec(),
                namespace: request
                    .blob_id
                    .namespace
                    .id_v0()
                    .ok_or(TonicStatus::invalid_argument("Namespace invalid"))?
                    .to_vec(),
                height: request.blob_id.height.into(),
                batch_number: request.batch_number,
                chain_id: request.l2_chain_id,
            };
            let mut client = InclusionClient::new(self.grpc_channel.clone());
            match client.get_zk_stack(request).await {
                Ok(response) => Ok(response.into_inner()),
                Err(e) => Err(e),
            }
        }
    }
}