import 'dart:async';

import 'package:hooks_riverpod/hooks_riverpod.dart';

class JsEvent {
  const JsEvent(this.method, [this.args]);

  final String method;
  final List<dynamic>? args;
}

class WebReloadController {
  final _controller = StreamController<JsEvent>.broadcast();

  Stream<JsEvent> get stream => _controller.stream;
  void callEvent(JsEvent event) => _controller.add(event);
  Future<void> dispose() => _controller.close();
}

final webReloadControllerProvider = Provider<WebReloadController>((ref) {
  final controller = WebReloadController();
  ref.onDispose(() => unawaited(controller.dispose()));
  return controller;
});

final webReloadPProvider = StreamProvider.autoDispose<JsEvent>((ref) {
  return ref.watch(webReloadControllerProvider).stream;
});