Method process

packages/server/src/agent/agent.processor.ts:31–627

(job: Job<GenerationInput>)

  }

  async process(job: Job<GenerationInput>): Promise<void> {
    const { projectId, runId, threadId } = job.data;
    console.log(`[processor] === Starting generation job ===`);
    console.log(`[processor] projectId=${projectId} runId=${runId} threadId=${threadId}`);

    const [run] = await this.db
      .select({ status: schema.agentRuns.status })
      .from(schema.agentRuns)
      .where(eq(schema.agentRuns.id, runId));
    if (run && run.status !== "running" && run.status !== "queued") {
      console.log(`[processor] Skipping run=${runId}; status=${run.status}`);
      return;
    }

    // Build the graph with checkpointer
    console.log(`[processor] Building graph...`);
    const graph = buildPhase2Graph();
    const checkpointer = new MemorySaver();
    const compiled = graph.compile({ checkpointer });
    console.log(`[processor] Graph compiled with ${Object.keys(graph).length} nodes`);

    const config = { configurable: { thread_id: threadId } };
    const [project] = await this.db
      .select({
        title: schema.projects.title,
        story: schema.projects.story,
        style: schema.projects.style,
        targetShotCount: schema.projects.targetShotCount,
        storyOutline: schema.projects.storyOutline,
        visualBible: schema.projects.visualBible,
      })
      .from(schema.projects)
      .where(eq(schema.projects.id, projectId));

    const projectContext = buildProjectContext(projectId, project, job.data);
    let latestOutline: Record<string, unknown> | null = project?.storyOutline || null;
    let latestVisualBible: string | null = project?.visualBible || null;

    // ---- Build the REAL agent context ----
    const ctx = {
      projectId,
      runId,
      threadId,
      sendMessage: async (content: string, opts?: { summary?: string; progress?: number; isLoading?: boolean; stage?: string }) => {
        console.log(`[processor:msg] content="${content.substring(0, 80)}..." progress=${opts?.progress ?? "N/A"} stage=${opts?.stage ?? "N/A"}`);
        try {
          await this.db.insert(schema.messages).values({
            projectId,
            runId,
            agent: "system",
            role: "assistant",
            content,
            summary: opts?.summary || null,
            progress: opts?.progress || null,
            isLoading: opts?.isLoading || false,
            createdAt: new Date(),
          });
        } catch (dbErr) {