iota-sdk 0.4.0

The IOTA SDK provides developers with a seamless experience to develop on IOTA by providing account abstractions and clients to interact with node APIs.
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

// Copyright 2022 IOTA Stiftung
// SPDX-License-Identifier: Apache-2.0

//! Node indexer API.

pub mod query_parameters;
pub mod routes;

pub(crate) use self::query_parameters::{QueryParameter, QueryParameters};
use crate::{
    client::{ClientInner, Result},
    types::api::plugins::indexer::OutputIdsResponse,
};

impl ClientInner {
    /// Get all output ids for a provided URL route and query parameters.
    /// If a `QueryParameter::Cursor(_)` is provided, only a single page will be queried.
    pub async fn get_output_ids(
        &self,
        route: &str,
        mut query_parameters: QueryParameters,
        need_quorum: bool,
        prefer_permanode: bool,
    ) -> Result<OutputIdsResponse> {
        let mut merged_output_ids_response = OutputIdsResponse {
            ledger_index: 0,
            cursor: None,
            items: Vec::new(),
        };

        // Return early with only a single page if a `QueryParameter::Cursor(_)` is provided.
        let return_early = query_parameters.contains(QueryParameter::Cursor(String::new()).kind());

        while let Some(cursor) = {
            let output_ids_response = self
                .node_manager
                .read()
                .await
                .get_request::<OutputIdsResponse>(
                    route,
                    query_parameters.to_query_string().as_deref(),
                    self.get_timeout().await,
                    need_quorum,
                    prefer_permanode,
                )
                .await?;

            if return_early {
                return Ok(output_ids_response);
            }

            merged_output_ids_response.ledger_index = output_ids_response.ledger_index;
            merged_output_ids_response.cursor = output_ids_response.cursor;
            merged_output_ids_response.items.extend(output_ids_response.items);

            &merged_output_ids_response.cursor
        } {
            query_parameters.replace(QueryParameter::Cursor(cursor.to_string()));
        }

        Ok(merged_output_ids_response)
    }
}