You've already forked authentication-service
mirror of
https://github.com/matrix-org/matrix-authentication-service.git
synced 2025-07-29 22:01:14 +03:00
admin: add tests for the get OAuth session API
This commit is contained in:
@ -99,7 +99,7 @@ oauth2-types.workspace = true
|
||||
zxcvbn = "3.1.0"
|
||||
|
||||
[dev-dependencies]
|
||||
insta = "1.39.0"
|
||||
insta.workspace = true
|
||||
tracing-subscriber.workspace = true
|
||||
cookie_store = "0.21.0"
|
||||
sqlx.workspace = true
|
||||
|
@ -83,3 +83,77 @@ pub async fn handler(
|
||||
session,
|
||||
))))
|
||||
}
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
use hyper::{Request, StatusCode};
|
||||
use mas_data_model::AccessToken;
|
||||
use sqlx::PgPool;
|
||||
use ulid::Ulid;
|
||||
|
||||
use crate::test_utils::{setup, RequestBuilderExt, ResponseExt, TestState};
|
||||
|
||||
#[sqlx::test(migrator = "mas_storage_pg::MIGRATOR")]
|
||||
async fn test_get(pool: PgPool) {
|
||||
setup();
|
||||
let mut state = TestState::from_pool(pool).await.unwrap();
|
||||
let token = state.token_with_scope("urn:mas:admin").await;
|
||||
|
||||
// state.token_with_scope did create a session, so we can get it here
|
||||
let mut repo = state.repository().await.unwrap();
|
||||
let AccessToken { session_id, .. } = repo
|
||||
.oauth2_access_token()
|
||||
.find_by_token(&token)
|
||||
.await
|
||||
.unwrap()
|
||||
.unwrap();
|
||||
repo.save().await.unwrap();
|
||||
|
||||
let request = Request::get(format!("/api/admin/v1/oauth2-sessions/{session_id}"))
|
||||
.bearer(&token)
|
||||
.empty();
|
||||
let response = state.request(request).await;
|
||||
response.assert_status(StatusCode::OK);
|
||||
let body: serde_json::Value = response.json();
|
||||
assert_eq!(body["data"]["type"], "oauth2-session");
|
||||
insta::assert_json_snapshot!(body, @r###"
|
||||
{
|
||||
"data": {
|
||||
"type": "oauth2-session",
|
||||
"id": "01FSHN9AG0MKGTBNZ16RDR3PVY",
|
||||
"attributes": {
|
||||
"created_at": "2022-01-16T14:40:00Z",
|
||||
"finished_at": null,
|
||||
"user_id": null,
|
||||
"user_session_id": null,
|
||||
"client_id": "01FSHN9AG0FAQ50MT1E9FFRPZR",
|
||||
"scope": "urn:mas:admin",
|
||||
"user_agent": null,
|
||||
"last_active_at": null,
|
||||
"last_active_ip": null
|
||||
},
|
||||
"links": {
|
||||
"self": "/api/admin/v1/oauth2-sessions/01FSHN9AG0MKGTBNZ16RDR3PVY"
|
||||
}
|
||||
},
|
||||
"links": {
|
||||
"self": "/api/admin/v1/oauth2-sessions/01FSHN9AG0MKGTBNZ16RDR3PVY"
|
||||
}
|
||||
}
|
||||
"###);
|
||||
}
|
||||
|
||||
#[sqlx::test(migrator = "mas_storage_pg::MIGRATOR")]
|
||||
async fn test_not_found(pool: PgPool) {
|
||||
setup();
|
||||
let mut state = TestState::from_pool(pool).await.unwrap();
|
||||
let token = state.token_with_scope("urn:mas:admin").await;
|
||||
|
||||
let session_id = Ulid::nil();
|
||||
let request = Request::get(format!("/api/admin/v1/oauth2-sessions/{session_id}"))
|
||||
.bearer(&token)
|
||||
.empty();
|
||||
let response = state.request(request).await;
|
||||
response.assert_status(StatusCode::NOT_FOUND);
|
||||
}
|
||||
}
|
||||
|
@ -38,5 +38,5 @@ url.workspace = true
|
||||
mas-iana.workspace = true
|
||||
|
||||
[dev-dependencies]
|
||||
insta = { version = "1.39.0" }
|
||||
insta.workspace = true
|
||||
rand_chacha = "0.3.1"
|
||||
|
@ -36,5 +36,5 @@ mas-iana.workspace = true
|
||||
mas-jose.workspace = true
|
||||
|
||||
[dev-dependencies]
|
||||
insta = { version = "1.39.0", features = ["yaml"] }
|
||||
insta.workspace = true
|
||||
rand_chacha = "0.3.1"
|
||||
|
Reference in New Issue
Block a user