helen

defmodule Fact.RelativeHumidity do
  @moduledoc false

  use Instream.Series
  alias Fact.RelativeHumidity
  import(Fact.Influx, only: [write: 2])

  alias TimeSupport

  series do
    database(Application.get_env(:helen, Fact.Influx) |> Keyword.get(:database))
    measurement("relative_humidity")

    tag(:remote_host)
    tag(:device)
    tag(:name)
    tag(:env, default: Application.get_env(:helen, :build_env, "dev"))

    field(:val)
  end

  def record(opts)
      when is_list(opts) do
    def_mtime = TimeSupport.unix_now(:second)
    f = %RelativeHumidity{}

    f = set_tag(f, opts, :remote_host)
    f = set_tag(f, opts, :name)
    f = set_tag(f, opts, :device)

    f = set_field(f, opts, :val)

    f = %{f | timestamp: Keyword.get(opts, :mtime, def_mtime)}
    write(f, precision: :second, async: true)
  end

  defp set_tag(map, opts, key)
       when is_map(map) and is_list(opts) and is_atom(key) do
    set_tag(map, key, Keyword.get(opts, key))
  end

  defp set_tag(map, _key, nil) when is_map(map), do: map

  defp set_tag(map, key, value)
       when is_map(map) and is_atom(key) do
    %{map | tags: %{map.tags | key => value}}
  end

  defp set_field(map, opts, key)
       when is_map(map) and is_list(opts) and is_atom(key) do
    set_field(map, key, Keyword.get(opts, key))
  end

  defp set_field(map, _key, nil) when is_map(map), do: map

  defp set_field(map, key, value)
       when is_map(map) and is_atom(key) do
    %{map | fields: %{map.fields | key => value}}
  end
end