#!/usr/bin/env ruby

def drain_events
  @processor.send(:foreach_on_queue, 'events') do |event|
    @processor.send(:process_event, event)
  end
  drain_notifications
end

def drain_notifications
  return unless @notifier
  @notifier.instance_variable_get('@queue').send(:foreach) do |notification|
    @notifier.send(:process_notification, notification)
  end
end

def set_scheduled_maintenance(entity_name, check_name, duration)
  check = Flapjack::Data::Check.intersect(:name => "#{entity_name}:#{check_name}").all.first
  expect(check).not_to be_nil

  t = Time.now
  sched_maint = Flapjack::Data::ScheduledMaintenance.new(:start_time => Time.at(t.to_i - 60),
    :end_time => Time.at(t.to_i + duration), :summary => 'upgrading everything')
  expect(sched_maint.save).to be true
  check.scheduled_maintenances << sched_maint
end

def remove_scheduled_maintenance(entity_name, check_name)
  check = Flapjack::Data::Check.intersect(:name => "#{entity_name}:#{check_name}").all.first
  expect(check).not_to be_nil

  t = Time.now
  check.scheduled_maintenances.each do |sm|
    check.end_scheduled_maintenance(sm, t)
    sched_maint.destroy
  end
end

def set_unscheduled_maintenance(entity_name, check_name, duration)
  check = Flapjack::Data::Check.intersect(:name => "#{entity_name}:#{check_name}").all.first
  expect(check).not_to be_nil

  t = Time.now
  unsched_maint = Flapjack::Data::UnscheduledMaintenance.new(:start_time => t,
    :end_time => Time.at(t.to_i + duration), :summary => 'fixing now')
  expect(unsched_maint.save).to be true
  check.set_unscheduled_maintenance(unsched_maint)
end

def clear_unscheduled_maintenance(entity_name, check_name)
  check = Flapjack::Data::Check.intersect(:name => "#{entity_name}:#{check_name}").all.first
  expect(check).not_to be_nil

  check.clear_unscheduled_maintenance(Time.now)
end

def set_state(entity_name, check_name, condition, last_update = Time.now)
  check = Flapjack::Data::Check.intersect(:name => "#{entity_name}:#{check_name}").all.first
  expect(check).not_to be_nil

  state = Flapjack::Data::State.new(:created_at => last_update, :updated_at => last_update,
    :condition => condition)
  state.save
  check.states << state
end

def submit_event(condition, entity_name, check_name)
  err_rate = case condition
  when 'ok'
    '0'
  when 'warning'
    '25'
  when 'critical'
    '100'
  end
  event = {
    'type'    => 'service',
    'state'   => condition,
    'summary' => "#{err_rate}% packet loss",
    'entity'  => entity_name,
    'check'   => check_name,
  }
  ['initial_failure', 'repeat_failure', 'initial_recovery'].each do |delay_type|
    delay = instance_variable_get("@event_#{delay_type}_delay")
    next if delay.nil? || delay < 0
    event.update("#{delay_type}_delay".to_sym => delay)
  end
  Flapjack.redis.rpush('events', Flapjack.dump_json(event))
end

def submit_acknowledgement(entity_name, check_name)
  event = {
    'type'    => 'action',
    'state'   => 'acknowledgement',
    'summary' => "I'll have this fixed in a jiffy, saw the same thing yesterday",
    'entity'  => entity_name,
    'check'   => check_name,
  }
  Flapjack.redis.rpush('events', Flapjack.dump_json(event))
end

def submit_test(entity_name, check_name)
  event = {
    'type'    => 'action',
    'state'   => 'test_notifications',
    'summary' => "test notification for all contacts interested in #{entity_name}",
    'entity'  => entity_name,
    'check'   => check_name,
  }
  Flapjack.redis.rpush('events', Flapjack.dump_json(event))
end

def stringify(obj)
  return obj.inject({}){|memo,(k,v)| memo[k.to_s] =  stringify(v); memo} if obj.is_a?(Hash)
  return obj.inject([]){|memo,v    | memo         << stringify(v); memo} if obj.is_a?(Array)
  obj
end

Given /^the check is check '(.*)' on entity '([\w\.\-]+)'$/ do |check_name, entity_name|
  check = Flapjack::Data::Check.intersect(:name => "#{entity_name}:#{check_name}").all.first
  if check.nil?
    check = Flapjack::Data::Check.new(:name => "#{entity_name}:#{check_name}",
      :enabled => true)
    expect(check.save).to be true
  end

  @check_name  = check_name
  @entity_name = entity_name
end

Given /^(?:the check|check '([\w\.\-]+)' for entity '([\w\.\-]+)') has no state$/ do |check_name, entity_name|
  check_name  ||= @check_name
  entity_name ||= @entity_name
end

Given /^(?:the check|check '([\w\.\-]+)' for entity '([\w\.\-]+)') is in an? (ok|critical) state$/ do |check_name, entity_name, state|
  check_name  ||= @check_name
  entity_name ||= @entity_name
  set_state(entity_name, check_name, state, Time.now)
