configuration.rb in basquiat-1.3.0.pre.1

- old
+ new

@@ -1,18 +1,42 @@
-require 'basquiat/support/hash_refinements'
 require 'naught'
 require 'erb'
+require 'basquiat/support/hash_refinements'
 
 module Basquiat
   require 'logger'
   DefaultLogger = Naught.build { |config| config.mimic Logger }
 
   class Configuration
     using HashRefinements
 
+    def initialize
+      @yaml        = {}
+      @rescue_proc = lambda do |exception, message|
+        logger.error do
+          { exception: exception, stack_trace: exception.stack_trace, message: message }.to_json
+        end
+        fail exception
+      end
+    end
+
+    # @!attribute queue_name
+    #   @return [String] the queue name. Defaults to 'basquiat.queue'
+    # @!attribute exchange_name
+    #   @return [String] the exchange name. Defaults to 'basquiat.exchange'
+    # @!attribute logger
+    #   @return [Logger] return the application logger. Defaults to {DefaultLogger}.
+    # @!attribute environment
+    #   @return [Symbol] return the set environment or the value of the 'BASQUIAT_ENV' environment variable
+    #     or :development
     attr_writer :queue_name, :exchange_name, :logger, :environment
 
+    # @!attribute rescue_proc
+    #   @return [#call] return the callable to be executed when some exception is thrown. The callable receives the
+    #     exception and message
+    attr_accessor :rescue_proc
+
     def queue_name
       @queue_name || 'basquiat.queue'
     end
 
     def exchange_name
@@ -25,38 +49,43 @@
 
     def environment
       (@environment || ENV['BASQUIAT_ENV'] || 'development').to_sym
     end
 
+    # Loads a YAML file with the configuration options
+    # @param path [String] the path of the configuration file
     def config_file=(path)
       load_yaml(path)
       setup_basic_options
     end
 
+    # @return [Hash] return the configured adapter options. Defaults to an empty {::Hash}
     def adapter_options
       config.fetch(:adapter_options) { Hash.new }
     end
 
+    # @return [String] return the configured default adapter. Defaults to {Adapters::Test}
     def default_adapter
-      config.fetch(:default_adapter) { Basquiat::Adapter::Test }
+      config.fetch(:default_adapter) { 'Basquiat::Adapters::Test' }
     end
 
+    # Used by the railtie. Forces the reconfiguration of all extended classes
     def reload_classes
       Basquiat::Base.descendants.each(&:reload_adapter_from_configuration)
     end
 
     private
 
     def config
-      @yaml.fetch(environment)
+      @yaml.fetch(environment, {})
     end
 
     def load_yaml(path)
       @yaml = YAML.load(ERB.new(IO.readlines(path).join).result).symbolize_keys
     end
 
     def setup_basic_options
-      @queue_name    ||= config.fetch(:queue_name) { 'basquiat.exchange' }
+      @queue_name ||= config.fetch(:queue_name) { 'basquiat.exchange' }
       @exchange_name ||= config.fetch(:exchange_name) { 'basquiat.queue' }
     end
   end
 end