test(reactant-share): fix testing

Author: unadlib

packages/reactant-share/src/checkPatches.ts

@@ -1,3 +1,4 @@
+import { routerModuleName } from './constants';
 import { ActionOptions } from './interfaces';
 
 export const checkPatches = (
@@ -16,7 +17,7 @@ export const checkPatches = (
       if (
         oldState &&
         typeof oldState === 'object' &&
-        path[0] !== 'reactant:router'
+        path[0] !== routerModuleName
       ) {
         const state = path.join('.');
         console.warn(

packages/reactant-share/src/constants.ts

@@ -11,3 +11,6 @@ export const syncToClientsName = '@@reactant:syncToClients';
 export const syncWorkerRouterName = '@@reactant:syncWorkerRouter';
 
 export const SharedAppOptions = Symbol('SharedAppOptions');
+
+export const storageModuleName = 'Storage';
+export const routerModuleName = 'Router';

packages/reactant-share/src/router.ts

@@ -17,7 +17,9 @@ import type {
 } from 'reactant-router';
 import type { LocationState } from 'history';
 import {
+  routerModuleName,
   SharedAppOptions,
+  storageModuleName,
   syncRouterName,
   syncWorkerRouterName,
 } from './constants';
@@ -40,7 +42,7 @@ export interface IRouterOptions extends IBaseRouterOptions {
 }
 
 @injectable({
-  name: 'Router',
+  name: routerModuleName,
 })
 class ReactantRouter extends BaseReactantRouter {
   constructor(
@@ -191,9 +193,10 @@ class ReactantRouter extends BaseReactantRouter {
         if (rehydrated) {
           stopWatching();
           const router = this._routers[this.portDetector.name];
-          if (router) {
-            this._changeRoutingOnSever(this.portDetector.name, router);
-          }
+          this._changeRoutingOnSever(
+            this.portDetector.name,
+            router ?? this.defaultHistory
+          );
         }
       }
     );
@@ -288,11 +291,12 @@ class ReactantRouter extends BaseReactantRouter {
   }
 
   protected get enableCacheRouting() {
-    const { Storage } = (this as any)[modulesKey];
+    const Storage = (this as any)[modulesKey][storageModuleName];
+    const routerPersistConfig = Storage?.persistConfig[routerModuleName];
     return (
-      Storage?.persistConfig.Router &&
-      (Storage.persistConfig.Router!.whitelist?.includes('_routers') ||
-        Storage.persistConfig.Router!.blacklist?.includes('_routers') === false)
+      routerPersistConfig &&
+      (routerPersistConfig!.whitelist?.includes('_routers') ||
+        routerPersistConfig!.blacklist?.includes('_routers') === false)
     );
   }
 
@@ -304,7 +308,7 @@ class ReactantRouter extends BaseReactantRouter {
       hash: '',
       state: undefined,
     },
-  };
+  } as RouterState;
 
   protected dispatchChanged(router: RouterState) {
     this.store?.dispatch(

packages/reactant-share/src/storage.ts

@@ -10,13 +10,14 @@ import type {
   SetStorageOptions,
 } from 'reactant-storage';
 import { PortDetector } from './portDetector';
+import { storageModuleName } from './constants';
 
 export interface IStorageOptions extends IBaseStorageOptions {
   //
 }
 
 @injectable({
-  name: 'Storage',
+  name: storageModuleName,
 })
 class ReactantStorage extends BaseReactantStorage {
   constructor(

packages/reactant-share/test/MemoryStorage.ts

@@ -0,0 +1,23 @@
+export class MemoryStorage {
+  constructor(public data: Record<string, any> = {}) {}
+
+  getItem(key: string): Promise<string> {
+    return new Promise((resolve) => {
+      resolve(this.data[key]);
+    });
+  }
+
+  setItem(key: string, item: string) {
+    return new Promise((resolve) => {
+      this.data[key] = item;
+      resolve(undefined);
+    });
+  }
+
+  removeItem(key: string) {
+    return new Promise((resolve) => {
+      delete this.data[key];
+      resolve(undefined);
+    });
+  }
+}