Method networkThreads

internal/daemon/native_tools.go:1493–1530

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

}

func (n *daemonNativeTools) networkThreads(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input networkThreadsInput
	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
	}
	query := store.NetworkThreadQuery{
		Limit: input.Limit,
		After: strings.TrimSpace(input.After),
	}
	if err := query.Validate(); err != nil {
		return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err)
	}
	workspaceID, err := n.nativeNetworkWorkspaceID(ctx, req.ToolID, input.WorkspaceID, scope)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	threads, err := n.deps.NetworkStore.ListThreads(
		ctx,
		store.NetworkChannelRef{WorkspaceID: workspaceID, Channel: channel},
		query,
	)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	payload := core.NetworkThreadSummaryPayloadsFromStore(threads)
	return structuredNetworkResult(
		map[string]any{"threads": payload},
		fmt.Sprintf("%d threads", len(payload)),
	)
}

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