( ctx context.Context, scope toolspkg.Scope, req toolspkg.CallRequest, )
| 1288 | } |
| 1289 | |
| 1290 | func (n *daemonNativeTools) networkPeers( |
| 1291 | ctx context.Context, |
| 1292 | scope toolspkg.Scope, |
| 1293 | req toolspkg.CallRequest, |
| 1294 | ) (toolspkg.ToolResult, error) { |
| 1295 | var input networkPeersInput |
| 1296 | if err := decodeNativeInput(req, &input); err != nil { |
| 1297 | return toolspkg.ToolResult{}, err |
| 1298 | } |
| 1299 | workspaceID, err := n.nativeNetworkWorkspaceID(ctx, req.ToolID, input.WorkspaceID, scope) |
| 1300 | if err != nil { |
| 1301 | return toolspkg.ToolResult{}, err |
| 1302 | } |
| 1303 | peers, err := n.deps.Network.ListPeers(ctx, workspaceID, input.Channel) |
| 1304 | if err != nil { |
| 1305 | return toolspkg.ToolResult{}, err |
| 1306 | } |
| 1307 | return structuredNetworkResult(map[string]any{"peers": peers}, fmt.Sprintf("%d peers", len(peers))) |
| 1308 | } |
| 1309 | |
| 1310 | func (n *daemonNativeTools) networkStatus( |
| 1311 | ctx context.Context, |
nothing calls this directly
no test coverage detected