defmodule Exred.Node.RedisOut do
  @moduledoc """
  A Redis outut node.

  Select the Redis command in the config tab.

  Expects command arguments in msg.payload either as a list or a string if
  there's only one argument.

  Examples:

  **SET command:**
  msg.payload = ["myKey"]
  OR
  msg.payload = "myKey"

  **LPUSH command:**
  msg.payload = ["item-1", "item-2"]
  """

  @name "Redis Out"
  @category "output"
  @info @moduledoc
  @config %{
    connection_name: %{type: "string", value: "redis"},
    command: %{
      type: "select",
      value: "SET",
      attrs: %{options: ["SET", "LPUSH", "LPUSHX", "LSET"]}
    },
    name: %{type: "string", value: ""}
  }
  @ui_attributes %{right_icon: "send"}

  use Exred.NodePrototype

  @impl true
  def handle_msg(msg, state) do
    redix_conn = String.to_atom(state.config.connection_name.value)

    redix_cmd =
      if is_list(msg.payload) do
        [state.config.command.value | msg.payload]
      else
        [state.config.command.value, msg.payload]
      end

    result = Redix.command!(redix_conn, redix_cmd)

    msg_out = %{msg | payload: result}

    {msg_out, state}
  end
end