shadowsocks

defmodule Shadowsocks.Event do
  require Logger

  defmacro start_listener(port) do
    quote do
      :gen_event.notify(Shadowsocks.Event, {:port, :open, unquote(port)})
    end
  end

  defmacro open_conn(port, pid, addr) do
    quote do
      :gen_event.notify(Shadowsocks.Event, {:conn, :open, {unquote(port), unquote(pid), unquote(addr)}})
    end
  end

  defmacro close_conn(port, pid, reason, flow) do
    quote do
      :gen_event.notify(Shadowsocks.Event, {:conn, :close, {unquote(port), unquote(pid), unquote(reason), unquote(flow)}})
    end
  end

  defmacro bad_request(port, addr) do
    quote do
      :gen_event.notify(Shadowsocks.Event, {:bad_request, unquote(port), unquote(addr)})
    end
  end

  defmacro connect(port, pid, info) do
    quote do
      Logger.debug "#{inspect unquote(info)}"
      :gen_event.notify(Shadowsocks.Event, {:conn, :connect, {unquote(port), unquote(pid), unquote(info)}})
    end
  end

  defmacro flow(port, down, up) do
    quote do
      :gen_event.notify(Shadowsocks.Event, {:port, :flow, {unquote(port),unquote(down), unquote(up)}})
    end
  end
  defmacro sync_flow(port, down, up) do
    quote do
      :gen_event.sync_notify(Shadowsocks.Event, {:port, :flow, {unquote(port),unquote(down), unquote(up)}})
    end
  end

  defmacro dynamic_blocked(addr) do
    quote do
      :gen_event.notify(Shadowsocks.Event, {:dynamic_blocked, unquote(addr)})
    end
  end
end