Skip to main content

systemprompt_runtime/reporting/
status.rs

1//! Reporting bootstrap state and durable queue lag.
2//!
3//! Copyright (c) systemprompt.io — Business Source License 1.1.
4//! See <https://systemprompt.io> for licensing details.
5
6use systemprompt_analytics::AnalyticsError;
7use systemprompt_analytics::projection::{self, REPORTING_CONSUMER};
8use systemprompt_database::DbPool;
9
10use crate::RuntimeResult;
11
12pub type ReportingStatus = projection::ProjectionStatus;
13
14pub async fn status(db: &DbPool) -> RuntimeResult<ReportingStatus> {
15    let pool = db.write_pool_arc()?;
16    from_pool(&pool).await.map_err(Into::into)
17}
18
19pub(super) async fn from_pool(pool: &sqlx::PgPool) -> Result<ReportingStatus, AnalyticsError> {
20    projection::status(pool, REPORTING_CONSUMER).await
21}