dariusbakunas / cogrs / 13486377277

    async fn init() -> Result<()> {

        let config_manager = ConfigManager::instance();

        config_manager.lock().await.init()?;

        let (cogrs_home, _) = config_manager

            .await

            .ok_or_else(|| anyhow!("`COGRS_HOME` is not defined in the configuration"))?;

        set_plugin_paths(config_manager).await?;

        if !cogrs_home.exists() {

            fs::create_dir_all(&cogrs_home)?;

        Ok(())

async fn set_plugin_paths(config_manager: &Mutex<ConfigManager>) -> Result<()> {

    let plugin_loader = plugin_loader::PluginLoader::instance();

    let mut loader = plugin_loader.lock().await;

    let mut plugin_paths: HashMap<PluginType, Vec<PathBuf>> = HashMap::new();

    let callback_plugin_paths: Vec<PathBuf> =

    let connection_plugin_paths: Vec<PathBuf> =

    plugin_paths.insert(PluginType::Callback, callback_plugin_paths);

    plugin_paths.insert(PluginType::Connection, connection_plugin_paths);

    loader.set_plugin_paths(plugin_paths);

    Ok(())

async fn get_plugin_paths(

    let (config_value, _) = config_manager

        .await

        .get_config_value::<PathBuf>(config_key)?

        .ok_or_else(|| anyhow!("`{}` is not defined in the configuration", config_key))?;

    let paths: Vec<PathBuf> = config_value

        .map(|path| PathBuf::from(path))

    Ok(paths)