events.rsWhat happened on the site, kept: the Worker makes an archive::Event of
every request worth keeping and hands it to the archive, which writes it
as a row of events. The event itself, and what it reads from a request,
is packages/archive/src/event.rs; here is only what needs the Worker:
Cloudflare's account of where the request came from, and the sending.
The request as an event, before it is known what came of it.
11pub fn of(request: &HttpRequest) -> Event { 12 let headers = request.headers(); 13 let ip = headers.get("cf-connecting-ip").and_then(|value| value.to_str().ok()).unwrap_or_default().to_owned(); 14 let origin = match request.extensions().get::<worker::Cf>() { 15 Some(cf) => { 16 let coordinates = cf.coordinates(); 17 Origin { 18 ip, 19 country: cf.country().unwrap_or_default(), 20 region: cf.region().unwrap_or_default(), 21 city: cf.city().unwrap_or_default(), 22 postcode: cf.postal_code().unwrap_or_default(), 23 timezone: cf.timezone_name(), 24 latitude: coordinates.map(|(latitude, _)| f64::from(latitude)), 25 longitude: coordinates.map(|(_, longitude)| f64::from(longitude)), 26 asn: cf.asn(), 27 network: cf.as_organization().unwrap_or_default(), 28 colo: cf.colo(), 29 protocol: cf.http_protocol(), 30 tls: cf.tls_version(), 31 } 32 } 33 None => Origin { ip, ..Origin::default() }, 34 }; 35 Event::from(request.method(), request.uri(), headers, crate::browser(headers), origin) 36}
Keeps the event. A failure loses that one row and nothing else.
A name for how an ask ended.
44pub fn ending(ending: Option<&crate::view::Ending>) -> &'static str { 45 use crate::view::Ending; 46 match ending { 47 None => "", 48 Some(Ending::Empty) => "empty", 49 Some(Ending::NotAQuestion { .. }) => "refused", 50 Some(Ending::Answered) => "answered", 51 Some(Ending::Slow) => "slow", 52 Some(Ending::NoQuestion) => "no-question", 53 Some(Ending::Failed { .. }) => "failed", 54 Some(Ending::Offline) => "offline", 55 Some(Ending::Spent { .. }) => "spent", 56 Some(Ending::NotKept { .. }) => "not-kept", 57 } 58}