phoenix/schedtxt_auth
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refresh endpoint #7

Merged
phoenix merged 8 commits from refresh_token into main 2026-06-12 10:51:40 -04:00
Conversation 0 Commits 8 Files Changed 8
+24 -16
1 changed files with 24 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit e95d5ba468 - Show all commits
tests/tests.rs
+24 -16
View File
@@ -170,16 +170,20 @@ const TEST_SERVICE_USERNAME: &str = "swoon";
/// Test service passphrase
const TEST_SERVICE_PASSPHRASE: &str = "4n5cf349tfy34w857ty39wq45nfdq23";
async fn convert_response<T>(response: axum::response::Response) -> Result<T, std::io::Error>
where
T: serde::de::DeserializeOwned,
{
match axum::body::to_bytes(response.into_body(), usize::MAX).await {
Ok(body) => {
let resp: T = serde_json::from_slice(&body).unwrap();
Ok(resp)
mod util {
pub async fn convert_response<T>(
response: axum::response::Response,
) -> Result<T, std::io::Error>
where
T: serde::de::DeserializeOwned,
{
match axum::body::to_bytes(response.into_body(), usize::MAX).await {
Ok(body) => {
let resp: T = serde_json::from_slice(&body).unwrap();
Ok(resp)
}
Err(err) => Err(std::io::Error::other(err.to_string())),
}
Err(err) => Err(std::io::Error::other(err.to_string())),
}
}
@@ -194,7 +198,9 @@ async fn register_user(
response.status()
)))
} else {
match convert_response::<callers::register::response::Response>(response).await {
match util::convert_response::<callers::register::response::Response>(response)
.await
{
Ok(response) => {
if response.data.len() > 0 {
let user = response.data[0].clone();
@@ -224,7 +230,9 @@ async fn login_user(
response.status()
)))
} else {
match convert_response::<callers::login::response::LoginResponse>(response).await {
match util::convert_response::<callers::login::response::LoginResponse>(response)
.await
{
Ok(response) => {
if response.data.len() > 0 {
let user = response.data[0].clone();
@@ -252,9 +260,9 @@ async fn register_service_user(
response.status()
)))
} else {
match convert_response::<callers::register::response::RegisterServiceUserResponse>(
response,
)
match util::convert_response::<
callers::register::response::RegisterServiceUserResponse,
>(response)
.await
{
Ok(response) => {
@@ -286,7 +294,7 @@ async fn login_service_user(
response.status()
)))
} else {
match convert_response::<callers::login::response::ServiceUserLoginResponse>(
match util::convert_response::<callers::login::response::ServiceUserLoginResponse>(
response,
)
.await
@@ -415,7 +423,7 @@ async fn test_register_service_user() {
match requests::register_service_user(&app).await {
Ok(response) => {
match convert_response::<callers::register::response::RegisterServiceUserResponse>(
match util::convert_response::<callers::register::response::RegisterServiceUserResponse>(
response,
)
.await