class Riffer::Rig::Runtime::McpRegistrar

# File lib/riffer/rig/runtime/mcp_registrar.rb, line 19
def initialize(runtime_id, registry:, host:, env:, auth_path:)
  # Upstream candidate: riffer's MCP registry is process-wide and keyed by
  # server name alone, so each Runtime tags its registrations, and two
  # Runtimes declaring the same name replace each other's.
  @tag = :"riffer_rig_#{runtime_id}"
  @registry = registry
  @host = host
  @env = env
  @auth_path = auth_path
  @servers = {}
end

# File lib/riffer/rig/runtime/mcp_registrar.rb, line 33
def register(declarations)
  declarations.filter_map do |name, declaration|
    resolved = resolve(name, declaration)
    next nil unless resolved

    live = @servers[name]
    server = live && live.declaration == resolved ? live : register_server(name, resolved)
    [name, server] if server
  end.to_h
end

# File lib/riffer/rig/runtime/mcp_registrar.rb, line 46
def retain(servers)
  dropped = @servers.except(*servers.keys)
  @servers = servers
  # A retired registration was replaced under the same name, by another
  # Runtime or a later declaration, and is no longer this Runtime's to remove.
  dropped.each { |name, server| @registry.unregister(name) unless server.registration.retired? }
end