Method networkThreadMessages

internal/daemon/native_tools.go:1532–1569

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

}

func (n *daemonNativeTools) networkThreadMessages(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input networkThreadMessagesInput
	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
	}
	ref := store.NetworkConversationRef{
		WorkspaceID: workspaceID,
		Channel:     channel,
		Surface:     store.NetworkSurfaceThread,
		ThreadID:    strings.TrimSpace(input.ThreadID),
	}
	payload, err := n.networkConversationMessages(ctx, req.ToolID, ref, networkConversationMessageQueryInput{
		Before: strings.TrimSpace(input.Before),
		After:  strings.TrimSpace(input.After),
		Kind:   strings.TrimSpace(input.Kind),
		WorkID: strings.TrimSpace(input.WorkID),
		Limit:  input.Limit,
	})
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	return structuredNetworkResult(
		map[string]any{nativeToolsMessagesKey: payload},
		fmt.Sprintf("%d messages", len(payload)),
	)
}

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