ryra-core 0.3.1

Core library for ryra: config, registry, and service generation logic
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

use std::collections::HashSet;

use crate::error::{Error, Result};

const PORT_RANGE_START: u16 = 10000;
const PORT_RANGE_END: u16 = 11000;

/// Allocate the next available port from the range, skipping:
/// 1. Ports already assigned to installed services (from `config`)
/// 2. Ports in `extra_used` (for services with multiple `[[ports]]` entries —
///    e.g. ente-web publishing 3000/3002/3003 to distinct host ports)
/// 3. Ports reported as bound by `port_in_use`
///
/// The `port_in_use` callback is passed in rather than probing directly so
/// core can stay deterministic under test and so planning has no system-state
/// side effects: the CLI owns the actual `TcpListener::bind` probe.
pub fn allocate_port_excluding(
    extra_used: &HashSet<u16>,
    port_in_use: &dyn Fn(u16) -> bool,
) -> Result<u16> {
    // Ports already claimed by previously-installed services come from
    // the quadlet directory's `.env` files (the source of truth) via
    // `list_installed()` — preferences.toml no longer tracks them.
    let mut used: HashSet<u16> = crate::list_installed()
        .unwrap_or_default()
        .into_iter()
        .flat_map(|s| s.ports.into_values())
        .collect();
    used.extend(extra_used.iter().copied());

    (PORT_RANGE_START..PORT_RANGE_END)
        .find(|p| !used.contains(p) && !port_in_use(*p))
        .ok_or(Error::PortsExhausted {
            start: PORT_RANGE_START,
            end: PORT_RANGE_END,
        })
}