Pre4

.prettierrc.js

@@ -1,6 +1,6 @@
 module.exports = {
   trailingComma: "es5",
   tabWidth: 2,
-  semi: false,
+  semi: true,
   singleQuote: false,
-}
+};

lib/ckd/application.ex

@@ -6,6 +6,10 @@ defmodule Ckd.Application do
   use Application
 
   @dero_wallet_worker_registry :dero_wallet_worker_registry
+  @dero_queue_worker_registry :dero_queue_worker_registry
+  @dero_transfer_worker_registry :dero_transfer_worker_registry
+  @m_worker_registry :m_worker_registry
+  @rtbl_worker_registry :rtbl_worker_registry
 
   def start(_type, _args) do
     children = [
@@ -18,8 +22,16 @@ defmodule Ckd.Application do
       # State store
       {Ckd.State, [statefile: statefile_path()]},
       # Services
-      Ckd.DeroWallet,
       {Registry, [keys: :unique, name: @dero_wallet_worker_registry]},
+      {Registry, [keys: :unique, name: @dero_transfer_worker_registry]},
+      {Registry, [keys: :unique, name: @dero_queue_worker_registry]},
+      {Registry, [keys: :unique, name: @m_worker_registry]},
+      {Registry, [keys: :unique, name: @rtbl_worker_registry]},
+      Ckd.DeroWallet,
+      Ckd.DeroTransfer,
+      Ckd.DeroQueue,
+      Ckd.M,
+      Ckd.Rtbl,
       # Start the Endpoint (http/https)
       CkdWeb.Endpoint
       # Start a worker by calling: Ckd.Worker.start_link(arg)
@@ -42,6 +54,18 @@ defmodule Ckd.Application do
   @spec dero_wallet_worker_registry :: :dero_wallet_worker_registry
   def dero_wallet_worker_registry, do: @dero_wallet_worker_registry
 
+  @spec dero_queue_worker_registry :: :dero_queue_worker_registry
+  def dero_queue_worker_registry, do: @dero_queue_worker_registry
+
+  @spec dero_transfer_worker_registry :: :dero_transfer_worker_registry
+  def dero_transfer_worker_registry, do: @dero_transfer_worker_registry
+
+  @spec m_worker_registry :: :m_worker_registry
+  def m_worker_registry, do: @m_worker_registry
+
+  @spec rtbl_worker_registry :: :rtbl_worker_registry
+  def rtbl_worker_registry, do: @rtbl_worker_registry
+
   # Tell Phoenix to update the endpoint configuration
   # whenever the application is updated.
   def config_change(changed, _new, removed) do

lib/ckd/services/dero/dero_queue.ex

@@ -0,0 +1,96 @@
+defmodule Ckd.DeroQueue do
+  @moduledoc false
+
+  use DynamicSupervisor
+
+  alias Ckd.DeroQueueWorker
+
+  @spec start_link(any) :: :ignore | {:error, any} | {:ok, pid}
+  def start_link(_), do: DynamicSupervisor.start_link(__MODULE__, [], name: __MODULE__)
+
+  @impl true
+  @spec init(any) ::
+          {:ok,
+           %{
+             extra_arguments: list,
+             intensity: non_neg_integer,
+             max_children: :infinity | non_neg_integer,
+             period: pos_integer,
+             strategy: :one_for_one
+           }}
+  def init(_), do: DynamicSupervisor.init(strategy: :one_for_one)
+
+  @spec subscribe_info(
+          {:dero_queue, binary}
+          | {:dero_queue_item, [{:aid, binary} | {:qid, binary}, ...]}
+          | {:dero_queue_pending_item, binary}
+        ) :: any
+  def subscribe_info(key = {:dero_queue, aid}) when is_binary(aid),
+    do: GenServer.call(worker_pid(aid), {:subscribe_info, key})
+
+  def subscribe_info(key = {:dero_queue_item, aid: aid, qid: qid})
+      when is_binary(aid) and is_binary(qid),
+      do: GenServer.call(worker_pid(aid), {:subscribe_info, key})
+
+  def subscribe_info(key = {:dero_queue_pending_item, aid}) when is_binary(aid),
+    do: GenServer.call(worker_pid(aid), {:subscribe_info, key})
+
+  @spec unsubscribe_info(
+          {:dero_queue, binary}
+          | {:dero_queue_item, [{:aid, binary} | {:qid, binary}, ...]}
+          | {:dero_queue_pending_item, binary}
+        ) :: any
+  def unsubscribe_info(key = {:dero_queue, aid}) when is_binary(aid),
+    do: GenServer.call(worker_pid(aid), {:unsubscribe_info, key})
+
+  def unsubscribe_info(key = {:dero_queue_item, aid: aid, qid: qid})
+      when is_binary(aid) and is_binary(qid),
+      do: GenServer.call(worker_pid(aid), {:unsubscribe_info, key})
+
+  def unsubscribe_info(key = {:dero_queue_pending_item, aid}) when is_binary(aid),
+    do: GenServer.call(worker_pid(aid), {:unsubscribe_info, key})
+
+  @spec read(
+          {:dero_queue, binary}
+          | {:dero_queue_item, [{:aid, binary} | {:qid, binary}, ...]}
+          | {:dero_queue_pending_item, binary}
+        ) :: any
+  def read(key = {:dero_queue, aid}) when is_binary(aid),
+    do: GenServer.call(worker_pid(aid), {:read, key})
+
+  def read(key = {:dero_queue_item, aid: aid, qid: qid})
+      when is_binary(aid) and is_binary(qid),
+      do: GenServer.call(worker_pid(aid), {:read, key})
+
+  def read(key = {:dero_queue_pending_item, aid}) when is_binary(aid),
+    do: GenServer.call(worker_pid(aid), {:read, key})
+
+  def queue_action(aid, action = {name, opts})
+      when is_binary(aid) and is_atom(name) and is_map(opts),
+      do: GenServer.call(worker_pid(aid), {:queue_action, aid, action})
+
+  @spec authorize_action([{:aid, binary} | {:qid, binary}, ...]) :: any
+  def authorize_action(aid: aid, qid: qid) when is_binary(aid) and is_binary(qid),
+    do: GenServer.call(worker_pid(aid), {:authorize_action, qid})
+
+  @spec cancel_action([{:aid, binary} | {:qid, binary}, ...]) :: any
+  def cancel_action(aid: aid, qid: qid) when is_binary(aid) and is_binary(qid),
+    do: GenServer.call(worker_pid(aid), {:cancel_action, qid})
+
+  defp worker_pid(aid) when is_binary(aid),
+    do:
+      (case(maybe_worker(aid)) do
+         [{pid, _}] ->
+           pid
+
+         [] ->
+           {:ok, pid} = start_worker(aid)
+           pid
+       end)
+
+  defp maybe_worker(aid) when is_binary(aid),
+    do: Registry.lookup(Ckd.Application.dero_queue_worker_registry(), aid)
+
+  defp start_worker(aid) when is_binary(aid),
+    do: DynamicSupervisor.start_child(__MODULE__, {DeroQueueWorker, aid})
+end