feat: add endpoint to get logged in devices
This commit is contained in:
parent
671fc42555
commit
3647086adb
2 changed files with 60 additions and 0 deletions
58
src/api/v1/auth/devices.rs
Normal file
58
src/api/v1/auth/devices.rs
Normal file
|
@ -0,0 +1,58 @@
|
||||||
|
//! `/api/v1/auth/devices` Returns list of logged in devices
|
||||||
|
|
||||||
|
use actix_web::{HttpRequest, HttpResponse, get, web};
|
||||||
|
use diesel::{ExpressionMethods, QueryDsl, Queryable, Selectable, SelectableHelper};
|
||||||
|
use diesel_async::RunQueryDsl;
|
||||||
|
use serde::Serialize;
|
||||||
|
|
||||||
|
use crate::{
|
||||||
|
Data,
|
||||||
|
api::v1::auth::check_access_token,
|
||||||
|
error::Error,
|
||||||
|
schema::refresh_tokens::{self, dsl},
|
||||||
|
utils::get_auth_header,
|
||||||
|
};
|
||||||
|
|
||||||
|
#[derive(Serialize, Selectable, Queryable)]
|
||||||
|
#[diesel(table_name = refresh_tokens)]
|
||||||
|
#[diesel(check_for_backend(diesel::pg::Pg))]
|
||||||
|
struct Device {
|
||||||
|
device_name: String,
|
||||||
|
created_at: i64
|
||||||
|
}
|
||||||
|
|
||||||
|
/// `GET /api/v1/auth/devices` Returns list of logged in devices
|
||||||
|
///
|
||||||
|
/// requires auth: no
|
||||||
|
///
|
||||||
|
/// ### Response Example
|
||||||
|
/// ```
|
||||||
|
/// json!([
|
||||||
|
/// {
|
||||||
|
/// "device_name": "My Device!"
|
||||||
|
/// "created_at": "1752418856"
|
||||||
|
/// }
|
||||||
|
///
|
||||||
|
/// ]);
|
||||||
|
/// ```
|
||||||
|
#[get("/devices")]
|
||||||
|
pub async fn get(
|
||||||
|
req: HttpRequest,
|
||||||
|
data: web::Data<Data>,
|
||||||
|
) -> Result<HttpResponse, Error> {
|
||||||
|
let headers = req.headers();
|
||||||
|
|
||||||
|
let auth_header = get_auth_header(headers)?;
|
||||||
|
|
||||||
|
let mut conn = data.pool.get().await?;
|
||||||
|
|
||||||
|
let uuid = check_access_token(auth_header, &mut conn).await?;
|
||||||
|
|
||||||
|
let devices: Vec<Device> = dsl::refresh_tokens
|
||||||
|
.filter(dsl::uuid.eq(uuid))
|
||||||
|
.select(Device::as_select())
|
||||||
|
.get_results(&mut conn)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
Ok(HttpResponse::Ok().json(devices))
|
||||||
|
}
|
|
@ -8,6 +8,7 @@ use uuid::Uuid;
|
||||||
|
|
||||||
use crate::{Conn, error::Error, schema::access_tokens::dsl};
|
use crate::{Conn, error::Error, schema::access_tokens::dsl};
|
||||||
|
|
||||||
|
mod devices;
|
||||||
mod login;
|
mod login;
|
||||||
mod logout;
|
mod logout;
|
||||||
mod refresh;
|
mod refresh;
|
||||||
|
@ -32,6 +33,7 @@ pub fn web() -> Scope {
|
||||||
.service(verify_email::post)
|
.service(verify_email::post)
|
||||||
.service(reset_password::get)
|
.service(reset_password::get)
|
||||||
.service(reset_password::post)
|
.service(reset_password::post)
|
||||||
|
.service(devices::get)
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn check_access_token(access_token: &str, conn: &mut Conn) -> Result<Uuid, Error> {
|
pub async fn check_access_token(access_token: &str, conn: &mut Conn) -> Result<Uuid, Error> {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue