22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
# File 'lib/legion/mcp/tools/ask_peer.rb', line 22
def call(to:, query:, timeout: 30)
log.info('Starting legion.mcp.tools.ask_peer.call')
return error_response('lex-mesh is not available') unless mesh_available?
result = mesh_client.request_task(
from: 'legion.mcp',
to: to,
task: 'query',
payload: { query: query },
timeout: timeout
)
text_response(result)
rescue StandardError => e
handle_exception(e, level: :warn, operation: 'legion.mcp.tools.ask_peer.call')
log.warn("AskPeer#call failed: #{e.message}")
error_response("Failed to query peer: #{e.message}")
end
|