Class: Legion::MCP::Tools::BroadcastPeers

Inherits:
MCP::Tool
  • Object
show all
Extended by:
Logging::Helper
Defined in:
lib/legion/mcp/tools/broadcast_peers.rb

Class Method Summary collapse

Class Method Details

.call(message:, capability: nil) ⇒ Object 



21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
 
# File 'lib/legion/mcp/tools/broadcast_peers.rb', line 21

def call(message:, capability: nil)
  log.info('Starting legion.mcp.tools.broadcast_peers.call')
  return error_response('lex-mesh is not available') unless mesh_available?

  pattern = capability ? :multicast : :broadcast
  result  = mesh_client.send_message(
    from:    'legion.mcp',
    to:      capability || :all,
    pattern: pattern,
    payload: { message: message }
  )
  text_response(result)
rescue StandardError => e
  handle_exception(e, level: :warn, operation: 'legion.mcp.tools.broadcast_peers.call')
  log.warn("BroadcastPeers#call failed: #{e.message}")
  error_response("Failed to broadcast: #{e.message}")
end