Contents

module Unread
  class GarbageCollector
    def initialize(readable_class)
      @readable_class = readable_class
    end
    attr_reader :readable_class

    def run!
      ReadMark.reader_classes.each do |reader_class|
        readers_to_cleanup(reader_class).each do |reader|
          if oldest_timestamp = readable_class.read_scope(reader).
                                  unread_by(reader).
                                  minimum(readable_class.readable_options[:on])
            # There are unread items, so update the global read_mark for this reader to the oldest
            # unread item and delete older read_marks
            update_read_marks_for_user(reader, oldest_timestamp)
          else
            # There is no unread item, so deletes all markers and move global timestamp
            readable_class.reset_read_marks_for_user(reader)
          end
        end
      end
    end

  private
    # Not for every reader a cleanup is needed.
    # Look for those readers with at least one single read mark
    def readers_to_cleanup(reader_class)
      reader_class.
        reader_scope.
        joins(:read_marks).
        where(:read_marks => { :readable_type => readable_class.base_class.name }).
        group('read_marks.reader_type, read_marks.reader_id').
        having('COUNT(read_marks.id) > 1')
    end

    def update_read_marks_for_user(reader, timestamp)
      ReadMark.transaction do
        # Delete markers OLDER than the given timestamp
        reader.read_marks.
          where(:readable_type => readable_class.base_class.name).
          single.
          older_than(timestamp).
          delete_all

        # Change the global timestamp for this reader
        rm = reader.read_mark_global(readable_class) || reader.read_marks.build
        rm.readable_type = readable_class.base_class.name
        rm.timestamp     = timestamp - 1.second
        rm.save!
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
unread-0.7.0	lib/unread/garbage_collector.rb