Merge pull request #204 from rimbu-org/feature/api-improvements

Feature/api improvements

.github/workflows/build-packages.yaml

@@ -19,10 +19,10 @@ jobs:
   build:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v3
-      - uses: actions/setup-node@v3
+      - uses: actions/checkout@v4
+      - uses: actions/setup-node@v4
         with:
-          node-version: 18
+          node-version: 20
           registry-url: 'https://registry.npmjs.org'
           cache: 'yarn'
           # Defaults to the user or organization that owns the workflow file

.github/workflows/codeql-analysis.yml

@@ -38,7 +38,7 @@ jobs:
 
     steps:
       - name: Checkout repository
-        uses: actions/checkout@v3
+        uses: actions/checkout@v4
 
       # Initializes the CodeQL tools for scanning.
       - name: Initialize CodeQL

.github/workflows/documentation.yaml

@@ -10,10 +10,10 @@ jobs:
   checks:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v3
-      - uses: actions/setup-node@v3
+      - uses: actions/checkout@v4
+      - uses: actions/setup-node@v4
         with:
-          node-version: 18
+          node-version: 20
           cache: 'yarn'
       - uses: webfactory/ssh-agent@v0.7.0
         with:

.github/workflows/publish-canary-release.yaml

@@ -6,7 +6,7 @@ jobs:
   publish:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           fetch-depth: 0
       - name: Configure git credentials
@@ -16,9 +16,9 @@ jobs:
       - name: Attach to main branch
         run: git checkout main && git pull
       # Setup .npmrc file to publish to npm
-      - uses: actions/setup-node@v3
+      - uses: actions/setup-node@v4
         with:
-          node-version: 18
+          node-version: 20
           registry-url: 'https://registry.npmjs.org'
           cache: 'yarn'
           # Defaults to the user or organization that owns the workflow file

.github/workflows/publish-graduate-release.yaml

@@ -6,7 +6,7 @@ jobs:
   publish:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           fetch-depth: 0
       - name: Configure git credentials
@@ -16,9 +16,9 @@ jobs:
       - name: Attach to main branch
         run: git checkout main && git pull
       # Setup .npmrc file to publish to npm
-      - uses: actions/setup-node@v3
+      - uses: actions/setup-node@v4
         with:
-          node-version: 18
+          node-version: 20
           registry-url: 'https://registry.npmjs.org'
           cache: 'yarn'
           # Defaults to the user or organization that owns the workflow file

.github/workflows/publish-release.yaml

@@ -6,7 +6,7 @@ jobs:
   publish:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           fetch-depth: 0
       - name: Configure git credentials
@@ -16,9 +16,9 @@ jobs:
       - name: Attach to main branch
         run: git checkout main && git pull
       # Setup .npmrc file to publish to npm
-      - uses: actions/setup-node@v3
+      - uses: actions/setup-node@v4
         with:
-          node-version: 18
+          node-version: 20
           registry-url: 'https://registry.npmjs.org'
           cache: 'yarn'
           # Defaults to the user or organization that owns the workflow file

.gitignore

@@ -13,3 +13,5 @@ yarn-error.log
 lerna-debug.log
 
 **/.DS_Store
+
+.nx

config/tsconfig.common.json

@@ -4,7 +4,7 @@
     "module": "Node16",
     "moduleResolution": "node16",
     "verbatimModuleSyntax": true,
-    "lib": ["esnext"],
+    "lib": ["ESNext"],
     "importHelpers": true,
     "sourceMap": true,
     "strict": true,

deno_dist/actor/main/actor.ts

@@ -1,7 +1,7 @@
-import { OptLazy, type Reducer } from '../../common/mod.ts';
+import { OptLazy } from '../../common/mod.ts';
+import type { Reducer } from '../../stream/mod.ts';
 
 import type { ActionBase } from './internal.ts';
-
 /**
  *
  */

deno_dist/actor/main/generate-uuid.ts

@@ -1,23 +1,25 @@
 declare global {
   export const self: any;
-  export const crypto: any;
+}
+
+interface Context {
+  crypto?: { randomUUID?: () => string };
+  performance?: { now?: () => number };
 }
 
 /**
  * Internal function to generate a UUID.
  */
-export function generateUUID(): string {
-  const context = self;
-  if (undefined !== context?.crypto?.randomUUID) {
-    return crypto.randomUUID();
+export function generateUUID(context: Context = self): string {
+  if (typeof context?.crypto?.randomUUID === 'function') {
+    return context.crypto.randomUUID();
   }
 
   // Public Domain/MIT
   let d = new Date().getTime(); //Timestamp
   let d2 =
-    (typeof performance !== 'undefined' &&
-      performance.now &&
-      performance.now() * 1000) ||
+    (typeof context?.performance?.now === 'function' &&
+      context.performance.now() * 1000) ||
     0; //Time in microseconds since page-load or 0 if unsupported
   return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function (c) {
     let r = Math.random() * 16; //random number between 0 and 16

deno_dist/actor/main/lookup.ts

@@ -1,4 +1,5 @@
-import { Reducer, type OptLazy } from '../../common/mod.ts';
+import { OptLazy } from '../../common/mod.ts';
+import { Reducer } from '../../stream/mod.ts';
 
 import type { ActionBase } from './internal.ts';
 
@@ -49,18 +50,21 @@ export namespace Lookup {
   ): Reducer<ActionBase, S> {
     const { actions, fallback } = lookup;
 
-    return Reducer.createOutput(initState, (state, action) => {
-      if (undefined !== actions && action.tag in actions) {
-        const lookupValue = actions[action.tag];
+    return Reducer.createOutput(
+      () => OptLazy(initState),
+      (state, action) => {
+        if (undefined !== actions && action.tag in actions) {
+          const lookupValue = actions[action.tag];
 
-        return applyLookupValue(state, action, lookupValue);
-      }
+          return applyLookupValue(state, action, lookupValue);
+        }
 
-      if (undefined !== fallback) {
-        return applyFallback(state, action, fallback);
-      }
+        if (undefined !== fallback) {
+          return applyFallback(state, action, fallback);
+        }
 
-      return state;
-    });
+        return state;
+      }
+    );
   }
 }

deno_dist/actor/main/slice-config.ts

@@ -1,4 +1,4 @@
-import type { OptLazy } from '../../common/mod.ts';
+import { type OptLazy } from '../../common/mod.ts';
 
 import { Lookup, type ActionBase, type Slice } from './internal.ts';
 

deno_dist/actor/main/slice.ts

@@ -1,4 +1,4 @@
-import { Reducer } from '../../common/mod.ts';
+import { Reducer } from '../../stream/mod.ts';
 
 import { Action, SliceConfig, type Actor } from './internal.ts';
 import type { Tail } from './utils.ts';
@@ -83,7 +83,7 @@ export namespace Slice {
     }
 
     return {
-      reducer: Reducer.combineObj(reducers),
+      reducer: Reducer.combine(reducers) as any,
       actions,
     };
   }