cas/graphql/
query.rs

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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
use crate::{errors::AppError, graphql::types::*};
use async_graphql::{Context, Object};

/// Query struct
pub struct Query;

#[Object]
impl Query {
    /// Returns the API version. It is like a "greet" function
    async fn api_version(&self) -> &'static str {
        "1.0"
    }

    /// Returns all the users. It is restricted to admins only.
    ///
    /// Request example:
    /// ```text
    /// curl http://localhost:8000/graphql
    /// -H 'authorization: Bearer ***'
    /// -H 'content-type: application/json'
    /// -d '{"query":"{users(limit: 2) { id, email, password, name, address, isAdmin }}"}'
    /// ```
    async fn users<'ctx>(
        &self,
        ctx: &Context<'ctx>,
        #[graphql(desc = "Limit results")] limit: Option<i64>,
        #[graphql(desc = "Offset results")] offset: Option<i64>,
    ) -> Result<Option<Vec<user::User>>, AppError> {
        user::query::get_users(ctx, limit, offset).await
    }

    /// Returns an user by ID. Admins can check everyone.
    ///
    /// Request example:
    /// ```text
    /// curl http://localhost:8000/graphql
    /// -H 'authorization: Bearer ***'
    /// -H 'content-type: application/json'
    /// -d '{"query":"{user(id: 1) { id, email, password, name, address, isAdmin }}"}'
    /// ```
    async fn user<'ctx>(
        &self,
        ctx: &Context<'ctx>,
        #[graphql(desc = "User to find")] id: i32,
    ) -> Result<user::User, AppError> {
        user::query::get_user_by_id(ctx, id).await
    }

    /// Returns all the positions. It is restricted to admins only.
    ///
    /// Request example:
    /// ```text
    /// curl http://localhost:8000/graphql
    /// -H 'authorization: Bearer ***'
    /// -H 'content-type: application/json'
    /// -d '{"query":"{positions(movingActivity: IN_VEHICLE) {id, userId, createdAt, latitude, longitude, movingActivity}}"}'
    /// ```
    async fn positions<'ctx>(
        &self,
        ctx: &Context<'ctx>,
        #[graphql(desc = "Filter by moving activity")] moving_activity: Option<
            Vec<position::MovingActivity>,
        >,
        #[graphql(desc = "Limit results")] limit: Option<i64>,
        #[graphql(desc = "Offset results")] offset: Option<i64>,
    ) -> Result<Option<Vec<position::Position>>, AppError> {
        position::query::get_positions(ctx, moving_activity, limit, offset).await
    }

    /// Returns all the positions
    ///
    /// Request example:
    /// ```text
    /// curl http://localhost:8000/graphql
    /// -H 'authorization: Bearer ***'
    /// -H 'content-type: application/json'
    /// -d '{"query":"{alerts(id: 12) {id, userId, createdAt, area, areaLevel2, areaLevel3, text1, text2, text3, notifications {userId, latitude, longitude }}"}'
    /// ```
    async fn alerts<'ctx>(
        &self,
        ctx: &Context<'ctx>,
        #[graphql(desc = "Filter by ID")] id: Option<i32>,
        #[graphql(desc = "Limit results")] limit: Option<i64>,
        #[graphql(desc = "Offset results")] offset: Option<i64>,
    ) -> Result<Option<Vec<alert::Alert>>, AppError> {
        alert::query::get_alerts(ctx, id, limit, offset).await
    }

    /// Returns all the notifications. They can be filtered by an alert id.
    ///
    /// Request example:
    /// ```text
    /// curl http://localhost:8000/graphql
    /// -H 'authorization: Bearer ***'
    /// -H 'content-type: application/json'
    /// -d '{"query":"{notifications {
    /// id,
    /// alert { id, userId, createdAt, area, areaLevel2, areaLevel3, text1, text2, text3, audio1, audio2, audio3, reachedUsers },
    /// userId, latitude, longitude, movingActivity, level, seen, createdAt
    /// }}"}'
    /// ```
    async fn notifications<'ctx>(
        &self,
        ctx: &Context<'ctx>,
        #[graphql(desc = "Show only seen or not notifications")] seen: Option<bool>,
        #[graphql(desc = "Filter by ID")] id: Option<i32>,
        #[graphql(desc = "Filter by alert ID")] alert_id: Option<i32>,
        #[graphql(desc = "Limit results")] limit: Option<i64>,
        #[graphql(desc = "Offset results")] offset: Option<i64>,
    ) -> Result<Option<Vec<notification::Notification>>, AppError> {
        notification::query::get_notifications(ctx, seen, id, alert_id, limit, offset).await
    }
}