diff --git a/examples/client_test.rs b/examples/client_test.rs deleted file mode 100644 index 48210145bbce7df670ed364e123e3a3b3e69f0b0..0000000000000000000000000000000000000000 --- a/examples/client_test.rs +++ /dev/null @@ -1,67 +0,0 @@ -extern crate coap; - -use std::io::ErrorKind; -use coap::{CoAPClient, CoAPOption, CoAPRequest, IsMessage, MessageType}; -use coap::message::header::Requests; - -fn main() { - // let addr = "127.0.0.1:5683"; - let url = "127.0.0.1:9683"; - let endpoint = "servicediscovery/publish"; - - let client = CoAPClient::new(url).unwrap(); - let mut request = CoAPRequest::new(); - request.set_code("0.02"); - // let mut header = request.get_mut_header(); - // header = Requests::Post; - request.set_version(1); - //request.set_type(Requests::Post); - // request.set_code("0.01"); - // request.set_message_id(1); - // request.set_token(vec![0x51, 0x55, 0x77, 0xE8]); - - // - let service_description = " - { - \"name\": \"crazy-827635ef\", - \"type\": \"kalle._coap-json._udp\", - \"host\": \"[fdfd::ff]\", - \"port\": \"5683\", - \"domain\": \"unknown\", - \"properties\": { - \"property\": [ - { - \"name\": \"version\", - \"value\": \"1.0\" - }, - { - \"name\": \"path\", - \"value\": \"/palletAvailable\", - \"loc\": \"Station-01\" - } - ] - } - }"; - request.set_payload(service_description.to_string().into_bytes()); - request.add_option(CoAPOption::UriPath, endpoint.to_string().into_bytes()); - println!("{:?}", request); - - client.send(&request).unwrap(); - println!("Client request: coap://{}{}", url, endpoint); - - match client.receive() { - Ok(response) => { - println!( - "Server reply: {}", - String::from_utf8(response.message.payload).unwrap() - ); - } - Err(e) => { - match e.kind() { - ErrorKind::WouldBlock => println!("Request timeout"), // Unix - ErrorKind::TimedOut => println!("Request timeout"), // Windows - _ => println!("Request error: {:?}", e), - } - } - } -} diff --git a/examples/idiot.rs b/examples/idiot.rs deleted file mode 100644 index 537726a87b17b468ce38cc74f69617fea3606004..0000000000000000000000000000000000000000 --- a/examples/idiot.rs +++ /dev/null @@ -1,87 +0,0 @@ - -extern crate coap; - -use std::io::ErrorKind; -use coap::{CoAPClient, CoAPOption, CoAPRequest, CoAPResponse, CoAPServer}; -use coap::IsMessage; - -fn request_handler(request: CoAPRequest) -> Option<CoAPResponse> { - let uri_path = request.get_option(CoAPOption::UriPath).unwrap(); - - return match request.response { - Some(mut response) => { - response.set_payload(uri_path.front().unwrap().clone()); - Some(response) - } - _ => None, - }; -} - -fn register() { - let url = "127.0.0.1:9683"; - let endpoint = "servicediscovery/publish"; - - let client = CoAPClient::new(url).unwrap(); - let mut request = CoAPRequest::new(); - request.set_code("0.02"); - request.set_version(1); - - let service_description = " - { - \"name\": \"crazy-827635ef\", - \"type\": \"kalle._coap-json._udp\", - \"host\": \"127.0.0.1\", - \"port\": \"3400\", - \"domain\": \"unknown\", - \"properties\": { - \"property\": [ - { - \"name\": \"version\", - \"value\": \"1.0\" - }, - { - \"name\": \"path\", - \"value\": \"/palletAvailable\", - \"loc\": \"Station-01\" - } - ] - } - }"; - - request.set_payload(service_description.to_string().into_bytes()); - request.add_option(CoAPOption::UriPath, endpoint.to_string().into_bytes()); - println!("{:?}", request); - - client.send(&request).unwrap(); - println!("Client request: coap://{}{}", url, endpoint); - - match client.receive() { - Ok(response) => { - println!( - "Server reply: {}", - String::from_utf8(response.message.payload).unwrap() - ); - } - Err(e) => { - match e.kind() { - ErrorKind::WouldBlock => println!("Request timeout"), // Unix - ErrorKind::TimedOut => println!("Request timeout"), // Windows - _ => println!("Request error: {:?}", e), - } - } - } -} - -fn main() { - register(); - let mut server = CoAPServer::new("127.0.0.1:3400").unwrap(); - server.handle(request_handler).unwrap(); - let url = "coap://127.0.0.1:9683/servicediscovery/service/cra"; - println!("Client request: {}", url); - - let response: CoAPResponse = CoAPClient::request(url).unwrap(); - println!( - "Server reply: {}", - String::from_utf8(response.message.payload).unwrap() - ); -}