6.0.2

.gitlab-ci.yml

@@ -12,40 +12,36 @@ stages:
   - release
   - metadata
 
+before_script:
+  - pnpm install -g pnpm
+  - pnpm install -g @shipzone/npmci
+  - npmci npm prepare
+
+# ====================
+# security stage
+# ====================
 # ====================
 # security stage
 # ====================
-mirror:
-  stage: security
-  script:
-    - npmci git mirror
-  only:
-    - tags
-  tags:
-    - lossless
-    - docker
-    - notpriv
-
 auditProductionDependencies:
   image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
   stage: security
   script:
-    - npmci npm prepare
+     - npmci command npm config set registry https://registry.npmjs.org
-    - npmci command npm install --production --ignore-scripts
+     - npmci command pnpm audit --audit-level=high --prod
-    - npmci command npm config set registry https://registry.npmjs.org
-    - npmci command npm audit --audit-level=high --only=prod --production
   tags:
+    - lossless
     - docker
+  allow_failure: true
 
 auditDevDependencies:
   image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
   stage: security
   script:
-    - npmci npm prepare
-    - npmci command npm install --ignore-scripts
     - npmci command npm config set registry https://registry.npmjs.org
-    - npmci command npm audit --audit-level=high --only=dev
+    - npmci command pnpm audit --audit-level=high --dev
   tags:
+    - lossless
     - docker
   allow_failure: true
 
@@ -56,7 +52,6 @@ auditDevDependencies:
 testStable:
   stage: test
   script:
-    - npmci npm prepare
     - npmci node install stable
     - npmci npm install
     - npmci npm test
@@ -67,10 +62,9 @@ testStable:
 testBuild:
   stage: test
   script:
-    - npmci npm prepare
     - npmci node install stable
     - npmci npm install
-    - npmci command npm run build
+    - npmci npm build
   coverage: /\d+.?\d+?\%\s*coverage/
   tags:
     - docker
@@ -96,10 +90,9 @@ codequality:
   only:
     - tags
   script:
-    - npmci command npm install -g tslint typescript
+    - npmci command npm install -g typescript
     - npmci npm prepare
     - npmci npm install
-    - npmci command "tslint -c tslint.json ./ts/**/*.ts"
   tags:
     - lossless
     - docker
@@ -119,11 +112,9 @@ trigger:
 pages:
   stage: metadata
   script:
-    - npmci node install lts
+    - npmci node install stable
-    - npmci command npm install -g @gitzone/tsdoc
-    - npmci npm prepare
     - npmci npm install
-    - npmci command tsdoc
+    - npmci command npm run buildDocs
   tags:
     - lossless
     - docker

.vscode/launch.json

@@ -2,28 +2,10 @@
   "version": "0.2.0",
   "configurations": [
     {
-      "name": "current file",
+      "command": "# instrumented",
-      "type": "node",
+      "name": "Run instrumented terminal",
       "request": "launch",
-      "args": [
+      "type": "node-terminal"
-        "${relativeFile}"
-      ],
-      "runtimeArgs": ["-r", "@gitzone/tsrun"],
-      "cwd": "${workspaceRoot}",
-      "protocol": "inspector",
-      "internalConsoleOptions": "openOnSessionStart"
-    },
-    {
-      "name": "test.ts",
-      "type": "node",
-      "request": "launch",
-      "args": [
-        "test/test.ts"
-      ],
-      "runtimeArgs": ["-r", "@gitzone/tsrun"],
-      "cwd": "${workspaceRoot}",
-      "protocol": "inspector",
-      "internalConsoleOptions": "openOnSessionStart"
     }
   ]
 }

npmextra.json

@@ -9,7 +9,7 @@
       "githost": "gitlab.com",
       "gitscope": "pushrocks",
       "gitrepo": "lik",
-      "shortDescription": "light little helpers for node",
+      "description": "light little helpers for node",
       "npmPackagename": "@pushrocks/lik",
       "license": "MIT"
     }

package.json

