diff --git a/lib/controllers/client_controller.dart b/lib/controllers/client_controller.dart
index 1d59e4a..78e40ee 100644
--- a/lib/controllers/client_controller.dart
+++ b/lib/controllers/client_controller.dart
@@ -3,7 +3,13 @@ import "package:riverpod/riverpod.dart";
 
 class ClientController extends Notifier<Client> {
   @override
-  Client build() => Client(channels: "cozyp62", secure: true)..connect();
+  Client build() {
+    final client = Client(channels: "cozyp62", secure: true)
+      ..connect()
+      ..on("disconnected", (reason) => ref.invalidateSelf());
+
+    return client;
+  }
 
   static final provider = NotifierProvider<ClientController, Client>(
     ClientController.new,
diff --git a/lib/controllers/record_controller.dart b/lib/controllers/record_controller.dart
index 9f2b6af..7dae1ff 100644
--- a/lib/controllers/record_controller.dart
+++ b/lib/controllers/record_controller.dart
@@ -4,12 +4,7 @@ import "package:riverpod/riverpod.dart";
 class RecordController extends Notifier<String> {
   @override
   String build() {
-    ref.watch(ClientController.provider).on("message", (
-      _,
-      userstate,
-      message,
-      _,
-    ) {
+    ref.watch(ClientController.provider).on("chat", (_, userstate, message, _) {
       if (userstate["username"] == "streamlabs") {
         final match = RegExp(
           r"\d+[Ww]?-\d+[Ll]?",