telegram_mt

defmodule MTProto.Session.Brain do
  require Logger
  alias MTProto.{Auth, Registry, Session}
  alias MTProto.Session.Handler

  @moduledoc false

  # Process plain messages
  def process(msg, session_id, :plain) do
    name = Map.get(msg, :name)

    case name do
      "resPQ" -> Auth.resPQ(msg, session_id)
      "server_DH_params_ok" -> Auth.server_DH_params_ok(msg, session_id)
      "server_DH_params_fail" -> Auth.server_DH_params_fail(msg, session_id)
      "dh_gen_ok" -> Auth.dh_gen_ok(msg, session_id)
      "dh_gen_fail" -> Auth.dh_gen_fail(msg, session_id)
      "dh_gen_retry" -> Auth.dh_gen_fail(msg, session_id)
      "error" -> handle_error(session_id, msg)
      _ ->
        Logger.debug "[MT][Brain] Unknow predicate : #{name}"
    end
  end

  # Process encrypted messages
  def process(msg, session_id, :encrypted) do
    session = Registry.get :session, session_id
    name = Map.get(msg, :name)

    # Process RPC
    if name == "rpc_result" do
      result = Map.get msg, :result
      name = result |> Map.get(:name)

      case name do
        "auth.sentCode" ->
          hash = Map.get result, :phone_code_hash
          Registry.set :session, session_id, :phone_code_hash, hash
        "rpc_error" -> handle_rpc_error(session_id, result)
          _ -> :noop
      end

      # ACK
      msg_ids = [Map.get(msg, :msg_id)]
      ack = MTProto.Method.msgs_ack(msg_ids)
      Handler.send_encrypted(ack, session_id)
    end

    # Notify the client
    if session.client != nil do
      send session.client, {:recv, session_id, msg}
    else
      IO.puts "No client for #{session_id}, printing to console."
      IO.inspect {session_id, msg}
    end
  end

  ## Error Handling
  ## See https://core.telegram.org/api/errors

  # Handle errors for plain messages
  defp handle_error(session_id, msg) do
    error_code = Map.get(msg, :code)

    case error_code do
      -404 ->
        session = Registry.get(:session, session_id)
        dc = Registry.get(:dc, session.dc)
        if dc.auth_key == <<0::8*8>> do
          Logger.debug "[MT][Brain] I received a -404 error. I still don't have an auth key
          for this DC (#{dc.id}) so I'm going to generate one ! I'm a workaround ;("
          Auth.req_pq(session_id)
        end
        _ -> Logger.warn "[MT][Brain] Unknown error : #{error_code}"
    end
  end

  # Handle errors for encrypted messages
  defp handle_rpc_error(session_id, rpc_result) do
    error_code = Map.get(rpc_result, :error_code)
    error_message = Map.get(rpc_result, :error_message)

    Logger.warn "[MT][Brain] RPC error : #{error_code} | #{error_message}"
    case error_code do
      303 -> # 303 ERROR_SEE_OTHER
      if error_message =~ ~r/^PHONE_MIGRATE_(\d)$/ do # PHONE_MIGRATE_X
        dc_id = Regex.run(~r/^PHONE_MIGRATE_(\d)$/, error_message)
                  |> List.last
                  |> String.to_integer
        # Automatically reconnectto the new DC
        Session.reconnect(session_id, dc_id)
      end
      _ -> :noop
    end
  end
end