Struct AtrgApp 

pub struct AtrgApp { /* private fields */ }

The application builder. Accumulates user routers and configuration, then boots the full server when AtrgApp::run is called.

Implementations

impl AtrgApp

pub fn new() -> Self

Create a new, empty application builder.

pub fn mount(self, router: Router<AppState>) -> Self

Mount an additional [axum::Router] into the application.

Routes are merged, so multiple calls to mount accumulate routes.

pub fn with_auth_routes(self, router: Router<AppState>) -> Self

Register built-in auth routes (OAuth login/callback/logout, client-metadata, well-known).

The supplied router is merged before user routes so that atrg’s built-in endpoints take precedence.

Example

use atrg_core::AtrgApp;

AtrgApp::new()
    .with_auth_routes(atrg_auth::routes::auth_router())
    // ...

pub fn with_cleanup_task<F>(self, f: F) -> Self

where F: FnOnce(DbPool) + Send + 'static,

Register a background cleanup task that is spawned after the server starts. Typically used for periodic session / OAuth-state expiry.

The callback receives the [DbPool] and is expected to call tokio::spawn internally.

pub fn with_db_pool(self, pool: impl Into<DbPool>) -> Self

Use a caller-provided database pool instead of opening a fresh one from [database] url.

This is the recommended way to integrate atrg into an existing application that already manages its own connection pool — for example, a service that uses PostgreSQL for its business data and wants atrg’s internal tables (sessions, OAuth state) to live in the same database:

let pool = sqlx::PgPool::connect(&db_url).await?;

AtrgApp::new()
    .with_db_pool(pool.into())   // accepts SqlitePool, PgPool, or DbPool
    .mount(routes::api())
    .run()
    .await

When a pool is provided this way, [database] url from atrg.toml is ignored. atrg’s internal migrations are still applied to the supplied pool on startup.

pub fn with_extension<T: Send + Sync + 'static>(self, value: T) -> Self

Register an app-specific extension value.

Extensions are type-erased values accessible from any handler via AppState::extension::<T>() or AppState::try_extension::<T>().

Each type can appear at most once — inserting a second value of the same type replaces the first.

Examples

struct S3Client { bucket: String }
struct SmtpConfig { host: String }

AtrgApp::new()
    .with_extension(S3Client { bucket: "my-blobs".into() })
    .with_extension(SmtpConfig { host: "smtp.example.com".into() })
    .mount(routes())
    .run()
    .await

pub fn on_event<F, Fut>(self, handler: F) -> Self

where F: Fn(JetstreamEvent, AppState) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Register a Jetstream event handler.

The handler is called for every event received from the Jetstream firehose. It is spawned as a background task inside AtrgApp::run when [jetstream] is present in atrg.toml.

pub fn on_firehose_event<F, Fut>(self, handler: F) -> Self

where F: Fn(FirehoseEvent, AppState) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Register a firehose event handler.

The handler is called for every event received from the AT Protocol relay firehose (com.atproto.sync.subscribeRepos). It is spawned as a background task inside AtrgApp::run when [firehose] is present in atrg.toml.

pub fn with_feed_generator(self, feed_router: Router<AppState>) -> Self

Mount a feed generator’s routes.

Pass the router produced by FeedGenerator::into_router() (from the atrg-feed crate). This is a semantic alias for mount that makes the builder read more clearly.

Example

AtrgApp::new()
    .with_feed_generator(feed_gen.into_router())

pub fn with_labeler(self, labeler_router: Router<AppState>) -> Self

Mount a labeler service’s routes.

Pass the router produced by labeler_routes() (from the atrg-label crate). This is a semantic alias for mount that makes the builder read more clearly.

Example

AtrgApp::new()
    .with_labeler(atrg_label::routes::labeler_routes(service))

pub async fn run(self) -> Result<()>

Boot the server.

This is the only async entry point. It:

1. Initialises tracing (respects RUST_LOG).
2. Loads atrg.toml (or $ATRG_CONFIG).
3. Connects to SQLite and runs migrations.
4. Builds AppState (including the identity resolver).
5. Assembles the Axum router with CORS, tracing, and a JSON 404 fallback.
6. Spawns optional cleanup tasks.
7. Binds a TCP listener and serves.

Trait Implementations

impl Default for AtrgApp

fn default() -> Self

Returns the “default value” for a type.