Release 0.4.6

Author: dannote

CHANGELOG.md

@@ -1,5 +1,10 @@
 # Changelog
 
+## 0.4.6
+
+- Add packument disk cache (`~/.npm_ex/packuments/`) with 1h TTL — avoids refetching registry metadata on repeat installs
+- Skip resolution entirely when lockfile matches `package.json` and `node_modules` is intact
+
 ## 0.4.5
 
 - Switch default linker strategy from symlink to copy, fixing ESM module resolution for cached packages

lib/npm.ex

@@ -208,6 +208,22 @@ defmodule NPM do
 
   defp full_install(deps) do
     {:ok, old_lockfile} = NPM.Lockfile.read()
+
+    if old_lockfile != %{} and lockfile_matches?(old_lockfile, deps) and node_modules_intact?(old_lockfile) do
+      Mix.shell().info("Already up to date.")
+      :ok
+    else
+      resolve_and_install(deps, old_lockfile)
+    end
+  end
+
+  defp node_modules_intact?(lockfile) do
+    Enum.all?(lockfile, fn {name, _entry} ->
+      Path.join([@node_modules, name, "package.json"]) |> File.exists?()
+    end)
+  end
+
+  defp resolve_and_install(deps, old_lockfile) do
     {:ok, overrides} = NPM.PackageJSON.read_overrides()
 
     {resolve_us, result} =

lib/npm/packument_cache.ex

@@ -0,0 +1,41 @@
+defmodule NPM.PackumentCache do
+  @moduledoc false
+
+  @default_ttl_seconds 3600
+
+  def dir do
+    Path.join(NPM.Cache.dir(), "packuments")
+  end
+
+  @spec get(String.t()) :: {:ok, term()} | :miss
+  def get(package) do
+    path = path_for(package)
+
+    with {:ok, %{mtime: mtime}} <- File.stat(path, time: :posix),
+         true <- System.os_time(:second) - mtime < ttl(),
+         {:ok, data} <- File.read(path) do
+      {:ok, :erlang.binary_to_term(data)}
+    else
+      _ -> :miss
+    end
+  rescue
+    _ -> :miss
+  end
+
+  @spec put(String.t(), term()) :: :ok
+  def put(package, packument) do
+    path = path_for(package)
+    File.mkdir_p!(Path.dirname(path))
+    File.write!(path, :erlang.term_to_binary(packument))
+    :ok
+  end
+
+  defp path_for(package) do
+    encoded = String.replace(package, "/", "__")
+    Path.join(dir(), "#{encoded}.etf")
+  end
+
+  defp ttl do
+    Application.get_env(:npm, :packument_cache_ttl, @default_ttl_seconds)
+  end
+end

lib/npm/registry.ex

@@ -42,22 +42,40 @@ defmodule NPM.Registry do
   @doc "Fetch the abbreviated packument for a package."
   @spec get_packument(String.t()) :: {:ok, packument()} | {:error, term()}
   def get_packument(package) do
+    case NPM.PackumentCache.get(package) do
+      {:ok, packument} ->
+        {:ok, packument}
+
+      :miss ->
+        fetch_packument(package)
+    end
+  end
+
+  defp fetch_packument(package) do
     url = "#{registry_url()}/#{encode_package(package)}"
     headers = auth_headers() ++ [accept: "application/vnd.npm.install-v1+json"]
-
-    fetch_with_retry(url, headers, @max_retries)
+    fetch_with_retry(package, url, headers, @max_retries)
   end
 
-  defp fetch_with_retry(url, headers, retries_left) do
+  defp fetch_with_retry(package, url, headers, retries_left) do
     result = Req.get(url, headers: headers, decode_body: false)
 
     case classify_result(result) do
-      {:ok, body} -> {:ok, body |> decode_body() |> parse_packument()}
-      {:retry, _} when retries_left > 0 -> retry(url, headers, retries_left)
-      {_, error} -> error
+      {:ok, body} ->
+        packument = body |> decode_body() |> parse_packument()
+        NPM.PackumentCache.put(package, packument)
+        {:ok, packument}
+
+      {:retry, _} when retries_left > 0 ->
+        retry(package, url, headers, retries_left)
+
+      {_, error} ->
+        error
     end
   end
 
+
+
   defp classify_result({:ok, %{status: 200, body: body}}), do: {:ok, body}
   defp classify_result({:ok, %{status: 404}}), do: {:error, {:error, :not_found}}
   defp classify_result({:ok, %{status: 401}}), do: {:error, {:error, :unauthorized}}
@@ -66,9 +84,9 @@ defmodule NPM.Registry do
   defp classify_result({:ok, %{status: s}}), do: {:error, {:error, {:http, s}}}
   defp classify_result({:error, reason}), do: {:retry, {:error, reason}}
 
-  defp retry(url, headers, retries_left) do
+  defp retry(package, url, headers, retries_left) do
     Process.sleep(1000 * (@max_retries - retries_left + 1))
-    fetch_with_retry(url, headers, retries_left - 1)
+    fetch_with_retry(package, url, headers, retries_left - 1)
   end
 
   defp auth_headers do

mix.exs

@@ -1,7 +1,7 @@
 defmodule NPM.MixProject do
   use Mix.Project
 
-  @version "0.4.5"
+  @version "0.4.6"
   @source_url "https://github.com/elixir-volt/npm_ex"
 
   def project do