Sha256: 7c32fe24ae871b01226a27f492a15bad5d3ddf617148ea950b3961dc8d9f4b0e
Contents?: true
Size: 1.36 KB
Versions: 11
Compression:
Stored size: 1.36 KB
Contents
# frozen_string_literal: true
module Datadog
module Core
module Remote
# Repository update dispatcher
class Dispatcher
attr_reader :receivers
def initialize(receivers)
@receivers = 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 product'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
11 entries across 11 versions & 1 rubygems