mirror of
https://github.com/kevinveenbirkenbach/computer-playbook.git
synced 2026-11-06 02:54:26 +00:00
kevinveenbirkenbachandClaude Opus 5
dfe7a7fdd4
The merged branch moved every role-local script out of files/ into a folder named for its language (files/python/, files/php/, files/shell/), but the moves lost their staging and never landed. HEAD still carried the old paths while the worktree had the new ones. Move the 24 remaining scripts and update the six places that resolve them: the mcp-adapter instance/isolation/probe tasks, the litellm key task, the adapter README and the endpoint-path lint. Every changed line in those files is a path. Also drop roles/sys-svc-compose/files/swarm/stack_ready.sh, a stale duplicate of the copy already tracked under files/shell/swarm/. The added comments are the branch's own `nocheck: mirrored-unit-test` directives, which state why a script whose measurement only exists inside its container cannot have a mirrored unit test. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
57 lines
1.9 KiB
Ruby
57 lines
1.9 KiB
Ruby
# nocheck: mirrored-unit-test - opens an MCP session against the running GitLab sidecar
|
|
# from inside `gitlab-rails runner`, reading the host, port and path from the
|
|
# container's environment; the live handshake is the entire contract
|
|
require 'json'
|
|
require 'net/http'
|
|
require 'uri'
|
|
|
|
uri = URI("http://#{ENV.fetch('GITLAB_MCP_HOST')}:#{ENV.fetch('GITLAB_MCP_PORT')}#{ENV.fetch('GITLAB_MCP_PATH')}")
|
|
|
|
def post(uri, token, payload, session_id)
|
|
request = Net::HTTP::Post.new(uri)
|
|
request['Authorization'] = "Bearer #{token}"
|
|
request['Content-Type'] = 'application/json'
|
|
request['Accept'] = 'application/json, text/event-stream'
|
|
request['Mcp-Session-Id'] = session_id if session_id
|
|
request.body = JSON.generate(payload)
|
|
Net::HTTP.start(uri.hostname, uri.port, read_timeout: 30, open_timeout: 10) do |http|
|
|
http.request(request)
|
|
end
|
|
end
|
|
|
|
def rpc_body(response)
|
|
raw = response.body.to_s
|
|
return JSON.parse(raw) if response['Content-Type'].to_s.include?('application/json')
|
|
|
|
data = raw.each_line.select { |line| line.start_with?('data:') }
|
|
.map { |line| line.sub(/\Adata:\s*/, '').strip }
|
|
.join
|
|
data.empty? ? {} : JSON.parse(data)
|
|
rescue JSON::ParserError
|
|
{}
|
|
end
|
|
|
|
token = ENV.fetch('GITLAB_MCP_TOKEN')
|
|
|
|
response = post(uri, token, {
|
|
jsonrpc: '2.0',
|
|
id: 1,
|
|
method: 'initialize',
|
|
params: {
|
|
protocolVersion: ENV.fetch('GITLAB_MCP_PROTOCOL_VERSION'),
|
|
capabilities: {},
|
|
clientInfo: { name: 'infinito-nexus', version: '1' }
|
|
}
|
|
}, nil)
|
|
|
|
abort("REJECTED #{response.code}") unless response.code.to_i == 200
|
|
|
|
session_id = response['Mcp-Session-Id']
|
|
post(uri, token, { jsonrpc: '2.0', method: 'notifications/initialized' }, session_id)
|
|
|
|
listing = post(uri, token, { jsonrpc: '2.0', id: 2, method: 'tools/list', params: {} }, session_id)
|
|
tools = rpc_body(listing).dig('result', 'tools')
|
|
tools = [] unless tools.is_a?(Array)
|
|
|
|
puts "ACCEPTED #{response.code} tools=#{tools.length}"
|