vs-core 0.0.3

Core orchestration services for the vs version manager.
Documentation 
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143

//! Services for refreshing plugin metadata and sources.

use vs_plugin_api::PluginBackendKind;
use vs_registry::RegistryEntry;

use crate::plugin_source::is_remote_source;
use crate::registry_source::{
    fetch_plugin_manifest, fetch_plugin_manifest_from_url, fetch_url_text,
    is_remote_registry_source, parse_registry_entries, registry_index_url,
};
use crate::{App, CoreError};

impl App {
    /// Refreshes the searchable plugin index from the configured registry source.
    pub fn update_registry(&self) -> Result<usize, CoreError> {
        let config = self.app_config()?;
        let source = config.registry.address;
        if source.is_empty() {
            return Err(CoreError::Unsupported(String::from(
                "registry.address is not configured",
            )));
        }
        let registry_source = if is_remote_registry_source(&source) {
            registry_index_url(&source)
        } else {
            source
        };
        let mut entries = if is_remote_registry_source(&registry_source) {
            let content = fetch_url_text(&registry_source, self.proxy_url())?;
            parse_registry_entries(&content).map_err(|error| CoreError::RegistrySource {
                path: registry_source.clone().into(),
                message: error.to_string(),
            })?
        } else {
            let path = self.normalize_source_path(&registry_source);
            let content =
                std::fs::read_to_string(&path).map_err(|error| CoreError::RegistrySource {
                    path: path.clone(),
                    message: error.to_string(),
                })?;
            parse_registry_entries(&content).map_err(|error| CoreError::RegistrySource {
                path: path.clone(),
                message: error.to_string(),
            })?
        };

        if !is_remote_registry_source(&registry_source) {
            let path = self.normalize_source_path(&registry_source);
            let base_dir = path.parent().unwrap_or(&self.cwd);
            for entry in &mut entries {
                let source_path = std::path::PathBuf::from(&entry.source);
                if source_path.is_relative() {
                    entry.source = base_dir.join(source_path).display().to_string();
                }
            }
        }

        entries.retain(|entry| self.ensure_backend_supported(entry.backend).is_ok());
        self.registry.replace_available_plugins(&entries)?;
        Ok(entries.len())
    }

    /// Updates a locally added plugin from its manifest URL or registry metadata.
    pub fn update_plugin(&self, name: &str) -> Result<RegistryEntry, CoreError> {
        let entry = self
            .added_plugins()?
            .into_iter()
            .find(|entry| entry.matches(name))
            .ok_or_else(|| CoreError::UnknownPlugin(name.to_string()))?;
        let materialized = self.materialize_plugin_entry(&entry)?;
        let plugin = self.load_plugin(&materialized)?;
        let manifest = plugin.manifest().clone();

        let mut refreshed = RegistryEntry {
            name: entry.name.clone(),
            source: entry.source.clone(),
            backend: entry.backend,
            description: manifest.description.clone().or(entry.description.clone()),
            aliases: entry.aliases.clone(),
        };

        if let Some(source) =
            self.resolve_plugin_update_source(&entry, &manifest.name, &manifest)?
        {
            refreshed.source = source;
        }

        let refreshed = if is_remote_source(&refreshed.source) {
            self.materialize_plugin_entry_with_refresh(&refreshed, true)?
        } else {
            self.materialize_plugin_entry(&refreshed)?
        };
        self.registry.add_plugin(refreshed.clone())?;
        Ok(refreshed)
    }

    /// Updates every locally added plugin.
    pub fn update_all_plugins(&self) -> Result<Vec<RegistryEntry>, CoreError> {
        let entries = self.added_plugins()?;
        let mut updated = Vec::new();
        for entry in entries {
            updated.push(self.update_plugin(&entry.name)?);
        }
        Ok(updated)
    }

    fn resolve_plugin_update_source(
        &self,
        entry: &RegistryEntry,
        manifest_name: &str,
        manifest: &vs_plugin_api::PluginManifest,
    ) -> Result<Option<String>, CoreError> {
        if let Some(manifest_url) = manifest
            .manifest_url
            .as_deref()
            .or(manifest.update_url.as_deref())
        {
            let plugin_manifest = fetch_plugin_manifest_from_url(manifest_url, self.proxy_url())?;
            if !plugin_manifest.download_url.is_empty() {
                return Ok(Some(plugin_manifest.download_url));
            }
        }

        if entry.backend == PluginBackendKind::Lua {
            let config = self.app_config()?;
            if !config.registry.address.is_empty() {
                if let Ok(plugin_manifest) =
                    fetch_plugin_manifest(&config.registry.address, manifest_name, self.proxy_url())
                {
                    if !plugin_manifest.download_url.is_empty() {
                        return Ok(Some(plugin_manifest.download_url));
                    }
                }
            }
        }

        if is_remote_source(&entry.source) {
            return Ok(Some(entry.source.clone()));
        }

        Ok(None)
    }
}