Add basic specs

Author: frederikspang

sentry-sidekiq/spec/sentry/sidekiq/sentry_context_middleware_spec.rb

@@ -63,6 +63,27 @@
       expect(transaction.contexts.dig(:trace, :origin)).to eq('auto.queue.sidekiq')
     end
 
+    it "adds a queue.process spans" do
+      execute_worker(processor, HappyWorker)
+      execute_worker(processor, HappyWorker, jid: '123456')
+
+      expect(transport.events.count).to eq(2)
+
+      transaction = transport.events[0]
+      expect(transaction).not_to be_nil
+      expect(transaction.spans.count).to eq(1)
+      expect(transaction.spans[0][:data]['messaging.message.id']).to eq('123123') # Default defined in #execute_worker
+      expect(transaction.spans[0][:data]['messaging.destination.name']).to eq('default')
+      expect(transaction.spans[0][:data]['messaging.message.retry.count']).to eq(0)
+
+      transaction = transport.events[1]
+      expect(transaction).not_to be_nil
+      expect(transaction.spans.count).to eq(1)
+      expect(transaction.spans[0][:data]['messaging.message.id']).to eq('123456') # Explicitly set above.
+      expect(transaction.spans[0][:data]['messaging.destination.name']).to eq('default')
+      expect(transaction.spans[0][:data]['messaging.message.retry.count']).to eq(0)
+    end
+
     context "with trace_propagation_headers" do
       let(:parent_transaction) { Sentry.start_transaction(op: "sidekiq") }
 
@@ -155,5 +176,18 @@
       expect(second_headers["sentry-trace"]).to eq(transaction.to_sentry_trace)
       expect(second_headers["baggage"]).to eq(transaction.to_baggage)
     end
+
+    it "has a queue.publish span" do
+      message_id = client.push('queue' => 'default', 'class' => HappyWorker, 'args' => [])
+
+      transaction.finish
+
+      expect(transport.events.count).to eq(1)
+      event = transport.events.last
+      expect(event.spans.count).to eq(1)
+      expect(event.spans[0][:op]).to eq("queue.publish")
+      expect(event.spans[0][:data]['messaging.message.id']).to eq(message_id)
+      expect(event.spans[0][:data]['messaging.destination.name']).to eq('default')
+    end
   end
 end

sentry-sidekiq/spec/spec_helper.rb

@@ -232,7 +232,9 @@ def execute_worker(processor, klass, **options)
     options[k.to_sym] = v
   end
 
-  msg = Sidekiq.dump_json(created_at: Time.now.to_f, jid: "123123", class: klass, args: [], **options)
+  jid = options.delete(:jid) || "123123"
+
+  msg = Sidekiq.dump_json(created_at: Time.now.to_f, enqueued_at: Time.now.to_f, jid: jid, class: klass, args: [], **options)
   work = Sidekiq::BasicFetch::UnitOfWork.new('queue:default', msg)
   process_work(processor, work)
 end