Remove tracing functionality and simplify voice pipeline imports

Author: ciro-maciel

examples/voice/server.js

@@ -2,12 +2,7 @@
 import OpenAI from 'openai';
 import {
     Agent,
-    VoicePipeline,
-    VoicePipelineConfig,
-    OpenAITTSModel,
-    OpenAISTTModel,
-    SingleAgentVoiceWorkflow,
-    tracing
+    Voice
 } from '../../src/index';
 import { serve } from 'bun';
 import { join } from 'path';
@@ -43,90 +38,57 @@ class WorkflowCallbacks {
 }
 
 // Configurando o workflow de voz
-const workflow = new SingleAgentVoiceWorkflow(agent, {
+const workflow = new Voice.SingleAgentVoiceWorkflow(agent, {
     callbacks: new WorkflowCallbacks()
 });
 
-// Configurando o processador de tracing
-const tracingProcessor = new tracing.OpenAITracingProcessor();
-tracing.addTraceProcessor(tracingProcessor);
-
 // Criando os modelos de STT e TTS
-const sttModel = new OpenAISTTModel(client);
-const ttsModel = new OpenAITTSModel(client);
+const sttModel = new Voice.OpenAISTTModel(client);
+const ttsModel = new Voice.OpenAITTSModel(client);
 
 // Configurando o pipeline
-const config = new VoicePipelineConfig({
+const config = new Voice.VoicePipelineConfig({
     workflowName: "Exemplo de Voz",
-    tracingDisabled: false,
     sttSettings: {
         voice: 'coral'
     },
     ttsSettings: {
         voice: 'coral'
-    },
-    traceMetadata: {
-        environment: "development",
-        application: "voice-demo"
     }
 });
 
 
-const pipeline = new VoicePipeline({
+const pipeline = new Voice.VoicePipeline({
     workflow,
     sttModel,
     ttsModel,
     config
 });
 
-// Envolver as operações principais em traces
 async function handleAudioRequest(audio) {
-
     console.log(`[debug] handleAudioRequest called with audio: ${audio}`);
     const size = audio.size;
     const type = audio.type;
     console.log(`[debug] handleAudioRequest called with audio: ${size}, ${type}`);
-
-    return await tracing.withTrace("voice_interaction", async (trace) => {
-        const spanData = new tracing.CustomSpanData("process_audio", {
-            id: "voice_stream_event_" + Date.now().toString(),
-            type: "voice_stream_event_audio",
-            input_size: size,
-            content_type: type
-        });
-        return await tracing.withSpan("process_audio", async (span) => {
-            // Processar o áudio com o pipeline
-            const result = await pipeline.processAudio(audio);
-            return result;
-        }, spanData);
-    }, {
-        metadata: {
-            environment: "development",
-            application: "voice-demo"
-        }
-    });
+    // Processar o áudio com o pipeline diretamente
+    const result = await pipeline.processAudio(audio);
+    return result;
 }
 
 // Função para processar áudio
 async function processAudio(audioBlob) {
-    const spanData = new tracing.CustomSpanData("audio_processing", {
-        type: "voice_stream_event_lifecycle",
-        event: "turn_started"
-    });
-    return await tracing.withSpan("audio_processing", async (span) => {
-        // Ensure the blob is in the correct format
-        if (!(audioBlob instanceof Blob)) {
-            throw new Error('Input must be a Blob');
-        }
+    // Ensure the blob is in the correct format
+    if (!(audioBlob instanceof Blob)) {
+        throw new Error('Input must be a Blob');
+    }
 
-        const audioChunks = [];
-        for await (const chunk of await handleAudioRequest(audioBlob)) {
-            audioChunks.push(chunk);
-        }
+    const audioChunks = [];
+    for await (const chunk of await handleAudioRequest(audioBlob)) {
+        audioChunks.push(chunk);
+    }
 
-        // Keep the webm format as it's supported by OpenAI
-        return new Blob(audioChunks, { type: 'audio/webm' });
-    }, spanData);
+    // Keep the webm format as it's supported by OpenAI
+    return new Blob(audioChunks, { type: 'audio/webm' });
 }
 
 // Servidor Bun
@@ -176,8 +138,7 @@ const server = serve({
                 headers: { 'Content-Type': 'text/plain' }
             });
         } finally {
-            // Garante que o processador de tracing seja desligado corretamente
-            tracingProcessor.shutdown();
+            // Nenhuma ação de tracing necessária
         }
     }
 });