feat: Allow to pass a custom model in OpenAI RealtimeClient

packages/openai_realtime_dart/README.md

@@ -60,6 +60,9 @@ client.on(RealtimeEventType.conversationUpdated, (event) {
 // Connect to Realtime API
 await client.connect();
 
+// You can optionally specify a custom model
+// await client.connect(model: 'gpt-4o-mini-realtime-preview');
+
 // Send a item and triggers a generation
 await client.sendUserMessageContent([
   const ContentPart.inputText(text: 'How are you?'),

packages/openai_realtime_dart/example/openai_realtime_dart_example.dart

@@ -28,6 +28,8 @@ Future<void> main() async {
   });
 
   // Connect to Realtime API
+  // You can specify a custom model if needed
+  // await client.connect(model: 'gpt-4o-mini-realtime-preview');
   await client.connect();
 
   // Send a item and triggers a generation

packages/openai_realtime_dart/lib/src/api.dart

@@ -54,8 +54,11 @@ class RealtimeAPI extends RealtimeEventHandler {
   bool isConnected() => _ws != null;
 
   /// Connects to Realtime API Websocket Server.
+  ///
+  /// [model] specifies which model to use. You can find the list of available
+  /// models [here](https://platform.openai.com/docs/models).
   Future<bool> connect({
-    final String model = 'gpt-4o-realtime-preview-2024-10-01',
+    final String model = RealtimeUtils.defaultModel,
   }) async {
     if (isConnected()) {
       throw Exception('Already connected');

packages/openai_realtime_dart/lib/src/client.dart

@@ -245,11 +245,16 @@ class RealtimeClient extends RealtimeEventHandler {
 
   /// Connects to the Realtime WebSocket API.
   /// Updates session config and conversation config.
-  Future<bool> connect() async {
+  ///
+  /// [model] specifies which model to use. You can find the list of available
+  /// models [here](https://platform.openai.com/docs/models).
+  Future<bool> connect({
+    final String model = RealtimeUtils.defaultModel,
+  }) async {
     if (isConnected()) {
       throw Exception('Already connected, use .disconnect() first');
     }
-    final connected = await realtime.connect();
+    final connected = await realtime.connect(model: model);
     if (connected) {
       await updateSession();
     }

packages/openai_realtime_dart/lib/src/utils.dart

@@ -3,6 +3,9 @@ import 'dart:math';
 import 'dart:typed_data';
 
 class RealtimeUtils {
+  /// Default model for OpenAI Realtime API.
+  static const String defaultModel = 'gpt-4o-realtime-preview';
+
   static Uint8List mergeUint8Lists(Uint8List left, Uint8List right) {
     final result = Uint8List(left.length + right.length);
     result.setRange(0, left.length, left);

packages/openai_realtime_dart/test/api_test.dart

@@ -60,7 +60,7 @@ void main() {
     });
 
     test('Should handle multiple connections and disconnections', () async {
-      for (int i = 0; i < 3; i++) {
+      for (var i = 0; i < 3; i++) {
         final isConnected = await realtime.connect();
         expect(isConnected, isTrue, reason: 'Connection $i failed');
         expect(realtime.isConnected(), isTrue, reason: 'Connection $i failed');

packages/openai_realtime_dart/test/client_test.dart

@@ -6,6 +6,24 @@ import 'package:test/test.dart';
 
 void main() {
   group('RealtimeClient Tests', () {
+    test('RealtimeClient connect with custom model', () async {
+      final client = RealtimeClient(
+        apiKey: Platform.environment['OPENAI_API_KEY'],
+        debug: true,
+      );
+
+      // Connect with a custom model
+      const customModel = 'gpt-4o-mini-realtime-preview';
+      final isConnected = await client.connect(model: customModel);
+
+      expect(isConnected, isTrue);
+      expect(client.isConnected(), isTrue);
+
+      // Clean up
+      await client.disconnect();
+      expect(client.isConnected(), isFalse);
+    });
+
     test('RealtimeClient test', () async {
       final realtimeEvents = <RealtimeEvent>[];
       final client = RealtimeClient(