module CIA

# File lib/cia.rb, line 23
def self.amend_audit(options = {}, &block)
  if current_transaction
    audit(current_transaction.merge(options), &block)
  else
    audit(options, &block)
  end
end

# File lib/cia.rb, line 15
def self.audit(options = {})
  old = Thread.current[:cia_transaction]
  Thread.current[:cia_transaction] = options
  yield
ensure
  Thread.current[:cia_transaction] = old
end

# File lib/cia.rb, line 39
def self.current_actor
  current_transaction[:actor] if current_transaction
end

# File lib/cia.rb, line 35
def self.current_actor=(user)
  current_transaction[:actor] = user if current_transaction
end

# File lib/cia.rb, line 31
def self.current_transaction
  Thread.current[:cia_transaction]
end

# File lib/cia.rb, line 43
def self.record(action, source)
  return unless current_transaction
  options = source.class.audited_attribute_options
  return if options and options[:if] and not source.send(options[:if])
  return if options and options[:unless] and source.send(options[:unless])

  changes = (source.cia_previous_changes || source.cia_changes).slice(*source.class.audited_attributes)
  if source.respond_to?(:audit_message)
    message = source.audit_message.presence
    source.audit_message = nil
  end

  return if not message and changes.empty? and action.to_s == "update"

  transaction_attributes = current_transaction.dup
  transaction_attributes.reject! { |k, _v| non_recordable_attributes.include?(k) } if non_recordable_attributes

  event = CIA::Event.new(transaction_attributes.reverse_merge(
    action: action.to_s,
    source: source,
    message: message
  ))
  event.add_attribute_changes(changes)
  event.save!
  event
rescue StandardError
  if exception_handler
    exception_handler.call $!
  else
    raise
  end
end