lib/gorgon/originator_logger.rb in gorgon-0.11.0 vs lib/gorgon/originator_logger.rb in gorgon-0.11.1

@@ -1,39 +1,41 @@
 require 'gorgon/g_logger'
 
-class OriginatorLogger
-  include GLogger
+module Gorgon
+  class OriginatorLogger
+    include GLogger
 
-  def initialize log_file
-    initialize_logger log_file
-  end
+    def initialize log_file
+      initialize_logger log_file
+    end
 
-  def log_message(payload)
-    if payload[:action] == "start"
-      log("Started running '#{payload[:filename]}' at '#{payload[:hostname]}:#{payload[:worker_id]}'")
-    elsif payload[:action] == "finish"
-      print_finish(payload)
-    elsif payload[:type] == "crash" || payload[:type] == "exception"
-      # TODO: improve logging of these messages
-      log(payload)
-    else # to be removed
-      ap payload
+    def log_message(payload)
+      if payload[:action] == "start"
+        log("Started running '#{payload[:filename]}' at '#{payload[:hostname]}:#{payload[:worker_id]}'")
+      elsif payload[:action] == "finish"
+        print_finish(payload)
+      elsif payload[:type] == "crash" || payload[:type] == "exception"
+        # TODO: improve logging of these messages
+        log(payload)
+      else # to be removed
+        ap payload
+      end
     end
-  end
 
-  private
+    private
 
-  def print_finish(payload)
-    msg = "Finished running '#{payload[:filename]}' at '#{payload[:hostname]}:#{payload[:worker_id]}'"
-    msg << failure_message(payload[:failures]) if payload[:type] == "fail"
-    log msg
-  end
+    def print_finish(payload)
+      msg = "Finished running '#{payload[:filename]}' at '#{payload[:hostname]}:#{payload[:worker_id]}'"
+      msg << failure_message(payload[:failures]) if payload[:type] == "fail"
+      log msg
+    end
 
-  def failure_message(failures)
-    msg = []
-    failures.each do |failure|
-      msg << failure
+    def failure_message(failures)
+      msg = []
+      failures.each do |failure|
+        msg << failure
+      end
+      msg << ''
+      msg.join("\n")
     end
-    msg << ''
-    msg.join("\n")
   end
 end