Function hashAndSaveDatasetEntryInput

app/src/server/utils/nodes/hashNode.ts:47–83

({
  projectId,
  tool_choice,
  tools,
  messages,
  response_format,
  inputTokens,
  trx = kysely,
}: {
  projectId: string;
  inputTokens?: number;
  trx?: typeof kysely;
} & Pick<ChatCompletionCreateParams, "tool_choice" | "tools" | "messages" | "response_format">)

};

export const hashAndSaveDatasetEntryInput = async ({
  projectId,
  tool_choice,
  tools,
  messages,
  response_format,
  inputTokens,
  trx = kysely,
}: {
  projectId: string;
  inputTokens?: number;
  trx?: typeof kysely;
} & Pick<ChatCompletionCreateParams, "tool_choice" | "tools" | "messages" | "response_format">) => {
  const inputHash = hashDatasetEntryInput({
    projectId,
    tool_choice,
    tools,
    messages,
    response_format,
  });

  await trx
    .insertInto("DatasetEntryInput")
    .values({
      projectId,
      hash: inputHash,
      tool_choice: tool_choice ? JSON.stringify(tool_choice) : undefined,
      tools: tools ? JSON.stringify(tools) : undefined,
      messages: JSON.stringify(messages),
      response_format: response_format ? JSON.stringify(response_format) : undefined,
      inputTokens,
    })
    .onConflict((oc) => oc.columns(["hash"]).doNothing())
    .execute();

  return inputHash;
};

export const hashDatasetEntryOutput = ({
  projectId,