Skip to main content

server_watchdog/infrastructure/config/
client.rs

1use std::error::Error;
2use std::sync::Arc;
3use async_trait::async_trait;
4use derive_new::new;
5use crate::application::config::ClientConfigUseCase;
6use crate::domain::config::{ClientConfig, Config};
7use crate::domain::file_accessor::FileAccessor;
8
9#[derive(new)]
10pub struct ClientConfigAdapter {
11    config_file_accessor: Arc<dyn FileAccessor<Config> + Send + Sync>
12}
13
14#[async_trait]
15impl ClientConfigUseCase for ClientConfigAdapter {
16    async fn add_client(&self, client_config: ClientConfig) -> Result<(), Box<dyn Error + Send + Sync>> {
17        let mut config = self.config_file_accessor.read().await?;
18        config.clients.push(client_config);
19        self.config_file_accessor.write(&config).await?;
20        Ok(())
21    }
22
23    async fn list_client(&self) -> Result<Vec<ClientConfig>, Box<dyn Error + Send + Sync>> {
24        let config = self.config_file_accessor.read().await?;
25        Ok(config.clients)
26    }
27}