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

//! A trait to generalize requests and responses of the Access API.

use crate::access::*;

mod private {
    pub trait Sealed {}
}

/// A callable request of the Flow Access API.
pub trait FlowRequest<Response>: private::Sealed {
    /// The path of the request.
    ///
    /// formatted as "/"({package} ".")? {service}"/" {method}.
    const PATH: &'static str;
}

macro_rules! access_api {
    (rpc $servName:ident$(<$($generics:ident),+>)?(noseal $reqTy:ty) returns ($resTy:ty) $(where($($tt:tt)*))?) => {
        impl$(<$($generics),+>)? FlowRequest<$resTy> for $reqTy $(where $($tt)*)? {
            const PATH: &'static str = concat!("/flow.access.AccessAPI/", stringify!($servName));
        }
    };
    (rpc $servName:ident$(<$($generics:ident),+>)?($reqTy:ty) returns ($resTy:ty) $(where($($tt:tt)*))?) => {
        access_api!(rpc $servName$(<$($generics),+>)?(noseal $reqTy) returns ($resTy) $(where($($tt)*))?);

        impl$(<$($generics),+>)? private::Sealed for $reqTy $(where $($tt)*)? {}
    };
    ($(rpc $servName:ident$(<$($generics:ident),+$(,)?>)?($($tt:tt)*) returns ($resTy:ty) $(where($($tts:tt)*))?;)+) => {
        $(
            access_api!(rpc $servName$(<$($generics),+>)?($($tt)*) returns ($resTy) $(where($($tts)*))?);
        )+
    };
}

access_api! {
    rpc Ping(PingRequest) returns (PingResponse);
    rpc GetLatestBlockHeader(GetLatestBlockHeaderRequest)
        returns (BlockHeaderResponse);
    rpc GetBlockHeaderByID<Id>(GetBlockHeaderByIdRequest<Id>)
        returns (BlockHeaderResponse);
    rpc GetBlockHeaderByHeight(GetBlockHeaderByHeightRequest)
        returns (BlockHeaderResponse);
    rpc GetLatestBlock(GetLatestBlockRequest) returns (BlockResponse);
    rpc GetBlockByID<Id>(GetBlockByIdRequest<Id>) returns (BlockResponse);
    rpc GetBlockByHeight(GetBlockByHeightRequest) returns (BlockResponse);
    rpc GetCollectionByID<Id>(GetCollectionByIdRequest<Id>) returns (CollectionResponse);
    rpc SendTransaction<
        Script,
        Arguments,
        ReferenceBlockId,
        ProposalKeyAddress,
        Payer,
        Authorizers,
        PayloadSignatures,
        EnvelopeSignatures,
    >(SendTransactionRequest<
        Script,
        Arguments,
        ReferenceBlockId,
        ProposalKeyAddress,
        Payer,
        Authorizers,
        PayloadSignatures,
        EnvelopeSignatures,
    >) returns (SendTransactionResponse);
    rpc GetTransaction<Id>(GetTransactionRequest<Id>) returns (TransactionResponse);
    rpc GetTransactionResult<Id>(noseal GetTransactionRequest<Id>)
        returns (TransactionResultResponse);
    rpc GetAccountAtLatestBlock<Addr>(GetAccountAtLatestBlockRequest<Addr>)
        returns (AccountResponse);
    rpc GetAccountAtBlockHeight<Addr>(GetAccountAtBlockHeightRequest<Addr>)
        returns (AccountResponse);
    rpc ExecuteScriptAtLatestBlock<Script, Arguments>(ExecuteScriptAtLatestBlockRequest<Script, Arguments>)
        returns (ExecuteScriptResponse);
    rpc ExecuteScriptAtBlockID<BlockId, Script, Arguments>(ExecuteScriptAtBlockIdRequest<BlockId, Script, Arguments>)
        returns (ExecuteScriptResponse);
    rpc ExecuteScriptAtBlockHeight<Script, Arguments>(ExecuteScriptAtBlockHeightRequest<Script, Arguments>)
        returns (ExecuteScriptResponse);
    rpc GetEventsForHeightRange<EventTy>(GetEventsForHeightRangeRequest<EventTy>)
        returns (EventsResponse);
    rpc GetEventsForBlockIDs<EventTy, BlockIds>(GetEventsForBlockIdsRequest<EventTy, BlockIds>)
        returns (EventsResponse);
    rpc GetNetworkParameters(GetNetworkParametersRequest)
        returns (GetNetworkParametersResponse);
    rpc GetLatestProtocolStateSnapshot(GetLatestProtocolStateSnapshotRequest)
        returns (ProtocolStateSnapshotResponse);
    rpc GetExecutionResultForBlockID<Id>(GetExecutionResultForBlockIdRequest<Id>)
        returns (ExecutionResultForBlockIdResponse);
}