Add endpoint and intercepters

Author: VeljkoMaksimovic

ee/ephemeral_environments/lib/ephemeral_environments/application.ex

@@ -9,15 +9,12 @@ defmodule EphemeralEnvironments.Application do
       "Starting EphemeralEnvironments in '#{Application.get_env(:ephemeral_environments, :env)}' environment"
     )
 
-    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}]}
+       endpoint: EphemeralEnvironments.Grpc.Endpoint,
+       port: Application.fetch_env!(:ephemeral_environments, :grpc_listen_port),
+       start_server: true}
     ]
 
     opts = [strategy: :one_for_one, name: EphemeralEnvironments.Supervisor]

ee/ephemeral_environments/lib/ephemeral_environments/grpc/endpoint.ex

@@ -0,0 +1,10 @@
+defmodule EphemeralEnvironments.Grpc.Endpoint do
+  use GRPC.Endpoint
+
+  run(EphemeralEnvironments.Grpc.EphemeralEnvironmentsServer,
+    interceptors: [
+      EphemeralEnvironments.Grpc.Interceptor.Metrics,
+      EphemeralEnvironments.Grpc.Interceptor.ProtoConverter
+    ]
+  )
+end

ee/ephemeral_environments/lib/grpc/ephemeral_environments_server.ex renamed to ee/ephemeral_environments/lib/ephemeral_environments/grpc/ephemeral_environments_server.ex

@@ -24,7 +24,8 @@ defmodule EphemeralEnvironments.Grpc.EphemeralEnvironmentsServer do
     %DescribeResponse{}
   end
 
-  def create(_request, _stream) do
+  def create(request, _stream) do
+    ret = EphemeralEnvironments.Service.EphemeralEnvironmentType.create(request.environment_type)
     %CreateResponse{}
   end
 
@@ -39,4 +40,4 @@ defmodule EphemeralEnvironments.Grpc.EphemeralEnvironmentsServer do
   def cordon(_request, _stream) do
     %CordonResponse{}
   end
-end
+end

ee/ephemeral_environments/lib/ephemeral_environments/grpc/interceptors/metrics.ex

@@ -0,0 +1,13 @@
+defmodule EphemeralEnvironments.Grpc.Interceptor.Metrics do
+  @behaviour GRPC.ServerInterceptor
+  require Logger
+
+  def init(options) do
+    options
+  end
+
+  def call(request, stream, next, _) do
+    Logger.debug("Metrics intercepter #{inspect(request)}")
+    next.(request, stream)
+  end
+end

ee/ephemeral_environments/lib/ephemeral_environments/grpc/interceptors/proto_converte.ex

@@ -0,0 +1,14 @@
+defmodule EphemeralEnvironments.Grpc.Interceptor.ProtoConverter do
+  @behaviour GRPC.ServerInterceptor
+  require Logger
+
+  def init(options) do
+    options
+  end
+
+  def call(request, stream, next, _) do
+    Logger.debug("Proto intercepter #{inspect(request)}")
+    converted = EphemeralEnvironments.Utils.Proto.to_map(request)
+    next.(converted, stream)
+  end
+end