Struct Supervisor

pub struct Supervisor {
    f_cont_lock: Arc<RwLock<FlightComputer>>,
    safe_mon: Arc<Notify>,
    zo_mon: Sender<KnownImgObjective>,
    bo_mon: Sender<BeaconObjective>,
    event_hub: Sender<(DateTime<Utc>, String)>,
    current_secret_objectives: RwLock<Vec<ImageObjective>>,
}

The Supervisor is responsible for high-level management of active operations, including observation tracking, secret objective handling, daily map uploads, safe-mode monitoring, and real-time event listening.

It acts as coordinator between observation, event streams, and objective scheduling, while ensuring asynchronous notifications and channel-based communication between system components.

Fields

f_cont_lock: Arc<RwLock<FlightComputer>>

Lock-protected reference to the FlightComputer, used for updating the global observation.

safe_mon: Arc<Notify>

Notifier that signals when a safe-mode transition is detected.

zo_mon: Sender<KnownImgObjective>

Channel for sending newly discovered zoned objectives to the main scheduling system.

bo_mon: Sender<BeaconObjective>

Channel for sending active beacon objectives to the main scheduling system.

event_hub: Sender<(DateTime<Utc>, String)>

Broadcast channel for relaying real-time mission announcements or telemetry updates.

current_secret_objectives: RwLock<Vec<ImageObjective>>

In-memory buffer of currently known secret imaging objectives that await triggering.

Implementations

impl Supervisor

const OBS_UPDATE_INTERVAL: Duration

Constant update interval for observation updates in the run() method

const OBJ_UPDATE_INTERVAL: TimeDelta

Constant update interval for objective updates in the run() method

const B_O_MIN_DT: TimeDelta

Constant minimum time delta to the objective start for sending the objective to main

const ENV_SKIP_OBJ: &'static str = "SKIP_OBJ"

Environment variable used to skip known objectives by ID (comma-separated).

pub(crate) fn new( f_cont_lock: Arc<RwLock<FlightComputer>>, ) -> (Supervisor, Receiver<KnownImgObjective>, Receiver<BeaconObjective>)

Creates a new Supervisor instance and returns associated receivers for zoned and beacon objectives.

Arguments

• f_cont_lock – Shared lock to the flight computer state.

Returns

Tuple of (Supervisor, zo_receiver, bo_receiver)

pub(crate) fn safe_mon(&self) -> Arc<Notify>

Returns a clone of the safe-mode notifier.

pub(crate) fn subscribe_event_hub(&self) -> Receiver<(DateTime<Utc>, String)>

Subscribes to the event hub to receive mission announcement broadcasts.

pub(crate) async fn run_announcement_hub(&self)

Listens to the /announcements Event Source endpoint and broadcasts messages to subscribers.

Automatically closes on error and logs termination as fatal.

pub(crate) async fn run_daily_map_uploader(&self, c_cont: Arc<CameraController>)

Triggers daily full map export and upload at 22:55 UTC.

This repeats daily and logs errors upon failure.

Arguments

• c_cont – Shared reference to the CameraController.

pub(crate) async fn schedule_secret_objective(&self, id: usize, zone: [i32; 4])

Receive and schedule a secret objective id and assigns coordinates to it if valid. This is called by the user console when assigning a zone to a secret objective.

Only triggers if the objective is currently active and not expired.

Arguments

• id – Unique identifier of the objective.
• zone – Assigned coordinates [x_1, y_1, x_2, y_2].

pub(crate) async fn run_obs_obj_mon(&self)

Main observation loop that:

• Monitors for safe-mode transitions.
• Periodically polls objectives from the backend.
• Filters and sends active objectives to downstream systems.

Includes ID caching, secret filtering, and fail-safe alerts.

fn prefill_id_list(id_list: &mut HashSet<usize>)

Reads the environment variable SKIP_OBJ and adds valid IDs to the internal filter list.

Used to prevent repeat processing of already completed or irrelevant objectives.

Arguments

• id_list – A mutable reference to the set of objective IDs.