Method networkChannels

internal/daemon/native_tools.go:1330–1379

(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
)

}

func (n *daemonNativeTools) networkChannels(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input networkChannelsInput
	if err := decodeNativeInput(req, &input); err != nil {
		return toolspkg.ToolResult{}, err
	}
	bound, err := n.nativeBoundSession(ctx, scope)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	workspaceID, err := n.nativeNetworkWorkspaceID(
		ctx,
		req.ToolID,
		nativeBoundWorkspaceRef(bound, input.WorkspaceID),
		scope,
	)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	var channels any
	var count int
	if n.deps.Sessions != nil && n.deps.NetworkStore != nil {
		payload, err := core.NetworkChannelPayloads(
			ctx,
			n.deps.Network,
			n.deps.Sessions,
			n.deps.NetworkStore,
			workspaceID,
		)
		if err != nil {
			return toolspkg.ToolResult{}, err
		}
		payload = nativeFilterNetworkChannelPayloads(bound, payload)
		channels = payload
		count = len(payload)
	} else {
		infos, err := n.deps.Network.ListChannels(ctx, workspaceID)
		if err != nil {
			return toolspkg.ToolResult{}, err
		}
		payload := core.NetworkChannelPayloadsFromInfos(infos)
		payload = nativeFilterNetworkChannelPayloads(bound, payload)
		channels = payload
		count = len(payload)
	}
	return structuredNetworkResult(map[string]any{"channels": channels}, fmt.Sprintf("%d channels", count))
}

func (n *daemonNativeTools) networkInbox(
	ctx context.Context,