Function constructThreadsPost

packages/atmosphere/src/providers/threads/post.ts:15–94

(
  rawId: string,
  userAgent: string | undefined
)

}

export async function constructThreadsPost(
  rawId: string,
  userAgent: string | undefined
): Promise<SocialThread> {
  const shortcode = normalizeThreadsPostId(rawId);
  let mediaId: string;
  try {
    mediaId = threadsShortcodeToMediaId(shortcode);
  } catch {
    return { code: 400, status: null, thread: null, author: null };
  }

  const session = await fetchThreadsSession(userAgent);
  if (!session) {
    return { code: 500, status: null, thread: null, author: null };
  }

  const res = await fetchThreadsPostPage({
    mediaId,
    sortOrder: 'TOP',
    after: null,
    first: null,
    session,
    userAgent
  });
  if (!res.ok || res.json == null) {
    return { code: res.status === 404 ? 404 : 500, status: null, thread: null, author: null };
  }

  const { edges } = extractPostPageEdges(res.json);
  if (!edges.length) {
    return { code: 404, status: null, thread: null, author: null };
  }

  const focalNode = edges[0]?.node;
  if (!focalNode) {
    return { code: 404, status: null, thread: null, author: null };
  }

  const items = (focalNode.thread_items as unknown[]) ?? [];
  if (!Array.isArray(items) || items.length === 0) {
    return { code: 404, status: null, thread: null, author: null };
  }

  const firstPost = (items[0] as { post?: Record<string, unknown> })?.post;
  const owner = firstPost?.user as Record<string, unknown> | undefined;
  const ownerFb = {
    id: String(owner?.pk ?? owner?.id ?? ''),
    username: String(owner?.username ?? ''),
    fullName: typeof owner?.full_name === 'string' ? owner.full_name : undefined,
    pic: typeof owner?.profile_pic_url === 'string' ? owner.profile_pic_url : null
  };

  const chainStatuses = items
    .map(it => {
      const p = (it as { post?: Record<string, unknown> }).post;
      return p ? threadsPostToStatus(p, ownerFb) : null;
    })