bestool-alertd 2.0.2

use std::{sync::Arc, time::Duration};

use axum::response::IntoResponse;
use bestool_alertd::InternalContext;
use tokio::sync::mpsc;

#[tokio::test]
async fn test_reload_command_when_no_daemon_running() {
	// This test verifies that the reload command fails gracefully when no daemon is running
	let client = reqwest::Client::new();

	let result = client
		.get("http://127.0.0.1:8271/status")
		.timeout(Duration::from_secs(1))
		.send()
		.await;

	// If there's no daemon running, the request should fail
	// (either connection refused or timeout)
	assert!(result.is_err());
}

#[tokio::test]
async fn test_status_endpoint_response_format() {
	// Start a mock HTTP server
	let (reload_tx, _reload_rx) = mpsc::channel::<()>(10);
	let started_at = jiff::Timestamp::now();
	let pid = std::process::id();

	let db_url = std::env::var("DATABASE_URL").expect("DATABASE_URL must be set for tests");
	let pool = bestool_postgres::pool::create_pool(&db_url, "bestool-alertd-test")
		.await
		.unwrap();
	let ctx = Arc::new(InternalContext {
		pg_pool: pool.clone(),
		http_client: reqwest::Client::new(),
		canopy_client: None,
	});

	let scheduler = Arc::new(bestool_alertd::scheduler::Scheduler::new(
		vec![],
		ctx.clone(),
		None,
		true,
	));

	let state = Arc::new(bestool_alertd::http_server::ServerState {
		reload_tx,
		started_at,
		pid,
		event_manager: None,
		internal_context: ctx,
		email_config: None,
		dry_run: true,
		scheduler,
		watchdog_timeout: None,
	});

	// This verifies the response structure without needing a full daemon
	let response = bestool_alertd::http_server::handle_status(axum::extract::State(state))
		.await
		.into_response();

	assert_eq!(response.status(), axum::http::StatusCode::OK);

	let body = axum::body::to_bytes(response.into_body(), usize::MAX)
		.await
		.unwrap();
	let status: serde_json::Value = serde_json::from_slice(&body).unwrap();

	assert_eq!(status["name"], "bestool-alertd");
	assert!(status["version"].is_string());
	assert!(status["started_at"].is_string());
	assert_eq!(status["pid"], pid);
}