Contents

# frozen_string_literal: true

RSpec.describe 'Subscribing to instrumentation events' do
  subject(:notifications) { Dry::Monitor::Notifications.new(:app) }

  before do
    Dry::Monitor::Notifications.register_event(:sql, name: 'rom[sql]')
  end

  describe '#instrument' do
    it 'allows subscribing via block' do
      captured = []
      payload = { query: 'SELECT 1 FROM users' }

      notifications.subscribe(:sql) do |event|
        captured << [event.id, event[:query]]
      end

      notifications.instrument(:sql, payload)

      expect(captured).to eql([[:sql, 'SELECT 1 FROM users']])
    end

    it 'allows instrumenting via block' do
      captured = []
      payload = { query: 'SELECT 1 FROM users' }

      notifications.subscribe(:sql) do |event|
        captured << [event.id, event[:query]]
      end

      notifications.instrument(:sql, payload) do
        payload
      end

      expect(captured).to eql([[:sql, 'SELECT 1 FROM users']])
    end

    it 'allows instrumenting via block when no payload given' do
      captured = []

      notifications.subscribe(:sql) do |event|
        captured << [event.id]
      end

      notifications.instrument(:sql) {}

      expect(captured).to eql([[:sql]])
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
dry-monitor-0.3.1	spec/integration/instrumentation_spec.rb