Ensure console repository is created on plural instances (#1440)

Author: michaeljguarino

apps/core/lib/core/services/cloud.ex

@@ -266,6 +266,30 @@ defmodule Core.Services.Cloud do
     end
   end
 
+  def ensure_console_repository() do
+    case Repositories.get_repository_by_name("console") do
+      nil -> create_console_repository()
+      %Core.Schema.Repository{} = repo -> {:ok, repo}
+    end
+  end
+
+  defp create_console_repository() do
+    with %User{} = user <- Users.get_user_by_email!(Core.conf(:initial_user)),
+         %Core.Schema.Publisher{} = publisher <- Users.get_publisher_by_owner(user.id) do
+      Repositories.create_repository(%{
+        name: "console",
+        category: :devops,
+        git_url: "https://github.com/pluralsh/console",
+        oauth_settings: %{
+          auth_method: :post,
+          uri_format: "https://{domain}/oauth/callback"
+        }
+      }, publisher.id, user)
+    else
+      _ -> {:error, "failed to create console repository"}
+    end
+  end
+
   defp aes_key() do
     :crypto.strong_rand_bytes(32)
     |> Base.url_encode64()

apps/core/priv/repo/seeds/016_add_console_repo.exs

@@ -0,0 +1,5 @@
+import Botanist
+
+seed do
+  Core.Services.Cloud.ensure_console_repository()
+end

apps/core/test/services/cloud_test.exs

@@ -261,4 +261,19 @@ defmodule Core.Services.CloudTest do
       end
     end
   end
+
+  describe "#ensure_console_repository/0" do
+    test "it will create the console repository if it doesn't exist" do
+      user = insert(:user, email: Core.conf(:initial_user))
+      insert(:publisher, owner: user)
+
+      {:ok, repo} = Cloud.ensure_console_repository()
+
+      assert repo.name == "console"
+      assert repo.category == :devops
+      assert repo.git_url == "https://github.com/pluralsh/console"
+      assert repo.oauth_settings.auth_method == :post
+      assert repo.oauth_settings.uri_format == "https://{domain}/oauth/callback"
+    end
+  end
 end

config/config.exs

@@ -154,7 +154,8 @@ config :core,
   cloud_domain: "cloud.plural.sh",
   base_stripe_product: "test-base",
   metered_stripe_product: "test-metered",
-  cluster_meter_name: "pro_clusters"
+  cluster_meter_name: "pro_clusters",
+  initial_user: "[email protected]"
 
 config :briefly,
   directory: [{:system, "TMPDIR"}, {:system, "TMP"}, {:system, "TEMP"}, "/tmp"],

rel/config/config.exs

@@ -101,7 +101,8 @@ config :core,
   cloud_domain: get_env("CONSOLE_CLOUD_DOMAIN") || "cloud.plural.sh",
   base_stripe_product: get_env("STRIPE_PRO_PRODUCT"),
   metered_stripe_product: get_env("STRIPE_PRO_CLUSTER_PRODUCT"),
-  cluster_meter_name: get_env("CLUSTER_METER_NAME") || "pro_clusters"
+  cluster_meter_name: get_env("CLUSTER_METER_NAME") || "pro_clusters",
+  initial_user: get_env("ADMIN_EMAIL") || "[email protected]"
 
 
 if get_env("VAULT_HOST") do