kanbanworkflowstimelinescrumrubyroadmapproject-planningproject-managementopenprojectangularissue-trackerifcgantt-chartganttbug-trackerboardsbcf
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
101 lines
3.2 KiB
101 lines
3.2 KiB
#-- encoding: UTF-8
|
|
|
|
#-- copyright
|
|
# OpenProject is an open source project management software.
|
|
# Copyright (C) 2012-2021 the OpenProject GmbH
|
|
#
|
|
# This program is free software; you can redistribute it and/or
|
|
# modify it under the terms of the GNU General Public License version 3.
|
|
#
|
|
# OpenProject is a fork of ChiliProject, which is a fork of Redmine. The copyright follows:
|
|
# Copyright (C) 2006-2013 Jean-Philippe Lang
|
|
# Copyright (C) 2010-2013 the ChiliProject Team
|
|
#
|
|
# This program is free software; you can redistribute it and/or
|
|
# modify it under the terms of the GNU General Public License
|
|
# as published by the Free Software Foundation; either version 2
|
|
# of the License, or (at your option) any later version.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with this program; if not, write to the Free Software
|
|
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
|
#
|
|
# See docs/COPYRIGHT.rdoc for more details.
|
|
#++
|
|
|
|
require 'spec_helper'
|
|
|
|
describe Notifications::ScheduleReminderMailsJob, type: :job do
|
|
subject(:job) { scheduled_job.invoke_job }
|
|
|
|
let(:scheduled_job) do
|
|
described_class.ensure_scheduled!
|
|
|
|
Delayed::Job.first
|
|
end
|
|
|
|
let(:ids) { [23, 42] }
|
|
let(:run_at) { scheduled_job.run_at }
|
|
|
|
before do
|
|
# We need to access the job as stored in the database to get at the run_at time persisted there
|
|
allow(ActiveJob::Base)
|
|
.to receive(:queue_adapter)
|
|
.and_return(ActiveJob::QueueAdapters::DelayedJobAdapter.new)
|
|
|
|
scheduled_job.update_column(:run_at, run_at)
|
|
|
|
scope = instance_double(ActiveRecord::Relation)
|
|
allow(User)
|
|
.to receive(:having_reminder_mail_to_send)
|
|
.and_return(scope)
|
|
|
|
allow(scope)
|
|
.to receive(:pluck)
|
|
.with(:id)
|
|
.and_return(ids)
|
|
end
|
|
|
|
describe '#perform' do
|
|
shared_examples_for 'schedules reminder mails' do
|
|
it 'schedules reminder jobs for every user with a reminder mails to be sent' do
|
|
expect { subject }
|
|
.to change(Delayed::Job, :count)
|
|
.by(2)
|
|
|
|
jobs = Delayed::Job.all.map do |job|
|
|
YAML.safe_load(job.handler, permitted_classes: [ActiveJob::QueueAdapters::DelayedJobAdapter::JobWrapper])
|
|
end
|
|
|
|
reminder_jobs = jobs.select { |job| job.job_data['job_class'] == "Mails::ReminderJob" }
|
|
|
|
expect(reminder_jobs[0].job_data['arguments'])
|
|
.to match_array([23])
|
|
|
|
expect(reminder_jobs[1].job_data['arguments'])
|
|
.to match_array([42])
|
|
end
|
|
|
|
it 'queries with the intended job execution time (which might have been missed due to high load)' do
|
|
subject
|
|
|
|
expect(User)
|
|
.to have_received(:having_reminder_mail_to_send)
|
|
.with(run_at)
|
|
end
|
|
end
|
|
|
|
it_behaves_like 'schedules reminder mails'
|
|
|
|
context 'with a job that missed some runs' do
|
|
let(:run_at) { scheduled_job.run_at - 3.hours }
|
|
|
|
it_behaves_like 'schedules reminder mails'
|
|
end
|
|
end
|
|
end
|
|
|