A GenStage producer that connects to a HLDS server and sets up log forwarding to itself. Should only be calling this module directly if you want to manage the supervision of these processes yourself, otherwise the functions in HLDSLogs will create processes under a dynamic supervisor.

When a process is started, it is provided with host:port informtion for the HLDS server, and self-referenial host:port information to provide to the HLDS server. The self-referencial host information must be reachable from the HLDS server.

Log Forwarding

HLDS provides a mechanisim for forwarding logged messages over UDP to a designated host:port. This is set up with the logaddress console commands. This module will use HLDSRcon to set up an rcon connection to the HLDS server, then it will issue the logaddress_add command with the self-referencial host information it was provided - this will cause HLDS to forward all log entries to this process.

Producer

This producer will create a single event, represented by the HLDSLogs.LogEntry struct, for each log entry it recieves. It does not respond to consumer demand, and instead creates events as soon as possible, based on the log activity from the HLDS server.

Example Consumer

This example module is set up to simply forward log bodies from HLDS to Logger.info/1.

defmodule LoggerConsumer do
  use GenStage

  require Logger

  def start_link() do
    GenStage.start_link(__MODULE__, :ok)
  end

  def init(:ok) do
    {:consumer, nil}
  end

  def handle_events(events, _from, nil) do
    events
    |> Enum.map(fn log_entry -> log_entry.body end)
    |> Enum.map(&Logger.info/1)
    {:noreply, [], nil}
  end
end