technofab/jwt-authorizer
1
0
Fork 0
mirror of https://github.com/TECHNOFAB11/jwt-authorizer.git synced 2025-12-11 23:50:07 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

chore: simplify

Browse source
This commit is contained in:
cduvray 2023-12-31 09:18:27 +01:00
parent 976d65d362
commit 12eeed5240
1 changed files with 8 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

17
jwt-authorizer/tests/integration_tests.rs
View file

@ -1,5 +1,5 @@
use std::{
net::{SocketAddr, TcpListener},
net::SocketAddr,
sync::{
atomic::{AtomicI16, Ordering},
Arc, Once,
@ -14,6 +14,7 @@ use jwt_authorizer::{IntoLayer, JwtAuthorizer, JwtClaims, Refresh, RefreshStrate
use lazy_static::lazy_static;
use serde::{Deserialize, Serialize};
use serde_json::Value;
use tokio::net::TcpListener;
use tower::Service;
use tower::ServiceExt;
@ -64,9 +65,8 @@ async fn jwks() -> Json<Value> {
Json(common::JWKS_RSA1.clone())
}
fn run_jwks_server() -> String {
let listener = TcpListener::bind("0.0.0.0:0".parse::<SocketAddr>().unwrap()).unwrap();
listener.set_nonblocking(true).unwrap();
async fn run_jwks_server() -> String {
let listener = TcpListener::bind("0.0.0.0:0".parse::<SocketAddr>().unwrap()).await.unwrap();
let addr = listener.local_addr().unwrap();
let url = format!("http://{}:{}", addr.ip(), addr.port());
@ -77,7 +77,6 @@ fn run_jwks_server() -> String {
.route("/jwks", get(jwks));
tokio::spawn(async move {
let listener: tokio::net::TcpListener = tokio::net::TcpListener::from_std(listener).unwrap();
axum::serve(listener, app.into_make_service()).await.unwrap();
});
@ -163,7 +162,7 @@ async fn sequential_tests() {
async fn scenario1() {
init_test();
let url = run_jwks_server();
let url = run_jwks_server().await;
let auth: JwtAuthorizer<User> = JwtAuthorizer::from_oidc(&url);
let mut app = app(auth).await;
assert_eq!(1, Stats::discovery_counter());
@ -191,7 +190,7 @@ async fn scenario1() {
/// Refresh strategy: INTERVAL
async fn scenario2() {
init_test();
let url = run_jwks_server();
let url = run_jwks_server().await;
let refresh = Refresh {
refresh_interval: Duration::from_millis(40),
retry_interval: Duration::from_millis(0),
@ -220,7 +219,7 @@ async fn scenario2() {
/// Refresh strategy: KeyNotFound
async fn scenario3() {
init_test();
let url = run_jwks_server();
let url = run_jwks_server().await;
let refresh = Refresh {
strategy: RefreshStrategy::KeyNotFound,
refresh_interval: Duration::from_millis(40),
@ -251,7 +250,7 @@ async fn scenario3() {
/// Refresh strategy: NoRefresh
async fn scenario4() {
init_test();
let url = run_jwks_server();
let url = run_jwks_server().await;
let refresh = Refresh {
strategy: RefreshStrategy::NoRefresh,
refresh_interval: Duration::from_millis(0),