Function unregister_server

mserver/MasterService/src/http.rs:602–647

(
    State(state): State<AppState>,
    headers: HeaderMap,
    Path(server_id): Path<String>,
)

    match state.service.mod_artifact_stream(&mod_id).await {
        Ok(Some((size, stream))) => {
            // Stream the artifact straight from the store — never buffer the whole file.
            let headers = [
                (CONTENT_TYPE, "application/octet-stream".to_string()),
                (
                    CONTENT_DISPOSITION,
                    format!("attachment; filename=\"{mod_id}.pbo\""),
                ),
                (CONTENT_LENGTH, size.to_string()),
            ];
            (headers, Body::from_stream(stream)).into_response()
        }
        Ok(None) => StatusCode::NOT_FOUND.into_response(),
        Err(_) => StatusCode::INTERNAL_SERVER_ERROR.into_response(),
    }
}

async fn read_text_field(
    field: axum::extract::multipart::Field<'_>,
) -> Result<String, (StatusCode, String)> {
    field
        .text()
        .await
        .map_err(|error| (StatusCode::BAD_REQUEST, error.to_string()))
}

#[utoipa::path(
    delete,
    path = "/v1/servers/{serverId}",
    params(
        ("serverId" = String, Path, description = "Server identifier")
    ),
    responses(
        (status = 204, description = "Server removed"),
        (status = 404, description = "Server not found")
    )
)]
async fn unregister_server(
    State(state): State<AppState>,
    headers: HeaderMap,
    Path(server_id): Path<String>,
) -> Result<StatusCode, (StatusCode, String)> {
    // Only the owning IP may unregister its server (server_id is "<ip>:<port>").
    if let Some(ip) = caller_client_ip(&state, &headers) {
        let owner_ip = server_id
            .rsplit_once(':')
            .map_or(server_id.as_str(), |(host, _)| host);
        if owner_ip != ip {
            return Err((
                StatusCode::FORBIDDEN,