maintenance: consolidate maintenance tasks in logical/maintenance.rb.
This commit is contained in:
@@ -1,5 +1,12 @@
|
|||||||
class DailyMaintenance
|
module Maintenance
|
||||||
def run
|
module_function
|
||||||
|
|
||||||
|
def hourly
|
||||||
|
UploadErrorChecker.new.check!
|
||||||
|
DelayedJobErrorChecker.new.check!
|
||||||
|
end
|
||||||
|
|
||||||
|
def daily
|
||||||
ActiveRecord::Base.connection.execute("set statement_timeout = 0")
|
ActiveRecord::Base.connection.execute("set statement_timeout = 0")
|
||||||
PostPruner.new.prune!
|
PostPruner.new.prune!
|
||||||
Upload.where('created_at < ?', 1.day.ago).delete_all
|
Upload.where('created_at < ?', 1.day.ago).delete_all
|
||||||
@@ -18,4 +25,11 @@ class DailyMaintenance
|
|||||||
TagChangeRequestPruner.reject_all
|
TagChangeRequestPruner.reject_all
|
||||||
Ban.prune!
|
Ban.prune!
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def weekly
|
||||||
|
ActiveRecord::Base.connection.execute("set statement_timeout = 0")
|
||||||
|
UserPasswordResetNonce.prune!
|
||||||
|
ApproverPruner.prune!
|
||||||
|
TagRelationshipRetirementService.find_and_retire!
|
||||||
|
end
|
||||||
end
|
end
|
||||||
@@ -1,5 +0,0 @@
|
|||||||
class MonthlyMaintenance
|
|
||||||
def run
|
|
||||||
ActiveRecord::Base.connection.execute("set statement_timeout = 0")
|
|
||||||
end
|
|
||||||
end
|
|
||||||
@@ -1,8 +0,0 @@
|
|||||||
class WeeklyMaintenance
|
|
||||||
def run
|
|
||||||
ActiveRecord::Base.connection.execute("set statement_timeout = 0")
|
|
||||||
UserPasswordResetNonce.prune!
|
|
||||||
ApproverPruner.prune!
|
|
||||||
# JanitorPruner.new.prune!
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|||||||
@@ -2,15 +2,11 @@ set :output, "/var/log/whenever.log"
|
|||||||
#env "MAILTO", "webmaster@danbooru.donmai.us"
|
#env "MAILTO", "webmaster@danbooru.donmai.us"
|
||||||
|
|
||||||
every 1.hour do
|
every 1.hour do
|
||||||
runner "UploadErrorChecker.new.check!"
|
runner "Maintenance.hourly"
|
||||||
end
|
|
||||||
|
|
||||||
every 1.hour do
|
|
||||||
runner "DelayedJobErrorChecker.new.check!"
|
|
||||||
end
|
end
|
||||||
|
|
||||||
every 1.day do
|
every 1.day do
|
||||||
runner "DailyMaintenance.new.run"
|
runner "Maintenance.daily"
|
||||||
end
|
end
|
||||||
|
|
||||||
every 1.day, :at => "1:00 am" do
|
every 1.day, :at => "1:00 am" do
|
||||||
@@ -18,10 +14,5 @@ every 1.day, :at => "1:00 am" do
|
|||||||
end
|
end
|
||||||
|
|
||||||
every 1.week, :at => "1:30 am" do
|
every 1.week, :at => "1:30 am" do
|
||||||
runner "WeeklyMaintenance.new.run"
|
runner "Maintenance.weekly"
|
||||||
runner "TagRelationshipRetirementService.find_and_retire!"
|
|
||||||
end
|
|
||||||
|
|
||||||
every 1.month, :at => "2:00 am" do
|
|
||||||
runner "MonthlyMaintenance.new.run"
|
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
require 'test_helper'
|
require 'test_helper'
|
||||||
|
|
||||||
class DailyMaintenanceTest < ActiveSupport::TestCase
|
class MaintenanceTest < ActiveSupport::TestCase
|
||||||
context "daily maintenance" do
|
context "daily maintenance" do
|
||||||
setup do
|
setup do
|
||||||
# have ApiCacheGenerator save files to a temp dir.
|
# have ApiCacheGenerator save files to a temp dir.
|
||||||
@@ -17,14 +17,14 @@ class DailyMaintenanceTest < ActiveSupport::TestCase
|
|||||||
end
|
end
|
||||||
|
|
||||||
should "work" do
|
should "work" do
|
||||||
assert_nothing_raised { DailyMaintenance.new.run }
|
assert_nothing_raised { Maintenance.daily }
|
||||||
end
|
end
|
||||||
|
|
||||||
should "prune expired posts" do
|
should "prune expired posts" do
|
||||||
@pending = FactoryBot.create(:post, is_pending: true, created_at: 4.days.ago)
|
@pending = FactoryBot.create(:post, is_pending: true, created_at: 4.days.ago)
|
||||||
@flagged = FactoryBot.create(:post, is_flagged: true, created_at: 4.days.ago)
|
@flagged = FactoryBot.create(:post, is_flagged: true, created_at: 4.days.ago)
|
||||||
|
|
||||||
DailyMaintenance.new.run
|
Maintenance.daily
|
||||||
|
|
||||||
assert(true, @pending.reload.is_deleted)
|
assert(true, @pending.reload.is_deleted)
|
||||||
assert(true, @flagged.reload.is_deleted)
|
assert(true, @flagged.reload.is_deleted)
|
||||||
@@ -38,7 +38,7 @@ class DailyMaintenanceTest < ActiveSupport::TestCase
|
|||||||
CurrentUser.as(banner) { FactoryBot.create(:ban, user: user, banner: banner, duration: 1) }
|
CurrentUser.as(banner) { FactoryBot.create(:ban, user: user, banner: banner, duration: 1) }
|
||||||
|
|
||||||
assert_equal(true, user.reload.is_banned)
|
assert_equal(true, user.reload.is_banned)
|
||||||
travel_to(2.days.from_now) { DailyMaintenance.new.run }
|
travel_to(2.days.from_now) { Maintenance.daily }
|
||||||
assert_equal(false, user.reload.is_banned)
|
assert_equal(false, user.reload.is_banned)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
Reference in New Issue
Block a user