periodic_jobs.rb

# Defines periodic jobs run by DelayedJobs.
#
# Scheduling is done by rufus-scheduler
#
# You should only use "cron" type jobs, not "every". Cron jobs have deterministic
# times to run which help across daemon restarts, and distributing periodic
# jobs across multiple job servers.
#
# Periodic jobs default to low priority. You can override this in the arguments
# passed to Delayed::Periodic.cron

if ActionController::Base.session_store == ActiveRecord::SessionStore
  expire_after = (Setting.from_config("session_store") || {})[:expire_after]
  expire_after ||= 1.day

  Delayed::Periodic.cron 'ActiveRecord::SessionStore::Session.delete_all', '*/5 * * * *' do
    ActiveRecord::SessionStore::Session.delete_all(['updated_at < ?', expire_after.ago])
  end
end

Delayed::Periodic.cron 'ExternalFeedAggregator.process', '*/30 * * * *' do
  ExternalFeedAggregator.process
end

Delayed::Periodic.cron 'SummaryMessageConsolidator.process', '*/15 * * * *' do
  SummaryMessageConsolidator.process
end

Delayed::Periodic.cron 'Attachment.process_scribd_conversion_statuses', '*/5 * * * *' do
  Attachment.process_scribd_conversion_statuses
end

Delayed::Periodic.cron 'Twitter processing', '*/15 * * * *' do
  TwitterSearcher.process
  TwitterUserPoller.process
end

Delayed::Periodic.cron 'Reporting::CountsReport.process', '0 11 * * *' do
  Reporting::CountsReport.process
end

Delayed::Periodic.cron 'StreamItem.destroy_stream_items', '45 11 * * *' do
  # we pass false for the touch_users argument, on the assumption that these
  # stream items that we delete aren't visible on the user's dashboard anymore
  # anyway, so there's no need to invalidate all the caches.
  StreamItem.destroy_stream_items(4.weeks.ago, false)
end

if Mailman.config.poll_interval == 0 && Mailman.config.ignore_stdin == true
  Delayed::Periodic.cron 'IncomingMessageProcessor.process', '*/1 * * * *' do
    IncomingMessageProcessor.process
  end
end

if PageView.page_view_method == :cache
  # periodically pull new page views off the cache and insert them into the db
  Delayed::Periodic.cron 'PageView.process_cache_queue', '*/1 * * * *' do
    PageView.process_cache_queue
  end
end

Delayed::Periodic.cron 'ErrorReport.destroy_error_reports', '35 */1 * * *' do
  cutoff = Setting.get('error_reports_retain_for', 3.months.to_s).to_i
  if cutoff > 0
    ErrorReport.destroy_error_reports(cutoff.ago)
  end
end

if Delayed::Stats.enabled?
  Delayed::Periodic.cron 'Delayed::Stats.cleanup', '0 11 * * *' do
    Delayed::Stats.cleanup
  end
end

Delayed::Periodic.cron 'Alert.process', '30 11 * * *', :priority => Delayed::LOW_PRIORITY do
  Alert.process
end