require "spec_helper"

describe DispatchRider::ScheduledJob do
  let(:message_details) {
    {
      destinations: [:allied_forces],
      message: {
        subject: :war_update,
        body: { enigma_machine: :broken }
      }
    }
  }

  let!(:due_job) { described_class.create! message_details.merge(scheduled_at: 1.minute.ago) }
  let!(:later_job) { described_class.create! message_details.merge(scheduled_at: 30.minutes.since) }

  describe ".due" do
    describe "due now" do
      subject(:due_jobs) { described_class.due }

      it { expect(due_jobs).to include due_job }
      it { expect(due_jobs).to_not include later_job }
    end

    describe "due tomorrow" do
      subject(:due_jobs) { described_class.due Date.tomorrow.midnight }

      it { expect(due_jobs).to include due_job }
      it { expect(due_jobs).to include later_job }
    end
  end

  describe ".publish_due_jobs" do
    example {
      expect(described_class.publisher).to receive(:publish).once.with destinations: [:allied_forces],
                                                                       message: {
                                                                         subject: :war_update,
                                                                         body: { enigma_machine: :broken }
                                                                       }

      2.times { described_class.publish_due_jobs }
    }
  end

  describe "#destinations serialization" do
    subject { described_class.find(due_job.id).destinations }

    it { is_expected.to eq [:allied_forces] }
  end

  describe "#message serialization" do
    subject { described_class.find(due_job.id).message }

    it {
      is_expected.to eq subject: :war_update,
                        body: { enigma_machine: :broken }
    }
  end

  describe "#publish" do
    subject(:job) { described_class.find(due_job.id) }

    example {
      expect(described_class.publisher).to receive(:publish).with destinations: [:allied_forces],
                                                                  message: {
                                                                    subject: :war_update,
                                                                    body: { enigma_machine: :broken }
                                                                  }

      job.publish
    }
  end
end