Function processOneJob

server/background-worker.ts:47–242

()

}

async function processOneJob(): Promise<void> {
  if (processing) return;
  processing = true;

  try {
    // Check daily budget
    const spent = await getTodaySpend();
    if (spent >= DAILY_BUDGET_CENTS) return;

    // Pick the oldest pending job
    const [job] = await db
      .select()
      .from(pipelineJobs)
      .where(
        and(
          eq(pipelineJobs.jobType, "chat-triggered-analysis"),
          eq(pipelineJobs.status, "pending"),
        ),
      )
      .orderBy(asc(pipelineJobs.createdAt))
      .limit(1);

    if (!job) return;

    const documentId = job.documentId;
    if (!documentId) {
      await db.update(pipelineJobs).set({ status: "failed", errorMessage: "No document ID" }).where(eq(pipelineJobs.id, job.id));
      return;
    }

    // Mark as running
    await db.update(pipelineJobs).set({
      status: "running",
      startedAt: new Date(),
      attempts: job.attempts + 1,
    }).where(eq(pipelineJobs.id, job.id));

    // Get document info
    const [doc] = await db.select().from(documents).where(eq(documents.id, documentId));
    if (!doc) {
      await db.update(pipelineJobs).set({ status: "failed", errorMessage: "Document not found" }).where(eq(pipelineJobs.id, job.id));
      return;
    }

    // Read all pages for this document
    const pages = await db
      .select({ content: documentPages.content, pageNumber: documentPages.pageNumber })
      .from(documentPages)
      .where(eq(documentPages.documentId, documentId))
      .orderBy(asc(documentPages.pageNumber));

    const fullText = pages.map((p) => `Page ${p.pageNumber}\n${p.content}`).join("\n\n");

    if (fullText.length < MIN_TEXT_LENGTH) {
      await db.update(pipelineJobs).set({ status: "completed", completedAt: new Date(), errorMessage: "Text too short" }).where(eq(pipelineJobs.id, job.id));
      await db.update(documents).set({ aiAnalysisStatus: "skipped" }).where(eq(documents.id, documentId));
      return;
    }