feat: add module event handle registries attr

luisburgos · Jun 25, 2022 · ea7494c · ea7494c
1 parent 02555e0
commit ea7494c
Show file tree

Hide file tree

Showing 4 changed files with 47 additions and 13 deletions.
diff --git a/lib/buzz.dart b/lib/buzz.dart
@@ -2,6 +2,7 @@ library buzz;
 
 export 'buzz_impl.dart';
 export 'infra/event_bus_holder.dart';
+export 'infra/registries.dart';
 export 'infra/typed_event_bus.dart';
 export 'kinds/app_events.dart';
 export 'kinds/commands.dart';

diff --git a/lib/buzz_impl.dart b/lib/buzz_impl.dart
@@ -1,5 +1,6 @@
 import 'package:buzz/buzz.dart';
 
+import 'infra/registries.dart';
 import 'utils.dart';
 
 IBuzzBase? _buzz;
@@ -45,19 +46,18 @@ class BuzzBase implements IBuzzBase {
   UiEventBus get uiEvents => EventBusHolder.of<UiEventBus>();
 
   late Navigator _navigator;
+  List<ModuleBuzzRegistries>? _moduleRegistries;
 
   @override
   void init({
     required Navigator navigator,
+    List<ModuleBuzzRegistries>? moduleRegistries,
   }) {
     _navigator = navigator;
+    _moduleRegistries = moduleRegistries;
 
-    commands.on<NavigationCommand>().listen((navigationCommand) {
-      NavigationCommandHandler(
-        navigator: _navigator,
-        backDefault: _navigator.backDefaultRoute,
-      ).handle(navigationCommand);
-    });
+    _bindNavigationCommandHandler();
+    _bindRegistries();
   }
 
   @override
@@ -73,4 +73,21 @@ class BuzzBase implements IBuzzBase {
   void destroy() {
     //TODO: implement
   }
+
+  void _bindNavigationCommandHandler() {
+    commands.on<NavigationCommand>().listen((navigationCommand) {
+      NavigationCommandHandler(
+        navigator: _navigator,
+        backDefault: _navigator.backDefaultRoute,
+      ).handle(navigationCommand);
+    });
+  }
+
+  void _bindRegistries() {
+    _moduleRegistries?.forEach((moduleRegistry) {
+      uiEvents.bindRegistries(moduleRegistry.uiEvents);
+      commands.bindRegistries(moduleRegistry.commands);
+      appEvents.bindRegistries(moduleRegistry.appEvents);
+    });
+  }
 }
diff --git a/lib/infra/registries.dart b/lib/infra/registries.dart
@@ -1,12 +1,12 @@
 import 'package:buzz/buzz.dart';
 
-abstract class _IModuleBuzzRegistries<T> {
+abstract class _IModuleBuzzRegistries {
   List<CommandRegistry> get commands;
   List<UiEventRegistry> get uiEvents;
   List<AppEventRegistry> get appEvents;
 }
 
-abstract class ModuleBuzzRegistries<T> extends _IModuleBuzzRegistries<T> {
+abstract class ModuleBuzzRegistries extends _IModuleBuzzRegistries {
   @override
   List<CommandRegistry> get commands => const [];
 
@@ -42,6 +42,8 @@ abstract class EventHandlerRegistry<T> {
 
   final Function(T) handler;
 
+  dynamic get registryType => T;
+
   @override
   String toString() => '$runtimeType type:$T';
 }
diff --git a/lib/infra/typed_event_bus.dart b/lib/infra/typed_event_bus.dart
@@ -1,3 +1,4 @@
+import 'package:buzz/buzz.dart';
 import 'package:event_bus/event_bus.dart';
 
 import '../utils.dart';
@@ -18,16 +19,29 @@ class TypedEventBus<T> {
     return _eventBus.on<X>();
   }
 
-  /*TODO: Verify use case still valid or remove.
-  Stream of(bool Function(dynamic) evaluateCast) {
+  Stream of(dynamic type) {
     return _eventBus.streamController.stream.where(
       (event) {
-        final isType = evaluateCast(event);
-        //debugPrint('$event isType: $isType');
+        final isType = isTypeSupported(type);
+        developerLog('$event isType: $isType');
         return isType;
       },
     ).cast();
-  }*/
+  }
+}
+
+extension TypedEventBusRegistry<T> on TypedEventBus<T> {
+  void bindRegistries(List<EventHandlerRegistry<T>> registries) {
+    registries.forEach((registry) {
+      bindRegistry(registry);
+    });
+  }
+
+  void bindRegistry(EventHandlerRegistry<T> registry) {
+    of(registry.registryType).listen(
+      (event) => registry.handler(event),
+    );
+  }
 }
 
 abstract class TypedEventHandler<T> {