dprint 0.11.1

Binary for dprint code formatter—a pluggable and configurable code formatting platform.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use std::sync::Arc;
use rayon::prelude::*;

use dprint_core::types::ErrBox;

use crate::environment::Environment;
use crate::plugins::{Plugin, PluginSourceReference, PluginCache, PluginPools};
use super::implementations::{create_plugin};

pub struct PluginResolver<TEnvironment : Environment> {
    environment: TEnvironment,
    plugin_cache: Arc<PluginCache<TEnvironment>>,
    plugin_pools: Arc<PluginPools<TEnvironment>>,
}

impl<TEnvironment : Environment> PluginResolver<TEnvironment> {
    pub fn new(
        environment: TEnvironment,
        plugin_cache: Arc<PluginCache<TEnvironment>>,
        plugin_pools: Arc<PluginPools<TEnvironment>>,
    ) -> Self {
        PluginResolver { environment, plugin_cache, plugin_pools }
    }

    pub fn resolve_plugins(&self, plugin_references: Vec<PluginSourceReference>) -> Result<Vec<Box<dyn Plugin>>, ErrBox> {
        let plugins = plugin_references
            .into_par_iter()
            .map(|plugin_reference| self.resolve_plugin(plugin_reference))
            .collect::<Result<Vec<Box<dyn Plugin>>, ErrBox>>()?;

        Ok(plugins)
    }

    fn resolve_plugin(&self, plugin_reference: PluginSourceReference) -> Result<Box<dyn Plugin>, ErrBox> {
        match create_plugin(self.plugin_pools.clone(), &self.plugin_cache, self.environment.clone(), &plugin_reference) {
            Ok(plugin) => Ok(plugin),
            Err(err) => {
                match self.plugin_cache.forget(&plugin_reference) {
                    Ok(()) => {},
                    Err(inner_err) => return err!("Error resolving plugin {} and forgetting from cache: {}\n{}", plugin_reference.display(), err, inner_err),
                }
                return err!("Error resolving plugin {}: {}", plugin_reference.display(), err);
            }
        }
    }
}