Function useThreadLinking

src/features/threads/hooks/useThreadLinking.ts:100–219

({
  dispatch,
  threadParentById,
  onSubagentThreadDetected,
}: UseThreadLinkingOptions)

}

export function useThreadLinking({
  dispatch,
  threadParentById,
  onSubagentThreadDetected,
}: UseThreadLinkingOptions) {
  const wouldCreateThreadCycle = useCallback(
    (parentId: string, childId: string) => {
      const visited = new Set([childId]);
      let current: string | undefined = parentId;
      while (current) {
        if (visited.has(current)) {
          return true;
        }
        visited.add(current);
        current = threadParentById[current];
      }
      return false;
    },
    [threadParentById],
  );

  const updateThreadParent = useCallback(
    (parentId: string, childIds: string[]) => {
      if (!parentId || childIds.length === 0) {
        return;
      }
      childIds.forEach((childId) => {
        if (!childId || childId === parentId) {
          return;
        }
        const existingParent = threadParentById[childId];
        if (existingParent === parentId) {
          return;
        }
        if (existingParent) {
          return;
        }
        if (wouldCreateThreadCycle(parentId, childId)) {
          return;
        }
        dispatch({ type: "setThreadParent", threadId: childId, parentId });
      });
    },
    [dispatch, threadParentById, wouldCreateThreadCycle],
  );

  const applyCollabThreadLinks = useCallback(
    (
      workspaceId: string,
      fallbackThreadId: string,
      item: Record<string, unknown>,
    ) => {
      const itemType = asString(item?.type ?? "");
      const isCollabType =
        itemType === "collabToolCall" || itemType === "collabAgentToolCall";
      if (!isCollabType && !hasCollabLinkHints(item)) {
        return;
      }