use coap_lite::{CoapRequest, Packet};
use std::net::UdpSocket;
use coap_handler::Handler as _;
use coap_handler_implementations::{HandlerBuilder, SimpleRendered};
fn main() {
let mut handler = coap_handler_implementations::new_dispatcher()
.at(
&[".well-known", "core"],
SimpleRendered::new_typed_str("</>,</time>", Some(40)),
)
.at(&[], SimpleRendered("Welcome to the Demo server"));
let socket = UdpSocket::bind("127.0.0.1:5683").unwrap();
let mut buf = [0; 1280];
loop {
let (size, src) =
socket.recv_from(&mut buf).expect("Didn't receive data");
let packet = Packet::from_bytes(&buf[..size]).unwrap();
let request = CoapRequest::from_packet(packet, src);
let extracted = handler.extract_request_data(&request.message);
let mut response = request.response.unwrap();
use coap_message_0_3::error::RenderableOnMinimal;
match extracted {
Ok(extracted) => {
if let Err(e2) =
handler.build_response(&mut response.message, extracted)
{
response.message.payload = Default::default();
response.message.clear_all_options();
e2.render(&mut response.message).unwrap();
}
}
Err(e) => {
e.render(&mut response.message).unwrap();
}
}
let packet = response.message.to_bytes().unwrap();
socket
.send_to(&packet[..], src)
.expect("Could not send the data");
}
}