Connect reducer

dethi · Dec 9, 2017 · 7d90898 · 7d90898
1 parent e24899e
commit 7d90898
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/src/main/java/com/epita/guereza/Main.java b/src/main/java/com/epita/guereza/Main.java
@@ -75,12 +75,22 @@ private static void runIndexer(Scope scope) {
 
     private static void runStore(Scope scope) {
         final Function<Scope, UrlStore> newUrlStore = (s) -> new UrlStore(s.instanceOf(EventBusClient.class));
+        final Function<Scope, RetroIndex> newRetroIndex = (s) -> new RetroIndex();
         final Function<Scope, App> newEventStoreApp = (s) -> new EventStoreApp(
                 s.instanceOf(EventBusClient.class), s.instanceOf(EventStore.class));
 
         scope.scope()
                 .register(new Singleton<>(EventStore.class, new EventStore()))
-                .register(new LazySingleton<>(UrlStore.class, newUrlStore))
+                .register(new LazySingleton<>(UrlStore.class, newUrlStore)
+                        .afterCreate((s, obj) -> {
+                            EventStore eventStore = s.instanceOf(EventStore.class);
+                            eventStore.addReducer(obj);
+                        }))
+                .register(new LazySingleton<>(RetroIndex.class, newRetroIndex)
+                        .afterCreate((s, obj) -> {
+                            EventStore eventStore = s.instanceOf(EventStore.class);
+                            eventStore.addReducer(obj);
+                        }))
                 .register(new Prototype<>(App.class, newEventStoreApp))
                 .block(Main::runApp);
     }