Pass more context from Sidekiq jobs to Logster

config/initializers/sidekiq.rb

@@ -43,18 +43,28 @@ end
 
 Sidekiq.logger.level = Logger::WARN
 
-class LogsterErrorHandler
+class SidekiqLogsterReporter
-  def call(ex, hash={})
+  def call(ex, context = {})
-    text = "exception: #{ex}\ncontext: #{hash.inspect}\n"
+    # Pass context to Logster
-    if ex.backtrace
+    fake_env = {}
-      text << "backtrace: #{ex.backtrace.join("\n")}"
+    context.each do |key, value|
+      Logster.add_to_env(fake_env, key, value)
     end
-    Rails.logger.error(text)
+
+    text = "Job exception: #{ex}\n"
+    if ex.backtrace
+      Logster.add_to_env(fake_env, :backtrace, ex.backtrace)
+    end
+
+    Thread.current[Logster::Logger::LOGSTER_ENV] = fake_env
+    Logster.logger.error(text)
   rescue => e
-    Rails.logger.fatal("Failed to log exception #{ex} #{hash}\nReason: #{e}\n#{e.backtrace.join("\n")}")
+    Logster.logger.fatal("Failed to log exception #{ex} #{hash}\nReason: #{e.class} #{e}\n#{e.backtrace.join("\n")}")
+  ensure
+    Thread.current[Logster::Logger::LOGSTER_ENV] = nil
   end
 end
 
-Sidekiq.error_handlers << LogsterErrorHandler.new
+Sidekiq.error_handlers << SidekiqLogsterReporter.new
 
 

lib/discourse.rb

@@ -9,7 +9,8 @@ module Discourse
     extend Sidekiq::ExceptionHandler
   end
 
-  def self.handle_exception(ex, context=nil, parent_logger = nil)
+  # Responsible for exceptions in Sidekiq jobs - not requests!
+  def self.handle_exception(ex, context = nil, parent_logger = nil)
     context ||= {}
     parent_logger ||= SidekiqExceptionHandler