97 lines
4.0 KiB
Rust
97 lines
4.0 KiB
Rust
use std::sync::Arc;
|
|
use async_trait::async_trait;
|
|
use sqlx::PgPool;
|
|
|
|
use activitypub::ThoughtsObjectHandler;
|
|
use activitypub_base::{ApFederationConfig, FederationData};
|
|
use domain::{errors::DomainError, events::DomainEvent, ports::EventPublisher};
|
|
use event_transport::EventPublisherAdapter;
|
|
use nats::NatsTransport;
|
|
use postgres::activitypub::PgActivityPubRepository;
|
|
use postgres_federation::{PostgresApUserRepository, PostgresFederationRepository};
|
|
use presentation::state::AppState;
|
|
|
|
use crate::config::Config;
|
|
|
|
/// Everything the binary needs to start serving.
|
|
pub struct Infrastructure {
|
|
pub state: AppState,
|
|
pub fed_config: ApFederationConfig,
|
|
}
|
|
|
|
struct NoOpEventPublisher;
|
|
|
|
#[async_trait]
|
|
impl EventPublisher for NoOpEventPublisher {
|
|
async fn publish(&self, _e: &DomainEvent) -> Result<(), DomainError> { Ok(()) }
|
|
}
|
|
|
|
pub async fn build(cfg: &Config) -> Infrastructure {
|
|
// 1. Database connection + migrations
|
|
let pool = PgPool::connect(&cfg.database_url)
|
|
.await
|
|
.expect("Failed to connect to database");
|
|
sqlx::migrate!("../adapters/postgres/migrations")
|
|
.run(&pool)
|
|
.await
|
|
.expect("Failed to run migrations");
|
|
tracing::info!("Database connected and migrations applied");
|
|
|
|
// 2. Event publisher — real NATS or no-op fallback
|
|
let event_publisher: Arc<dyn EventPublisher> = match &cfg.nats_url {
|
|
Some(url) => match async_nats::connect(url).await {
|
|
Ok(client) => {
|
|
tracing::info!("Connected to NATS at {url}");
|
|
Arc::new(EventPublisherAdapter::new(NatsTransport::new(client)))
|
|
}
|
|
Err(e) => {
|
|
tracing::warn!("NATS connect failed ({e}) — falling back to no-op publisher");
|
|
Arc::new(NoOpEventPublisher)
|
|
}
|
|
},
|
|
None => {
|
|
tracing::info!("NATS_URL not set — using no-op event publisher");
|
|
Arc::new(NoOpEventPublisher)
|
|
}
|
|
};
|
|
|
|
// 3. ActivityPub federation
|
|
let fed_data = FederationData::new(
|
|
Arc::new(PostgresFederationRepository::new(pool.clone())),
|
|
Arc::new(PostgresApUserRepository::new(pool.clone(), cfg.base_url.clone())),
|
|
Arc::new(ThoughtsObjectHandler::new(
|
|
Arc::new(PgActivityPubRepository::new(pool.clone())),
|
|
&cfg.base_url,
|
|
)),
|
|
cfg.base_url.clone(),
|
|
cfg.allow_registration,
|
|
"thoughts".to_string(),
|
|
None,
|
|
);
|
|
let fed_config = ApFederationConfig::new(fed_data, cfg.debug)
|
|
.await
|
|
.expect("Failed to build federation config");
|
|
|
|
// 4. Application state
|
|
let state = AppState {
|
|
users: Arc::new(postgres::user::PgUserRepository::new(pool.clone())),
|
|
thoughts: Arc::new(postgres::thought::PgThoughtRepository::new(pool.clone())),
|
|
likes: Arc::new(postgres::like::PgLikeRepository::new(pool.clone())),
|
|
boosts: Arc::new(postgres::boost::PgBoostRepository::new(pool.clone())),
|
|
follows: Arc::new(postgres::follow::PgFollowRepository::new(pool.clone())),
|
|
blocks: Arc::new(postgres::block::PgBlockRepository::new(pool.clone())),
|
|
tags: Arc::new(postgres::tag::PgTagRepository::new(pool.clone())),
|
|
api_keys: Arc::new(postgres::api_key::PgApiKeyRepository::new(pool.clone())),
|
|
top_friends: Arc::new(postgres::top_friend::PgTopFriendRepository::new(pool.clone())),
|
|
notifications: Arc::new(postgres::notification::PgNotificationRepository::new(pool.clone())),
|
|
remote_actors: Arc::new(postgres::remote_actor::PgRemoteActorRepository::new(pool.clone())),
|
|
feed: Arc::new(postgres::feed::PgFeedRepository::new(pool.clone())),
|
|
search: Arc::new(postgres_search::PgSearchRepository::new(pool.clone())),
|
|
auth: Arc::new(auth::JwtAuthService::new(cfg.jwt_secret.clone(), 86400 * 30)),
|
|
hasher: Arc::new(auth::Argon2PasswordHasher),
|
|
events: event_publisher,
|
|
};
|
|
|
|
Infrastructure { state, fed_config }
|
|
}
|