defmodule Tai.VenueAdapters.OkEx.Stream.RouteOrderBooks do
use GenServer
alias Tai.VenueAdapters.OkEx.Stream.ProcessOrderBook
defmodule State do
@type venue_id :: Tai.Venue.id()
@type venue_symbol :: Tai.Venues.Product.symbol()
@type store_name :: atom
@type stores :: %{optional(venue_symbol) => store_name}
@type t :: %State{venue: venue_id, stores: stores}
@enforce_keys ~w(venue stores)a
defstruct ~w(venue stores)a
end
@type venue_id :: Tai.Venue.id()
@type product :: Tai.Venues.Product.t()
@type state :: State.t()
@spec start_link(venue: venue_id, order_books: [product]) :: GenServer.on_start()
def start_link(venue: venue, order_books: order_books) do
stores = order_books |> build_stores()
state = %State{venue: venue, stores: stores}
name = venue |> to_name()
GenServer.start_link(__MODULE__, state, name: name)
end
@spec to_name(venue_id) :: atom
def to_name(venue), do: :"#{__MODULE__}_#{venue}"
@spec init(state) :: {:ok, state}
def init(state), do: {:ok, state}
def handle_cast(
{%{"action" => "partial", "data" => data}, received_at},
state
) do
data
|> Enum.each(fn %{"instrument_id" => venue_symbol} = msg ->
{state, venue_symbol}
|> forward({:snapshot, msg, received_at})
end)
{:noreply, state}
end
def handle_cast(
{%{"action" => "update", "data" => data}, received_at},
state
) do
data
|> Enum.each(fn %{"instrument_id" => venue_symbol} = msg ->
{state, venue_symbol}
|> forward({:update, msg, received_at})
end)
{:noreply, state}
end
defp build_stores(order_books) do
order_books
|> Enum.reduce(
%{},
&Map.put(&2, &1.venue_symbol, &1.venue_id |> ProcessOrderBook.to_name(&1.venue_symbol))
)
end
defp forward({state, venue_symbol}, msg) do
state.stores
|> Map.fetch!(venue_symbol)
|> GenServer.cast(msg)
end
end