reevoo/sapience-rb

# frozen_string_literal: true
begin
  require "active_support"
  require "active_support/notifications"
rescue LoadError
  warn "ActiveSupport not available"
end

module Sapience
  module Extensions
    class Notifications
      attr_reader :tags, :metric_name

      def self.use(options = {})
        new(options)
      end

      def self.subscribe(pattern, &block)
        if defined?(ActiveSupport::Notifications)
          ::ActiveSupport::Notifications.subscribe(pattern) do |*args|
            block.call ::ActiveSupport::Notifications::Event.new(*args)
          end
        else
          warn "ActiveSupport not available"
        end
      end

      def initialize(options = {})
        @tags = options[:tags] || []
      end

      def record?
        !metrics.nil?
      end

      def metrics
        Sapience.metrics
      end
    end
  end
end