Method networkSetSubscription

internal/daemon/native_tools.go:1787–1827

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

}

func (n *daemonNativeTools) networkSetSubscription(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
	mode string,
) (toolspkg.ToolResult, error) {
	var input networkSubscriptionInput
	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
	}
	now := time.Now().UTC()
	entry := store.NetworkSubscriptionEntry{
		WorkspaceID:    workspaceID,
		Channel:        channel,
		ThreadID:       strings.TrimSpace(input.ThreadID),
		PeerID:         strings.TrimSpace(input.PeerID),
		Mode:           mode,
		KeywordFilters: cloneTrimmedStrings(input.KeywordFilters),
		CreatedAt:      now,
		UpdatedAt:      now,
	}
	if err := entry.Validate(); err != nil {
		return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
	}
	if err := n.ensureNativeNetworkSubscriptionChannel(ctx, scope, entry); err != nil {
		return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
	}
	if err := n.deps.NetworkStore.PutNetworkSubscription(ctx, entry); err != nil {
		return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
	}
	payload := core.NetworkSubscriptionPayloadFromStore(entry)
	return structuredNetworkResult(map[string]any{"subscription": payload}, payload.Mode)
}

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