Fix conneciton pool

Author: vtm9

apps/codebattle/lib/codebattle/code_check/checker.ex

@@ -75,13 +75,16 @@ defmodule Codebattle.CodeCheck.Checker do
   defp maybe_emit_telemetry(_token, _meta), do: :ok
 
   defp run_error_description(%{status: status} = result) when status in @failure_results do
+    output_error = Map.get(result, :output_error)
+    output = Map.get(result, :output)
+
     description =
       cond do
-        is_binary(result[:output_error]) and String.trim(result[:output_error]) != "" ->
-          result[:output_error]
+        is_binary(output_error) and String.trim(output_error) != "" ->
+          output_error
 
-        is_binary(result[:output]) and String.trim(result[:output]) != "" ->
-          result[:output]
+        is_binary(output) and String.trim(output) != "" ->
+          output
 
         status in ["service_timeout", "timeout"] ->
           "Code check execution timed out"

apps/codebattle/test/codebattle/code_check/checker_test.exs

@@ -0,0 +1,38 @@
+defmodule Codebattle.CodeCheck.CheckerTest.ExecutorStub do
+  @moduledoc false
+
+  def call(token) do
+    %{token | execution_error: RuntimeError.exception("executor failed")}
+  end
+end
+
+defmodule Codebattle.CodeCheck.CheckerTest do
+  use Codebattle.DataCase, async: false
+
+  alias Codebattle.CodeCheck.Checker
+  alias Codebattle.CodeCheck.Result.V2
+
+  setup do
+    previous_executor = Application.get_env(:codebattle, :checker_executor)
+    Application.put_env(:codebattle, :checker_executor, Codebattle.CodeCheck.CheckerTest.ExecutorStub)
+    FunWithFlags.disable(:use_remote_zig_executor)
+
+    on_exit(fn ->
+      case previous_executor do
+        nil -> Application.delete_env(:codebattle, :checker_executor)
+        executor -> Application.put_env(:codebattle, :checker_executor, executor)
+      end
+
+      FunWithFlags.disable(:use_remote_zig_executor)
+    end)
+
+    :ok
+  end
+
+  test "handles struct result when building run error description" do
+    task = insert(:task)
+
+    assert %V2{status: "service_failure"} =
+             Checker.call(task, "any_solution", "js", %{game_id: 1, user_id: 1})
+  end
+end

config/runtime.exs

@@ -42,7 +42,9 @@ config :codebattle, Codebattle.Repo,
   password: System.get_env("CODEBATTLE_DB_PASSWORD"),
   hostname: System.get_env("CODEBATTLE_DB_HOSTNAME"),
   database: System.get_env("CODEBATTLE_DB_NAME"),
-  pool_size: "CODEBATTLE_POOL_SIZE" |> System.get_env("10") |> String.to_integer(),
+  pool_size: "CODEBATTLE_POOL_SIZE" |> System.get_env("20") |> String.to_integer(),
+  queue_target: "CODEBATTLE_DB_QUEUE_TARGET" |> System.get_env("2000") |> String.to_integer(),
+  queue_interval: "CODEBATTLE_DB_QUEUE_INTERVAL" |> System.get_env("5000") |> String.to_integer(),
   log_level: :error
 
 config :codebattle, CodebattleWeb.BotEndpoint,

k8s/app-chart/templates/zig_runner_deployment.yaml

@@ -55,9 +55,26 @@ spec:
       {{- end }}
       containers:
         - name: "runner"
+          securityContext:
+            privileged: true
+            allowPrivilegeEscalation: true
+            runAsUser: 0
+            runAsGroup: 0
+            seccompProfile:
+              type: Unconfined
           env:
             - name: DEBUG
               value: {{ $.Values.zigRunners.env.DEBUG | quote }}
+            {{- if eq .name "csharp" }}
+            - name: HOME
+              value: /tmp
+            - name: DOTNET_CLI_HOME
+              value: /tmp
+            - name: NUGET_PACKAGES
+              value: /tmp/.nuget/packages
+            - name: NUGET_HTTP_CACHE_PATH
+              value: /tmp/.nuget/http-cache
+            {{- end }}
           resources:
             {{- toYaml $.Values.zigRunners.resources | nindent 12 }}
           imagePullPolicy: Always