tinql 0.1.6

Tinkerbell GraphQL server wrapping tinkc client
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

use juniper::{graphql_object, EmptyMutation, EmptySubscription, FieldResult, RootNode};
use std::sync::Arc;
use tinkc::Tink;

mod hardware;
mod workflow;

use hardware::Hardware;
use workflow::{Workflow, WorkflowActionStatus};

#[derive(Clone)]
pub struct Context {
    tink: Arc<Tink>,
}

impl Context {
    pub fn new(tink: Tink) -> Self {
        Self {
            tink: Arc::new(tink),
        }
    }
}

impl juniper::Context for Context {}
pub struct Query;

#[graphql_object(context = Context)]
impl Query {
    async fn workflows<'ctx>(&self, context: &'ctx Context) -> FieldResult<Vec<Workflow>> {
        let mut tink = context.tink.as_ref().clone();
        Ok(tink.workflows().await?)
    }

    async fn workflow_events<'ctx>(
        &self,
        context: &'ctx Context,
        id: String,
    ) -> FieldResult<Vec<WorkflowActionStatus>> {
        let mut tink = context.tink.as_ref().clone();
        Ok(tink.workflow_events(id).await?)
    }

    async fn hardware<'ctx>(&self, context: &'ctx Context) -> FieldResult<Vec<Hardware>> {
        let mut tink = context.tink.as_ref().clone();
        Ok(tink.hardware().await?)
    }

    async fn hardware_from_mac<'ctx>(
        &self,
        context: &'ctx Context,
        mac: String,
    ) -> FieldResult<Hardware> {
        let mut tink = context.tink.as_ref().clone();
        Ok(tink.hardware_from_mac(mac).await?)
    }
}

pub type Schema = RootNode<'static, Query, EmptyMutation<Context>, EmptySubscription<Context>>;

pub fn schema() -> Schema {
    Schema::new(
        Query,
        EmptyMutation::<Context>::new(),
        EmptySubscription::<Context>::new(),
    )
}

#[cfg(test)]
mod tests {
    #[test]
    fn it_works() {
        let result = 2 + 2;
        assert_eq!(result, 4);
    }
}