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
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
use crate::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>>, String> {
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, String> {
user::query::get_user_by_id(ctx, id).await
}
/// Returns all the positions
///
/// Request example:
/// ```text
/// curl http://localhost:8000/graphql
/// -H 'authorization: Bearer ***'
/// -H 'content-type: application/json'
/// -d '{"query":"{positions {id, userId, createdAt, latitude, longitude, movingActivity}}"}'
/// ```
async fn positions<'ctx>(
&self,
ctx: &Context<'ctx>,
#[graphql(desc = "Filter by user id")] user_id: Option<i32>,
#[graphql(desc = "Limit results")] limit: Option<i64>,
#[graphql(desc = "Offset results")] offset: Option<i64>,
) -> Result<Option<Vec<position::Position>>, String> {
position::query::get_positions(ctx, user_id, limit, offset).await
}
/// Returns all the last positions for each user.
/// It is restricted to only admin users.
///
/// Request example:
/// ```text
/// curl http://localhost:8000/graphql
/// -H 'authorization: Bearer ***'
/// -H 'content-type: application/json'
/// -d '{"query":"lastPositions(movingActivity: IN_VEHICLE) {id, userId, createdAt, latitude, longitude, movingActivity}}"}'
/// ```
async fn last_positions<'ctx>(
&self,
ctx: &Context<'ctx>,
#[graphql(desc = "Filter by moving activity")] moving_activity: Option<
position::MovingActivity,
>,
) -> Result<Option<Vec<position::Position>>, String> {
position::query::last_positions(ctx, moving_activity).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}}"}'
/// ```
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>>, String> {
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(seen: false alertId: 1) {
/// id,
/// alert { id, userId, createdAt, area, areaLevel2, areaLevel3, text1, text2, text3, reachedUsers },
/// position {id, userId, createdAt, latitude, longitude, movingActivity},
/// seen,
/// level,
/// 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>>, String> {
notification::query::get_notifications(ctx, seen, id, alert_id, limit, offset).await
}
}
|
