Function parseBody

packages/queue/src/tasks/llm/index.ts:149–190

(
  response: LLMPredictionResponse,
  { account, communityName }: { account: accounts; communityName: string }
)

}

export async function parseBody(
  response: LLMPredictionResponse,
  { account, communityName }: { account: accounts; communityName: string }
): Promise<string> {
  // TODO: if is a url, show it, otherwise, it will be a threadId, we should build the url
  // TODO https urls should not be wrapped by <>
  const references = getReferences(response.sourceDocuments);
  const urls = getUrls(references);
  const threadIds = getThreadIds(references);
  const threads = await prisma.threads.findMany({
    where: {
      id: { in: threadIds },
    },
  });

  const threadUrls = threads.map((thread) => {
    return getThreadUrl({
      isSubDomainRouting: true,
      slug: thread.slug,
      incrementId: thread.incrementId,
      settings: {
        communityName,
        redirectDomain: account.redirectDomain as string | undefined,
      },
      LINEN_URL:
        process.env.NODE_ENV === 'development'
          ? 'http://localhost:3000'
          : 'https://www.linen.dev',
    });
  });

  const refs = [...urls, ...threadUrls];

  if (refs.length > 0) {
    return [
      response.text,
      'References:',
      [...urls, ...threadUrls].map((source) => `- ${source}`).join('\n'),
    ].join('\n\n');
  }
  return response.text;
}

// TODO: follow up (replies)