feat(openai): implement close() cleanup for STT

.changeset/funny-pugs-rhyme.md

@@ -0,0 +1,5 @@
+---
+'@livekit/agents-plugin-openai': patch
+---
+
+Implement robust close() cleanup for openAI STT/TTS plugins using AbortController to prevent resource leaks.

plugins/openai/src/stt.ts

@@ -27,6 +27,7 @@ export class STT extends stt.STT {
   #opts: STTOptions;
   #client: OpenAI;
   label = 'openai.STT';
+  private abortController = new AbortController();
 
   /**
    * Create a new instance of OpenAI STT.
@@ -145,13 +146,19 @@ export class STT extends stt.STT {
     const config = this.#sanitizeOptions(language);
     buffer = mergeFrames(buffer);
     const file = new File([this.#createWav(buffer)], 'audio.wav', { type: 'audio/wav' });
-    const resp = await this.#client.audio.transcriptions.create({
-      file,
-      model: this.#opts.model,
-      language: config.language,
-      prompt: config.prompt,
-      response_format: 'json',
-    });
+
+    const resp = await this.#client.audio.transcriptions.create(
+      {
+        file,
+        model: this.#opts.model,
+        language: config.language,
+        prompt: config.prompt,
+        response_format: 'json',
+      },
+      {
+        signal: this.abortController.signal,
+      },
+    );
 
     return {
       type: stt.SpeechEventType.FINAL_TRANSCRIPT,
@@ -171,4 +178,8 @@ export class STT extends stt.STT {
   stream(): stt.SpeechStream {
     throw new Error('Streaming is not supported on OpenAI STT');
   }
+
+  async close(): Promise<void> {
+    this.abortController.abort();
+  }
 }