Contents

module Imap::Backup
  class Downloader
    attr_reader :folder
    attr_reader :serializer
    attr_reader :block_size

    def initialize(folder, serializer, block_size: 1)
      @folder = folder
      @serializer = serializer
      @block_size = block_size
    end

    def run
      uids = folder.uids - serializer.uids
      count = uids.count
      debug "#{count} new messages"
      uids.each_slice(block_size).with_index do |block, i|
        uids_and_bodies = folder.fetch_multi(block)
        if uids_and_bodies.nil?
          if block_size > 1
            debug("Multi fetch failed for UIDs #{block.join(", ")}, switching to single fetches")
            @block_size = 1
            redo
          else
            debug("Fetch failed for UID #{block[0]} - skipping")
            next
          end
        end

        offset = i * block_size + 1
        uids_and_bodies.each.with_index do |uid_and_body, j|
          uid = uid_and_body[:uid]
          body = uid_and_body[:body]
          case
          when !body
            info("Fetch returned empty body - skipping")
          when !uid
            info("Fetch returned empty UID - skipping")
          else
            debug("uid: #{uid} (#{offset + j}/#{count}) - #{body.size} bytes")
            serializer.save(uid, body)
          end
        end
      end
    end

    private

    def info(message)
      Imap::Backup::Logger.logger.info("[#{folder.name}] #{message}")
    end

    def debug(message)
      Imap::Backup::Logger.logger.debug("[#{folder.name}] #{message}")
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
imap-backup-5.2.0	lib/imap/backup/downloader.rb
imap-backup-5.1.0	lib/imap/backup/downloader.rb
imap-backup-5.0.0	lib/imap/backup/downloader.rb
imap-backup-4.2.2	lib/imap/backup/downloader.rb