sprawling-wire 0.0.12

// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at https://mozilla.org/MPL/2.0/.
// Copyright (c) 2026 2youg1 and the sprawling contributors

//! Whether one HTTP request may reach the work behind a door.
//!
//! The socket's peer is judged at the hello frame, and judged again
//! whenever the door ends a session token, so a forgotten browser loses
//! the sockets it already opened (`crates/wire/spec/Server/Sessions.lean` §8-93s);
//! a POST has no session, so every request is judged on its own. Both
//! judgements are [`Keys::pairing`], and they live in `reception` rather
//! than in the shell that calls them.

use kernel::{AxCode, AxError, TimeMs};

use super::BindFace;
use super::sessions::Sessions;
use crate::auth::{self, Pairing};

/// Every credential this city accepts at this moment: the face's key,
/// and the browsers' session tokens that admit at `now`. One value,
/// because the two are one question
/// (`crates/wire/spec/Reception/Admission.lean` §8-40).
#[derive(Debug, Clone, Copy)]
pub struct Keys<'a> {
    pub face: &'a BindFace,
    pub sessions: &'a Sessions,
    pub now: TimeMs,
}

impl Keys<'_> {
    /// Whether `offered` is this city's key or a live session token.
    #[must_use]
    pub fn pairing(&self, offered: Option<&str>) -> Pairing {
        let Some(offered) = offered else {
            return Pairing::Absent;
        };
        if auth::verify(Some(offered), self.face.key()) || self.sessions.holds(offered, self.now) {
            Pairing::Held
        } else {
            Pairing::Absent
        }
    }
}

/// What a live socket does once the door may have ended a session token:
/// it goes on while the credential its hello showed still admits, and
/// ends with the refusal once it does not.
#[derive(Debug)]
pub enum Standing {
    Stands,
    Ends(Box<AxError>),
}

/// Judges a live socket again, from what [`Keys::pairing`] says now of
/// the credential its hello showed. The native key always stands; a
/// session token stands until its device is forgotten.
#[must_use]
pub fn decide_standing(pairing: Pairing) -> Standing {
    match pairing {
        Pairing::Held => Standing::Stands,
        Pairing::Absent => Standing::Ends(Box::new(
            AxError::failure(
                AxCode::GateDenied,
                "keep a browser session open",
                "this browser was forgotten, or its session token has ended",
            )
            .with_recovery(
                "pair this browser again with the pairing code the terminal shows; a browser \
                 the city still knows reconnects by itself",
            ),
        )),
    }
}

/// Which HTTP door a request arrived at.
///
/// Exhaustive, because the pairing rule is not the same at all three:
/// a door that answers a stranger with a refusal and a door that lets
/// the refusal be worded further inward are different rules, and a
/// boolean would let a new door inherit whichever one was nearer.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum Door {
    /// `POST /transcribe`: bytes that cost money at a provider.
    Transcribe,
    /// `POST /enroll`: a credential on its way to the vault.
    Enroll,
    /// `POST /acp`: an outside editor driving the city.
    Acp,
    /// `POST /drop`: a file written onto the city's disk.
    Drop,
}

/// What a door does with one request, before any of its bytes are read.
#[derive(Debug)]
pub enum Admission {
    /// Let it through, carrying whether the caller held the token. Only
    /// [`Door::Acp`] is ever admitted unpaired.
    Admit(Pairing),
    Refuse(AxError),
}

/// Decides whether one HTTP request may reach the work behind a door,
/// once [`Keys::pairing`] has judged what it offered.
///
/// **The one place an HTTP caller's credential decides a door.** Every
/// face demands a key, so a caller with nothing is turned away from the
/// three doors that act wherever the city listens.
///
/// [`Door::Acp`] is admitted without one on purpose: what an
/// unauthenticated editor may learn is `agent_protocols::admit`'s to
/// word, and it words it so that a stranger learns exactly one bit.
#[must_use]
pub fn decide_admission(door: Door, pairing: Pairing) -> Admission {
    let action = match (pairing, door) {
        (Pairing::Held, _) => return Admission::Admit(Pairing::Held),
        (Pairing::Absent, Door::Acp) => return Admission::Admit(Pairing::Absent),
        (Pairing::Absent, Door::Transcribe) => "transcribe a recording",
        (Pairing::Absent, Door::Enroll) => "enrol a credential",
        (Pairing::Absent, Door::Drop) => "keep a dropped file",
    };
    Admission::Refuse(
        AxError::failure(
            AxCode::GateDenied,
            action,
            "the request carried neither this city's key nor a live session token",
        )
        .with_recovery(
            "send the session token or the city's key as an `Authorization: Bearer` header; \
             a program on this machine reads the key from the city's key file",
        ),
    )
}

/// The one spelling of how an HTTP caller offers the pairing token.
///
/// The socket offers it inside the hello frame, where the frame type
/// names the field; a POST has no frame, so it carries the standard
/// bearer header and this function is where that scheme is read. A
/// value that is not a bearer token is no token at all rather than a
/// token that happens to fail, so a caller cannot learn the scheme by
/// watching which refusal it gets.
#[must_use]
pub fn offered_pairing(header: Option<&str>) -> Option<&str> {
    let raw = header?.trim();
    let (scheme, token) = raw.split_once(' ')?;
    scheme
        .eq_ignore_ascii_case("Bearer")
        .then(|| token.trim())
        .filter(|token| !token.is_empty())
}

#[cfg(test)]
#[allow(clippy::panic, reason = "test code")]
mod tests {
    use super::*;

    #[test]
    fn the_acting_doors_refuse_an_empty_hand_and_the_editor_door_carries_the_bit() {
        for door in [Door::Transcribe, Door::Enroll, Door::Drop] {
            let Admission::Refuse(err) = decide_admission(door, Pairing::Absent) else {
                panic!("{door:?} acts on a request, so it refuses an unpaired one");
            };
            assert_eq!(*err.code(), AxCode::GateDenied);
        }
        assert!(matches!(
            decide_admission(Door::Acp, Pairing::Absent),
            Admission::Admit(Pairing::Absent)
        ));
    }

    #[test]
    fn the_key_and_nothing_else_is_held_on_a_loopback_face() {
        let face = BindFace::Loopback {
            key: kernel::B3Hash::digest(b"native-key"),
        };
        let sessions = Sessions::default();
        let keys = Keys {
            face: &face,
            sessions: &sessions,
            now: kernel::TimeMs::new(0),
        };
        assert_eq!(keys.pairing(Some("native-key")), Pairing::Held);
        assert_eq!(keys.pairing(Some("guess")), Pairing::Absent);
        assert_eq!(keys.pairing(None), Pairing::Absent);
    }

    #[test]
    fn only_a_bearer_header_offers_a_token() {
        assert_eq!(offered_pairing(Some("Bearer abc")), Some("abc"));
        assert_eq!(offered_pairing(Some("bearer  abc ")), Some("abc"));
        assert_eq!(offered_pairing(Some("Basic abc")), None);
        assert_eq!(offered_pairing(Some("abc")), None);
        assert_eq!(offered_pairing(Some("Bearer ")), None);
        assert_eq!(offered_pairing(None), None);
    }
}