update.

lib/src/core/room.dart

@@ -19,6 +19,7 @@ import 'dart:async';
 import 'package:flutter/foundation.dart';
 
 import 'package:collection/collection.dart';
+import 'package:http/http.dart' as http;
 import 'package:meta/meta.dart';
 
 import '../core/signal_client.dart';
@@ -38,6 +39,7 @@ import '../proto/livekit_models.pb.dart' as lk_models;
 import '../proto/livekit_rtc.pb.dart' as lk_rtc;
 import '../support/disposable.dart';
 import '../support/platform.dart';
+import '../support/region_url_provider.dart';
 import '../track/local/audio.dart';
 import '../track/local/video.dart';
 import '../track/track.dart';
@@ -110,6 +112,9 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
   //
   late EventsListener<SignalEvent> _signalListener;
 
+  RegionUrlProvider? _regionUrlProvider;
+  String? _regionUrl;
+
   Room({
     @Deprecated('deprecated, please use connectOptions in room.connect()')
     ConnectOptions connectOptions = const ConnectOptions(),
@@ -148,6 +153,31 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
     });
   }
 
+  void prepareConnection(String url, String? token) async {
+    if (engine.connectionState != ConnectionState.disconnected) {
+      return;
+    }
+    logger.info('prepareConnection to $url');
+    try {
+      if (isCloudUrl(Uri.parse(url)) && token != null) {
+        _regionUrlProvider = RegionUrlProvider(token: token, url: url);
+        final regionUrl = await _regionUrlProvider!.getNextBestRegionUrl();
+        // we will not replace the regionUrl if an attempt had already started
+        // to avoid overriding regionUrl after a new connection attempt had started
+        if (regionUrl != null &&
+            connectionState == ConnectionState.disconnected) {
+          _regionUrl = regionUrl;
+          await http.head(Uri.parse(toHttpUrl(regionUrl)));
+          logger.fine('prepared connection to ${regionUrl}');
+        }
+      } else {
+        await http.head(Uri.parse(toHttpUrl(url)));
+      }
+    } catch (e) {
+      logger.warning('could not prepare connection');
+    }
+  }
+
   Future<void> connect(
     String url,
     String token, {
@@ -174,8 +204,28 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
       );
     }
 
+    if (_regionUrlProvider?.getServerUrl().toString() != url) {
+      _regionUrl = null;
+      _regionUrlProvider = null;
+    }
+    if (isCloudUrl(Uri.parse(url))) {
+      if (_regionUrlProvider == null) {
+        _regionUrlProvider = RegionUrlProvider(url: url, token: token);
+      } else {
+        _regionUrlProvider?.updateToken(token);
+      }
+      // trigger the first fetch without waiting for a response
+      // if initial connection fails, this will speed up picking regional url
+      // on subsequent runs
+      try {
+        await _regionUrlProvider?.fetchRegionSettings();
+      } catch (e) {
+        logger.warning('could not fetch region settings $e');
+      }
+    }
+
     await engine.connect(
-      url,
+      _regionUrl ?? url,
       token,
       connectOptions: connectOptions,
       roomOptions: roomOptions,

lib/src/support/region_url_provider.dart

@@ -25,10 +25,7 @@ class RegionUrlProvider {
     this.token = token;
   }
 
-  bool isCloud() {
-    return serverUrl.host.endsWith('.livekit.cloud') ||
-        serverUrl.host.endsWith('.livekit.run');
-  }
+  bool isCloud() => isCloudUrl(serverUrl);
 
   Uri getServerUrl() {
     return serverUrl;
@@ -64,8 +61,8 @@ class RegionUrlProvider {
 
   /* @internal */
   Future<lk_models.RegionSettings> fetchRegionSettings() async {
-    http.Response regionSettingsResponse =
-        await http.get(Uri.parse(getCloudConfigUrl(serverUrl)), headers: {
+    http.Response regionSettingsResponse = await http
+        .get(Uri.parse('${getCloudConfigUrl(serverUrl)}/regions'), headers: {
       'authorization': 'Bearer $token',
     });
     if (regionSettingsResponse.statusCode == 200) {
@@ -106,3 +103,22 @@ extension RegionSettingsExtension on lk_models.RegionSettings {
             .toList(),
       );
 }
+
+bool isCloudUrl(Uri url) {
+  return url.host.contains('.livekit.cloud') ||
+      url.host.contains('.livekit.run');
+}
+
+String toHttpUrl(String url) {
+  if (url.startsWith('ws')) {
+    return url.replaceAll('ws', 'http');
+  }
+  return url;
+}
+
+String toWebsocketUrl(String url) {
+  if (url.startsWith('http')) {
+    return url.replaceAll('http', 'ws');
+  }
+  return url;
+}