chaincraft 0.3.0

A high-performance Rust-based platform for blockchain education and prototyping
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

//! Randomness Beacon Example
//!
//! Demonstrates the verifiable randomness beacon protocol.
//! Ported from the Python chaincraft examples (randomness_beacon.py).
//!
//! Features:
//! - Validator registration
//! - VRF proof submission
//! - Threshold-based randomness finalization
//!
//! Run with: `cargo run --example randomness_beacon_example`

use chaincraft::{
    error::Result,
    examples::randomness_beacon::{helpers, RandomnessBeaconObject},
    network::PeerId,
    shared_object::ApplicationObject,
    storage::MemoryStorage,
    ChaincraftNode,
};
use std::sync::Arc;
use tokio::time::{sleep, Duration};

#[tokio::main]
async fn main() -> Result<()> {
    tracing_subscriber::fmt::init();

    println!("Chaincraft Randomness Beacon Example");
    println!("=====================================\n");

    let beacon = RandomnessBeaconObject::new(60, 2)?;
    let my_address = beacon.my_validator_address.clone();

    let id = PeerId::new();
    let storage = Arc::new(MemoryStorage::new());
    let mut node = ChaincraftNode::new(id, storage);

    let beacon_obj: Box<dyn ApplicationObject> = Box::new(beacon);
    node.add_shared_object(beacon_obj).await?;
    node.start().await?;

    println!(
        "Node started. Validator address: {}...",
        &my_address[..my_address.len().min(40)]
    );

    let reg_signer = chaincraft::crypto::ecdsa::ECDSASigner::new()?;
    let reg_msg = helpers::create_validator_registration(
        my_address.clone(),
        reg_signer.get_public_key_pem()?,
        "vrf_key_placeholder".to_string(),
        100,
        &reg_signer,
    )?;

    node.create_shared_message_with_data(reg_msg).await?;
    println!("Validator registration sent");
    sleep(Duration::from_millis(200)).await;

    let shared_objects = node.shared_objects().await;
    if let Some(obj) = shared_objects.first() {
        if obj.type_name() == "RandomnessBeacon" {
            let state = obj.get_state().await?;
            println!("\nBeacon state: {}", serde_json::to_string_pretty(&state).unwrap());
        }
    }

    println!("\nShutting down...");
    node.close().await?;
    println!("Done.");

    Ok(())
}