ccxt_client

defmodule CCXT.WS.Subscription.OpSubscribe do
  @moduledoc """
  Bybit/Bitmex-style subscribe frame.

      %{"op" => "subscribe", "args" => ["tickers.BTCUSDT", "orderbook.50.BTCUSDT"]}

  Config keys: `:op_field` (default `"op"`), `:args_field` (default `"args"`).
  """

  @behaviour CCXT.WS.Subscription.Behaviour

  @impl true
  def subscribe(channels, config) when is_list(channels) do
    build(channels, config, "subscribe")
  end

  @impl true
  def unsubscribe(channels, config) when is_list(channels) do
    build(channels, config, "unsubscribe")
  end

  defp build(channels, config, action) do
    op = Map.get(config, :op_field, "op")
    args = Map.get(config, :args_field, "args")
    %{op => action, args => channels}
  end
end