@@ -1,13 +1,15 @@
 {
   "name": "@pushrocks/lik",
-  "version": "4.0.19",
+  "version": "6.0.2",
   "private": false,
   "description": "light little helpers for node",
   "main": "dist_ts/index.js",
   "typings": "dist_ts/index.d.ts",
+  "type": "module",
   "scripts": {
     "test": "(tstest test/)",
-    "build": "(tsbuild --web && tsbundle npm)"
+    "build": "(tsbuild --web --allowimplicitany && tsbundle npm)",
+    "buildDocs": "tsdoc"
   },
   "repository": {
     "type": "git",
@@ -20,22 +22,21 @@
   },
   "homepage": "https://gitlab.com/pushrocks/lik#README",
   "devDependencies": {
-    "@gitzone/tsbuild": "^2.1.25",
+    "@gitzone/tsbuild": "^2.1.63",
-    "@gitzone/tsbundle": "^1.0.78",
+    "@gitzone/tsbundle": "^2.0.4",
-    "@gitzone/tsrun": "^1.2.12",
+    "@gitzone/tsrun": "^1.2.39",
-    "@gitzone/tstest": "^1.0.52",
+    "@gitzone/tstest": "^1.0.71",
-    "@pushrocks/tapbundle": "^3.2.9",
+    "@pushrocks/tapbundle": "^5.0.3",
-    "@types/node": "^14.14.9",
+    "@types/node": "^18.11.18"
-    "tslint": "^6.1.3",
-    "tslint-config-prettier": "^1.18.0"
   },
   "dependencies": {
-    "@pushrocks/smartdelay": "^2.0.10",
+    "@pushrocks/smartdelay": "^2.0.13",
-    "@pushrocks/smartmatch": "^1.0.7",
+    "@pushrocks/smartmatch": "^2.0.0",
-    "@pushrocks/smartpromise": "^3.1.3",
+    "@pushrocks/smartpromise": "^3.1.7",
-    "@pushrocks/smartrx": "^2.0.19",
+    "@pushrocks/smartrx": "^3.0.0",
-    "@pushrocks/smarttime": "^3.0.37",
+    "@pushrocks/smarttime": "^4.0.1",
-    "@types/minimatch": "^3.0.3",
+    "@types/minimatch": "^5.1.2",
+    "@types/symbol-tree": "^3.2.2",
     "symbol-tree": "^3.2.4"
   },
   "files": [

readme.md

@@ -21,7 +21,6 @@ Code Style | [![Code Style](https://badgen.net/badge/style/prettier/purple)](htt
 PackagePhobia (total standalone install weight) | [![PackagePhobia](https://badgen.net/packagephobia/install/@pushrocks/lik)](https://lossless.cloud)
 PackagePhobia (package size on registry) | [![PackagePhobia](https://badgen.net/packagephobia/publish/@pushrocks/lik)](https://lossless.cloud)
 BundlePhobia (total size when bundled) | [![BundlePhobia](https://badgen.net/bundlephobia/minzip/@pushrocks/lik)](https://lossless.cloud)
-Platform support | [![Supports Windows 10](https://badgen.net/badge/supports%20Windows%2010/yes/green?icon=windows)](https://lossless.cloud) [![Supports Mac OS X](https://badgen.net/badge/supports%20Mac%20OS%20X/yes/green?icon=apple)](https://lossless.cloud)
 
 ## Usage
 
@@ -48,7 +47,6 @@ We are always happy for code contributions. If you are not the code contributing
 
 For further information read the linked docs at the top of this readme.
 
-> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
+## Legal
+> MIT licensed | **©** [Task Venture Capital GmbH](https://task.vc)
 | By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy)
-
-[![repo-footer](https://lossless.gitlab.io/publicrelations/repofooter.svg)](https://maintainedby.lossless.com)

test/test.asyncexecutionstack.both.ts

@@ -0,0 +1,29 @@
+import { tap, expect } from '@pushrocks/tapbundle';
+import * as lik from '../ts/index.js';
+
+let testAsyncExecutionStack: lik.AsyncExecutionStack;
+
+tap.test('should create a valid instance of AsyncExectionStack', async () => {
+  testAsyncExecutionStack = new lik.AsyncExecutionStack();
+  expect(testAsyncExecutionStack).toBeInstanceOf(lik.AsyncExecutionStack);
+});
+
+tap.test('should run in parallel', async (toolsArg) => {
+  await testAsyncExecutionStack.getExclusiveExecutionSlot(async () => {
+    await toolsArg.delayFor(2000);
+    console.log('should run first');
+  }, 2500);
+  testAsyncExecutionStack.getNonExclusiveExecutionSlot(async () => {
+    await toolsArg.delayFor(2000);
+    console.log('should run third');
+  }, 2500);
+  testAsyncExecutionStack.getNonExclusiveExecutionSlot(async () => {
+    await toolsArg.delayFor(1000);
+    console.log('should run second');
+  }, 2500);
+  await testAsyncExecutionStack.getExclusiveExecutionSlot(async () => {
+    console.log('should run fourth');
+  }, 0);
+});
+
+tap.start();

test/test.fastmap.both.ts

@@ -0,0 +1,30 @@
+import { tap, expect } from '@pushrocks/tapbundle';
+
+import * as lik from '../ts/index.js';
+
+tap.test('should create a valid fastmap', async () => {
+  const fastmap = new lik.FastMap();
+  expect(fastmap).toBeInstanceOf(lik.FastMap);
+});
+
+tap.test('should find an entry', async () => {
+  const fastmap = new lik.FastMap<{
+    value1: string;
+    value2: string;
+  }>();
+  fastmap.addToMap('heythere', {
+    value1: 'heyho',
+    value2: 'heyho2',
+  });
+  fastmap.addToMap('heythere2', {
+    value1: 'heyho3',
+    value2: 'heyho4',
+  });
+
+  const result = await fastmap.find(async (itemArg) => {
+    return itemArg.value2 === 'heyho4';
+  });
+  expect(result.value1).toEqual('heyho3');
+});
+
+tap.start();

test/test.interestmap.both.ts

@@ -1,5 +1,5 @@
 import { tap, expect } from '@pushrocks/tapbundle';
-import * as lik from '../ts/index';
+import * as lik from '../ts/index.js';
 
 let testInterestmap: lik.InterestMap<number, number>;
 

test/test.limitedarray.both.ts

@@ -1,17 +1,17 @@
 import { tap, expect } from '@pushrocks/tapbundle';
 
-import { LimitedArray } from '../ts/index';
+import { LimitedArray } from '../ts/index.js';
 
 let testLimitedArray: LimitedArray<string>;
 
 tap.test('should create a LimitedArray', async () => {
   testLimitedArray = new LimitedArray(6);
-  expect(testLimitedArray).to.be.instanceof(LimitedArray);
+  expect(testLimitedArray).toBeInstanceOf(LimitedArray);
 });
 
 tap.test('should never be longer than the set length', async () => {
   testLimitedArray.addMany(['hi', 'this', 'is', 'quite', 'a', 'long', 'string', ':)']);
-  expect(testLimitedArray.array.length).to.be.lessThan(7);
+  expect(testLimitedArray.array.length < 7).toBeTrue();
 });
 
 tap.start();

test/test.looptracker.both.ts

@@ -1,10 +1,8 @@
 // import test framework
 import { expect, tap } from '@pushrocks/tapbundle';
-import * as events from 'events';
-import * as smartpromise from '@pushrocks/smartpromise';
 
 // import the module
-import * as lik from '../ts/index';
+import * as lik from '../ts/index.js';
 
 let object1 = {};
 let object2 = {};
@@ -13,14 +11,14 @@ let myLoopTracker: lik.LoopTracker<any>;
 // tests
 tap.test('should create a valid looptracker instance', async () => {
   myLoopTracker = new lik.LoopTracker();
-  expect(myLoopTracker).to.be.instanceof(lik.LoopTracker);
+  expect(myLoopTracker).toBeInstanceOf(lik.LoopTracker);
 });
 
 tap.test('should add objects once and return true', async () => {
-  expect(myLoopTracker.checkAndTrack(object1)).to.be.true;
+  expect(myLoopTracker.checkAndTrack(object1)).toBeTrue();
-  expect(myLoopTracker.checkAndTrack(object1)).to.be.false;
+  expect(myLoopTracker.checkAndTrack(object1)).toBeFalse();
-  expect(myLoopTracker.checkAndTrack(object2)).to.be.true;
+  expect(myLoopTracker.checkAndTrack(object2)).toBeTrue();
-  expect(myLoopTracker.checkAndTrack(object2)).to.be.false;
+  expect(myLoopTracker.checkAndTrack(object2)).toBeFalse();
 });
 
 tap.start();

test/test.objectmap.both.ts

@@ -1,10 +1,8 @@
 // import test framework
 import { expect, tap } from '@pushrocks/tapbundle';
-import * as events from 'events';
-import * as smartpromise from '@pushrocks/smartpromise';
 
 // import the module
-import * as lik from '../ts/index';
+import * as lik from '../ts/index.js';
 
 // Objectmap
 interface ITestObject {
@@ -23,56 +21,56 @@ let testObject2: ITestObject = {
 
 tap.test('new lik.Objectmap() -> should correctly instantiate an Objectmap', async () => {
   testObjectmap = new lik.ObjectMap<ITestObject>();
-  expect(testObjectmap).be.instanceof(lik.ObjectMap);
+  expect(testObjectmap).toBeInstanceOf(lik.ObjectMap);
 });
 
 tap.test('lik.Objectmap.add() -> should correctly add an object to Objectmap', async () => {
   testObjectmap.add(testObject1);
   // tslint:disable-next-line:no-unused-expression
-  expect(testObjectmap.checkForObject(testObject1)).be.true;
+  expect(testObjectmap.checkForObject(testObject1)).toBeTrue();
   // tslint:disable-next-line:no-unused-expression
-  expect(testObjectmap.checkForObject(testObject2)).be.false;
+  expect(testObjectmap.checkForObject(testObject2)).toBeFalse();
 });
 
 tap.test('lik.Objectmap.remove() -> should correctly remove an object to Objectmap', async () => {
   testObjectmap.add(testObject2);
   testObjectmap.remove(testObject1);
   // tslint:disable-next-line:no-unused-expression
-  expect(testObjectmap.checkForObject(testObject1)).be.false;
+  expect(testObjectmap.checkForObject(testObject1)).toBeFalse();
   // tslint:disable-next-line:no-unused-expression
-  expect(testObjectmap.checkForObject(testObject2)).be.true;
+  expect(testObjectmap.checkForObject(testObject2)).toBeTrue();
 });
 
 tap.test('Objectmap.forEach -> should correctly run a function forEach map object', async () => {
   testObjectmap.forEach((itemArg) => {
-    expect(itemArg).to.have.property('propOne');
+    expect(itemArg).toHaveProperty('propOne');
   });
 });
 
 tap.test('lik.Objectmap.find() -> should correctly find an object', async () => {
   let myObject = { propOne: 'helloThere', propTwo: 'helloAnyway' };
   testObjectmap.add(myObject);
-  let referenceObject = testObjectmap.find((itemArg) => {
+  let referenceObject = await testObjectmap.find(async (itemArg) => {
     return itemArg.propOne === 'helloThere';
   });
   // tslint:disable-next-line:no-unused-expression
-  expect(myObject === referenceObject).be.true;
+  expect(myObject === referenceObject).toBeTrue();
 });
 
 tap.test('lik.Objectmap.getArray() -> should return a cloned array', async () => {
   let myObject = { propOne: 'test1', propTwo: 'wow, how awesome' };
   testObjectmap.add(myObject);
   let clonedArray = testObjectmap.getArray();
-  expect(clonedArray[clonedArray.length - 1]).to.eql(myObject);
+  expect(clonedArray[clonedArray.length - 1]).toEqual(myObject);
 });
 
 tap.test('should get one object and then remove it', async () => {
   let originalLength = testObjectmap.getArray().length;
   let oneObject = testObjectmap.getOneAndRemove();
   // tslint:disable-next-line:no-unused-expression
-  expect(oneObject).not.be.null;
+  expect(oneObject).not.toBeNull();
-  expect(testObjectmap.getArray().length).equal(originalLength - 1);
+  expect(testObjectmap.getArray().length).toEqual(originalLength - 1);
-  expect(testObjectmap.getArray()).to.not.contain(oneObject);
+  expect(testObjectmap.getArray()).not.toContain(oneObject);
 });
 
 tap.start();

test/test.stringmap.both.ts

@@ -1,10 +1,8 @@
 // import test framework
 import { expect, tap } from '@pushrocks/tapbundle';
-import * as events from 'events';
-import * as smartpromise from '@pushrocks/smartpromise';
 
 // import the module
-import * as lik from '../ts/index';
+import * as lik from '../ts/index.js';
 
 // testData
 let testStringmap: lik.Stringmap;
@@ -18,14 +16,14 @@ let testString6 = 'testString6';
 // tests
 tap.test('new lik.Objectmap() -> should create an instance of Stringmap', async () => {
   testStringmap = new lik.Stringmap();
-  expect(testStringmap).be.instanceof(lik.Stringmap);
+  expect(testStringmap).toBeInstanceOf(lik.Stringmap);
 });
 
 tap.test(
   'lik.Stringmap.checkString -> should return false for an string not in Stringmap',
   async () => {
     // tslint:disable-next-line:no-unused-expression
-    expect(testStringmap.checkString(testString1)).be.false;
+    expect(testStringmap.checkString(testString1)).toBeFalse();
   }
 );
 
@@ -34,37 +32,37 @@ tap.test('lik.Stringmap.addString -> should add an string to Stringmap', async (
   testStringmap.addString(testString2);
   testStringmap.addString(testString3);
   // tslint:disable-next-line:no-unused-expression
-  expect(testStringmap.checkString(testString1)).be.true;
+  expect(testStringmap.checkString(testString1)).toBeTrue();
   // tslint:disable-next-line:no-unused-expression
-  expect(testStringmap.checkString(testString2)).be.true;
+  expect(testStringmap.checkString(testString2)).toBeTrue();
   // tslint:disable-next-line:no-unused-expression
-  expect(testStringmap.checkString(testString3)).be.true;
+  expect(testStringmap.checkString(testString3)).toBeTrue();
   // tslint:disable-next-line:no-unused-expression
-  expect(testStringmap.checkMinimatch('*String1')).be.true;
+  expect(testStringmap.checkMinimatch('*String1')).toBeTrue();
   // tslint:disable-next-line:no-unused-expression
-  expect(testStringmap.checkMinimatch('*String2')).be.true;
+  expect(testStringmap.checkMinimatch('*String2')).toBeTrue();
   // tslint:disable-next-line:no-unused-expression
-  expect(testStringmap.checkMinimatch('*String4')).be.false;
+  expect(testStringmap.checkMinimatch('*String4')).toBeFalse();
 });
 
 tap.test('lik.Stringmap.addStringArray -> should add an array of strings', async () => {
   testStringmap.addStringArray([testString4, testString5, testString6]);
   // tslint:disable-next-line:no-unused-expression
-  expect(testStringmap.checkMinimatch('*String4')).be.true;
+  expect(testStringmap.checkMinimatch('*String4')).toBeTrue();
 });
 
 tap.test('lik.Stringmap.removeString -> should remove a string from Stringmap', async () => {
   testStringmap.removeString(testString2);
   // tslint:disable-next-line:no-unused-expression
-  expect(testStringmap.checkString(testString2)).be.false;
+  expect(testStringmap.checkString(testString2)).toBeFalse();
 });
 
 tap.test('lik.Stringmap.getStringArray() -> should return a copy of stringArray', async () => {
   let clonedArray = testStringmap.getStringArray();
   // tslint:disable-next-line:no-unused-expression
-  expect(clonedArray[0] === 'testString1').be.true;
+  expect(clonedArray[0] === 'testString1').toBeTrue();
   // tslint:disable-next-line:no-unused-expression
-  expect(clonedArray[0] === testString1).be.true;
+  expect(clonedArray[0] === testString1).toBeTrue();
 });
 
 tap.test(

test/test.timedaggregator.both.ts

@@ -1,10 +1,8 @@
 // import test framework
 import { expect, tap } from '@pushrocks/tapbundle';
-import * as events from 'events';
-import * as smartpromise from '@pushrocks/smartpromise';
 
 // import the module
-import * as lik from '../ts/index';
+import * as lik from '../ts/index.js';
 
 let testTimedAggregator: lik.TimedAggregtor<string>;
 

test/test.tree.both.ts

@@ -1,5 +1,5 @@
 import { tap, expect } from '@pushrocks/tapbundle';
-import * as lik from '../ts/index';
+import * as lik from '../ts/index.js';
 
 class TestClass {
   constructor(public hey: string) {
@@ -18,13 +18,13 @@ let testInstance6 = new TestClass('sixth');
 
 tap.test('create a valid tree instance', async () => {
   testTree = new lik.Tree();
-  expect(testTree).to.be.instanceOf(lik.Tree);
+  expect(testTree).toBeInstanceOf(lik.Tree);
 });
 
 tap.test('should insert an object', async () => {
   testTree.initialize(testInstance);
   let resultArray = testTree.treeToArray(testInstance, {});
-  expect(resultArray).to.contain(testInstance);
+  expect(resultArray).toContain(testInstance);
 });
 
 tap.test('should add other objects in a hierachy', async () => {

ts/00_commitinfo_data.ts

@@ -0,0 +1,8 @@
+/**
+ * autocreated commitinfo by @pushrocks/commitinfo
+ */
+export const commitinfo = {
+  name: '@pushrocks/lik',
+  version: '6.0.2',
+  description: 'light little helpers for node'
+}

ts/index.ts

@@ -1,9 +1,10 @@
-export * from './lik.fastmap';
+export * from './lik.asyncexecutionstack.js';
-export * from './lik.interestmap';
+export * from './lik.fastmap.js';
-export * from './lik.interestmap.interest';
+export * from './lik.interestmap.js';
-export * from './lik.limitedarray';
+export * from './lik.interestmap.interest.js';
-export * from './lik.looptracker';
+export * from './lik.limitedarray.js';
-export * from './lik.objectmap';
+export * from './lik.looptracker.js';
-export * from './lik.stringmap';
+export * from './lik.objectmap.js';
-export * from './lik.timedaggregator';
+export * from './lik.stringmap.js';
-export * from './lik.tree';
+export * from './lik.timedaggregator.js';
+export * from './lik.tree.js';

ts/lik.asyncexecutionstack.ts

@@ -0,0 +1,82 @@
+import * as plugins from './lik.plugins.js';
+
+interface IExecutionSlot<T> {
+  executionDeferred: plugins.smartpromise.Deferred<T>;
+  funcToExecute: () => Promise<T>;
+  timeout?: number;
+  mode: 'exclusive' | 'nonexclusive';
+}
+
+/**
+ * allows for avoiding race condition
+ */
+export class AsyncExecutionStack {
+  private executionSlots: IExecutionSlot<any>[] = [];
+  public async getExclusiveExecutionSlot<T = any>(funcArg: () => Promise<T>, timeoutArg?: number) {
+    const executionDeferred = plugins.smartpromise.defer<T>();
+    const executionSlot: IExecutionSlot<T> = {
+      funcToExecute: funcArg,
+      executionDeferred,
+      timeout: timeoutArg,
+      mode: 'exclusive',
+    };
+    this.executionSlots.push(executionSlot);
+    this.processExecutionSlots();
+    return executionDeferred.promise;
+  }
+  public async getNonExclusiveExecutionSlot<T = any>(
+    funcArg: () => Promise<T>,
+    timeoutArg?: number
+  ) {
+    const executionDeferred = plugins.smartpromise.defer<T>();
+    const executionSlot: IExecutionSlot<T> = {
+      funcToExecute: funcArg,
+      executionDeferred,
+      timeout: timeoutArg,
+      mode: 'nonexclusive',
+    };
+    this.executionSlots.push(executionSlot);
+    this.processExecutionSlots();
+    return executionDeferred.promise;
+  }
+
+  private currentlyExecutingDeferred: plugins.smartpromise.Deferred<any>;
+  private async processExecutionSlots() {
+    if (this.currentlyExecutingDeferred) {
+      return;
+    }
+    this.currentlyExecutingDeferred = plugins.smartpromise.defer();
+    let nonExclusiveRunningSlots: IExecutionSlot<any>[] = [];
+    const checkNonExclusiveRunningSlots = async (cleanArg = false) => {
+      if (nonExclusiveRunningSlots.length > 100 || cleanArg) {
+        await Promise.all(nonExclusiveRunningSlots.map(nonExclusiveRunningSlotArg => nonExclusiveRunningSlotArg.executionDeferred.promise));
+        nonExclusiveRunningSlots = [];
+      }
+    };
+    while (this.executionSlots.length > 0) {
+      const nextExecutionSlot = this.executionSlots.shift();
+      const runNextExecution = async () => {
+        if (nextExecutionSlot.timeout) {
+          const result = await Promise.race([
+            nextExecutionSlot.funcToExecute(),
+            plugins.smartdelay.delayFor(nextExecutionSlot.timeout),
+          ]);
+          nextExecutionSlot.executionDeferred.resolve(result);
+        } else {
+          nextExecutionSlot.executionDeferred.resolve(await nextExecutionSlot.funcToExecute());
+        }
+      };
+      if (nextExecutionSlot.mode === 'exclusive') {
+        await checkNonExclusiveRunningSlots(true);
+        await runNextExecution();
+      } else {
+        nonExclusiveRunningSlots.push(nextExecutionSlot);
+        await checkNonExclusiveRunningSlots(false);
+        runNextExecution();
+      }
+    }
+    this.currentlyExecutingDeferred.resolve();
+    this.currentlyExecutingDeferred = null;
+    
+  }
+}

ts/lik.fastmap.ts

@@ -1,4 +1,9 @@
-import * as plugins from './lik.plugins';
+/* ============
+The FastMap has the goal of creating the fastes to use map possible in JS
+
+============ */
+
+import * as plugins from './lik.plugins.js';
 
 /**
  * fast map allows for very quick lookups of objects with a unique key
@@ -29,7 +34,7 @@ export class FastMap<T> {
     return this.mapObject[keyArg];
   }
 
-  public removeFromMap(keyArg): T {
+  public removeFromMap(keyArg: string): T {
     const removedItem = this.getByKey(keyArg);
     delete this.mapObject[keyArg];
     return removedItem;
@@ -50,7 +55,7 @@ export class FastMap<T> {
   }
 
   /**
-   * returns a new Objectmap that includes
+   * returns a new Fastmap that includes all values from this and all from the fastmap in the argument
    */
   public concat(fastMapArg: FastMap<T>) {
     const concatedFastmap = new FastMap<T>();
@@ -68,9 +73,9 @@ export class FastMap<T> {
   }
 
   /**
-   * tries to merge another Objectmap
+   * tries to merge another Fastmap
    * Note: uniqueKeyCollisions will cause overwrite
-   * @param objectMapArg
+   * @param fastMapArg
    */
   public addAllFromOther(fastMapArg: FastMap<T>) {
     for (const key of fastMapArg.getKeys()) {
@@ -79,4 +84,14 @@ export class FastMap<T> {
       });
     }
   }
+
+  public async find(findFunctionArg: (mapItemArg: T) => Promise<boolean>) {
+    for (const key of this.getKeys()) {
+      const item = this.getByKey(key);
+      const findFunctionResult = await findFunctionArg(item);
+      if (findFunctionResult) {
+        return item;
+      }
+    }
+  }
 }

ts/lik.interestmap.interest.ts

@@ -1,6 +1,6 @@
-import * as plugins from './lik.plugins';
+import * as plugins from './lik.plugins.js';
 
-import { InterestMap, IInterestComparisonFunc } from './lik.interestmap';
+import { InterestMap, IInterestComparisonFunc } from './lik.interestmap.js';
 
 export interface IInterestOptions<DTInterestFullfillment> {
   markLostAfterDefault: number;
@@ -28,9 +28,8 @@ export class Interest<DTInterestId, DTInterestFullfillment> {
     return this.comparisonFunc(this.originalInterest);
   }
 
-  private interestDeferred: plugins.smartpromise.Deferred<
+  private interestDeferred: plugins.smartpromise.Deferred<DTInterestFullfillment> =
-    DTInterestFullfillment
+    new plugins.smartpromise.Deferred();
-  > = new plugins.smartpromise.Deferred();
   public interestFullfilled = this.interestDeferred.promise;
 
   /**

ts/lik.interestmap.ts

@@ -1,9 +1,16 @@
-import * as plugins from './lik.plugins';
+/* ===========
-import { ObjectMap } from './lik.objectmap';
+The InterestMap is an mechanism that collects interests into something
+An interest is expressed by an object, string or number.
+A comparison func can be specified to make interests comparable
 
-import { Observable } from 'rxjs';
+For every unique interestId an interest is created.
+Subssequent interests will be mapped to the same interest
+which is then is only fullfilled once.
+=========== */
 
-import { Interest } from './lik.interestmap.interest';
+import * as plugins from './lik.plugins.js';
+import { ObjectMap } from './lik.objectmap.js';
+import { Interest } from './lik.interestmap.interest.js';
 
 export type IInterestComparisonFunc<T> = (objectArg: T) => string;
 
@@ -34,17 +41,17 @@ export class InterestMap<DTInterestId, DTInterestFullfillment> {
 
   /**
    * adds an interest to the InterestMap
-   * @param objectArg
+   * @param interestId
    */
   public async addInterest(
-    objectArg: DTInterestId,
+    interestId: DTInterestId,
     defaultFullfillmentArg?: DTInterestFullfillment
   ): Promise<Interest<DTInterestId, DTInterestFullfillment>> {
-    const comparisonString = this.comparisonFunc(objectArg);
+    const comparisonString = this.comparisonFunc(interestId);
     let returnInterest: Interest<DTInterestId, DTInterestFullfillment>;
     const newInterest = new Interest<DTInterestId, DTInterestFullfillment>(
       this,
-      objectArg,
+      interestId,
       this.comparisonFunc,
       {
         markLostAfterDefault: this.options.markLostAfterDefault,
@@ -68,15 +75,13 @@ export class InterestMap<DTInterestId, DTInterestFullfillment> {
     return returnInterest;
   }
 
-  // tslint:disable-next-line:member-ordering
   public interestObservable = new plugins.smartrx.ObservableIntake<Interest<DTInterestId, any>>();
 
   /**
    * removes an interest from the interest map
-   * @param objectArg removes an interest from the InterestMap
    */
   public removeInterest(interestArg: Interest<DTInterestId, DTInterestFullfillment>) {
-    const interestToRemove = this.interestObjectMap.findOneAndRemove((interestArg2) => {
+    const interestToRemove = this.interestObjectMap.findOneAndRemoveSync((interestArg2) => {
       return interestArg.comparisonString === interestArg2.comparisonString;
     });
   }
@@ -94,7 +99,7 @@ export class InterestMap<DTInterestId, DTInterestFullfillment> {
    * @param comparisonStringArg
    */
   public checkInterestByString(comparisonStringArg: string): boolean {
-    const foundInterest = this.interestObjectMap.find((interest) => {
+    const foundInterest = this.interestObjectMap.findSync((interest) => {
       return interest.comparisonString === comparisonStringArg;
     });
     if (foundInterest) {
@@ -117,11 +122,11 @@ export class InterestMap<DTInterestId, DTInterestFullfillment> {
 
   /**
    * finds an interest
-   * @param objectArg
+   * @param interestId
    */
-  public findInterest(objectArg: DTInterestId): Interest<DTInterestId, DTInterestFullfillment> {
+  public findInterest(interestId: DTInterestId): Interest<DTInterestId, DTInterestFullfillment> {
-    const comparableString = this.comparisonFunc(objectArg);
+    const comparableString = this.comparisonFunc(interestId);
-    const interest = this.interestObjectMap.find((interestArg) => {
+    const interest = this.interestObjectMap.findSync((interestArg) => {
       return interestArg.comparisonString === comparableString;
     });
     return interest; // if an interest is found, the interest is returned, otherwise interest is null

ts/lik.limitedarray.ts

@@ -1,4 +1,4 @@
-import * as plugins from './lik.plugins';
+import * as plugins from './lik.plugins.js';
 
 export class LimitedArray<T> {
   array: T[] = [];

ts/lik.looptracker.ts

@@ -1,6 +1,6 @@
-import * as plugins from './lik.plugins';
+import * as plugins from './lik.plugins.js';
 
-import { ObjectMap } from './lik.objectmap';
+import { ObjectMap } from './lik.objectmap.js';
 
 export class LoopTracker<T> {
   referenceObjectMap = new ObjectMap<any>();

ts/lik.objectmap.ts

@@ -1,5 +1,5 @@
-import * as plugins from './lik.plugins';
+import * as plugins from './lik.plugins.js';
-import { FastMap } from './lik.fastmap';
+import { FastMap } from './lik.fastmap.js';
 
 export const uni = (prefix: string = 'uni') => {
   return `${prefix}xxxxxxxxxxx`.replace(/[xy]/g, (c) => {
@@ -13,10 +13,19 @@ export interface IObjectmapForEachFunction<T> {
   (itemArg: T): void;
 }
 
-export interface IObjectmapFindFunction<T> {
+export interface IObjectmapFindFunctionSync<T> {
   (itemArg: T): boolean;
 }
 
+export interface IObjectmapFindFunction<T> {
+  (itemArg: T): Promise<boolean>;
+}
+
+export interface IObjectMapEventData<T> {
+  operation: 'add' | 'remove';
+  payload: T;
+}
+
 /**
  * allows keeping track of objects
  */
@@ -24,7 +33,7 @@ export class ObjectMap<T> {
   private fastMap = new FastMap<T>();
 
   // events
-  public eventSubject = new plugins.smartrx.rxjs.Subject<any>();
+  public eventSubject = new plugins.smartrx.rxjs.Subject<IObjectMapEventData<T>>();
 
   /**
    * returns a new instance
@@ -57,8 +66,6 @@ export class ObjectMap<T> {
     const object = this.getMappedUnique(uniqueKey);
   }
 
-  public addSubject = new plugins.smartrx.rxjs.Subject<T>();
-
   /**
    * add object to Objectmap
    * returns false if the object is already in the map
@@ -76,7 +83,10 @@ export class ObjectMap<T> {
     // otherwise lets create it
     const uniqueKey = uni('key');
     this.addMappedUnique(uniqueKey, objectArg);
-    this.addSubject.next(objectArg);
+    this.eventSubject.next({
+      operation: 'add',
+      payload: objectArg,
+    });
     return uniqueKey;
   }
 
@@ -115,7 +125,11 @@ export class ObjectMap<T> {
   /**
    * find object
    */
-  public find(findFunction: IObjectmapFindFunction<T>): T {
+  public async find(findFunction: IObjectmapFindFunction<T>): Promise<T> {
+    return this.fastMap.find(findFunction);
+  }
+
+  public findSync(findFunction: IObjectmapFindFunctionSync<T>): T {
     for (const keyArg of this.fastMap.getKeys()) {
       if (findFunction(this.fastMap.getByKey(keyArg))) {
         return this.getMappedUnique(keyArg);
@@ -126,8 +140,15 @@ export class ObjectMap<T> {
   /**
    * finds a specific element and then removes it
    */
-  public findOneAndRemove(findFunction: IObjectmapFindFunction<T>): T {
+  public async findOneAndRemove(findFunction: IObjectmapFindFunction<T>): Promise<T> {
-    const foundElement = this.find(findFunction);
+    const foundElement = await this.find(findFunction);
+    if (foundElement) {
+      this.remove(foundElement);
+    }
+    return foundElement;
+  }
+  public findOneAndRemoveSync(findFunction: IObjectmapFindFunctionSync<T>): T {
+    const foundElement = this.findSync(findFunction);
     if (foundElement) {
       this.remove(foundElement);
     }
@@ -153,7 +174,10 @@ export class ObjectMap<T> {
     } else {
       const keyToUse = keys[0];
       const removedItem = this.fastMap.removeFromMap(keyToUse);
-      this.eventSubject.next('remove');
+      this.eventSubject.next({
+        operation: 'remove',
+        payload: removedItem,
+      });
       return removedItem;
     }
   }
@@ -183,7 +207,10 @@ export class ObjectMap<T> {
     if (this.checkForObject(objectArg)) {
       const keyArg = this.getKeyForObject(objectArg);
       const removedObject = this.fastMap.removeFromMap(keyArg);
-      this.eventSubject.next('remove');
+      this.eventSubject.next({
+        operation: 'remove',
+        payload: removedObject,
+      });
       return removedObject;
     }
     return null;

ts/lik.plugins.ts

@@ -12,6 +12,6 @@ export { smartdelay, smartmatch, smartpromise, smartrx, smarttime };
 // ==============
 // third party
 // ==============
-const symbolTree = require('symbol-tree');
+import symbolTree from 'symbol-tree';
 
 export { symbolTree };

ts/lik.stringmap.ts

@@ -1,4 +1,4 @@
-import * as plugins from './lik.plugins';
+import * as plugins from './lik.plugins.js';
 
 /**
  * allows you to easily keep track of a bunch of strings

ts/lik.timedaggregator.ts

@@ -1,4 +1,4 @@
-import * as plugins from './lik.plugins';
+import * as plugins from './lik.plugins.js';
 
 export interface ITimedAggregatorOptions<T> {
   aggregationIntervalInMillis: number;

ts/lik.tree.ts

@@ -1,4 +1,4 @@
-import * as plugins from './lik.plugins';
+import * as plugins from './lik.plugins.js';
 
 export class Tree<T> {
   symbolTree: any;
@@ -62,15 +62,15 @@ export class Tree<T> {
     return this.symbolTree.ancestorsToArray(objectArg, optionsArg);
   }
 
-  treeToArray(rootArg, optionsArg: any): T[] {
+  treeToArray(rootArg: T, optionsArg: any): T[] {
     return this.symbolTree.treeToArray(rootArg, optionsArg);
   }
 
-  childrenIterator(parentArg: T, optionsArg): T {
+  childrenIterator(parentArg: T, optionsArg: any): T {
     return this.symbolTree.childrenIterator(parentArg, optionsArg);
   }
 
-  previousSiblingsIterator(objectArg): T {
+  previousSiblingsIterator(objectArg: T): T {
     return this.symbolTree.previousSiblingsIterator(objectArg);
   }
 
@@ -78,11 +78,11 @@ export class Tree<T> {
     return this.symbolTree.nextSiblingsIterator();
   }
 
-  ancestorsIterator(objectArg) {
+  ancestorsIterator(objectArg: T) {
     this.symbolTree.ancestorsIterator();
   }
 
-  treeIterator(rootArg: T, optionsArg): Iterable<T> {
+  treeIterator(rootArg: T, optionsArg: any): Iterable<T> {
     return this.symbolTree.treeIterator(rootArg);
   }
 
@@ -114,7 +114,7 @@ export class Tree<T> {
     return this.symbolTree.prependChild(referenceObjectArg, newObjectArg);
   }
 
-  appendChild(referenceObjectArg, newObjectArg) {
+  appendChild(referenceObjectArg: T, newObjectArg: T) {
     return this.symbolTree.appendChild(referenceObjectArg, newObjectArg);
   }
 
@@ -126,7 +126,7 @@ export class Tree<T> {
    * returns a branch of the tree as JSON
    * can be user
    */
-  toJsonWithHierachy(rootElement) {
+  toJsonWithHierachy(rootElement: T) {
     const treeIterable = this.treeIterator(rootElement, {});
     for (const treeItem of treeIterable) {
       console.log(treeItem);
@@ -137,5 +137,5 @@ export class Tree<T> {
    * builds a tree from a JSON with hierachy
    * @param rootElement
    */
-  fromJsonWithHierachy(rootElement) {}
+  fromJsonWithHierachy(rootElement: T) {}
 }

tsconfig.json

@@ -0,0 +1,10 @@
+{
+  "compilerOptions": {
+    "experimentalDecorators": true,
+    "useDefineForClassFields": false,
+    "target": "ES2022",
+    "module": "ES2022",
+    "moduleResolution": "nodenext",
+    "esModuleInterop": true
+  }
+}

tslint.json

@@ -1,17 +0,0 @@
-{
-  "extends": ["tslint:latest", "tslint-config-prettier"],
-  "rules": {
-    "semicolon": [true, "always"],
-    "no-console": false,
-    "ordered-imports": false,
-    "object-literal-sort-keys": false,
-    "member-ordering": {
-      "options":{
-        "order": [
-          "static-method"
-        ]
-      }
-    }
-  },
-  "defaultSeverity": "warning"
-}