feat(bootstrap): wire ApiKeyServiceImpl + PgEngagementRepository
This commit is contained in:
@@ -7,10 +7,12 @@ use std::sync::Arc;
|
|||||||
|
|
||||||
use activitypub::ThoughtsObjectHandler;
|
use activitypub::ThoughtsObjectHandler;
|
||||||
use activitypub_base::service::ActivityPubService;
|
use activitypub_base::service::ActivityPubService;
|
||||||
|
use auth::ApiKeyServiceImpl;
|
||||||
use domain::{errors::DomainError, events::DomainEvent, ports::{EventPublisher, OutboxWriter}};
|
use domain::{errors::DomainError, events::DomainEvent, ports::{EventPublisher, OutboxWriter}};
|
||||||
use event_transport::EventPublisherAdapter;
|
use event_transport::EventPublisherAdapter;
|
||||||
use nats::NatsTransport;
|
use nats::NatsTransport;
|
||||||
use postgres::activitypub::PgActivityPubRepository;
|
use postgres::activitypub::PgActivityPubRepository;
|
||||||
|
use postgres::engagement::PgEngagementRepository;
|
||||||
use postgres::outbox::PgOutboxWriter;
|
use postgres::outbox::PgOutboxWriter;
|
||||||
use postgres::remote_actor_connections::PgRemoteActorConnectionRepository;
|
use postgres::remote_actor_connections::PgRemoteActorConnectionRepository;
|
||||||
use postgres_federation::{PostgresApUserRepository, PostgresFederationRepository};
|
use postgres_federation::{PostgresApUserRepository, PostgresFederationRepository};
|
||||||
@@ -127,6 +129,10 @@ pub async fn build(cfg: &Config) -> Infrastructure {
|
|||||||
ap_repo: Arc::new(PgActivityPubRepository::new(pool.clone())),
|
ap_repo: Arc::new(PgActivityPubRepository::new(pool.clone())),
|
||||||
remote_actor_connections: Arc::new(PgRemoteActorConnectionRepository::new(pool.clone())),
|
remote_actor_connections: Arc::new(PgRemoteActorConnectionRepository::new(pool.clone())),
|
||||||
federation_scheduler: ap_service.clone() as Arc<dyn domain::ports::FederationSchedulerPort>,
|
federation_scheduler: ap_service.clone() as Arc<dyn domain::ports::FederationSchedulerPort>,
|
||||||
|
api_key_auth: Arc::new(ApiKeyServiceImpl::new(
|
||||||
|
Arc::new(postgres::api_key::PgApiKeyRepository::new(pool.clone())),
|
||||||
|
)),
|
||||||
|
engagement: Arc::new(PgEngagementRepository::new(pool.clone())),
|
||||||
};
|
};
|
||||||
|
|
||||||
Infrastructure { state, ap_service }
|
Infrastructure { state, ap_service }
|
||||||
|
|||||||
@@ -133,5 +133,7 @@ pub fn make_state() -> AppState {
|
|||||||
ap_repo: Arc::new(NoOpApRepo),
|
ap_repo: Arc::new(NoOpApRepo),
|
||||||
remote_actor_connections: store.clone(),
|
remote_actor_connections: store.clone(),
|
||||||
federation_scheduler: store.clone(),
|
federation_scheduler: store.clone(),
|
||||||
|
api_key_auth: store.clone(),
|
||||||
|
engagement: store.clone(),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user