Server refreshed token (#73)

lib/src/core/engine.dart

@@ -649,6 +649,10 @@ class Engine extends Disposable with EventsEmittable<EngineEvent> {
     ..on<SignalSubscribedQualityUpdatedEvent>((event) => events.emit(event))
     // relay to Room
     ..on<SignalSubscriptionPermissionUpdateEvent>((event) => events.emit(event))
+    ..on<SignalTokenUpdatedEvent>((event) {
+      logger.fine('Server refreshed the token');
+      token = event.token;
+    })
     ..on<SignalLeaveEvent>((event) async {
       if (_connectionState == ConnectionState.reconnecting) {
         logger.warning(

lib/src/core/signal_client.dart

@@ -206,6 +206,9 @@ class SignalClient extends Disposable with EventsEmittable<SignalEvent> {
           allowed: msg.subscriptionPermissionUpdate.allowed,
         ));
         break;
+      case lk_rtc.SignalResponse_Message.refreshToken:
+        events.emit(SignalTokenUpdatedEvent(token: msg.refreshToken));
+        break;
       default:
         logger.warning('skipping unsupported signal message');
     }

lib/src/internal/events.dart

@@ -231,6 +231,14 @@ class SignalSubscriptionPermissionUpdateEvent
   });
 }
 
+@internal
+class SignalTokenUpdatedEvent with SignalEvent, InternalEvent {
+  final String token;
+  const SignalTokenUpdatedEvent({
+    required this.token,
+  });
+}
+
 // ----------------------------------------------------------------------
 // Engine events
 // ----------------------------------------------------------------------