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

//! Copyright (c) 2022 MASSA LABS <info@massa.net>
//! Json RPC API for a massa-node
use jsonrpsee::core::{RpcResult, SubscriptionResult};
use jsonrpsee::proc_macros::rpc;
use massa_api_exports::page::PagedVecV2;
use massa_api_exports::ApiRequest;
use massa_models::address::Address;
use massa_models::block_id::BlockId;
use massa_models::version::Version;

/// Exposed API methods
#[rpc(server)]
pub trait MassaApi {
    /// Get the active stakers and their active roll counts for the current cycle sorted by largest roll counts.
    #[method(name = "get_largest_stakers")]
    async fn get_largest_stakers(
        &self,
        page_request: Option<ApiRequest>,
    ) -> RpcResult<PagedVecV2<(Address, u64)>>;

    /// Get the ids of best parents for the next block to be produced along with their period
    #[method(name = "get_next_block_best_parents")]
    async fn get_next_block_best_parents(&self) -> RpcResult<Vec<(BlockId, u64)>>;

    /// Get Massa node version.
    #[method(name = "get_version")]
    async fn get_version(&self) -> RpcResult<Version>;

    /// New produced block.
    #[subscription(
		name = "subscribe_new_blocks" => "new_blocks",
		unsubscribe = "unsubscribe_new_blocks",
		item = Block
	)]
    async fn subscribe_new_blocks(&self) -> SubscriptionResult;

    /// New produced blocks headers.
    #[subscription(
        name = "subscribe_new_blocks_headers" => "new_blocks_headers",
        unsubscribe = "unsubscribe_new_blocks_headers",
        item = SecureShare<BlockHeader, BlockId>
    )]
    async fn subscribe_new_blocks_headers(&self) -> SubscriptionResult;

    /// New produced blocks with operations content.
    #[subscription(
		name = "subscribe_new_filled_blocks" => "new_filled_blocks",
		unsubscribe = "unsubscribe_new_filled_blocks",
		item = FilledBlock
	)]
    async fn subscribe_new_filled_blocks(&self) -> SubscriptionResult;

    /// New produced operations.
    #[subscription(
		name = "subscribe_new_operations" => "new_operations",
		unsubscribe = "unsubscribe_new_operations",
		item = Operation
	)]
    async fn subscribe_new_operations(&self) -> SubscriptionResult;
}