Implements a metadata cache for the npm resolver

packages/zpm/Cargo.toml

@@ -48,3 +48,4 @@ hickory-resolver = "0.25.2"
 indexmap = {version = "2.11.0", features = ["serde"]}
 sha2 = "0.10.8"
 hex = "0.4.3"
+dashmap = "6.1.0"

packages/zpm/src/commands/debug/print_hoisting.rs

@@ -35,7 +35,9 @@ impl PrintHoisting {
             = Hoister::new(&mut work_tree);
 
         hoister.set_print_logs(self.verbose);
+        println!("Hoisting...");
         hoister.hoist();
+        println!("Hoisted!");
 
         let root_node
             = hoist::TreeRenderer::new(&work_tree).convert();

packages/zpm/src/install.rs

@@ -1,5 +1,6 @@
 use std::{collections::{BTreeMap, BTreeSet}, hash::Hash, marker::PhantomData, sync::LazyLock};
 
+use dashmap::DashMap;
 use rayon::iter::{IntoParallelIterator, ParallelIterator};
 use zpm_config::PackageExtension;
 use zpm_primitives::{Descriptor, Ident, Locator, PatchRange, PeerRange, Range, RegistrySemverRange, RegistryTagRange, SemverDescriptor, SemverPeerRange};
@@ -9,7 +10,7 @@ use serde::{Deserialize, Serialize};
 use zpm_utils::{FromFileString, ToFileString};
 
 use crate::{
-    build, cache::CompositeCache, content_flags::ContentFlags, error::Error, fetchers::{fetch_locator, patch::has_builtin_patch, try_fetch_locator_sync, PackageData, SyncFetchAttempt}, graph::{GraphCache, GraphIn, GraphOut, GraphTasks}, linker, lockfile::{Lockfile, LockfileEntry, LockfileMetadata}, primitives_exts::RangeExt, project::{InstallMode, Project}, report::{async_section, with_context_result, ReportContext}, resolvers::{resolve_descriptor, resolve_locator, try_resolve_descriptor_sync, validate_resolution, Resolution, SyncResolutionAttempt}, system, tree_resolver::{ResolutionTree, TreeResolver}
+    build, cache::CompositeCache, content_flags::ContentFlags, error::Error, fetchers::{fetch_locator, patch::has_builtin_patch, try_fetch_locator_sync, PackageData, SyncFetchAttempt}, graph::{GraphCache, GraphIn, GraphOut, GraphTasks}, linker, lockfile::{Lockfile, LockfileEntry, LockfileMetadata}, primitives_exts::RangeExt, project::{InstallMode, Project}, report::{async_section, with_context_result, ReportContext}, resolvers::{npm::NpmPayload, resolve_descriptor, resolve_locator, try_resolve_descriptor_sync, validate_resolution, Resolution, SyncResolutionAttempt}, system, tree_resolver::{ResolutionTree, TreeResolver}
 };
 
 
@@ -21,6 +22,7 @@ pub struct InstallContext<'a> {
     pub check_checksums: bool,
     pub check_resolutions: bool,
     pub enforced_resolutions: BTreeMap<Descriptor, Locator>,
+    pub npm_metadata_cache: Option<&'a DashMap<Ident, NpmPayload>>,
     pub refresh_lockfile: bool,
     pub mode: Option<InstallMode>,
 }
@@ -34,13 +36,19 @@ impl<'a> Default for InstallContext<'a> {
             check_checksums: false,
             check_resolutions: false,
             enforced_resolutions: BTreeMap::new(),
+            npm_metadata_cache: None,
             refresh_lockfile: false,
             mode: None,
         }
     }
 }
 
 impl<'a> InstallContext<'a> {
+    pub fn with_npm_metadata_cache(mut self, npm_metadata_cache: Option<&'a DashMap<Ident, NpmPayload>>) -> Self {
+        self.npm_metadata_cache = npm_metadata_cache;
+        self
+    }
+
     pub fn with_package_cache(mut self, package_cache: Option<&'a CompositeCache>) -> Self {
         self.package_cache = package_cache;
         self

packages/zpm/src/project.rs

@@ -1,5 +1,6 @@
 use std::{collections::{BTreeMap, HashSet}, io::ErrorKind, sync::Arc, time::UNIX_EPOCH};
 
+use dashmap::DashMap;
 use globset::{GlobBuilder, GlobSetBuilder};
 use zpm_config::{Configuration, ConfigurationContext};
 use zpm_macro_enum::zpm_enum;
@@ -625,7 +626,11 @@ impl Project {
                 }
             }
 
+            let npm_metadata_cache
+                = DashMap::new();
+
             let install_context = InstallContext::default()
+                .with_npm_metadata_cache(Some(&npm_metadata_cache))
                 .with_package_cache(Some(&package_cache))
                 .with_project(Some(self))
                 .set_check_checksums(options.check_checksums)