Contents

require 'resolv'
require 'forwardable'

module RichEmailValidator
  # Validates list of emails and return the valid ones
  class ListValidator
    class << self
      # Validates list of emails
      # @param list [Enumerator]
      # @param [Hash] options
      # @option options [#to_int] :threads_count number of threads that will
      #  be fired simultaneously to calculate the result
      # @return [Array]
      def filter(list, options = {})
        new(list, options).filter
      end
    end

    attr_reader :list, :threads_count

    # Validates list of emails
    # @param list [Enumerator]
    # @param [Hash] options
    # @option options [#to_int] :threads_count number of threads that will
    #  be fired simultaneously to calculate the result
    def initialize(list, options = {})
      @list = list
      @threads_count = options.fetch(:threads_count) { 20 }
      @result = []
      @total_slices = (@list.size / @threads_count.to_f).ceil
    end

    # Validates list of emails
    # @return [Array]
    def filter
      @filtered ||= run_filter
    end

    private

    attr_reader :result, :total_slices

    def run_filter
      threads = (0...total_slices).map do |slice_index|
        Thread.new { filter_slice(slice_index) }
      end
      threads.each { |thread| thread.join }
      result.select { |email| email }
    end

    def filter_slice(slice_index)
      start_index = (threads_count * slice_index)
      end_index = [start_index + threads_count, list.size].min
      (start_index...end_index).each do |list_index|
        email = list[list_index]
        result[list_index] = email if EmailValidator.valid?(email)
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rich_email_validator-0.0.1	lib/rich_email_validator/list_validator.rb