Not able to use new FLUX CSR

[OnlinePage]

What is the current behavior?

Client is not able to connect to the flux and returns error

Steps to reproduce

here is my class for flux csr:

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

class DeepGramFluxCSR {
  constructor(apiKey) {
    this.apiKey = apiKey;
    this.client = createClient(apiKey);
    this.connection = null;
    this.onStartTurn = null;
    this.onEndTurn = null;
  }

  setOnStartTurn(callback) {
    this.onStartTurn = callback;
  }

  setOnEndTurn(callback) {
    this.onEndTurn = callback;
  }

  start() {
    this.connection = this.client.listen.live({
      model: "flux-general-en",
      language: "en",
      smart_format: true,
      interim_results: true,
      endpointing: true,

    });

    this.connection.on(LiveTranscriptionEvents.Open, () => {
      console.log("Deepgram Flux connection opened");
    });

    this.connection.on(LiveTranscriptionEvents.Transcript, (data) => {
      if (data.type === "TurnInfo") {
        switch (data.event) {
          case "StartOfTurn":
            if (this.onStartTurn) {
              this.onStartTurn();
            }
            break;
          case "EndOfTurn":
            if (this.onEndTurn) {
              this.onEndTurn();
            }
            break;
          // Optionally handle other events like 'EagerEndOfTurn', 'TurnResumed', 'Update'
        }
      }
    });

    this.connection.on(LiveTranscriptionEvents.Close, () => {
      console.log("Deepgram Flux connection closed");
    });

    this.connection.on(LiveTranscriptionEvents.Error, (error) => {
      console.error("Deepgram Flux error:", error);
    });
  }

  send(audioBuffer) {
    if (this.connection && !this.connection.getReadyState() === 1) {
      // OPEN
      this.connection.send(audioBuffer);
    } else {
      console.warn("Connection not open");
    }
  }

  stop() {
    if (this.connection) {
      this.connection.finish();
      this.connection = null;
    }
  }
}

module.exports = DeepGramFluxCSR;

and here is the test code:

const API_KEY = "myyfukkiinngkeeeyyy"; // ← CRITICAL: 
const csr = new DeepGramFluxCSR(API_KEY);

csr.setOnStartTurn(() => {
  console.log("🔊 Start of turn detected!");
});

csr.setOnEndTurn(() => {
  console.log("🛑 End of turn detected!");
});

csr.start();

and here is the error trace:

Deepgram Flux error: {
  error: DeepgramWebSocketError: Received network error or non-101 status code.
      at ListenLiveClient.createEnhancedError (C:\Users\.....\node_modules\@deepgram\sdk\dist\main\packages\AbstractLiveClient.js:357:31)
      at conn.onerror ...
    __dgError: true,
    originalEvent: ErrorEvent {
      type: 'error',
      defaultPrevented: false,
      cancelable: false,
      timeStamp: 1230.7981
    },
    statusCode: undefined,
    requestId: undefined,
    responseHeaders: undefined,
    url: 'wss://api.deepgram.com/v1/listen?model=flux-general-en&language=en&smart_format=true&interim_results=true&endpointing=true',
    readyState: 0
  },
  statusCode: undefined,
  requestId: undefined,
  responseHeaders: undefined,
  url: 'wss://api.deepgram.com/v1/listen?model=flux-general-en&language=en&smart_format=true&interim_results=true&endpointing=true',
  readyState: 0,
  message: 'Received network error or non-101 status code. (Ready State: CONNECTING, URL: wss://api.deepgram.com/v1/listen?model=flux-general-en&language=en&smart_format=true&interim_results=true&endpointing=true)',
  [Symbol(type)]: 'error',
  [Symbol(kTarget)]: WebSocket {},
  [Symbol(kIsBeingDispatched)]: true
}
:microphone: Starting microphone capture... Speak into the mic and watch for turn events.
Press Ctrl+C to stop early.

:wave: Shutting down...

[naomi-lgbt]

Hiya! Our JS SDK does not have Flux support yet (we are working very hard to get that out soon). Unfortunately, this means that the SDK is going to try connecting to /v1/listen, but Flux has a separate endpoint at /v2/listen.

[shneeki]

ListenClient.live accepts an endpoint as a second param, so you can connect as such
const deepgram = createClient({ accessToken: token }); const conn = deepgram.listen.live(options, endpoint); where endpoint is 'wss://api.deepgram.com/v2/listen'

Read documentation carefully, and add appropriate options.
I don't think your current ones are supported with flux, which could be causing an error.

  smart_format: true,
  interim_results: true,
  endpointing: true,

As @naomi-lgbt has mentioned SDK is not updated, so you can't rely on it to provide you with LiveTranscriptionEvents.Transcript events. You have to add a listener to 'message' event on the websocket itself
connection.conn.addEventListener('message', onTranscript);

Well and then you have to process your audio to have a correct format as well before you send it.

If it's not urgent I would advice to just wait for an SDK update

[taylor-lindores-reeves]

wen flux typescript?

[uneeq-paul]

@naomi-lgbt Do you have any updates you can share on Flux support in JS SDK? Thanks.