const ReverieClient = require("@reverieit/reverie-client");

const reverieClient = new ReverieClient({
apiKey: "YOUR-API-KEY",
appId: "YOUR-APP-ID",
});

await reverieClient.init_stt({
src_lang: "hi",
callback: (event) => {
console.log("STT event:", event);
},
element: document.getElementById("transcript"),
domain: "generic"

});

// Start/Stop streaming
await reverieClient.start_stt();
await reverieClient.stop_stt();

import pyaudio, asyncio
from reverie_sdk import ReverieClient
from reverie_sdk.services.asr import AudioStream

client = ReverieClient(
    api_key="REVERIE_API_KEY",
    app_id="REVERIE_APP_ID",
)

stream = AudioStream()
pa = pyaudio.PyAudio()

def mic_callback(in_data, frame_count, time_info, status):
    try:
        asyncio.run(stream.add_chunk_async(in_data))
    except:
        return (None, pyaudio.paAbort)
    return (None, pyaudio.paContinue)

async def main():
    pa_stream = pa.open(
        rate=RATE,
        channels=CHANNELS,
        format=FORMAT,
        frames_per_buffer=CHUNK_SIZE,
        input=True,
        stream_callback=mic_callback,
    )
    pa_stream.start_stream()

    print("listening... press ctrl+C to stop", flush=True)

    try:
        await client.asr.stt_stream_async(
            src_lang="en",
            bytes_or_stream=stream,
            callback=print,
            continuous="0",
            domain="generic",
            format="16k_int16",
            logging="true",
            punctuate="true",
            silence=15,
            timeout=15,
        )
    except Exception as err:
        print(err)
    finally:
        pa_stream.stop_stream()
        pa_stream.close()


asyncio.run(main())

pa.terminate()