add reconnects
This commit is contained in:
parent
a2e93e30ee
commit
fd0d598f4c
2 changed files with 8 additions and 7 deletions
|
|
@ -3,7 +3,13 @@ import "package:riverpod/riverpod.dart";
|
||||||
|
|
||||||
class ClientController extends Notifier<Client> {
|
class ClientController extends Notifier<Client> {
|
||||||
@override
|
@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>(
|
static final provider = NotifierProvider<ClientController, Client>(
|
||||||
ClientController.new,
|
ClientController.new,
|
||||||
|
|
|
||||||
|
|
@ -4,12 +4,7 @@ import "package:riverpod/riverpod.dart";
|
||||||
class RecordController extends Notifier<String> {
|
class RecordController extends Notifier<String> {
|
||||||
@override
|
@override
|
||||||
String build() {
|
String build() {
|
||||||
ref.watch(ClientController.provider).on("message", (
|
ref.watch(ClientController.provider).on("chat", (_, userstate, message, _) {
|
||||||
_,
|
|
||||||
userstate,
|
|
||||||
message,
|
|
||||||
_,
|
|
||||||
) {
|
|
||||||
if (userstate["username"] == "streamlabs") {
|
if (userstate["username"] == "streamlabs") {
|
||||||
final match = RegExp(
|
final match = RegExp(
|
||||||
r"\d+[Ww]?-\d+[Ll]?",
|
r"\d+[Ww]?-\d+[Ll]?",
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue