Sha256: ed328e8978b8a6fbc908bf8a79f301a94b6659e87a1ccd3891fd38c5d61a73bf
Contents?: true
Size: 1.34 KB
Versions: 24
Compression:
Stored size: 1.34 KB
Contents
# frozen_string_literal: true
module Datadog
module Core
module Remote
# Repository update dispatcher
class Dispatcher
attr_reader :receivers
def initialize
@receivers = []
end
def dispatch(changes, repository)
receivers.each do |receiver|
matching_changes = changes.select { |c| receiver.match?(c.path) }
receiver.call(repository, matching_changes) if matching_changes.any?
end
end
# Store Matcher and block to be executed on a match
class Receiver
def initialize(matcher, &block)
@block = block
@matcher = matcher
end
def match?(path)
@matcher.match?(path)
end
def call(repository, changes)
@block.call(repository, changes)
end
end
# Matcher checks if the path matches
class Matcher
def initialize(&block)
@block = block
end
def match?(path)
@block.call(path)
end
# Matches on the produc's path
class Product < Matcher
def initialize(products)
block = ->(path) { products.include?(path.product) }
super(&block)
end
end
end
end
end
end
end
Version data entries
24 entries across 24 versions & 2 rubygems