helen

defmodule Mqtt.Timesync do
  @moduledoc false

  alias __MODULE__

  require Logger
  use Task

  import TimeSupport, only: [ms: 1, unix_now: 1]

  alias Mqtt.Client

  @timesync_cmd "time.sync"

  def run(opts) do
    # reasonable defaults if configuration is not set
    frequency = Map.get(opts, :frequency, {:mins, 1})
    loops = Map.get(opts, :loops, 0)
    forever = Map.get(opts, :forever, true)
    log = Map.get(opts, :log, false)
    single = Map.get(opts, :single, false)

    # construct the timesync message and publish it
    res = Timesync.new_cmd() |> Client.publish_cmd()

    log && Logger.info(["published timesync ", inspect(res, pretty: true)])

    opts = %{opts | loops: opts.loops - 1}

    cond do
      single ->
        :ok

      forever or loops - 1 > 0 ->
        :timer.sleep(ms(frequency))
        run(opts)

      true ->
        :executed_requested_loops
    end
  end

  def send do
    run(%{single: true})
  end

  def new_cmd do
    %{}
    |> Map.put(:mtime, unix_now(:second))
    |> Map.put(:cmd, @timesync_cmd)
  end
end