chore: fix clippy lints
This commit is contained in:
parent
2ab9c5d134
commit
eec62c129a
7
Cargo.lock
generated
7
Cargo.lock
generated
@ -229,12 +229,6 @@ version = "1.0.15"
|
|||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "4a5f13b858c8d314ee3e8f639011f7ccefe71f97f96e50151fb991f267928e2c"
|
checksum = "4a5f13b858c8d314ee3e8f639011f7ccefe71f97f96e50151fb991f267928e2c"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "lazy_static"
|
|
||||||
version = "1.5.0"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "bbd2bcb4c963f2ddae06a2efc7e9f3591312473c50c6685e1f298068316e66fe"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "libc"
|
name = "libc"
|
||||||
version = "0.2.174"
|
version = "0.2.174"
|
||||||
@ -511,7 +505,6 @@ dependencies = [
|
|||||||
"ctrlc",
|
"ctrlc",
|
||||||
"dashmap",
|
"dashmap",
|
||||||
"httparse",
|
"httparse",
|
||||||
"lazy_static",
|
|
||||||
"parking_lot",
|
"parking_lot",
|
||||||
"serde",
|
"serde",
|
||||||
"shlex",
|
"shlex",
|
||||||
|
@ -11,7 +11,6 @@ cookie = "0"
|
|||||||
ctrlc = "3"
|
ctrlc = "3"
|
||||||
dashmap = "6"
|
dashmap = "6"
|
||||||
httparse = "1"
|
httparse = "1"
|
||||||
lazy_static = "1"
|
|
||||||
parking_lot = { version = "0", features = ["arc_lock", "serde"] }
|
parking_lot = { version = "0", features = ["arc_lock", "serde"] }
|
||||||
serde = { version = "1", features = ["derive"] }
|
serde = { version = "1", features = ["derive"] }
|
||||||
shlex = "1"
|
shlex = "1"
|
||||||
|
25
src/main.rs
25
src/main.rs
@ -18,7 +18,6 @@ use std::{
|
|||||||
use anyhow::Context;
|
use anyhow::Context;
|
||||||
use clap::Parser;
|
use clap::Parser;
|
||||||
use dashmap::{DashMap, mapref::one::Ref};
|
use dashmap::{DashMap, mapref::one::Ref};
|
||||||
use lazy_static::lazy_static;
|
|
||||||
use thiserror::Error;
|
use thiserror::Error;
|
||||||
|
|
||||||
use crate::utils::headers::HeadersExt;
|
use crate::utils::headers::HeadersExt;
|
||||||
@ -156,7 +155,7 @@ impl AuthData {
|
|||||||
into.write_all(b"X-WEBAUTH-FULLNAME: ")?;
|
into.write_all(b"X-WEBAUTH-FULLNAME: ")?;
|
||||||
into.write_all(fullname.as_bytes())?;
|
into.write_all(fullname.as_bytes())?;
|
||||||
into.write_all(NL)?;
|
into.write_all(NL)?;
|
||||||
};
|
}
|
||||||
};
|
};
|
||||||
r.map_err(ClientError::AuthHeadersIoError)
|
r.map_err(ClientError::AuthHeadersIoError)
|
||||||
}
|
}
|
||||||
@ -165,10 +164,10 @@ impl AuthData {
|
|||||||
fn what_to_do<'a>(
|
fn what_to_do<'a>(
|
||||||
req: &httparse::Request,
|
req: &httparse::Request,
|
||||||
id_auth: Option<(String, Option<Ref<'a, String, AuthData>>)>,
|
id_auth: Option<(String, Option<Ref<'a, String, AuthData>>)>,
|
||||||
backend: (net::SocketAddr, String, String),
|
_backend: (net::SocketAddr, String, String),
|
||||||
) -> ProxyAction<'a> {
|
) -> ProxyAction<'a> {
|
||||||
let is_auth = id_auth.as_ref().is_some_and(|id_auth| id_auth.1.is_some());
|
let is_authd = id_auth.as_ref().is_some_and(|id_auth| id_auth.1.is_some());
|
||||||
match (req.path, req.method, is_auth) {
|
match (req.path, req.method, is_authd) {
|
||||||
(Some("/user/login"), Some("GET"), false) => todo!(),
|
(Some("/user/login"), Some("GET"), false) => todo!(),
|
||||||
(Some("/user/login"), Some("POST"), false) => todo!(),
|
(Some("/user/login"), Some("POST"), false) => todo!(),
|
||||||
_ => ProxyAction {
|
_ => ProxyAction {
|
||||||
@ -179,11 +178,11 @@ fn what_to_do<'a>(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
lazy_static! {
|
// TODO: might wanna save this one between runtimes
|
||||||
// TODO: might wanna save this one between runtimes
|
static AUTH_MAP: std::sync::LazyLock<DashMap<String, AuthData>> =
|
||||||
static ref AUTH_MAP: DashMap<String, AuthData> = DashMap::new();
|
std::sync::LazyLock::new(DashMap::new);
|
||||||
static ref CSRF_MAP: DashMap<String, AuthData> = DashMap::new();
|
static _CSRF_MAP: std::sync::LazyLock<DashMap<String, String>> =
|
||||||
}
|
std::sync::LazyLock::new(DashMap::new);
|
||||||
|
|
||||||
fn handle_client(client: &mut TcpStream, config: &config::Schema) -> Result<(), ClientError> {
|
fn handle_client(client: &mut TcpStream, config: &config::Schema) -> Result<(), ClientError> {
|
||||||
use ClientError as E;
|
use ClientError as E;
|
||||||
@ -223,7 +222,7 @@ fn handle_client(client: &mut TcpStream, config: &config::Schema) -> Result<(),
|
|||||||
// Try to find auth data
|
// Try to find auth data
|
||||||
let id_auth = if let Some(cookies) = cookies {
|
let id_auth = if let Some(cookies) = cookies {
|
||||||
if let Some(id_ck) = cookie::Cookie::split_parse(cookies)
|
if let Some(id_ck) = cookie::Cookie::split_parse(cookies)
|
||||||
.filter_map(|ck| ck.ok())
|
.filter_map(Result::ok)
|
||||||
.find(|ck| ck.name() == id_keyname)
|
.find(|ck| ck.name() == id_keyname)
|
||||||
{
|
{
|
||||||
let id = id_ck.value().to_string();
|
let id = id_ck.value().to_string();
|
||||||
@ -251,7 +250,7 @@ fn handle_client(client: &mut TcpStream, config: &config::Schema) -> Result<(),
|
|||||||
.map_err(E::ExchangeIoError)?;
|
.map_err(E::ExchangeIoError)?;
|
||||||
if let Some(auth) = action.auth {
|
if let Some(auth) = action.auth {
|
||||||
auth.write_as_headers(&mut stream)?;
|
auth.write_as_headers(&mut stream)?;
|
||||||
};
|
}
|
||||||
|
|
||||||
// send our overhead
|
// send our overhead
|
||||||
stream
|
stream
|
||||||
@ -270,7 +269,7 @@ fn handle_client(client: &mut TcpStream, config: &config::Schema) -> Result<(),
|
|||||||
} else {
|
} else {
|
||||||
io::copy(&mut stream, client).map_err(E::ExchangeIoError)?;
|
io::copy(&mut stream, client).map_err(E::ExchangeIoError)?;
|
||||||
}
|
}
|
||||||
};
|
}
|
||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user