Trouble closing, then re-creating deepgram instance

[brewcrew059]

I am building a conversational app. The user clicks a button, then speaks into the microphone to have their speech transcribed by deepgram. This works perfectly fine on the initial run. The user can speak back and forth with the AI no problem.
When the user switches screens, I try to clean up deepgram instances and send CloseStream so they can be cleanly re-instantiated upon returning to this page. This is where the issue lies.
I am unable to send data to deepgram after one conversation has already been completed.

Here is the relevant Client-Side and Server-Side code:

Client-Side

import io from 'socket.io-client';
const clientSocket = useRef(null);
// Upon opening the page, check if we need to connect the socket
if (!clientSocket.current || !clientSocket.current.connected) {
        clientSocket.current = io.connect('http://localhost:9000');
        
        // Upon connection, send relevant info to server
        clientSocket.current.on('connect', () => {


// Clean up on unmount
if (clientSocket.current !== null) {
        clientSocket.current.off("transcript");
        
        clientSocket.current.disconnect();
        clientSocket.current.removeAllListeners();


Server-Side

const { Deepgram } = require("@deepgram/sdk");

io.on("connection", (socket) => {
  let id = socket.id;

  userMap.set(id, new UserData(socket));

  setupDeepgram(id);
  
const setupDeepgram = (id) => {
  
  if (userMap.get(id).deepInstance === "") {
    userMap.get(id).setDeepInstance(createNewDeepgram());
  }
  userMap.get(id).setDeepLiveInstance(createNewDeepgramLive(userMap.get(id).deepInstance));
  addDeepgramTranscriptListener(id);
  addDeepgramOpenListener(id);
  addDeepgramCloseListener(id);
  addDeepgramErrorListener(id);
  
  userMap.get(id).clientSock.on("audioData", async (data) =>
    dgPacketResponse(data, id)
  );
};

const createNewDeepgram = () => {
  return new Deepgram(process.env.DEEPGRAM_API_KEY);
};

const createNewDeepgramLive = (dg) => {
  return dg.transcription.live({
    language: "en",
    punctuate: true,
    smart_format: true,
    model: "nova",
  });
};

const addDeepgramTranscriptListener = (id) => {
  userMap.get(id).deepLiveInstance.addListener("transcriptReceived", async (packet) => {
    try {
      if (userMap.has(id) && userMap.get(id).clientSock !== null) {
        //console.log("deepgram: packet received");
        const data = JSON.parse(packet);
        const { type } = data;
        switch (type) {
          case "Results":
            //console.log(data);
            const transcript = data.channel.alternatives[0].transcript ?? "";
            console.log(transcript);
            userMap.get(id).clientSock.emit("transcript", transcript);
            userMap.get(id).accumulateCurrentMessage(transcript);
            break;
          case "Metadata":
            console.log("deepgram: metadata received");
            console.log(data);
            break;
          default:
            console.log("deepgram: unknown packet received");
            break;
        }
        userMap.get(id).setGotOneResponseFromDG(true);
      }
    } catch (err) {
      console.log(err);
    }
  });
};

// cleanup
  userMap.get(id).clientSock.on("disconnect", () => {
    console.log("socket: client disconnected");

    userMap.get(id).deepLiveInstance._socket.send(
      JSON.stringify({
        type: "CloseStream"
      })
    );

    userMap.get(id).setDeepInstance("");
    
    userMap.get(id).clientSock.removeAllListeners();
  });

Am I missing something? Once metadata is received (and console logs deepgram: metadata received), I am unable to re-create an instance to send data afterwards. Any help is appreciated.

[team-deepgram]

Thanks for asking your question about Deepgram! If you didn't already include it in your post, please be sure to add as much detail as possible so we can assist you efficiently, such as:

• The request_id if you have a question about your requests or transcription responses.
• The features you used or the full api.deepgram.com URL you sent your request to, including parameters.
• Any code snippets you can share.

[brewcrew059]

How could I have missed such a simple solution?

Despite setting DeepInstance to "" on cleanup, it actually becomes null for some reason. So by adding the null check, the new instance is created properly.

//Cleanup
userMap.get(id).setDeepInstance("");

//Create instance
if (userMap.get(id).deepInstance === "" || userMap.get(id).deepInstance === null) {
userMap.get(id).setDeepInstance(createNewDeepgram());
}