aleph_client 3.0.0

This crate provides a Rust application interface for submitting transactions to `aleph-node` chain.
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

use anyhow::Result;

/// Verification key identifier alias, copied from `pallet_baby_liminal`.
pub type VerificationKeyIdentifier = [u8; 8];

use crate::{
    aleph_runtime::RuntimeCall::BabyLiminal,
    api,
    pallet_baby_liminal::pallet::Call::{delete_key, overwrite_key},
    RootConnection, SignedConnection, SignedConnectionApi, SudoCall, TxInfo, TxStatus,
};

/// Pallet baby liminal API.
#[async_trait::async_trait]
pub trait BabyLiminalUserApi {
    /// Store verifying key in pallet's storage.
    async fn store_key(
        &self,
        identifier: VerificationKeyIdentifier,
        key: Vec<u8>,
        status: TxStatus,
    ) -> Result<TxInfo>;

    /// Verify a proof.
    async fn verify(
        &self,
        identifier: VerificationKeyIdentifier,
        proof: Vec<u8>,
        public_input: Vec<u8>,
        status: TxStatus,
    ) -> Result<TxInfo>;
}

/// Pallet baby liminal API that requires sudo.
#[async_trait::async_trait]
pub trait BabyLiminalSudoApi {
    /// Delete verifying key from pallet's storage.
    async fn delete_key(
        &self,
        identifier: VerificationKeyIdentifier,
        status: TxStatus,
    ) -> Result<TxInfo>;

    /// Overwrite verifying key in pallet's storage.
    async fn overwrite_key(
        &self,
        identifier: VerificationKeyIdentifier,
        key: Vec<u8>,
        status: TxStatus,
    ) -> Result<TxInfo>;
}

#[async_trait::async_trait]
impl BabyLiminalUserApi for SignedConnection {
    async fn store_key(
        &self,
        identifier: VerificationKeyIdentifier,
        key: Vec<u8>,
        status: TxStatus,
    ) -> Result<TxInfo> {
        let tx = api::tx().baby_liminal().store_key(identifier, key);
        self.send_tx(tx, status).await
    }

    async fn verify(
        &self,
        identifier: VerificationKeyIdentifier,
        proof: Vec<u8>,
        public_input: Vec<u8>,
        status: TxStatus,
    ) -> Result<TxInfo> {
        let tx = api::tx()
            .baby_liminal()
            .verify(identifier, proof, public_input);
        self.send_tx(tx, status).await
    }
}

#[async_trait::async_trait]
impl BabyLiminalSudoApi for RootConnection {
    async fn delete_key(
        &self,
        identifier: VerificationKeyIdentifier,
        status: TxStatus,
    ) -> Result<TxInfo> {
        let call = BabyLiminal(delete_key { identifier });
        self.sudo_unchecked(call, status).await
    }

    async fn overwrite_key(
        &self,
        identifier: VerificationKeyIdentifier,
        key: Vec<u8>,
        status: TxStatus,
    ) -> Result<TxInfo> {
        let call = BabyLiminal(overwrite_key { identifier, key });
        self.sudo_unchecked(call, status).await
    }
}