services/api/lib/sweep_trashed_collections.rb

   1 require 'current_api_client'
   2
   3 module SweepTrashedCollections
   4   extend CurrentApiClient
   5
   6   def self.sweep_now
   7     act_as_system_user do
   8       Collection.unscoped.
   9         where('delete_at is not null and delete_at < statement_timestamp()').
  10         destroy_all
  11       Collection.unscoped.
  12         where('is_trashed = false and trash_at < statement_timestamp()').
  13         update_all('is_trashed = true')
  14     end
  15   end
  16
  17   def self.sweep_if_stale
  18     return if Rails.configuration.trash_sweep_interval <= 0
  19     exp = Rails.configuration.trash_sweep_interval.seconds
  20     need = false
  21     Rails.cache.fetch('SweepTrashedCollections', expires_in: exp) do
  22       need = true
  23     end
  24     if need
  25       Thread.new do
  26         begin
  27           sweep_now
  28         ensure
  29           ActiveRecord::Base.connection.close
  30         end
  31       end
  32     end
  33   end
  34 end