add tasks

yarigo · Jun 29, 2021 · e84d1e6 · e84d1e6
1 parent c1439e6
commit e84d1e6
Show file tree

Hide file tree

Showing 4 changed files with 38 additions and 20 deletions.
diff --git a/packages/redux-dynamic-modules-saga/README.md b/packages/redux-dynamic-modules-saga/README.md
@@ -3,13 +3,13 @@
 Run
 
 ```
-npm install redux-dynamic-modules-saga
+npm install @yarigo/redux-dynamic-modules-saga
 ```
 
 or
 
 ```
-yarn add redux-dynamic-modules-saga
+yarn add @yarigo/redux-dynamic-modules-saga
 ```
 
 ## Usage
@@ -39,12 +39,12 @@ import { getSagaExtension } from "redux-dynamic-modules-saga";
 import { getUsersModule } from "./usersModule";
 
 const store: IModuleStore<IState> = createStore(
-  {
-    initialState: {},
-    enhancers: [],
-    extensions: [getSagaExtension({} /* saga context */)],
-  },
-  getUsersModule()
-  /* ...any additional modules */
+    {
+        initialState: {},
+        enhancers: [],
+        extensions: [getSagaExtension({} /* saga context */)],
+    },
+    getUsersModule()
+    /* ...any additional modules */
 );
 ```
diff --git a/packages/redux-dynamic-modules-saga/package.json b/packages/redux-dynamic-modules-saga/package.json
@@ -1,10 +1,10 @@
 {
-    "name": "redux-dynamic-modules-saga",
+    "name": "@yarigo/redux-dynamic-modules-saga",
     "version": "5.2.3",
-    "description": "Saga Extension for redux-dynamic-modules",
+    "description": "Saga Extension for redux-dynamic-modules (fork https://github.com/microsoft/redux-dynamic-modules)",
     "repository": {
         "type": "github",
-        "url": "https://github.com/Microsoft/redux-dynamic-modules"
+        "url": "https://github.com/yarigo/redux-dynamic-modules"
     },
     "main": "./lib/index.js",
     "types": "./lib/index.d.ts",

diff --git a/packages/redux-dynamic-modules-saga/src/SagaExtension.ts b/packages/redux-dynamic-modules-saga/src/SagaExtension.ts
@@ -1,26 +1,37 @@
-import { default as createSagaMiddleware, SagaMiddleware } from "redux-saga";
+import {
+    default as createSagaMiddleware,
+    SagaMiddleware,
+    Task,
+} from "redux-saga";
 import {
     IExtension,
-    IItemManager,
     getRefCountedManager,
     IModuleManager,
+    IMap,
 } from "redux-dynamic-modules-core";
 import { ISagaRegistration, ISagaModule } from "./Contracts";
-import { getSagaManager } from "./SagaManager";
+import { getSagaManager, ISagaItemManager } from "./SagaManager";
 import { sagaEquals } from "./SagaComparer";
 
+export interface ISagaExtension extends IExtension {
+    tasks: IMap<ISagaRegistration<any>, Task>;
+}
+
 /**
  * Get an extension that integrates saga with the store
  * @param sagaContext The context to provide to the saga
  */
 export function getSagaExtension<C>(
     sagaContext?: C,
     onError?: (error: Error) => void
-): IExtension {
+): ISagaExtension {
     let sagaMonitor = undefined;
 
     //@ts-ignore
-    if (process.env.NODE_ENV === "development" && typeof window !== "undefined") {
+    if (
+        process.env.NODE_ENV === "development" &&
+        typeof window !== "undefined"
+    ) {
         sagaMonitor = window["__SAGA_MONITOR_EXTENSION__"] || undefined;
     }
 
@@ -31,11 +42,13 @@ export function getSagaExtension<C>(
         onError,
     });
 
-    let _sagaManager: IItemManager<
+    let _sagaManager: ISagaItemManager<
         ISagaRegistration<any>
     > = getRefCountedManager(getSagaManager(sagaMiddleware), sagaEquals);
 
     return {
+        tasks: _sagaManager.tasks,
+
         middleware: [sagaMiddleware],
 
         onModuleManagerCreated: (moduleManager: IModuleManager) => {

diff --git a/packages/redux-dynamic-modules-saga/src/SagaManager.ts b/packages/redux-dynamic-modules-saga/src/SagaManager.ts
@@ -1,17 +1,22 @@
 import { ISagaRegistration, ISagaWithArguments } from "./Contracts";
 import { SagaMiddleware, Task } from "redux-saga";
 import { sagaEquals } from "./SagaComparer";
-import { IItemManager, getMap } from "redux-dynamic-modules-core";
+import { IItemManager, getMap, IMap } from "redux-dynamic-modules-core";
+
+export interface ISagaItemManager<T> extends IItemManager<T> {
+    tasks: IMap<ISagaRegistration<any>, Task>;
+}
 
 /**
  * Creates saga items which can be used to start and stop sagas dynamically
  */
 export function getSagaManager(
     sagaMiddleware: SagaMiddleware<any>
-): IItemManager<ISagaRegistration<any>> {
+): ISagaItemManager<ISagaRegistration<any>> {
     const tasks = getMap<ISagaRegistration<any>, Task>(sagaEquals);
 
     return {
+        tasks,
         getItems: (): ISagaRegistration<any>[] => [...tasks.keys],
         add: (sagas: ISagaRegistration<any>[]) => {
             if (!sagas) {