chore: adjustments in interop script and formatting

Author: Adriano Santos

interop/.formatter.exs

@@ -1,11 +1,7 @@
 [
   inputs: [
     "{mix,.formatter}.exs",
-    "{config,lib,test,src}/**/*.{ex,exs}"
+    "{config,lib,test,src,script}/**/*.{ex,exs}"
   ],
-  import_deps: [:grpc_core, :protobuf],
-  locals_without_parens: [rpc: 3, intercept: 1, intercept: 2, run: 1, run: 2],
-  export: [
-    locals_without_parens: [rpc: 3, intercept: 1, intercept: 2, run: 1, run: 2]
-  ]
+  import_deps: [:grpc_core, :protobuf]
 ]

interop/lib/interop/endpoint.ex

@@ -1,5 +1,5 @@
 defmodule Interop.Endpoint do
   use GRPC.Endpoint
 
-  run Interop.Server
+  run(Interop.Server)
 end

interop/mix.exs

@@ -22,8 +22,8 @@ defmodule Interop.MixProject do
 
   defp deps do
     [
-      {:grpc_server, path: "..", override: true},
-      {:grpc_client, path: "../../grpc_client", override: true},
+      {:grpc_server, path: "../grpc_server", override: true},
+      {:grpc_client, path: "../grpc_client", override: true},
       {:protobuf, "~> 0.14"},
       {:grpc_statsd, "~> 0.1.0"},
       {:statix, ">= 1.2.1"},

interop/script/run.exs

@@ -1,4 +1,8 @@
-{options, _, _} = OptionParser.parse(System.argv(), strict: [rounds: :integer, concurrency: :integer, port: :integer, level: :string])
+{options, _, _} =
+  OptionParser.parse(System.argv(),
+    strict: [rounds: :integer, concurrency: :integer, port: :integer, level: :string]
+  )
+
 rounds = Keyword.get(options, :rounds) || 20
 max_concurrency = System.schedulers_online()
 concurrency = Keyword.get(options, :concurrency) || max_concurrency
@@ -24,7 +28,6 @@ defmodule InteropTestRunner do
     ch = Client.connect("127.0.0.1:#{port}", opts)
 
     for round <- 1..rounds do
-      
       Client.empty_unary!(ch)
       Client.cacheable_unary!(ch)
       Client.large_unary!(ch)
@@ -46,20 +49,27 @@ defmodule InteropTestRunner do
 
       IO.inspect(round, label: "Round #{round} --------------------------------")
     end
+
     :ok
   end
 end
 
+res = DynamicSupervisor.start_link(strategy: :one_for_one, name: GRPC.Client.Supervisor)
+
 {:ok, _pid} =
-  DynamicSupervisor.start_link(
-    strategy: :one_for_one,
-    name: GRPC.Client.Supervisor
-  )
+  case res do
+    {:ok, pid} ->
+      {:ok, pid}
+
+    {:error, {:already_started, pid}} ->
+      {:ok, pid}
+  end
 
 for adapter <- [Gun, Mint] do
   Logger.info("Starting run for adapter: #{adapter}")
   args = [adapter, port, rounds]
   stream_opts = [max_concurrency: concurrency, ordered: false, timeout: :infinity]
+
   1..concurrency
   |> Task.async_stream(InteropTestRunner, :run, args, stream_opts)
   |> Enum.to_list()