Method networkSubscriptions

internal/daemon/native_tools.go:1722–1761

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

}

func (n *daemonNativeTools) networkSubscriptions(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input networkSubscriptionsInput
	if err := decodeNativeInput(req, &input); err != nil {
		return toolspkg.ToolResult{}, err
	}
	channel, err := nativeNetworkChannel(req.ToolID, input.Channel)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	workspaceID, err := n.nativeNetworkWorkspaceID(ctx, req.ToolID, input.WorkspaceID, scope)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	query := store.NetworkSubscriptionQuery{
		WorkspaceID: workspaceID,
		Channel:     channel,
		ThreadID:    strings.TrimSpace(input.ThreadID),
		PeerID:      strings.TrimSpace(input.PeerID),
		Limit:       input.Limit,
	}
	if query.Limit == 0 {
		query.Limit = 100
	}
	if err := query.Validate(); err != nil {
		return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
	}
	subscriptions, err := n.deps.NetworkStore.ListNetworkSubscriptions(ctx, query)
	if err != nil {
		return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
	}
	payload := core.NetworkSubscriptionPayloadsFromStore(subscriptions)
	return structuredNetworkResult(
		map[string]any{"subscriptions": payload},
		fmt.Sprintf("%d subscriptions", len(payload)),
	)
}

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