wot-serve 0.3.0

Web of Things (WoT) Thing server
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

use std::time::Duration;

use serde::{Deserialize, Serialize};
use wot_serve::servient::*;
use wot_td::{
    builder::{affordance::BuildableInteractionAffordance, data_schema::SpecializableDataSchema},
    extend::ExtendableThing,
};

#[derive(Debug, Clone, Serialize, Deserialize)]
struct A {}

impl ExtendableThing for A {
    type InteractionAffordance = ();
    type PropertyAffordance = ();
    type ActionAffordance = ();
    type EventAffordance = ();
    type Form = ();
    type ExpectedResponse = ();
    type DataSchema = ();
    type ObjectSchema = ();
    type ArraySchema = ();
}

#[tokio::main]
async fn main() {
    let servient = Servient::builder("TestThing")
        .ext(A {})
        .finish_extend()
        .http_bind("127.0.0.1:8080".parse().unwrap())
        .property("hello", |b| {
            b.ext(())
                .ext_interaction(())
                .ext_data_schema(())
                .finish_extend_data_schema()
                .form(|b| {
                    b.ext(())
                        .http_get(|| async { "Hello World!" })
                        .href("/hello")
                })
                .string()
        })
        .action("say_hello", |b| {
            b.ext(())
                .ext_interaction(())
                .form(|b| {
                    b.ext(())
                        .http_post(|| async { "I'm saying hello" })
                        .href("/say_hello")
                })
                .input(|b| b.ext(()).finish_extend().null())
                .form(|b| {
                    b.ext(())
                        .href("/say_hello/{action_id}")
                        .http_get(|| async { "Checking ..." })
                        .op(wot_td::thing::FormOperation::QueryAction)
                        .http_delete(|| async { "Canceling ..." })
                        .op(wot_td::thing::FormOperation::CancelAction)
                })
                .uri_variable("action_id", |b| b.ext(()).finish_extend().string())
        })
        .build_servient()
        .unwrap();

    eprintln!("Listening to 127.0.0.1:8080");
    dbg!(&servient.router);

    println!("Running the servient for 10 seconds.");
    let _ = tokio::time::timeout(Duration::from_secs(10), async {
        servient.serve().await.unwrap()
    })
    .await;
}