provider-openai-chat.ts

import { createEval2Otel, convertOpenAIChatToEval2Otel } from '../src';
import * as fs from 'fs';
import * as readline from 'readline';

// Usage: ts-node examples/provider-openai-chat.ts <openai_chat.jsonl>
// Each line: { startTime, endTime, request, response }
async function main() {
  const file = process.argv[2];
  if (!file) { console.error('Usage: ts-node examples/provider-openai-chat.ts <openai_chat.jsonl>'); process.exit(1); }
  const inst = createEval2Otel({ serviceName: 'openai-chat-replay', useSdk: false } as any);
  const rl = readline.createInterface({ input: fs.createReadStream(file), crlfDelay: Infinity });
  for await (const line of rl) {
    const trimmed = line.trim(); if (!trimmed) continue;
    const obj = JSON.parse(trimmed);
    const start = obj.startTime ?? Date.now();
    const end = obj.endTime ?? (start + 1);
    const evalRes = convertOpenAIChatToEval2Otel(obj.request, obj.response, start, end);
    inst.processEvaluation(evalRes);
  }
  await inst.shutdown();
}

main().catch((e) => { console.error(e); process.exit(1); });