Deepgram Voice Agent now available in Voximplant

/**
* Voximplant + Deepgram Voice Agent connector demo
* Feature highlighted: CROSS-CALL CONVERSATION HISTORY (simple “memory” per caller ID)
*/
require(Modules.Deepgram); // 
require(Modules.ApplicationStorage);
const SYSTEM_PROMPT = `
You are a helpful English-speaking voice assistant for phone callers. Your name is Voxi.
You are speaking on behalf of Voximplant and Deepgram about Voximplant's Deepgram Voice Agent integration.
Keep your turns short and telephony-friendly (usually 1–2 sentences).


If conversation history is present (prior turns are provided), begin the call by briefly summarizing what the user asked or tried to accomplish last time in one sentence before asking how you can help.


KNOWLEDGE ABOUT VOXIMPLANT + DEEPGRAM
- The Voximplant Deepgram Voice Agent connector exposes the full Deepgram Voice Agent configuration and event stream (e.g., AgentThinking and History) and supports low-latency, interruption-friendly conversations via turn-taking, barge-in, and mid-session updates, and conversation history.
- Voximplant can bridge phone, SIP, WebRTC, or WhatsApp calls from Voximplant directly into Deepgram Voice Agent using a single VoxEngine scenario, with Voximplant handling the telephony, media conversion, and streaming WebSockets so you can focus on agent behavior.
`;
VoxEngine.addEventListener(AppEvents.CallAlerting, async ({ call }) => {
   let voiceAgentClient;
   try {
       call.answer();
       call.record({ hd_audio: true, stereo: true }); // optional: call recording
       // -------------------- CROSS-CALL HISTORY (per caller ID) --------------------
       const callerId = call.callerid() || null; // Caller ID is our “user identity”
       const historyKey = `dgva_history:${callerId}`;
       let rollingHistory = [];
       const stored = await ApplicationStorage.get(historyKey);
       if (callerId && stored && stored.value) {
           const parsed = JSON.parse(stored.value);
           if (Array.isArray(parsed))
               rollingHistory = parsed;
       }
       Logger.write("===CROSS_CALL_HISTORY_LOADED===");
       Logger.write(`Loaded ${rollingHistory.length} messages for caller ${callerId}`);
       // -------------------- Deepgram Voice Agent settings --------------------
       const SETTINGS_OPTIONS = {
           tags: ["voximplant", "deepgram", "voice_agent_connector", "cross_call_history_demo"],
           agent: {
               language: "en",
               greeting: "Hi! I'm Voxy. How can I help today?",
               context: {
                   messages: rollingHistory, // pass prior turns into the new session as conversation history.
               },
               listen: {
                   provider: {
                       type: "deepgram",
                       model: "flux-general-en",
                   },
               },
               think: {
                   provider: {
                       type: "open_ai",
                       model: "gpt-4o-mini",
                       temperature: 0.6,
                   },
                   prompt: SYSTEM_PROMPT
               },
               speak: {
                   provider: {
                       type: "deepgram",
                       model: "aura-2-cordelia-en",
                   },
               },
           },
       };
       // Create client and wire media
       voiceAgentClient = await Deepgram.createVoiceAgentClient({
           apiKey: (await ApplicationStorage.get("DEEPGRAM_API_KEY")).value, // Add your API key or save it to storage
           settingsOptions: SETTINGS_OPTIONS,
       });
       VoxEngine.sendMediaBetween(call, voiceAgentClient);
       // single terminate that saves history
       async function terminate() {
           try {
               await ApplicationStorage.put(historyKey, JSON.stringify(rollingHistory), 7 * 24 * 3600);
               Logger.write("===CROSS_CALL_HISTORY_SAVED===");
               Logger.write(JSON.stringify({ callerId, messages: rollingHistory.length }));
           }
           catch (e) {
               Logger.write(`Error during terminate ${JSON.stringify(e)}`);
           }
           finally {
               try {
                   voiceAgentClient?.close();
               }
               catch (e) {
                   Logger.write(e);
               }
               VoxEngine.terminate();
           }
       }
       call.addEventListener(CallEvents.Disconnected, function () { terminate(); });
       call.addEventListener(CallEvents.Failed, function () { terminate(); });
       // ---------------------- Event handlers -----------------------
       // Barge-in: keep conversation responsive
       voiceAgentClient.addEventListener(Deepgram.VoiceAgentEvents.UserStartedSpeaking, () => {
           Logger.write("===BARGE-IN: Deepgram.VoiceAgentEvents.UserStartedSpeaking===");
           voiceAgentClient.clearMediaBuffer();
       });
       // Capture transcript and history
       voiceAgentClient.addEventListener(Deepgram.VoiceAgentEvents.ConversationText, (e) => {
           const { role, text } = e?.data?.payload;
           Logger.write(`✍️: ${role}: ${text}`);
       });
       // Update rolling history
       voiceAgentClient.addEventListener(Deepgram.VoiceAgentEvents.History, (e) => {
           rollingHistory.push(e?.data?.payload); // TODO: check size first
           rollingHistory = rollingHistory.slice(-5); // keep last 5 turns; prod should limit size
       });
       // Consolidated “log-only” handlers - all Deepgram API events supported
       [
           Deepgram.VoiceAgentEvents.Welcome,
           Deepgram.VoiceAgentEvents.SettingsApplied,
           Deepgram.VoiceAgentEvents.AgentThinking,
           Deepgram.VoiceAgentEvents.AgentAudioDone,
           Deepgram.VoiceAgentEvents.ConnectorInformation,
           Deepgram.VoiceAgentEvents.HTTPResponse,
           Deepgram.VoiceAgentEvents.Warning,
           Deepgram.VoiceAgentEvents.Error,
           Deepgram.VoiceAgentEvents.Unknown,
           Deepgram.Events.WebSocketMediaStarted,
           Deepgram.Events.WebSocketMediaEnded
       ].forEach(evt => {
           voiceAgentClient.addEventListener(evt, evt => {
               Logger.write(`===${evt.name}===`);
               Logger.write(JSON.stringify(evt));
           });
       });
   }
   catch (e) {
       Logger.write("===UNHANDLED_ERROR===");
       Logger.write(e);
       try {
           voiceAgentClient?.close();
       }
       catch (err) {
           Logger.write(err);
       }
       VoxEngine.terminate();
   }
});