agala_vk

defmodule Agala.Provider.Vk.Chain.Parser do
  alias Agala.Provider.Vk.Model.Updates.{NewMessage, ReadOutgoing, DialogTyping, ReadIngoing}
  alias Agala.Provider.Vk.Model.Updates.{LeftMenuCounterEqual, SetDialogFlags, UpdateDialogFlags, ResetDialogFlags}

  def init(_) do
    []
  end

  def call(conn = %Agala.Conn{
    request: request
  }, _opts) do
    conn
    |> Map.put(:request, parse_request(request))
  end

  def parse_request([4,
    message_id,
    flags,
    user_id,
    bot_id,
    tree_dots,
    text,
    opts,
    random_id
  ]) do
    %NewMessage{
      message_id: message_id,
      flags: flags,
      user_id: user_id,
      bot_id: bot_id,
      tree_dots: tree_dots,
      text: text,
      opts: opts,
      random_id: random_id
    }
  end

  def parse_request([6,
    user_id,
    last_vk_message_id
  ]) do
    %ReadIngoing{
      user_id: user_id,
      last_vk_message_id: last_vk_message_id
    }
  end

  def parse_request([10,
    peer_id,
    mask
  ]) do
    %ResetDialogFlags{
      peer_id: peer_id,
      mask: mask
    }
  end

  def parse_request([11,
    peer_id,
    mask
  ]) do
    %UpdateDialogFlags{
      peer_id: peer_id,
      mask: mask
    }
  end

  def parse_request([12,
    peer_id,
    mask
  ]) do
    %SetDialogFlags{
      peer_id: peer_id,
      mask: mask
    }
  end

  def parse_request([7,
    user_id,
    last_vk_message_id
  ]) do
    %ReadOutgoing{
      user_id: user_id,
      last_vk_message_id: last_vk_message_id
    }
  end

  def parse_request([61,
    user_id,
    1
  ]) do
    %DialogTyping{
      user_id: user_id
    }
  end

  def parse_request([80,
    count,
    0
  ]) do
    %LeftMenuCounterEqual{
      count: count
    }
  end

  def parse_request(unknown_request), do: unknown_request
end