Method nativeThreadPromotionSource

internal/daemon/native_tools.go:3064–3126

(
	ctx context.Context,
	scope toolspkg.Scope,
	toolID toolspkg.ToolID,
	input taskPromoteFromThreadInput,
)

}

func (n *daemonNativeTools) nativeThreadPromotionSource(
	ctx context.Context,
	scope toolspkg.Scope,
	toolID toolspkg.ToolID,
	input taskPromoteFromThreadInput,
) (nativeThreadPromotionSource, error) {
	if n.deps.NetworkStore == nil {
		return nativeThreadPromotionSource{}, nativeUnavailableError(toolID, "network store is unavailable")
	}
	channel, err := nativeNetworkChannel(toolID, input.Channel)
	if err != nil {
		return nativeThreadPromotionSource{}, err
	}
	threadID := strings.TrimSpace(input.ThreadID)
	if err := network.ValidateConversationID(threadID, "thread_id"); err != nil {
		return nativeThreadPromotionSource{}, nativeNetworkInputError(toolID, err)
	}
	originMessageID, err := requiredNativeString(toolID, "origin_message_id", input.OriginMessageID)
	if err != nil {
		return nativeThreadPromotionSource{}, err
	}
	workspaceID, err := n.nativeNetworkWorkspaceID(ctx, toolID, input.WorkspaceID, scope)
	if err != nil {
		return nativeThreadPromotionSource{}, err
	}
	messages, err := n.deps.NetworkStore.ListConversationMessages(
		ctx,
		store.NetworkConversationRef{
			WorkspaceID: workspaceID,
			Channel:     channel,
			Surface:     store.NetworkSurfaceThread,
			ThreadID:    threadID,
		},
		store.NetworkConversationMessageQuery{Limit: 200},
	)
	if err != nil {
		return nativeThreadPromotionSource{}, nativeNetworkInputError(toolID, err)
	}
	digest, sourceMessageIDs, found := nativeNetworkThreadPromotionDigest(messages, originMessageID)
	if !found {
		return nativeThreadPromotionSource{}, nativeNetworkInputError(
			toolID,
			fmt.Errorf("origin_message_id %q is not part of thread %q", originMessageID, threadID),
		)
	}
	thread, err := n.deps.NetworkStore.GetThread(
		ctx,
		store.NetworkChannelRef{WorkspaceID: workspaceID, Channel: channel},
		threadID,
	)
	if err != nil {
		return nativeThreadPromotionSource{}, nativeNetworkInputError(toolID, err)
	}
	return nativeThreadPromotionSource{
		workspaceID:      workspaceID,
		channel:          channel,
		threadID:         threadID,
		originMessageID:  originMessageID,