coaplite/
coaplite.rs

1use coap_lite::{CoapRequest, Packet};
2use std::net::UdpSocket;
3
4use coap_handler::Handler;
5use coap_message::error::RenderableOnMinimal;
6
7fn main() {
8    let log = Some(coap_message_demos::log::Log::start_once());
9
10    let mut handler = coap_message_demos::full_application_tree(log);
11
12    let socket = UdpSocket::bind("localhost:5683").unwrap();
13    let mut buf = [0; 1280];
14
15    loop {
16        let (size, src) = socket.recv_from(&mut buf).expect("Didn't receive data");
17
18        let packet = Packet::from_bytes(&buf[..size]).unwrap();
19        let request = CoapRequest::from_packet(packet, src);
20
21        let extracted = handler.extract_request_data(&request.message);
22
23        let mut response = request.response.unwrap();
24        match extracted {
25            Ok(extracted) => {
26                if let Err(e2) = handler.build_response(&mut response.message, extracted) {
27                    response.message.payload = Default::default();
28                    response.message.clear_all_options();
29                    e2.render(&mut response.message).unwrap();
30                }
31            }
32            Err(e) => {
33                e.render(&mut response.message).unwrap();
34            }
35        }
36
37        let packet = response.message.to_bytes().unwrap();
38        socket
39            .send_to(&packet[..], &src)
40            .expect("Could not send the data");
41    }
42}
coaplite/coaplite.rs

coaplite/
coaplite.rs
