use http::Method;
use parlov_core::{NormativeStrength, OracleClass, Technique, Vector};
use crate::context::ScanContext;
use crate::strategy::Strategy;
use crate::types::{ProbeSpec, RiskLevel, StrategyMetadata};
use crate::util::build_pair;
fn metadata() -> StrategyMetadata {
StrategyMetadata {
strategy_id: "emg-query-validation",
strategy_name: "EMG: Query Parameter Validation",
risk: RiskLevel::Safe,
}
}
fn technique() -> Technique {
Technique {
id: "emg-query-validation",
name: "Resource-aware query validation differential",
oracle_class: OracleClass::Existence,
vector: Vector::ErrorMessageGranularity,
strength: NormativeStrength::May,
}
}
pub struct EmgQueryValidation;
impl Strategy for EmgQueryValidation {
fn id(&self) -> &'static str {
"emg-query-validation"
}
fn name(&self) -> &'static str {
"EMG: Query Parameter Validation"
}
fn risk(&self) -> RiskLevel {
RiskLevel::Safe
}
fn methods(&self) -> &[Method] {
&[Method::GET]
}
fn is_applicable(&self, _ctx: &ScanContext) -> bool {
true
}
fn generate(&self, ctx: &ScanContext) -> Vec<ProbeSpec> {
let mut pair = build_pair(
ctx,
Method::GET,
ctx.headers.clone(),
ctx.headers.clone(),
None,
metadata(),
technique(),
);
pair.baseline.url.push_str("?fields=_parlov_invalid");
pair.probe.url.push_str("?fields=_parlov_invalid");
vec![ProbeSpec::Pair(pair)]
}
}
#[cfg(test)]
mod tests {
use super::*;
use http::HeaderMap;
fn make_ctx() -> ScanContext {
ScanContext {
target: "https://api.example.com/users/{id}".to_string(),
baseline_id: "1001".to_string(),
probe_id: "9999".to_string(),
headers: HeaderMap::new(),
max_risk: RiskLevel::Safe,
known_duplicate: None,
state_field: None,
alt_credential: None,
body_template: None,
}
}
#[test]
fn generates_correct_technique_vector() {
let specs = EmgQueryValidation.generate(&make_ctx());
assert_eq!(specs[0].technique().vector, Vector::ErrorMessageGranularity);
}
#[test]
fn generates_correct_technique_strength() {
let specs = EmgQueryValidation.generate(&make_ctx());
assert_eq!(specs[0].technique().strength, NormativeStrength::May);
}
#[test]
fn is_always_applicable() {
assert!(EmgQueryValidation.is_applicable(&make_ctx()));
}
#[test]
fn risk_is_safe() {
assert_eq!(EmgQueryValidation.risk(), RiskLevel::Safe);
}
#[test]
fn generates_get_method() {
let specs = EmgQueryValidation.generate(&make_ctx());
let ProbeSpec::Pair(pair) = &specs[0] else {
panic!("expected Pair variant")
};
assert_eq!(pair.baseline.method, Method::GET);
}
#[test]
fn urls_have_query_param() {
let specs = EmgQueryValidation.generate(&make_ctx());
let ProbeSpec::Pair(pair) = &specs[0] else {
panic!("expected Pair variant")
};
assert!(
pair.baseline.url.contains("?fields=_parlov_invalid"),
"baseline URL missing query param: {}",
pair.baseline.url
);
assert!(
pair.probe.url.contains("?fields=_parlov_invalid"),
"probe URL missing query param: {}",
pair.probe.url
);
}
}