end

Given /^(?:the check|check '([\w\.\-]+)' for entity '([\w\.\-]+)') is in scheduled maintenance(?: for (.+))?$/ do |check_name, entity_name, duration|
  check_name  ||= @check_name
  entity_name ||= @entity_name
  durn = duration ? ChronicDuration.parse(duration) : (6 * 60 *60)
  set_scheduled_maintenance(entity_name, check_name, durn)
end

Given /^(?:the check|check '([\w\.\-]+)' for entity '([\w\.\-]+)') is in unscheduled maintenance$/ do |check_name, entity_name|
  check_name  ||= @check_name
  entity_name ||= @entity_name
  set_unscheduled_maintenance(entity_name, check_name, 60*60*2)
end

# Set the delays for next events
Given /^event (initial failure|repeat failure|initial recovery) delay is (\d+) seconds$/ do |delay_type, delay|
  instance_variable_set("@event_#{delay_type.sub(/ /, '_')}_delay", delay.to_i)
end

When /^an? (ok|failure|critical|warning|unknown) event is received(?: for check '([\w\.\-]+)' on entity '([\w\.\-]+)')?$/ do |condition, check_name, entity_name|
  check_name  ||= @check_name
  entity_name ||= @entity_name
  submit_event(condition, entity_name, check_name)
  drain_events
end

When /^an acknowledgement .*is received(?: for check '([\w\.\-]+)' on entity '([\w\.\-]+)')?$/ do |check_name, entity_name|
  check_name  ||= @check_name
  entity_name ||= @entity_name
  submit_acknowledgement(entity_name, check_name)
  drain_events
end

When /^a test .*is received(?: for check '([\w\.\-]+)' on entity '([\w\.\-]+)')?$/ do |check_name, entity_name|
  check_name  ||= @check_name
  entity_name ||= @entity_name
  submit_test(entity_name, check_name)
  drain_events
end

When /^the unscheduled maintenance is ended(?: for check '([\w\.\-]+)' on entity '([\w\.\-]+)')?$/ do |check_name, entity_name|
  check_name  ||= @check_name
  entity_name ||= @entity_name
  clear_unscheduled_maintenance(entity_name, check_name)
end

Then /^(no|\d+) notifications? should have been generated(?: for check '([\w\.\-]+)' on entity '([\w\.\-]+)')?$/ do |count, check_name, entity_name|
  check_name  ||= @check_name
  entity_name ||= @entity_name

  check = Flapjack::Data::Check.intersect(:name => "#{entity_name}:#{check_name}").all.first
  expect(check).not_to be_nil

  case count
  when 'no', 0
    expect(check.notification_count).to be_nil
  else
    expect(check.notification_count).to eq(count.to_i)
  end
end

Then /^(un)?scheduled maintenance should be generated(?: for check '([\w\.\-]+)' on entity '([\w\.\-]+)')?$/ do |unsched, check_name, entity_name|
  check_name  ||= @check_name
  entity_name ||= @entity_name

  check = Flapjack::Data::Check.intersect(:name => "#{entity_name}:#{check_name}").all.first
  expect(check).not_to be_nil

  expect(check).to (unsched ? be_in_unscheduled_maintenance : be_in_scheduled_maintenance)
end

Then /^show me the (\w+ )*log$/ do |adjective|
  puts "the #{adjective}log:"
  puts Flapjack.logger.messages.join("\n")
end

Then /^(\w+) (\w+) alert(?:s)?(?: of)?(?: type (\w+))?(?: and)?(?: rollup (\w+))? should be queued for (.*)$/ do |num_queued, media, notification_type, rollup, address|
  case num_queued
  when 'no'
    num_queued = 0
  end
  queued = redis_peek("#{media}_notifications", Flapjack::Data::Alert, 0, 30)
  queued_length = queued.find_all {|alert|
    type_ok = notification_type ? ( alert.notification_type == notification_type ) : true
    rollup_ok = true
    if rollup
      if rollup == 'none'
        rollup_ok = alert.rollup.nil?
      else
        rollup_ok = (alert.rollup == rollup)
      end
    end
    type_ok && rollup_ok && (alert.medium.address == address)
  }.length
  expect(queued_length).to eq(num_queued.to_i)
end

When(/^the rule with id '(\S+)' is removed$/) do |rule_id|
  rule = Flapjack::Data::Rule.find_by_id(rule_id)
  expect(rule).not_to be_nil

  # # this should happen anyway...
  # rule.contact.rules.remove(rule) unless rule.contact.nil?

  rule.destroy
end

When /^check '([\w\.\-]+)' (?:for|on) entity '([\w\.\-]+)' is (dis|en)abled$/ do |check_name, entity_name, dis_en|
  check = Flapjack::Data::Check.intersect(:name => "#{entity_name}:#{check_name}").all.first
  expect(check).not_to be_nil

  check.enabled = 'en'.eql?(dis_en)
  check.save!
end