radicle-explorer/crates/test-http-api/src/lib.rs

use std::net::SocketAddr;
use std::sync::Arc;

use axum::Router;
use tokio::net::TcpListener;

use radicle::cob::cache::COBS_DB_FILE;
use radicle::Profile;

use radicle_types::domain::patch::service::Service as PatchService;

mod api;

#[derive(Debug, Clone)]
pub struct Options {
    pub listen: SocketAddr,
}

pub async fn run(options: Options) -> anyhow::Result<()> {
    let profile = Profile::load()?;
    let listener = TcpListener::bind(options.listen).await?;
    let app = router(profile)?.into_make_service_with_connect_info::<SocketAddr>();

    axum::serve(listener, app)
        .await
        .map_err(anyhow::Error::from)
}

fn router(profile: Profile) -> anyhow::Result<Router> {
    let profile = Arc::new(profile);

    let patch_db =
        radicle_types::outbound::sqlite::Sqlite::reader(profile.cobs().join(COBS_DB_FILE))?;
    let patch_service = PatchService::new(patch_db);

    let ctx = api::Context::new(profile, Arc::new(patch_service));

    Ok(api::router(ctx))
}