Function recordLoggedCall

app/src/utils/recordRequest.ts:175–232

({
  projectId,
  usage,
  requestedAt,
  receivedAt,
  cacheHit,
  reqPayload,
  respPayload,
  statusCode,
  errorMessage,
  tags = {},
}: {
  projectId: string;
  usage?: CalculatedUsage;
  requestedAt: number;
  receivedAt?: number;
  cacheHit: boolean;
  reqPayload: unknown;
  respPayload?: unknown;
  statusCode?: number;
  errorMessage?: string;
  tags?: Record<string, string>;
})

});

export const recordLoggedCall = async ({
  projectId,
  usage,
  requestedAt,
  receivedAt,
  cacheHit,
  reqPayload,
  respPayload,
  statusCode,
  errorMessage,
  tags = {},
}: {
  projectId: string;
  usage?: CalculatedUsage;
  requestedAt: number;
  receivedAt?: number;
  cacheHit: boolean;
  reqPayload: unknown;
  respPayload?: unknown;
  statusCode?: number;
  errorMessage?: string;
  tags?: Record<string, string>;
}) => {
  const newLoggedCallId = uuidv4();

  const validatedReqPayload = await reqValidator.spa(reqPayload);
  const validatedRespPayload = await chatCompletionOutput.spa(respPayload);

  try {
    await prisma.loggedCall.create({
      data: {
        id: newLoggedCallId,
        projectId,
        requestedAt: new Date(requestedAt),
        receivedAt: receivedAt ? new Date(receivedAt) : undefined,
        cacheHit: cacheHit ?? false,
        model: validatedReqPayload.success ? validatedReqPayload.data.model : null,
        reqPayload: (reqPayload === null ? Prisma.JsonNull : reqPayload) as Prisma.InputJsonValue,
        respPayload: (respPayload === null
          ? Prisma.JsonNull
          : respPayload) as Prisma.InputJsonValue,
        statusCode: statusCode,
        errorMessage: errorMessage,
        durationMs: receivedAt && receivedAt - requestedAt,
        inputTokens: usage?.inputTokens,
        outputTokens: usage?.outputTokens,
        cost: usage?.cost,
        completionId: validatedRespPayload.success ? validatedRespPayload.data.id : null,
      },
    });
  } catch (e) {
    throw new Error(`Failed to create logged call: ${(e as Error).message}`);
  }

  if (Object.keys(tags).length > 0) {
    await createTags(projectId, newLoggedCallId, tags);
  }
};