systemprompt-api 0.32.2

//! Bridges database outbox events into the in-process event bus.
//!
//! The relay takes the **write** pool: `LISTEN`/`NOTIFY`, the outbox insert,
//! and the retention prune all require the primary, and a read pool may be
//! pointed at a standby. `write_pool()` falls back to the read pool when no
//! separate write URL is configured.
//!
//! Copyright (c) systemprompt.io — Business Source License 1.1.
//! See <https://systemprompt.io> for licensing details.

use systemprompt_events::PostgresEventBridge;
use systemprompt_runtime::AppContext;

pub(in crate::services::server) fn start_event_bridge(ctx: &AppContext) {
    let Some(pool) = ctx.db_pool().write_pool() else {
        tracing::info!("No Postgres pool; cross-replica event relay disabled");
        return;
    };

    let handle = PostgresEventBridge::new(pool.as_ref().clone()).start();

    if ctx.event_bridge().set(handle).is_err() {
        tracing::warn!("Event bridge already started; ignoring duplicate start");
    } else {
        tracing::info!("Cross-replica event relay started");
    }
}