OxygenFlow claims hand a runner only jobs whose sandbox fits the room it reports; oxygenflow pin moved to the budgeted runner 76bc5a058351

/// What a runner can take on: free memory (MiB) and vCPUs, `None` for no limit.

#[derive(Clone, Copy, Debug, Default)]

pub struct Room {

    pub memory_mib: Option<u32>,

    pub cpus: Option<u32>,

}

impl Room {

    /// Whether a job's sandbox (its stored JSON) fits.

    pub fn fits(&self, sandbox_json: &str) -> bool {

        let v: serde_json::Value = serde_json::from_str(sandbox_json).unwrap_or_default();

        let need = |k: &str| v[k].as_u64().unwrap_or(0);

        self.memory_mib.is_none_or(|m| need("memory_mib") <= m as u64) && self.cpus.is_none_or(|c| need("cpus") <= c as u64)

    }

}

    claim_within(pool, runtimes, runner, token_hash, Room::default()).await

}

/// The oldest runnable job that fits in `room`.

pub async fn claim_within(pool: &Pool, runtimes: &[String], runner: &str, token_hash: &str, room: Room) -> sqlx::Result<Option<Job>> {

        if !runtimes.iter().any(|r| r == &j.runtime) || !room.fits(&j.sandbox) {

    let room = fdb::Room { memory_mib: req.free_memory_mib, cpus: req.free_cpus };

    let Some(job) = fdb::claim_within(&app.db, &req.runtimes, &runner, &crate::auth::token_hash(&secret), room).await? else {