Ensure Queue is always callable. Change default log level to error.

Author: metaskills

CHANGELOG.md

@@ -1,3 +1,8 @@
+## [0.0.6] - 2021-06-28
+
+- Ensure Queue is always callable.
+- Change default log level to `error`.
+
 ## [0.0.5] - 2021-06-28
 
 - Ensure Queue is always present.

Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    lambda_punch (0.0.5)
+    lambda_punch (0.0.6)
       concurrent-ruby
       rake
       rb-inotify

README.md

@@ -84,7 +84,7 @@ If your application integrates with API Gateway (which has a 30 second timeout)
 
 ### Logging
 
-The default log level is `fatal`, so you will not see any LambdaPunch lines in your logs. However, if you want some low level debugging information on how LambdaPunch is working, you can use this environment variable to change the log level.
+The default log level is `error`, so you will not see any LambdaPunch lines in your logs. However, if you want some low level debugging information on how LambdaPunch is working, you can use this environment variable to change the log level.
 
 ```yaml
 Environment:

lib/lambda_punch/logger.rb

@@ -16,8 +16,8 @@ def level=(value)
     private
 
     def level
-      l = (@level || ENV['LAMBDA_PUNCH_LOG_LEVEL'] || 'fatal').upcase.to_sym
-      ::Logger.const_defined?(l) ? ::Logger.const_get(l) : ::Logger::FATAL
+      l = (@level || ENV['LAMBDA_PUNCH_LOG_LEVEL'] || 'error').upcase.to_sym
+      ::Logger.const_defined?(l) ? ::Logger.const_get(l) : ::Logger::ERROR
     end
 
   end

lib/lambda_punch/version.rb

@@ -1,3 +1,3 @@
 module LambdaPunch
-  VERSION = "0.0.5"
+  VERSION = "0.0.6"
 end

lib/lambda_punch/worker.rb

@@ -26,17 +26,25 @@ def call(event_payload)
         new(event_payload).call
       end
 
-      # The `@queue` object is the local process' reference to the application `LambdaPunch::Queue`
-      # instance which does all the work in the applciation's scope.
+      # A safe and resilient way to call the remote queue.
       # 
-      def queue
-        @queue
+      def call_queue
+        queue.call
       rescue DRb::DRbConnError
+        logger.error "Worker#call_queue => DRb::DRbConnError"
         new_drb_queue
+        queue.call
       end
 
       private
 
+      # The `@queue` object is the local process' reference to the application `LambdaPunch::Queue`
+      # instance which does all the work in the applciation's scope.
+      # 
+      def queue
+        @queue
+      end
+
       def new_drb_queue
         @queue = DRbObject.new_with_uri(Server.uri)
       end
@@ -58,10 +66,10 @@ def initialize(event_payload)
     def call
       Timeout.timeout(timeout) { @notifier.process }
     rescue Timeout::Error
-      logger.debug "Worker#call => Function timeout reached."
+      logger.error "Worker#call => Function timeout reached."
     ensure
       @notifier.close
-      self.class.queue.call
+      self.class.call_queue
     end
 
     private