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(SqlitePool) + 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 [SqlitePool] and is expected to call tokio::spawn internally.

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.