Initial commit

sentry-sidekiq/lib/sentry/sidekiq/cron/job.rb

@@ -12,6 +12,26 @@ module Sentry
   module Sidekiq
     module Cron
       module Job
+        def enque!(**args)
+          # make sure the current thread has a clean hub
+          Sentry.clone_hub_to_current_thread
+
+          Sentry.with_scope do |scope|
+            Sentry.with_session_tracking do
+              scope.set_transaction_name("#{name} (#{klass})")
+
+              transaction = start_transaction(scope)
+              scope.set_span(transaction) if transaction
+              super
+
+              finish_transaction(transaction, 200)
+            rescue
+              finish_transaction(transaction, 500)
+              raise
+            end
+          end
+        end
+
         def save
           # validation failed, do nothing
           return false unless super
@@ -34,6 +54,28 @@ def save
 
           true
         end
+
+        def start_transaction(scope)
+          options = {
+            name: scope.transaction_name,
+            source: scope.transaction_source,
+            op: transaction_op,
+            origin: "auto.queue.sidekiq.cron"
+          }
+
+          Sentry.start_transaction(**options)
+        end
+
+        def finish_transaction(transaction, status_code)
+          return unless transaction
+
+          transaction.set_http_status(status_code)
+          transaction.finish
+        end
+
+        def transaction_op
+          "queue.sidekiq-cron"
+        end
       end
     end
   end

sentry-sidekiq/spec/spec_helper.rb

@@ -235,13 +235,14 @@ def execute_worker(processor, klass, **options)
   end
 
   jid = options.delete(:jid) || "123123"
+  timecop_delay = options.delete(:timecop_delay)
 
   msg = Sidekiq.dump_json(created_at: Time.now.to_f, enqueued_at: Time.now.to_f, jid: jid, class: klass, args: [], **options)
-  Timecop.freeze(options[:timecop_delay]) if options[:timecop_delay]
+  Timecop.freeze(timecop_delay) if timecop_delay
   work = Sidekiq::BasicFetch::UnitOfWork.new('queue:default', msg)
   process_work(processor, work)
 ensure
-  Timecop.return if options[:timecop_delay]
+  Timecop.return if timecop_delay
 end
 
 def process_work(processor, work)