opendht/rust/examples/dhtnode.rs

extern crate opendht;
use std::ffi::CString;
use std::{thread, time};
use libc::c_void;

use opendht::{InfoHash,DhtRunner,Value};

extern fn get_cb(v: *mut Value, ptr: *mut c_void) {
    if ptr.is_null() {
        return;
    }
    let _handler: &mut Handler = unsafe { &mut *(ptr as *mut Handler) };
    unsafe {
        println!("Got data: {}", *v);
    }
}

extern fn value_cb(v: *mut Value, expired: bool, ptr: *mut c_void) {
    if ptr.is_null() {
        return;
    }
    let _handler: &mut Handler = unsafe { &mut *(ptr as *mut Handler) };
    unsafe {
        println!("Got data: {} - expired: {}", *v, expired);
    }
}

extern fn done_cb(ok: bool, ptr: *mut c_void) {
    let _handler: &mut Handler = unsafe { &mut *(ptr as *mut Handler) };
    println!("In done - {}", ok);
}

struct Handler {
    _data: u8,
}


fn main() {
    println!("{}", InfoHash::random());
    println!("{}", InfoHash::new());
    // TODO inverted is_zero
    println!("{}", InfoHash::new().is_zero());
    println!("{}", InfoHash::get("alice"));
    println!("{}", InfoHash::get("alice").is_zero());

    let mut dht = DhtRunner::new();
    dht.run(1412);
    dht.bootstrap("bootstrap.jami.net", 4222);
    let ten_secs = time::Duration::from_secs(10);
    // TODO lambda instead
    let mut handler = Handler {
        _data: 8,
    };
    let ptr = &mut handler as *mut _ as *mut c_void;

    //println!("Start listening /foo");
    //let token = dht.listen(&InfoHash::get("foo"), value_cb, ptr);
    //thread::sleep(ten_secs);
    //println!("Stop listening /foo");
    //dht.cancel_listen(&InfoHash::get("foo"), token);
    //loop {
        println!("Get /alice");
        dht.get(&InfoHash::get("alice"), get_cb, done_cb, ptr);
        let v = Value::new("hi!");
        dht.put(&InfoHash::get("bob"), v, done_cb, ptr);
        //thread::sleep(ten_secs);
    //}
}