Packages

spawn

1.3.3
2.0.0-RC9 2.0.0-RC8 2.0.0-RC7 2.0.0-RC6 2.0.0-RC5 2.0.0-RC4 2.0.0-RC3 2.0.0-RC2 2.0.0-RC14 2.0.0-RC13 2.0.0-RC12 2.0.0-RC11 2.0.0-RC10 2.0.0-RC1 1.4.3 1.4.2 1.4.1 1.4.0 1.3.3 1.3.2 1.3.1 1.3.0 1.2.1 1.2.0 1.1.1 1.1.0 1.0.1 1.0.0 1.0.0-rc3 1.0.0-rc16 1.0.0-rc1 1.0.0-rc.38 1.0.0-rc.37 1.0.0-rc.36 1.0.0-rc.35 1.0.0-rc.34 1.0.0-rc.33 1.0.0-rc.32 1.0.0-rc.31 1.0.0-rc.30 1.0.0-rc.29 1.0.0-rc.28 1.0.0-rc.27 1.0.0-rc.26 1.0.0-rc.25 1.0.0-rc.24 1.0.0-rc.23 1.0.0-rc.22 1.0.0-rc.21 1.0.0-rc.20 1.0.0-rc.19 1.0.0-rc.18 1.0.0-rc.17 1.0.0-rc.2 0.6.3 0.6.2 0.6.1 0.6.0 0.5.5 0.5.4 0.5.3 0.5.1 0.5.0 0.5.0-rc.13 0.5.0-rc.12 0.5.0-rc.11 0.5.0-rc.10 0.5.0-rc.9 0.5.0-rc.8 0.5.0-rc.7 0.5.0-rc.6 0.5.0-rc.5 0.5.0-rc.3 0.5.0-alpha.13 0.5.0-alpha.12 0.5.0-alpha.11 0.5.0-alpha.10 0.5.0-alpha.9 0.5.0-alpha.8 0.5.0-alpha.7 0.5.0-alpha.6 0.5.0-alpha.5 0.5.0-alpha.4 0.5.0-alpha.3 0.5.0-alpha.2 0.5.0-alpha.1 0.1.0

Spawn is the core lib for Spawn Actors System

HexDocs

Current section

Files

Jump to
Readme
87 Versions
34 Dependencies
Dependants
Files
Activity
spawn lib spawn utils nats.ex
Raw

lib/spawn/utils/nats.ex 

defmodule Spawn.Utils.Nats do

  @moduledoc false



  alias Actors.Config.PersistentTermConfig, as: Config

  alias Eigr.Functions.Protocol.InvocationRequest



  import Spawn.Utils.Common, only: [to_existing_atom_or_new: 1]



  @spec request(String.t(), InvocationRequest.t(), Keyword.t()) :: any() | {:ok, :async}

  def request(system, payload, opts \\ []) do

    async? = Keyword.get(opts, :async, false)

    conn = connection_name()

    topic = get_topic(system)



    # TODO: Verify if necessary default value

    trace_context = Keyword.get(opts, :trace_context)



    case async? do

      false ->

        Gnat.request(conn, topic, InvocationRequest.encode(payload), headers: trace_context)



      true ->

        :ok = Gnat.pub(conn, topic, InvocationRequest.encode(payload), headers: trace_context)



        {:ok, :async}

    end

  end



  @spec connection_name() :: atom()

  def connection_name(), do: to_existing_atom_or_new("spawn.internal.nats")



  def get_internal_nats_connection(_opts) do

    raw_hosts = Config.get(:internal_nats_hosts)

    hosts_conn_map = get_nats_hosts(raw_hosts)



    # TODO: Get other parameters here to build complex connections



    hosts_conn_map

  end



  @spec get_nats_connection(Keyword.t()) :: map()

  def get_nats_connection(_opts) do

    raw_hosts = Config.get(:pubsub_adapter_nats_hosts)

    hosts_conn_map = get_nats_hosts(raw_hosts)



    # TODO: Get other parameters here to build complex connections



    hosts_conn_map

  end



  @spec get_topic(String.t()) :: String.t()

  def get_topic(system), do: "spawn.#{system}.actors.actions"



  defp get_nats_hosts(raw_hosts) do

    String.split(raw_hosts, ",")

    |> Enum.map(fn host ->

      host_port = String.replace(host, "nats://", "")

      host = String.split(host_port, ":") |> List.first()

      port = String.split(host_port, ":") |> List.last() |> String.to_integer()

      %{host: host, port: port, no_responders: true}

    end)

    |> List.first()

  end

end