module Riffer::Mcp::Registry

# File lib/riffer/mcp/registry.rb, line 48
def find_by_tags(tags)
  normalized = tags.map(&:to_sym)
  @mutex.synchronize do
    @store.values.select { |reg| reg.manifest.tags.intersect?(normalized) }
  end
end

# File lib/riffer/mcp/registry.rb, line 15
def register(manifest_or_hash)
  # steep cannot verify that an untyped Hash splat supplies Manifest's
  # required name:/endpoint: keywords; Manifest validates them at runtime.
  manifest = if manifest_or_hash.is_a?(Riffer::Mcp::Manifest)
               manifest_or_hash
             else
               Riffer::Mcp::Manifest.new(**manifest_or_hash) # steep:ignore InsufficientKeywordArguments
             end
  registration = Riffer::Mcp::Registration.new(manifest)
  old = @mutex.synchronize do
    previous = @store[manifest.name]
    @store[manifest.name] = registration
    previous
  end
  old&.retire!
  registration
end

# File lib/riffer/mcp/registry.rb, line 42
def registrations
  @mutex.synchronize { @store.dup.freeze }
end

# File lib/riffer/mcp/registry.rb, line 35
def unregister(name)
  removed = @mutex.synchronize { @store.delete(name.to_s) }
  removed&.retire!
end