Contents

# frozen_string_literal: true

module SolidCable
  class TrimJob < ActiveJob::Base
    def perform
      return unless trim?

      ::SolidCable::Message.transaction do
        ids = ::SolidCable::Message.trimmable.non_blocking_lock.
              limit(trim_batch_size).pluck(:id)
        ::SolidCable::Message.where(id: ids).delete_all
      end
    end

    private
      def trim_batch_size
        ::SolidCable.trim_batch_size
      end

      def trim?
        expires_per_write = (1 / trim_batch_size.to_f) * ::SolidCable.trim_chance

        rand < (expires_per_write - expires_per_write.floor)
      end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
solid_cable-3.0.7	app/jobs/solid_cable/trim_job.rb
solid_cable-3.0.6	app/jobs/solid_cable/trim_job.rb
solid_cable-3.0.5	app/jobs/solid_cable/trim_job.rb
solid_cable-3.0.4	app/jobs/solid_cable/trim_job.rb
solid_cable-3.0.3	app/jobs/solid_cable/trim_job.rb
solid_cable-3.0.2	app/jobs/solid_cable/trim_job.rb
solid_cable-3.0.1	app/jobs/solid_cable/trim_job.rb