Contents

# frozen_string_literal: true

require_relative "basket/batcher"
require_relative "basket/configuration"
require_relative "basket/error"
require_relative "basket/hash_backend"
require_relative "basket/queue_collection"
require_relative "basket/version"

module Basket
  class Error < StandardError; end

  def self.config
    @config ||= Configuration.new
  end

  def self.contents
    @queue_collection.data
  end

  def self.add(queue, data)
    @queue_collection = config.queue_collection
    queue_length = @queue_collection.push(queue, data)
    queue_class = Object.const_get(queue)
    queue_instance = queue_class.new

    queue_instance.define_singleton_method(:element) { data }
    queue_instance.on_add

    return unless queue_length == queue_class.basket_options_hash[:size]

    queue_instance.perform
    queue_instance.on_success
  rescue => e
    raise e if e.instance_of?(Basket::Error)
    queue_instance.define_singleton_method(:error) { e }
    queue_instance.on_failure
  end

  def self.clear_all
    config.queue_collection.reset_backend
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
basket-0.0.2	lib/basket.rb