iota-sdk 2.0.0-beta.1

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
64
65
66
67
68
69
70
71

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

pub mod options;
pub mod transaction;
pub mod transaction_builder;

use crate::{
    client::{constants::FIVE_MINUTES_IN_NANOSECONDS, Client, ClientError},
    types::block::{
        core::{BlockHeader, UnsignedBlock},
        output::AccountId,
        payload::Payload,
        BlockBody,
    },
};

impl Client {
    pub async fn build_basic_block(
        &self,
        issuer_id: AccountId,
        payload: impl Into<Option<Payload>> + Send,
    ) -> Result<UnsignedBlock, ClientError> {
        let issuance = self.get_issuance().await?;

        let issuing_time = {
            let issuing_time = instant::SystemTime::now()
                .duration_since(instant::SystemTime::UNIX_EPOCH)
                .expect("Time went backwards")
                .as_nanos() as u64;

            // Check that the issuing_time is in the range of +-5 minutes of the node to prevent potential issues
            if !(issuance.latest_parent_block_issuing_time - FIVE_MINUTES_IN_NANOSECONDS
                ..issuance.latest_parent_block_issuing_time + FIVE_MINUTES_IN_NANOSECONDS)
                .contains(&issuing_time)
            {
                return Err(ClientError::TimeNotSynced {
                    current_time: issuing_time,
                    tangle_time: issuance.latest_parent_block_issuing_time,
                });
            }
            // If timestamp is below latest_parent_block_issuing_time, just increase it to that +1 so the block doesn't
            // get rejected
            issuing_time.max(issuance.latest_parent_block_issuing_time + 1)
        };

        let protocol_params = self.get_protocol_parameters().await?;

        Ok(UnsignedBlock::new(
            BlockHeader::new(
                protocol_params.version(),
                protocol_params.network_id(),
                issuing_time,
                issuance.latest_commitment.id(),
                issuance.latest_finalized_slot,
                issuer_id,
            ),
            BlockBody::build_basic(
                issuance.strong_parents()?,
                (
                    protocol_params.work_score_parameters,
                    issuance.latest_commitment.reference_mana_cost(),
                ),
            )
            .with_weak_parents(issuance.weak_parents()?)
            .with_shallow_like_parents(issuance.shallow_like_parents()?)
            .with_payload(payload.into())
            .finish_block_body()?,
        ))
    }
}