wobserverfork

defmodule Wobserver.Util.Helper do
  @moduledoc ~S"""
  Helper functions and JSON encoders.
  """

  alias Poison.Encoder
  alias Encoder.BitString

  defimpl Encoder, for: PID do
    @doc ~S"""
    JSON encodes a `PID`.

    Uses `inspect/1` to turn the `pid` into a String and passes the `options` to `BitString.encode/1`.
    """
    @spec encode(pid :: pid, options :: any) :: String.t
    def encode(pid, options) do
      pid
      |> inspect
      |> BitString.encode(options)
    end
  end

  defimpl Encoder, for: Port do
    @doc ~S"""
    JSON encodes a `Port`.

    Uses `inspect/1` to turn the `port` into a String and passes the `options` to `BitString.encode/1`.
    """
    @spec encode(port :: port, options :: any) :: String.t
    def encode(port, options) do
      port
      |> inspect
      |> BitString.encode(options)
    end
  end

  defimpl Encoder, for: Reference do
    @doc ~S"""
    JSON encodes a `Reference`.

    Uses `inspect/1` to turn the `reference` into a String and passes the `options` to `BitString.encode/1`.
    """
    @spec encode(reference :: reference, options :: any) :: String.t
    def encode(reference, options) do
      reference
      |> inspect
      |> BitString.encode(options)
    end
  end

  @doc ~S"""
  Converts Strings to module names or atoms.

  The given `module` string will be turned into atoms that get concatted.
  """
  @spec string_to_module(module :: String.t) :: atom
  def string_to_module(module) do
    first_letter = String.first(module)

    case String.capitalize(first_letter) do
      ^first_letter ->
        module
        |> String.split(".")
        |> Enum.map(&String.to_atom/1)
        |> Module.concat
      _ ->
        module
        |> String.to_atom
    end
  end

  @doc ~S"""
  Formats function information as readable string.

  Only name will be return if only `name` is given.

  Example:
  ```bash
  iex> format_function {Logger, :log, 2}
  "Logger.log/2"
  ```
  ```bash
  iex> format_function :format_function
  "format_function"
  ```
  ```bash
  iex> format_function nil
  nil
  ```
  """
  @spec format_function(nil | {atom, atom, integer} | atom) :: String.t | nil
  def format_function(nil), do: nil
  def format_function({module, name, arity}), do: "#{module}.#{name}/#{arity}"
  def format_function(name), do: "#{name}"

  @doc ~S"""
  Parallel map implemented with `Task`.

  Maps the `function` over the `enum` using `Task.async/1` and `Task.await/1`.
  """
  @spec parallel_map(enum :: list, function :: fun) :: list
  def parallel_map(enum, function) do
    enum
    |> Enum.map(&(Task.async(fn -> function.(&1) end)))
    |> Enum.map(&Task.await/1)
  end
end