blob: 9cee79602ef0e8fb5d061e4a4594e5a133f4c88e (
plain)
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
|
use crate::graphql::types::jwt;
use crate::state::AppState;
use async_graphql::{Context, Error, FieldResult, Object};
/// Mutation struct
pub struct Mutation;
#[Object]
impl Mutation {
/// Make GraphQL login
async fn login<'ctx>(
&self,
ctx: &Context<'ctx>,
input: jwt::LoginCredentials,
) -> FieldResult<jwt::AuthBody> {
let state = ctx.data::<AppState>().expect("Can't connect to db");
let client = &*state.client;
let password = sha256::digest(input.password);
let rows = client
.query(
"SELECT id FROM users WHERE email = $1 AND password = $2",
&[&input.email, &password],
)
.await
.unwrap();
let id: Vec<i32> = rows.iter().map(|row| row.get(0)).collect();
if id.len() == 1 {
// Create a new claim using the found ID
let claims = jwt::Claims::new(id[0]);
let token = claims.get_token().unwrap();
Ok(jwt::AuthBody::new(token))
} else {
Err(Error::new("Invalid email or password"))
}
}
}
|
