lib/basket.rb in basket-0.0.1 vs lib/basket.rb in basket-0.0.2

@@ -1,18 +1,43 @@
 # 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"
+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_length = Basket::Queue.push(queue, data)
-    queue_class = queue.constantize.new
-    return unless queue_length == queue_class.batcher.options.queue_length
+    @queue_collection = config.queue_collection
+    queue_length = @queue_collection.push(queue, data)
+    queue_class = Object.const_get(queue)
+    queue_instance = queue_class.new
 
-    queue_class.perform
+    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