System Initiative

use std::{ sync::Arc, time::Duration, }; use dal::DalContextBuilder; use frigg::FriggStore; use si_data_nats::{ NatsClient, async_nats::jetstream, }; use tokio_util::{ sync::CancellationToken, task::TaskTracker, }; use crate::{ ServerMetadata, updates::EddaUpdates, }; /// Application state. #[derive(Clone, Debug)] pub(crate) struct AppState { pub(crate) metadata: Arc<ServerMetadata>, pub(crate) nats: NatsClient, pub(crate) frigg: FriggStore, pub(crate) edda_updates: EddaUpdates, pub(crate) parallel_build_limit: usize, pub(crate) requests_stream: jetstream::stream::Stream, pub(crate) ctx_builder: DalContextBuilder, pub(crate) quiescent_period: Duration, pub(crate) token: CancellationToken, pub(crate) server_tracker: TaskTracker, } impl AppState { /// Creates a new [`AppState`]. #[allow(clippy::too_many_arguments)] pub(crate) fn new( metadata: Arc<ServerMetadata>, nats: NatsClient, frigg: FriggStore, edda_updates: EddaUpdates, parallel_build_limit: usize, requests_stream: jetstream::stream::Stream, ctx_builder: DalContextBuilder, quiescent_period: Duration, token: CancellationToken, server_tracker: TaskTracker, ) -> Self { Self { metadata, nats, frigg, edda_updates, parallel_build_limit, requests_stream, ctx_builder, quiescent_period, token, server_tracker, } } }