module RSpec::Rails::Matchers

def be_a_new(model_class)
  BeANew.new(model_class)
end

def be_new_record
  BeANewRecord.new
end

def be_valid(*args)
  BeValid.new(*args)
end

def check_action_cable_adapter
  return if ::ActionCable::SubscriptionAdapter::Test === ::ActionCable.server.pubsub
  raise StandardError, "To use ActionCable matchers set `adapter: test` in your cable.yml"
end

def check_active_job_adapter
  return if ::ActiveJob::QueueAdapters::TestAdapter === ::ActiveJob::Base.queue_adapter
  raise StandardError, "To use ActiveJob matchers set `ActiveJob::Base.queue_adapter = :test`"
end

def have_been_enqueued
  check_active_job_adapter
  ActiveJob::HaveBeenEnqueued.new
end

def have_been_performed
  check_active_job_adapter
  ActiveJob::HaveBeenPerformed.new
end

def have_broadcasted_to(target = nil)
  check_action_cable_adapter
  ActionCable::HaveBroadcastedTo.new(target, channel: described_class)
end

def have_enqueued_job(job = nil)
  check_active_job_adapter
  ActiveJob::HaveEnqueuedJob.new(job)
end

def have_enqueued_mail(mailer_class = nil, mail_method_name = nil)
  HaveEnqueuedMail.new(mailer_class, mail_method_name)
end

def have_http_status(target)
  raise ArgumentError, "Invalid HTTP status: nil" unless target
  HaveHttpStatus.matcher_for_status(target)
end

def have_performed_job(job = nil)
  check_active_job_adapter
  ActiveJob::HavePerformedJob.new(job)
end

def receive_inbound_email(message)
  ActionMailbox::ReceiveInboundEmail.new(message)
end

def send_email(criteria = {})
  SendEmail.new(criteria)
end