d3d3b53dc1f761432ab8cd958b74b2b23b4427ad-PR-27

pending completion

Build # d3d3b53dc1f761432ab8cd958b74b2b23b4427ad-PR-27

Build Type

Pull #27

github

Committed by

mruoss

Commit Message

fix ssl connection and add ca

Pull Request Pull Request #27: SSL support

Run Details

22 of 22 new or added lines in 3 files covered. (100.0%)

74 of 532 relevant lines covered (13.91%)

4.56 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/lib/kompost/kompo/temporal/controller/api_server_controller.ex

defmodule Kompost.Kompo.Temporal.Controller.APIServerController do
  use Bonny.ControllerV2

  require Logger

  alias Kompost.Kompo.Temporal.Conn

  step Bonny.Pluggable.SkipObservedGenerations

  step Kompost.Pluggable.InitConditions, conditions: ["Connected"]
  step :handle_event

  @spec handle_event(Bonny.Axn.t(), Keyword.t()) :: Bonny.Axn.t()
  def handle_event(%Bonny.Axn{action: action} = axn, _opts)
      when action in [:add, :modify, :reconcile] do
    id = Conn.get_id(axn.resource)
    addr = "#{axn.resource["spec"]["host"]}:#{axn.resource["spec"]["port"]}"

    case Conn.connect(id, addr) do
      {:ok, _} ->
        axn
        |> success_event(message: "gRPC connection to Temporal established successfully.")
        |> set_condition(
          "Connected",
          true,
          "gRPC connection to Temporal established successfully."
        )

      {:error, reason} ->
        message = "Could not connect to Temporal cluster: #{reason}"
        Logger.warning("#{axn.action} failed. #{message}")

        axn
        |> failure_event(message: message)
        |> set_condition("Connected", false, message)
    end
  end

  def handle_event(%Bonny.Axn{action: :delete} = axn, _opts) do
    axn.resource
    |> Conn.get_id()
    |> Conn.disconnect()

    success_event(axn)
  end
end

1	defmodule Kompost.Kompo.Temporal.Controller.APIServerController do
2	use Bonny.ControllerV2
3
4	require Logger
5
6	alias Kompost.Kompo.Temporal.Conn
7
8	step Bonny.Pluggable.SkipObservedGenerations
9
10	step Kompost.Pluggable.InitConditions, conditions: ["Connected"]
11	step :handle_event
12
13	@spec handle_event(Bonny.Axn.t(), Keyword.t()) :: Bonny.Axn.t()
14	def handle_event(%Bonny.Axn{action: action} = axn, _opts)
15	when action in [:add, :modify, :reconcile] do
16	id = Conn.get_id(axn.resource)	×
17	addr = "#{axn.resource["spec"]["host"]}:#{axn.resource["spec"]["port"]}"	×
18
19	case Conn.connect(id, addr) do	×
20	{:ok, _} ->
21	axn
22	\|> success_event(message: "gRPC connection to Temporal established successfully.")
23	\|> set_condition(	×
24	"Connected",
25	true,
26	"gRPC connection to Temporal established successfully."
27	)
28
29	{:error, reason} ->
30	message = "Could not connect to Temporal cluster: #{reason}"	×
31	Logger.warning("#{axn.action} failed. #{message}")	×
32
33	axn
34	\|> failure_event(message: message)
35	\|> set_condition("Connected", false, message)	×
36	end
37	end
38
39	def handle_event(%Bonny.Axn{action: :delete} = axn, _opts) do
40	axn.resource	×
41	\|> Conn.get_id()
42	\|> Conn.disconnect()	×
43
44	success_event(axn)	×
45	end
46	end

mruoss / kompost / d3d3b53dc1f761432ab8cd958b74b2b23b4427ad-PR-27

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous