Node.js

npm install 'git+https://github.com/shubhamofbce/vaanieval-observer-nodejs-sdk.git#d2bb0f3629d724ea6bfc505e1b975d595dddddeb'

{
  "type": "module"
}

import { VaaniObserver } from '@vaanieal/observer';

const SAMPLE_RATE = 16000;
const FORMAT = { encoding: 'pcm_s16le', sampleRateHz: SAMPLE_RATE, channels: 1 };

/** A second of audible PCM, so the recording has something to play. */
function tone(hz, ms) {
  const frames = Math.floor((SAMPLE_RATE * ms) / 1000);
  const buffer = Buffer.alloc(frames * 2);
  for (let n = 0; n < frames; n += 1) {
    buffer.writeInt16LE(Math.round(9000 * Math.sin((2 * Math.PI * hz * n) / SAMPLE_RATE)), n * 2);
  }
  return buffer;
}

const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

const vaani = new VaaniObserver({
  endpoint: 'http://localhost:8000',
  apiKey: 'local-dev', // the local dashboard does not validate this
  spoolDirectory: './.vaani-spool',
  endpoints: [{ id: 'llm', type: 'llm', url: 'https://api.openai.com/v1' }],
});

const session = vaani.startSession({ agentId: 'quickstart-agent' });

for (let index = 0; index < 2; index += 1) {
  const turn = session.startTurn();

  // The caller speaks.
  const stt = turn.startOperation({ type: 'stt', provider: 'demo' });
  stt.event('speech_started');
  session.recordInboundAudio(tone(220, 900), FORMAT);
  await sleep(900);
  stt.event('final_transcript');
  stt.end({ status: 'ok', response: { transcript: `caller line ${index + 1}` } });

  // The model thinks.
  const llm = turn.startOperation({ type: 'llm', provider: 'demo', model: 'demo-model' });
  await sleep(400);
  llm.event('first_token');
  llm.end({ status: 'ok', response: { tokens: 128 } });

  // The agent speaks. `operationId` attributes the PCM to this exact reply.
  const tts = turn.startOperation({ type: 'tts', provider: 'demo' });
  session.recordOutboundAudio(tone(440, 1200), {
    ...FORMAT,
    turnId: turn.id,
    operationId: tts.id,
  });
  tts.end({ status: 'ok' });

  turn.end();
}

const finalized = await session.end({ outcome: 'completed' });
console.log('package written to', finalized.directory);

await vaani.uploadPackage(finalized);
console.log('uploaded session', finalized.sessionId);

node record-a-call.mjs

const session = vaani.startSession({ agentId: 'support' });
const turn = session.startTurn();

await turn.run(async () => {
  // Recorded as an LLM operation on this turn, because api.openai.com
  // matches the configured endpoint rule.
  await fetch('https://api.openai.com/v1/chat/completions', { method: 'POST', body });
});

import WebSocket from 'ws';

const socket = new WebSocket('wss://api.deepgram.com/v1/listen');
const handle = vaani.observeWebSocket(socket, { session, url: socket.url });

// ... later
handle.detach();