feat: add mix tasks for generating release artifacts (#119)

.gitignore

@@ -33,3 +33,5 @@ npm-debug.log
 /assets/node_modules/
 
 burrito_out/*
+
+supavisor-*.tar.gz

Makefile

@@ -25,7 +25,7 @@ dev.node2:
 	SECRET_KEY_BASE="dev" \
 	CLUSTER_POSTGRES="true" \
 	ERL_AFLAGS="-kernel shell_history enabled" \
-	iex --name [email protected] --cookie cookie -S mix phx.server	
+	iex --name [email protected] --cookie cookie -S mix phx.server
 
 dev_bin:
 	MIX_ENV=dev mix release supavisor_bin && ls -l burrito_out
@@ -55,3 +55,26 @@ pgbench_short:
 
 pgbench_long:
 	PGPASSWORD=postgres pgbench -M extended --transactions 100 --jobs 10 --client 60 -h localhost -p 7654 -U transaction.localhost postgres
+
+clean:
+	rm -rf _build && rm -rf deps
+
+dev_release:
+	mix deps.get && mix compile && mix release supavisor
+
+dev_up:
+	rm -rf _build/dev/lib/supavisor && \
+	MIX_ENV=dev mix compile && \
+	mix release supavisor
+
+dev_start_rel:
+	MIX_ENV=dev \
+	VAULT_ENC_KEY="aHD8DZRdk2emnkdktFZRh3E9RNg4aOY7" \
+	API_JWT_SECRET=dev \
+	METRICS_JWT_SECRET=dev \
+	REGION=eu \
+	FLY_ALLOC_ID=111e4567-e89b-12d3-a456-426614174000 \
+	SECRET_KEY_BASE="dev" \
+	CLUSTER_POSTGRES="true" \
+	ERL_AFLAGS="-kernel shell_history enabled" \
+	./_build/dev/rel/supavisor/bin/supavisor start_iex

VERSION

@@ -1 +1 @@
-0.2.9
+0.2.10

lib/tasks/gen.appup.ex

@@ -0,0 +1,51 @@
+defmodule Mix.Tasks.Supavisor.Gen.Appup do
+  @moduledoc """
+  Generates an appup file for a given release.
+
+  ## Examples
+
+      # Generate an appup from 0.0.1 to 0.0.2 versions
+
+      mix supavisor.gen.appup --from=0.0.1 --to=0.0.2
+  """
+
+  use Mix.Task
+  alias Distillery.Releases.Appup
+
+  @impl true
+  def run(args) do
+    {parsed, _, _} = OptionParser.parse(args, strict: [from: :string, to: :string])
+
+    {from_vsn, to_vsn} =
+      if !parsed[:from] || !parsed[:to] do
+        Mix.Task.run("help", ["supavisor.gen.appup"])
+        System.halt(1)
+      else
+        {parsed[:from], parsed[:to]}
+      end
+
+    IO.puts("Generating appup from #{from_vsn} to #{to_vsn}...\n")
+
+    rel_dir = Path.join([File.cwd!(), "_build", "#{Mix.env()}", "rel", "supavisor"])
+    lib_path = Path.join(rel_dir, "lib")
+    path_from = Path.join(lib_path, "supavisor-#{from_vsn}")
+    path_to = Path.join(lib_path, "supavisor-#{to_vsn}")
+    appup_path = Path.join([path_to, "ebin", "supavisor.appup"])
+
+    case Appup.make(:supavisor, from_vsn, to_vsn, path_from, path_to) do
+      {:ok, appup} ->
+        IO.puts("Writing appup to #{appup_path}")
+
+        case File.write(appup_path, :io_lib.format("~p.", [appup]), [:utf8]) do
+          :ok ->
+            IO.puts("Appup:\n#{File.read!(appup_path)}")
+
+          {:error, reason} ->
+            Mix.raise("Failed to write appup file: #{reason}")
+        end
+
+      {:error, reason} ->
+        Mix.raise("Failed to generate appup file: #{inspect(reason)}")
+    end
+  end
+end

lib/tasks/gen.relup.ex

@@ -0,0 +1,58 @@
+defmodule Mix.Tasks.Supavisor.Gen.Relup do
+  @moduledoc """
+  Generates an appup file for a given release.
+
+  ## Examples
+
+      # Generate an appup from 0.0.1 to 0.0.2 versions
+
+      mix supavisor.gen.appup --from=0.0.1 --to=0.0.2
+  """
+
+  use Mix.Task
+
+  @impl true
+  def run(args) do
+    {parsed, _, _} = OptionParser.parse(args, strict: [from: :string, to: :string])
+
+    {from_vsn, to_vsn} =
+      if !parsed[:from] || !parsed[:to] do
+        Mix.Task.run("help", ["supavisor.gen.relup"])
+        System.halt(1)
+      else
+        {parsed[:from], parsed[:to]}
+      end
+
+    IO.puts("Generating relup from #{from_vsn} to #{to_vsn}...\n")
+
+    rel_dir = Path.join([File.cwd!(), "_build", "#{Mix.env()}", "rel", "supavisor"])
+    prev_rel_dir = Path.join([rel_dir, "releases", from_vsn])
+    curr_rel_dir = Path.join([rel_dir, "releases", to_vsn])
+    lib_path = Path.join(rel_dir, "lib")
+    relup_path = Path.join(curr_rel_dir, "relup")
+
+    opts = [
+      {:path, [Path.join(lib_path, "*/ebin") |> to_charlist()]},
+      {:outdir, to_charlist(curr_rel_dir)}
+    ]
+
+    rel1 = Path.join(prev_rel_dir, "supavisor") |> to_charlist()
+    rel2 = Path.join(curr_rel_dir, "supavisor") |> to_charlist()
+
+    case :systools.make_relup(rel2, [rel1], [rel1], opts) do
+      :ok ->
+        IO.puts("Writing relup to #{relup_path}\n")
+
+        case File.read(relup_path) do
+          {:ok, content} ->
+            IO.puts("Relup:\n#{content}")
+
+          {:error, reason} ->
+            Mix.raise("Failed to read relup file: #{reason}")
+        end
+
+      other ->
+        Mix.raise("Failed to generate relup file: #{other}")
+    end
+  end
+end

