git-echo/linux_patch_manager
Private
Public Access
1
0
Fork 0
Code Releases 8 Wiki Activity

fix: remove ConnectInfo extractor to fix public endpoint 500 error
Some checks failed
CI Pipeline / Rust Format Check (push) Failing after 3s
Details
CI Pipeline / Clippy Lints (push) Successful in 53s
Details
CI Pipeline / Rust Unit Tests (push) Successful in 1m11s
Details
CI Pipeline / Security Audit (push) Successful in 4s
Details
CI Pipeline / Frontend Lint & Type Check (push) Successful in 14s
Details
CI Pipeline / Build .deb & Release (push) Has been skipped
Details

Browse Source
This commit is contained in:
Echo
2026-05-17 23:01:01 +00:00
parent 3aff64afb7
commit 024e800708
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
crates/pm-web/src/routes/enrollment.rs
View File

@ -37,17 +37,20 @@ pub fn router() -> Router<AppState> {
async fn enroll_host( async fn enroll_host(
State(state): State<AppState>, State(state): State<AppState>,
headers: HeaderMap, headers: HeaderMap,
ConnectInfo(addr): ConnectInfo<SocketAddr>,
Json(payload): Json<CreateEnrollmentRequest>, Json(payload): Json<CreateEnrollmentRequest>,
) -> Result<Response, (StatusCode, Json<serde_json::Value>)> { ) -> Result<Response, (StatusCode, Json<serde_json::Value>)> {
// 1. IP-based Rate Limiting // 1. IP-based Rate Limiting
// Prefer real IP from headers if behind proxy (e.g., X-Forwarded-For), else use SocketAddr // Prefer real IP from headers if behind proxy (e.g., X-Forwarded-For)
let ip = headers let ip = headers
.get("x-forwarded-for") .get("x-forwarded-for")
.and_then(|h| h.to_str().ok()) .and_then(|h| h.to_str().ok())
.and_then(|h| h.split(',').next()) .and_then(|h| h.split(',').next())
.and_then(|h| h.trim().parse::<IpAddr>().ok()) .and_then(|h| h.trim().parse::<IpAddr>().ok())
.unwrap_or_else(|| addr.ip()); .unwrap_or_else(|| {
tracing::warn!("No X-Forwarded-For header found for enrollment request from public endpoint");
// Default to a placeholder IP since we can't extract the socket addr without the ConnectInfo layer
"0.0.0.0".parse().unwrap()
});
{ {
let mut rate_limits = state let mut rate_limits = state