const connectionId = 'conn-' + Math.random().toString(36).substr(2, 9);

const ws = new WebSocket(
  `wss://api.nextevi.com/ws/voice/${connectionId}?api_key=oak_your_api_key&config_id=your_config_id`
);

ws.onopen = () => {
  console.log('Connected to NextEVI');
};

ws.onmessage = (event) => {
  const message = JSON.parse(event.data);
  console.log('Received:', message);
};

ws.onerror = (error) => {
  console.error('WebSocket error:', error);
};

ws.onclose = (event) => {
  console.log('Disconnected:', event.code, event.reason);
};

const ws = new WebSocket(
  `wss://api.nextevi.com/ws/voice/${connectionId}?authorization=Bearer%20${jwtToken}&config_id=your_config_id`
);

// Or with Authorization header (Node.js)
const ws = new WebSocket(`wss://api.nextevi.com/ws/voice/${connectionId}?config_id=your_config_id`, {
  headers: {
    'Authorization': `Bearer ${jwtToken}`
  }
});

class NextEVIConnection {
  constructor(config) {
    this.config = config;
    this.websocket = null;
    this.isConnected = false;
  }
  
  connect() {
    const url = `wss://api.nextevi.com/ws/voice/${this.config.connectionId}?api_key=${this.config.apiKey}&config_id=${this.config.configId}${ this.config.projectId ? '&project_id=' + this.config.projectId : ''}`;
    
    this.websocket = new WebSocket(url);
    
    this.websocket.onopen = () => {
      this.isConnected = true;
      this.onConnected();
    };
    
    this.websocket.onmessage = (event) => {
      this.handleMessage(JSON.parse(event.data));
    };
    
    this.websocket.onerror = (error) => {
      console.error('Connection error:', error);
    };
    
    this.websocket.onclose = () => {
      this.isConnected = false;
      this.onDisconnected();
    };
  }
  
  send(message) {
    if (this.isConnected) {
      this.websocket.send(JSON.stringify(message));
    }
  }
  
  onConnected() {
    // Configure session settings
    this.send({
      type: "session_settings",
      timestamp: Date.now() / 1000,
      message_id: "settings-1",
      data: {
        emotion_detection: { enabled: true },
        turn_detection: { enabled: true },
        audio: { sample_rate: 24000, channels: 1, encoding: "linear16" }
      }
    });
  }
  
  handleMessage(message) {
    switch (message.type) {
      case 'connection_metadata':
        console.log('Connection established:', message);
        break;
      case 'transcription':
        console.log('Transcription:', message.transcript);
        break;
      case 'tts_chunk':
        // Handle audio playback
        this.playAudio(message.content);
        break;
      default:
        console.log('Unknown message:', message);
    }
  }
  
  playAudio(base64Audio) {
    // Implement audio playback logic
    const audioBlob = this.base64ToBlob(base64Audio, 'audio/wav');
    const audioUrl = URL.createObjectURL(audioBlob);
    const audio = new Audio(audioUrl);
    audio.play();
  }
  
  base64ToBlob(base64, mimeType) {
    const bytes = atob(base64);
    const arrayBuffer = new ArrayBuffer(bytes.length);
    const uint8Array = new Uint8Array(arrayBuffer);
    
    for (let i = 0; i < bytes.length; i++) {
      uint8Array[i] = bytes.charCodeAt(i);
    }
    
    return new Blob([arrayBuffer], { type: mimeType });
  }
}

// Usage
const nextevi = new NextEVIConnection({
  connectionId: 'conn-123',
  apiKey: 'oak_your_api_key',
  configId: 'your_config_id'
});

nextevi.connect();