hubert 0.5.0

Secure distributed substrate for multiparty transactions using write-once key-value storage with ARID-based addressing
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

use std::io::Cursor;

use anyhow::Result;
use futures_util::TryStreamExt;
use ipfs_api_backend_hyper::{IpfsApi, IpfsClient};
use tokio::time::{Duration, sleep};

/// Requires a local Kubo daemon (default RPC at 127.0.0.1:5001).
/// Run with: cargo test -q -- --ignored --nocapture ipfs_immutable_roundtrip
#[tokio::test(flavor = "multi_thread")]
#[ignore = "Proof of Concept only. Needs a running IPFS daemon (kubo) on 127.0.0.1:5001"]
async fn ipfs_immutable_roundtrip() -> Result<()> {
    let client = IpfsClient::default();

    // 1) Add some bytes → CID
    let original: &[u8] = b"hello from ipfs (immutable)";
    let add_res = client.add(Cursor::new(original)).await?;
    let cid = add_res.hash; // e.g., "bafy..." (CIDv1) or "Qm..." (CIDv0)

    // Optional tiny delay (parity with your DHT tests; not strictly needed)
    sleep(Duration::from_millis(100)).await;

    // 2) cat the CID back as a byte stream
    let mut stream = client.cat(&cid);
    let mut roundtrip = Vec::new();
    while let Some(chunk) = stream.try_next().await? {
        roundtrip.extend_from_slice(&chunk);
    }

    assert_eq!(roundtrip.as_slice(), original, "CID roundtrip mismatch");
    Ok(())
}