feat(*): add actions dispatcher

Author: yackinn

.eslintrc.json

@@ -24,7 +24,10 @@
     {
       "files": ["*.ts", "*.tsx"],
       "extends": ["plugin:@nrwl/nx/typescript"],
-      "rules": {}
+      "rules": {
+        "@typescript-eslint/no-explicit-any": ["off"],
+        "@typescript-eslint/no-non-null-assertion": ["off"]
+      }
     },
     {
       "files": ["*.js", "*.jsx"],

apps/web/src/main.ts

@@ -1,8 +1,11 @@
 import { enableProdMode } from '@angular/core';
 import { platformBrowserDynamic } from '@angular/platform-browser-dynamic';
 
-import { AppModule } from './app/app.module';
+import { AppModule }   from './app/app.module';
 import { environment } from './environments/environment';
+import { devTools }    from '@ngneat/effects';
+
+devTools()
 
 if (environment.production) {
   enableProdMode();

libs/effects/src/index.ts

@@ -2,9 +2,10 @@ export {
   registerEffects,
   removeEffects,
   createEffect,
-  removeAllEffects,
-} from './lib/effects-manager';
-export { initEffects } from './lib/effects-manager';
-export { actions } from './lib/actions';
+  removeAllEffects
+}                                                 from './lib/effects-manager';
+export { initEffects }                            from './lib/effects-manager';
+export { actions, actionsDispatcher, Actions }    from './lib/actions';
 export { action as createAction, props, payload } from 'ts-action';
-export { ofType } from 'ts-action-operators';
+export { ofType }                                 from 'ts-action-operators';
+

libs/effects/src/lib/actions.ts

@@ -1,18 +1,11 @@
 import { Subject } from 'rxjs';
-import { Action } from './action.model';
+import { Action }  from './action.model';
 
 export class Actions extends Subject<Action> {
   dispatch(value: Action): void {
-    this.logAction(value);
-
     this.next(value);
   }
-
-  logAction(value: Action): void {
-    const { type, ...props } = value;
-    const hasPayload = Object.getOwnPropertyNames(props).length > 0;
-    // logAction(type, null, hasPayload ? props : null);
-  }
 }
 
-export const actions = new Actions();
+export const actions           = new Actions();
+export const actionsDispatcher = actions.asObservable();

libs/effects/src/lib/effects-manager.ts

@@ -1,24 +1,23 @@
 import { Observable, Subject, takeUntil } from 'rxjs';
-import { Effect, EffectConfig } from './effect.model';
-import { Action } from './action.model';
-import { Actions, actions } from './actions';
-import { coerceArray } from './utils';
+import { Effect, EffectConfig }           from './effect.model';
+import { Action }                         from './action.model';
+import { Actions, actions }               from './actions';
+import { coerceArray }                    from './utils';
+
 
 interface EffectsConfig {
-  logger?: any; // todo type
   dispatchByDefault?: boolean;
 }
 
-class EffectsManager {
-  private effects = new WeakMap<Effect, Subject<void>>();
+export class EffectsManager {
+  private effects         = new WeakMap<Effect, Subject<void>>();
   private destroyEffects$ = new Subject<void>();
   private config: EffectsConfig;
 
   constructor(config?: EffectsConfig) {
     this.config = {
-      // logger:
       dispatchByDefault: false,
-      ...config,
+      ...config
     };
   }
 
@@ -36,6 +35,7 @@ class EffectsManager {
 
   removeAllEffects() {
     this.destroyEffects$.next();
+    this.effects = new WeakMap<Effect, Subject<void>>();
   }
 
   private subscribeEffect(effect: Effect) {