result.ts

// api/agent/result.ts

import { type NextApiRequest, type NextApiResponse } from "next";

import { type AgentPacket } from "@acme/agent";
import { appRouter } from "@acme/api";
import { getServerSession, type Session } from "@acme/auth";
import {
  prisma,
  type DraftExecutionNode,
  type Execution,
  type ExecutionState,
  type Result,
} from "@acme/db";

export const config = {
  runtime: "nodejs",
};

export type CreateResultParams = {
  goalId: string;
  node: DraftExecutionNode;
  executionId: string;
  packet: AgentPacket;
  packets: AgentPacket[];
  state: ExecutionState;
  session?: Session | null;
};

// data proxy for edge
export default async function createResultProxy(
  req: NextApiRequest,
  res: NextApiResponse,
) {
  try {
    const session = await getServerSession({ req, res });

    const params = req.body as CreateResultParams;
    params["session"] = session;

    const result = await createResult(params);
    console.debug("createResult result", result);
    res.status(200).json(result);
  } catch (error) {
    console.error("createResult error", error);
    res.status(500).json({ error: (error as { message: string }).message });
  }
}

async function createResult(
  createResultOptions: CreateResultParams,
): Promise<[Result, Execution]> {
  const { session } = createResultOptions;
  const caller = appRouter.createCaller({ session: session || null, prisma });
  const createResult = caller.result.create(createResultOptions);
  return createResult;
}