mix.exs

@@ -10,7 +10,8 @@ defmodule Supavisor.MixProject do
       start_permanent: Mix.env() == :prod,
       aliases: aliases(),
       deps: deps(),
-      releases: releases()
+      releases: releases(),
+      dialyzer: [plt_add_apps: [:mix]]
     ]
   end
 
@@ -57,6 +58,7 @@ defmodule Supavisor.MixProject do
       {:burrito, github: "burrito-elixir/burrito"},
       {:libcluster, "~> 3.3.1"},
       {:logflare_logger_backend, github: "Logflare/logflare_logger_backend", tag: "v0.11.1-rc.1"},
+      {:distillery, "~> 2.1"},
 
       # pooller
       {:poolboy, "~> 1.5.2"},
@@ -69,6 +71,7 @@ defmodule Supavisor.MixProject do
   def releases do
     [
       supavisor: [
+        steps: [:assemble, &upgrade/1, :tar],
         include_erts: System.get_env("INCLUDE_ERTS", "true") == "true"
       ],
       supavisor_bin: [
@@ -107,5 +110,21 @@ defmodule Supavisor.MixProject do
     ]
   end
 
-  defp version, do: File.read!("./VERSION")
+  defp upgrade(release) do
+    from = System.get_env("UPGRADE_FROM")
+
+    if from do
+      vsn = release.version
+      path = Path.join([release.path, "releases", "supavisor-#{vsn}.rel"])
+      rel_content = File.read!(Path.join(release.version_path, "supavisor.rel"))
+
+      Mix.Task.run("supavisor.gen.appup", ["--from=" <> from, "--to=" <> vsn])
+      :ok = File.write!(path, rel_content)
+      Mix.Task.run("supavisor.gen.relup", ["--from=" <> from, "--to=" <> vsn])
+    end
+
+    release
+  end
+
+  defp version, do: File.read!("./VERSION") |> String.trim()
 end

mix.lock

@@ -1,4 +1,5 @@
 %{
+  "artificery": {:hex, :artificery, "0.4.3", "0bc4260f988dcb9dda4b23f9fc3c6c8b99a6220a331534fdf5bf2fd0d4333b02", [:mix], [], "hexpm", "12e95333a30e20884e937abdbefa3e7f5e05609c2ba8cf37b33f000b9ffc0504"},
   "backoff": {:hex, :backoff, "1.1.6", "83b72ed2108ba1ee8f7d1c22e0b4a00cfe3593a67dbc792799e8cce9f42f796b", [:rebar3], [], "hexpm", "cf0cfff8995fb20562f822e5cc47d8ccf664c5ecdc26a684cbe85c225f9d7c39"},
   "benchee": {:hex, :benchee, "1.1.0", "f3a43817209a92a1fade36ef36b86e1052627fd8934a8b937ac9ab3a76c43062", [:mix], [{:deep_merge, "~> 1.0", [hex: :deep_merge, repo: "hexpm", optional: false]}, {:statistex, "~> 1.0", [hex: :statistex, repo: "hexpm", optional: false]}], "hexpm", "7da57d545003165a012b587077f6ba90b89210fd88074ce3c60ce239eb5e6d93"},
   "bertex": {:hex, :bertex, "1.3.0", "0ad0df9159b5110d9d2b6654f72fbf42a54884ef43b6b651e6224c0af30ba3cb", [:mix], [], "hexpm", "0a5d5e478bb5764b7b7bae37cae1ca491200e58b089df121a2fe1c223d8ee57a"},
@@ -16,6 +17,7 @@
   "decimal": {:hex, :decimal, "2.1.1", "5611dca5d4b2c3dd497dec8f68751f1f1a54755e8ed2a966c2633cf885973ad6", [:mix], [], "hexpm", "53cfe5f497ed0e7771ae1a475575603d77425099ba5faef9394932b35020ffcc"},
   "deep_merge": {:hex, :deep_merge, "1.0.0", "b4aa1a0d1acac393bdf38b2291af38cb1d4a52806cf7a4906f718e1feb5ee961", [:mix], [], "hexpm", "ce708e5f094b9cd4e8f2be4f00d2f4250c4095be93f8cd6d018c753894885430"},
   "dialyxir": {:hex, :dialyxir, "1.1.0", "c5aab0d6e71e5522e77beff7ba9e08f8e02bad90dfbeffae60eaf0cb47e29488", [:mix], [{:erlex, ">= 0.2.6", [hex: :erlex, repo: "hexpm", optional: false]}], "hexpm", "07ea8e49c45f15264ebe6d5b93799d4dd56a44036cf42d0ad9c960bc266c0b9a"},
+  "distillery": {:hex, :distillery, "2.1.1", "f9332afc2eec8a1a2b86f22429e068ef35f84a93ea1718265e740d90dd367814", [:mix], [{:artificery, "~> 0.2", [hex: :artificery, repo: "hexpm", optional: false]}], "hexpm", "bbc7008b0161a6f130d8d903b5b3232351fccc9c31a991f8fcbf2a12ace22995"},
   "ecto": {:hex, :ecto, "3.8.4", "e06b8b87e62b27fea17fd2ff6041572ddd10339fd16cdf58446e402c6c90a74b", [:mix], [{:decimal, "~> 1.6 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: true]}, {:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "f9244288b8d42db40515463a008cf3f4e0e564bb9c249fe87bf28a6d79fe82d4"},
   "ecto_sql": {:hex, :ecto_sql, "3.8.3", "a7d22c624202546a39d615ed7a6b784580391e65723f2d24f65941b4dd73d471", [:mix], [{:db_connection, "~> 2.4.1 or ~> 2.5", [hex: :db_connection, repo: "hexpm", optional: false]}, {:ecto, "~> 3.8.4", [hex: :ecto, repo: "hexpm", optional: false]}, {:myxql, "~> 0.6.0", [hex: :myxql, repo: "hexpm", optional: true]}, {:postgrex, "~> 0.15.0 or ~> 0.16.0 or ~> 1.0", [hex: :postgrex, repo: "hexpm", optional: true]}, {:tds, "~> 2.1.1 or ~> 2.2", [hex: :tds, repo: "hexpm", optional: true]}, {:telemetry, "~> 0.4.0 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "348cb17fb9e6daf6f251a87049eafcb57805e2892e5e6a0f5dea0985d367329b"},
   "erlex": {:hex, :erlex, "0.2.6", "c7987d15e899c7a2f34f5420d2a2ea0d659682c06ac607572df55a43753aa12e", [:mix], [], "hexpm", "2ed2e25711feb44d52b17d2780eabf998452f6efda104877a3881c2f8c0c0c75"},