require "test_helper"
require "active_support/testing/time_helpers"

class CommandsAuditorTest < ActiveSupport::TestCase
  include ActiveSupport::Testing::TimeHelpers

  setup do
    freeze_time

    @config = {
      service: "app", image: "dhh/app", registry: { "username" => "dhh", "password" => "secret" }, servers: [ "1.1.1.1" ],
      audit_broadcast_cmd: "bin/audit_broadcast"
    }

    @auditor = new_command
    @performer = `whoami`.strip
    @recorded_at = Time.now.utc.iso8601
  end

  test "record" do
    assert_equal [
      :echo,
      "[#{@recorded_at}] [#{@performer}]",
      "app removed container",
      ">>", "mrsk-app-audit.log"
    ], @auditor.record("app removed container")
  end

  test "record with destination" do
    new_command(destination: "staging").tap do |auditor|
      assert_equal [
        :echo,
        "[#{@recorded_at}] [#{@performer}] [staging]",
        "app removed container",
        ">>", "mrsk-app-staging-audit.log"
      ], auditor.record("app removed container")
    end
  end

  test "record with command details" do
    new_command(role: "web").tap do |auditor|
      assert_equal [
        :echo,
        "[#{@recorded_at}] [#{@performer}] [web]",
        "app removed container",
        ">>", "mrsk-app-audit.log"
      ], auditor.record("app removed container")
    end
  end

  test "record with arg details" do
    assert_equal [
      :echo,
      "[#{@recorded_at}] [#{@performer}] [value]",
      "app removed container",
      ">>", "mrsk-app-audit.log"
    ], @auditor.record("app removed container", detail: "value")
  end

  test "broadcast" do
    assert_equal [
      "bin/audit_broadcast",
      "'[#{@performer}] [value] app removed container'",
      env: {
        "MRSK_RECORDED_AT" => @recorded_at,
        "MRSK_PERFORMER" => @performer,
        "MRSK_VERSION" => "123",
        "MRSK_EVENT" => "app removed container",
        "MRSK_DETAIL" => "value"
      }
    ], @auditor.broadcast("app removed container", detail: "value")
  end

  private
    def new_command(destination: nil, **details)
      Mrsk::Commands::Auditor.new(Mrsk::Configuration.new(@config, destination: destination, version: "123"), **details)
    end
end