opendht/rust/examples/dhtnode.rs

// Copyright (c) 2014-2026 Savoir-faire Linux Inc.
// SPDX-License-Identifier: MIT

extern crate opendht;
use std::{thread, time};

use opendht::{DhtRunner, DhtRunnerConfig, InfoHash, Value};
// use opendht::crypto::*;

fn main() -> std::io::Result<()> {
    println!("{}", InfoHash::random());
    println!("{}", InfoHash::new());
    println!("{}", InfoHash::new().is_zero());
    println!("{}", InfoHash::get("alice"));
    println!("{}", InfoHash::get("alice").is_zero());

    let mut dht = DhtRunner::new();
    let /*mut*/ config = DhtRunnerConfig::new();
    //// If you want to inject a certificate, uncomment the following lines and previous mut.
    //// Note: you can generate a certificate with
    //// openssl req -x509 -newkey rsa:4096 -sha256 -days 3650 -nodes -keyout example.key -out example.crt -subj /CN=example.com
    //let cert = DhtCertificate::import("example.crt").ok().expect("Invalid cert file");
    //let pk = PrivateKey::import("example.key", "");
    //config.set_identity(cert, pk);
    dht.run_config(1412, config)?;
    dht.bootstrap("bootstrap.jami.net", 4222)?;
    println!("Current node id: {}", dht.node_id());

    let /* mut */ data = 42;
    let get_cb = move |v: Box<Value>| {
        //data += 1;
        println!("GET: VALUE CB - data: {} - v: {}", data, v);
        true
    };
    let done_cb = move |ok: bool| {
        println!("GET: DONE CB - data: {} - ok: {}", data, ok);
    };

    dht.get(&InfoHash::get("alice"), get_cb, done_cb);

    let put_done_cb = move |ok: bool| {
        println!("PUT: DONE CB - data: {} - ok: {}", data, ok);
    };
    dht.put(&InfoHash::get("bob"), Value::new("hi!"), put_done_cb, false);

    println!("Start listening /foo");
    let value_cb = move |v, expired| {
        println!(
            "LISTEN: DONE CB - data: {} - v: {} - expired: {}",
            data, v, expired
        );
        true
    };
    let token = dht.listen(&InfoHash::get("foo"), value_cb)?;
    let one_min = time::Duration::from_secs(10);
    thread::sleep(one_min);
    dht.cancel_listen(&InfoHash::get("foo"), token);
    println!("Public ips: {:#?}", dht.public_addresses());
    dht.join()?;
    Ok(())
}