Pub sub

lib/rspecq.rb

@@ -1,5 +1,6 @@
 require "rspec/core"
 require "sentry-raven"
+require 'active_support'
 
 module RSpecQ
   # If a worker haven't executed an example for more than WORKER_LIVENESS_SEC
@@ -13,6 +14,8 @@ module RSpecQ
 require_relative "rspecq/formatters/job_timing_recorder"
 require_relative "rspecq/formatters/worker_heartbeat_recorder"
 
+require_relative "rspecq/integrations"
+
 require_relative "rspecq/queue"
 require_relative "rspecq/reporter"
 require_relative "rspecq/version"

lib/rspecq/formatters/failure_recorder.rb

@@ -29,6 +29,10 @@ def message(n)
       end
 
       def example_failed(notification)
+        ActiveSupport::Notifications.instrument('failure.rspec.rspecq', {
+          notification: notification
+        })
+
         example = notification.example
 
         presenter = RSpec::Core::Formatters::ExceptionPresenter.new(

lib/rspecq/integrations.rb

@@ -0,0 +1 @@
+require_relative 'integrations/dummy'

lib/rspecq/integrations/dummy.rb

@@ -0,0 +1,5 @@
+# ActiveSupport::Notifications.subscribe %r{.rspec.rspecq} do |*args|
+ActiveSupport::Notifications.subscribe "failure.rspec.rspecq" do |*args|
+  event = ActiveSupport::Notifications::Event.new(*args)
+  puts "FRAGOU #{event.payload[:notification].example.location_rerun_argument}"
+end

lib/rspecq/worker.rb

@@ -118,7 +118,16 @@ def work
         end
 
         opts = RSpec::Core::ConfigurationOptions.new(["--format", "progress", job])
-        _result = RSpec::Core::Runner.new(opts).run($stderr, $stdout)
+
+        data = {
+          job: job,
+          opts: opts,
+          seed: seed,
+          worker_id: @worker_id
+        }
+        ActiveSupport::Notifications.instrument('run.rspec.rspecq', data) do
+          RSpec::Core::Runner.new(opts).run($stderr, $stdout)
+        end
 
         queue.acknowledge_job(job)
       end

rspecq.gemspec

@@ -20,6 +20,7 @@ Gem::Specification.new do |s|
 
   s.add_dependency "redis"
   s.add_dependency "sentry-raven"
+  s.add_dependency "activesupport", "~> 6.0"
 
   s.add_development_dependency "minitest"
   s.add_development_dependency "pry-byebug"