coapum 0.2.0

A modern, ergonomic CoAP (Constrained Application Protocol) library for Rust with support for DTLS, observers, and asynchronous handlers
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
74
75
76
77
78
79
80
81
82

use std::{
    self,
    collections::HashMap,
    sync::{Arc, RwLock},
};

use coapum::{
    Raw,
    dtls::{
        Error,
        cipher_suite::CipherSuiteId,
        config::{Config, ExtendedMasterSecretType},
    },
    observer::memory::MemObserver,
    router::RouterBuilder,
    serve,
};

type PskStore = Arc<RwLock<HashMap<String, Vec<u8>>>>;

const PSK: &[u8] = "63ef2024b1de6417f856fab7005d38f6".as_bytes();

async fn test() -> Raw {
    let json = "{\"resp\":\"OK\"}";
    log::info!("Writing: {}", json);
    let json = json.as_bytes().to_vec();

    Raw {
        payload: json,
        content_format: None,
    }
}

#[tokio::main]
async fn main() {
    env_logger::init();

    log::info!("Server!");

    // Set up store
    let psk_store: PskStore = Arc::new(RwLock::new(HashMap::new()));

    // Add entry
    {
        let mut psk_store_write = psk_store.write().unwrap();
        psk_store_write.insert("goobie!".to_string(), PSK.to_vec());
    }

    let obs = MemObserver::new();

    let router = RouterBuilder::new((), obs).get("test", test).build();

    // Setup socket
    let addr = "127.0.0.1:5684";
    let dtls_cfg = Config {
        psk: Some(Arc::new(move |hint: &[u8]| -> Result<Vec<u8>, Error> {
            let hint = String::from_utf8(hint.to_vec()).unwrap();

            log::info!("Client's hint: {}", hint);

            // Look up the hint in the database
            if let Some(psk) = psk_store.read().unwrap().get(&hint) {
                Ok(psk.clone())
            } else {
                log::info!("Hint {} not found in store", hint);
                Err(Error::ErrIdentityNoPsk)
            }
        })),
        psk_identity_hint: Some("coapum server".as_bytes().to_vec()),
        cipher_suites: vec![CipherSuiteId::Tls_Psk_With_Aes_128_Gcm_Sha256],
        extended_master_secret: ExtendedMasterSecretType::Require,
        ..Default::default()
    };

    // Server config
    let cfg = coapum::config::Config {
        dtls_cfg,
        ..Default::default()
    };

    let _ = serve::serve(addr.to_string(), cfg, router).await;
}