bestool-alertd 14.2.0

//! Patient communications that errored within the lookback window.

use jiff::{Timestamp, ToSpan};

use super::{CheckContext, util::tiered_rows_check};
use crate::doctor::check::Check;
use bestool_tamanu::ApiServerKind;

const NAME: &str = "patient_communication_errors";
const SQL: &str = "SELECT * FROM patient_communications \
	WHERE status = 'Error' AND created_at > $1 ORDER BY created_at DESC";

// Lookback window for recent-error checks.
const LOOKBACK_HOURS: i64 = 1;

pub async fn run(ctx: CheckContext) -> Check {
	if ctx.kind != ApiServerKind::Central {
		return Check::skip(
			NAME,
			"not applicable on facility server",
			"central-only check",
		);
	}
	let Some(client) = ctx.db.as_ref() else {
		return Check::skip(NAME, "no DB connection", "db unavailable");
	};

	let since = Timestamp::now() - LOOKBACK_HOURS.hours();
	tiered_rows_check(
		client,
		"patient_communication_errors",
		"no recent patient communication errors",
		"patient communication errors: ",
		SQL,
		&[&since],
		1,
		10,
	)
	.await
}

#[cfg(test)]
mod tests {
	use crate::doctor::checks::test_support::{central_ctx, facility_ctx};

	#[tokio::test]
	async fn runs_against_central() {
		let Some(ctx) = central_ctx().await else {
			return;
		};
		let check = super::run(ctx).await;
		assert_eq!(check.name, "patient_communication_errors");
	}

	#[tokio::test]
	async fn skips_on_facility() {
		let check = super::run(facility_ctx()).await;
		assert!(check.status.is_skip());
	}
}