Add empty server implementation, tested locally

Author: VeljkoMaksimovic

ee/ephemeral_environments/Makefile

@@ -23,6 +23,9 @@ ifdef CI
 	sem-service start postgres 9.6 --db=$(POSTGRES_DB_NAME) --user=$(POSTGRES_DB_USER) --password=$(POSTGRES_DB_PASSWORD)
 endif
 
+console.ex:
+	docker compose run --service-ports $(CONTAINER_ENV_VARS) --rm app sh -c "mix ecto.create && mix ecto.migrate && iex -S mix"
+
 migration.gen:
 	@if [ -z "$(NAME)" ]; then \
 		echo "Usage: make migration.gen NAME={migration_name}"; \

ee/ephemeral_environments/lib/ephemeral_environments/application.ex

@@ -9,7 +9,16 @@ defmodule EphemeralEnvironments.Application do
       "Starting EphemeralEnvironments in '#{Application.get_env(:ephemeral_environments, :env)}' environment"
     )
 
-    children = [EphemeralEnvironments.Repo]
+    grpc_port = Application.get_env(:ephemeral_environments, :grpc_listen_port)
+
+    children = [
+      EphemeralEnvironments.Repo,
+      {GRPC.Server.Supervisor,
+        servers: [EphemeralEnvironments.Grpc.EphemeralEnvironmentsServer],
+        port: Application.get_env(:ephemeral_environments, :grpc_listen_port),
+        start_server: true,
+        adapter_opts: [ip: {0, 0, 0, 0}]}
+    ]
 
     opts = [strategy: :one_for_one, name: EphemeralEnvironments.Supervisor]
     Enum.each(children, fn child -> Logger.info("Starting #{inspect(child)}") end)

ee/ephemeral_environments/lib/ephemeral_environments/repo/ephemeral_environment_type.ex

@@ -0,0 +1,30 @@
+defmodule EphemeralEnvironments.Repo.EphemeralEnvironmentType do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key {:id, :binary_id, autogenerate: true}
+  @foreign_key_type :binary_id
+
+  schema "ephemeral_environment_types" do
+    field :org_id, :binary_id
+    field :name, :string
+    field :description, :string
+    field :created_by, :binary_id
+    field :last_modified_by, :binary_id
+    field :state, :string
+    field :max_number_of_instances, :integer
+
+    timestamps()
+  end
+
+  @doc false
+  def changeset(ephemeral_environment_type, attrs) do
+    ephemeral_environment_type
+    |> cast(attrs, [:org_id, :name, :description, :created_by, :last_modified_by, :state, :max_number_of_instances])
+    |> validate_required([:org_id, :name, :created_by, :last_modified_by, :state])
+    |> validate_length(:name, min: 1, max: 255)
+    |> validate_length(:description, max: 1000)
+    |> validate_inclusion(:state, [:draft, :ready, :cordoned, :deleted])
+    |> validate_number(:max_number_of_instances, greater_than: 0)
+  end
+end

ee/ephemeral_environments/lib/grpc/ephemeral_environments_server.ex

@@ -0,0 +1,42 @@
+defmodule EphemeralEnvironments.Grpc.EphemeralEnvironmentsServer do
+  use GRPC.Server, service: InternalApi.EphemeralEnvironments.EphemeralEnvironments.Service
+
+  alias InternalApi.EphemeralEnvironments.{
+    ListRequest,
+    ListResponse,
+    DescribeRequest,
+    DescribeResponse,
+    CreateRequest,
+    CreateResponse,
+    UpdateRequest,
+    UpdateResponse,
+    DeleteRequest,
+    DeleteResponse,
+    CordonRequest,
+    CordonResponse
+  }
+
+  def list(_request, _stream) do
+    %ListResponse{}
+  end
+
+  def describe(_request, _stream) do
+    %DescribeResponse{}
+  end
+
+  def create(_request, _stream) do
+    %CreateResponse{}
+  end
+
+  def update(_request, _stream) do
+    %UpdateResponse{}
+  end
+
+  def delete(_request, _stream) do
+    %DeleteResponse{}
+  end
+
+  def cordon(_request, _stream) do
+    %CordonResponse{}
+  end
+end