Compare commits
115 Commits
Author | SHA1 | Date | |
---|---|---|---|
8ec54c17a1 | |||
500a291b2a | |||
256a14fcb0 | |||
7aa0f05bae | |||
6208cab36a | |||
50a9697baf | |||
7956cf6ace | |||
d8956d4e32 | |||
c93a67c351 | |||
fafd9867ad | |||
2dfa96bbc5 | |||
a7484e791a | |||
2dba68df8c | |||
6aff4c9031 | |||
e81e0ebd41 | |||
18866b9a05 | |||
71b12b2d9c | |||
0669fc3779 | |||
7021f8f1ae | |||
2392915959 | |||
b8100f8dfc | |||
04e9d8be77 | |||
a9715381c1 | |||
c2f081d69a | |||
b98f075cbd | |||
5ff74aea88 | |||
a6eaf78c80 | |||
adda1c932a | |||
7c8643b090 | |||
9e81960095 | |||
a76832bedb | |||
3c229e8e26 | |||
29d6f2d7e0 | |||
2b5ff6a4ab | |||
c75437e73f | |||
61e4a62689 | |||
d53f5410cd | |||
53516b1c8f | |||
e59205490b | |||
38884ff59c | |||
861833e930 | |||
1274840d17 | |||
d2ce1094de | |||
6b3fcff971 | |||
011a865271 | |||
78914e54b3 | |||
281cfdc38a | |||
217252de1e | |||
ab7f7230ef | |||
7f03ae5248 | |||
0060ec2971 | |||
eec89a596a | |||
d34a91d283 | |||
db14306bcf | |||
cf446f90ee | |||
9c2f3cf678 | |||
18df32ae5a | |||
66b6e78bb1 | |||
408faa97a4 | |||
4a7749be47 | |||
570283551f | |||
c6c5c5ea40 | |||
ddd071ccb6 | |||
8b9c87d381 | |||
89ea1fdb18 | |||
5b2aea7626 | |||
cfbc47e365 | |||
bb3b02ed74 | |||
bb4820e980 | |||
fa17a998f1 | |||
afad357ed0 | |||
59173eebc4 | |||
515571dcb3 | |||
177ed2d03d | |||
23ecaddd5a | |||
924058c90a | |||
30e23a77b7 | |||
b228c3b2f0 | |||
610a037879 | |||
2f681911ae | |||
3b04f81b68 | |||
0c05cf4f7b | |||
5451cceaf3 | |||
04dbc36525 | |||
a820e0d1b3 | |||
57c67a287a | |||
d73bfa8f00 | |||
e917c8b9f7 | |||
c0a5cb6e30 | |||
b85e79b07d | |||
ba714fe637 | |||
3dd4698ce8 | |||
9814e93dda | |||
5d06e6e78f | |||
f6c03275f4 | |||
d6ca9910e3 | |||
ac2267d910 | |||
49f0d7018d | |||
009a1181e5 | |||
3c09f048a2 | |||
1bdcae0524 | |||
62892fa1b8 | |||
fc96e1e2da | |||
fe552763fe | |||
c544fc8e3a | |||
9d856ad813 | |||
24b260c3da | |||
e3a811bffd | |||
95fe1f7937 | |||
e2aee98acc | |||
2705b17dde | |||
5c6728a671 | |||
6d22ee466f | |||
24df2fd54f | |||
db55a46d8e |
24
.gitignore
vendored
24
.gitignore
vendored
@ -1,4 +1,22 @@
|
|||||||
node_modules/
|
|
||||||
docs/
|
|
||||||
coverage/
|
|
||||||
.nogit/
|
.nogit/
|
||||||
|
|
||||||
|
# artifacts
|
||||||
|
coverage/
|
||||||
|
public/
|
||||||
|
pages/
|
||||||
|
|
||||||
|
# installs
|
||||||
|
node_modules/
|
||||||
|
|
||||||
|
# caches
|
||||||
|
.yarn/
|
||||||
|
.cache/
|
||||||
|
.rpt2_cache
|
||||||
|
|
||||||
|
# builds
|
||||||
|
dist/
|
||||||
|
dist_web/
|
||||||
|
dist_serve/
|
||||||
|
dist_ts_web/
|
||||||
|
|
||||||
|
# custom
|
101
.gitlab-ci.yml
101
.gitlab-ci.yml
@ -1,36 +1,119 @@
|
|||||||
image: hosttoday/ht-docker-node:npmts
|
# gitzone ci_default
|
||||||
|
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
||||||
|
|
||||||
|
cache:
|
||||||
|
paths:
|
||||||
|
- .npmci_cache/
|
||||||
|
key: "$CI_BUILD_STAGE"
|
||||||
|
|
||||||
stages:
|
stages:
|
||||||
|
- security
|
||||||
- test
|
- test
|
||||||
- release
|
- release
|
||||||
|
- metadata
|
||||||
|
|
||||||
testLEGACY:
|
# ====================
|
||||||
stage: test
|
# security stage
|
||||||
|
# ====================
|
||||||
|
mirror:
|
||||||
|
stage: security
|
||||||
script:
|
script:
|
||||||
- npmci test legacy
|
- npmci git mirror
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
|
snyk:
|
||||||
|
stage: security
|
||||||
|
script:
|
||||||
|
- npmci npm prepare
|
||||||
|
- npmci command npm install -g snyk
|
||||||
|
- npmci command npm install --ignore-scripts
|
||||||
|
- npmci command snyk test
|
||||||
|
tags:
|
||||||
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
|
# ====================
|
||||||
|
# test stage
|
||||||
|
# ====================
|
||||||
|
|
||||||
testLTS:
|
testLTS:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
- npmci test lts
|
- npmci npm prepare
|
||||||
|
- npmci node install lts
|
||||||
|
- npmci npm install
|
||||||
|
- npmci npm test
|
||||||
|
coverage: /\d+.?\d+?\%\s*coverage/
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
testSTABLE:
|
testBuild:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
- npmci test stable
|
- npmci npm prepare
|
||||||
|
- npmci node install lts
|
||||||
|
- npmci npm install
|
||||||
|
- npmci command npm run build
|
||||||
|
coverage: /\d+.?\d+?\%\s*coverage/
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
release:
|
release:
|
||||||
stage: release
|
stage: release
|
||||||
environment: npmjs-com_registry
|
|
||||||
script:
|
script:
|
||||||
- npmci publish
|
- npmci node install lts
|
||||||
|
- npmci npm publish
|
||||||
only:
|
only:
|
||||||
- tags
|
- tags
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
|
# ====================
|
||||||
|
# metadata stage
|
||||||
|
# ====================
|
||||||
|
codequality:
|
||||||
|
stage: metadata
|
||||||
|
allow_failure: true
|
||||||
|
script:
|
||||||
|
- npmci command npm install -g tslint typescript
|
||||||
|
- npmci npm install
|
||||||
|
- npmci command "tslint -c tslint.json ./ts/**/*.ts"
|
||||||
|
tags:
|
||||||
|
- docker
|
||||||
|
- priv
|
||||||
|
|
||||||
|
trigger:
|
||||||
|
stage: metadata
|
||||||
|
script:
|
||||||
|
- npmci trigger
|
||||||
|
only:
|
||||||
|
- tags
|
||||||
|
tags:
|
||||||
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
|
pages:
|
||||||
|
image: hosttoday/ht-docker-dbase:npmci
|
||||||
|
services:
|
||||||
|
- docker:18-dind
|
||||||
|
stage: metadata
|
||||||
|
script:
|
||||||
|
- npmci command npm install -g @gitzone/tsdoc
|
||||||
|
- npmci npm prepare
|
||||||
|
- npmci npm install
|
||||||
|
- npmci command tsdoc
|
||||||
|
tags:
|
||||||
|
- docker
|
||||||
|
- notpriv
|
||||||
|
only:
|
||||||
|
- tags
|
||||||
|
artifacts:
|
||||||
|
expire_in: 1 week
|
||||||
|
paths:
|
||||||
|
- public
|
||||||
|
allow_failure: true
|
||||||
|
3
.vscode/settings.json
vendored
Normal file
3
.vscode/settings.json
vendored
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
{
|
||||||
|
"workbench.colorCustomizations": {}
|
||||||
|
}
|
41
README.md
41
README.md
@ -1,12 +1,43 @@
|
|||||||
# lik
|
# @pushrocks/lik
|
||||||
light little helpers for node
|
light little helpers for node
|
||||||
|
|
||||||
## Status
|
## Availabililty and Links
|
||||||
|
* [npmjs.org (npm package)](https://www.npmjs.com/package/@pushrocks/lik)
|
||||||
|
* [gitlab.com (source)](https://gitlab.com/pushrocks/lik)
|
||||||
|
* [github.com (source mirror)](https://github.com/pushrocks/lik)
|
||||||
|
* [docs (typedoc)](https://pushrocks.gitlab.io/lik/)
|
||||||
|
|
||||||
|
## Status for master
|
||||||
|
[](https://gitlab.com/pushrocks/lik/commits/master)
|
||||||
|
[](https://gitlab.com/pushrocks/lik/commits/master)
|
||||||
|
[](https://www.npmjs.com/package/@pushrocks/lik)
|
||||||
|
[](https://snyk.io/test/npm/@pushrocks/lik)
|
||||||
|
[](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||||
|
[](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||||
|
[](https://prettier.io/)
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
We recommend the use of TypeScript for good intellisense.
|
|
||||||
|
|
||||||
```typescript
|
Use TypeScript for best in class instellisense.
|
||||||
|
|
||||||
|
```javascript
|
||||||
// import any tool that you need from lik
|
// import any tool that you need from lik
|
||||||
import {Stringmap} from "lik";
|
import { Stringmap, Objectmap, Observablemap } from 'lik';
|
||||||
```
|
```
|
||||||
|
|
||||||
|
### class Stringmap
|
||||||
|
|
||||||
|
Stringmap allows you to keep track of strings. It allows you to register triggers for certain events
|
||||||
|
like when a certain string is removed or added to the map
|
||||||
|
|
||||||
|
### class Objectmap
|
||||||
|
|
||||||
|
Sometimes you need to keep track of objects, but implementing logic for removing, finding or updating is tedious.
|
||||||
|
Objectmap takes care of keeping track of objects for you.
|
||||||
|
|
||||||
|
For further information read the linked docs at the top of this readme.
|
||||||
|
|
||||||
|
> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
|
||||||
|
| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy.html)
|
||||||
|
|
||||||
|
[](https://maintainedby.lossless.com)
|
||||||
|
1
dist/index.d.ts
vendored
1
dist/index.d.ts
vendored
@ -1 +0,0 @@
|
|||||||
export * from "./lik.stringmap";
|
|
7
dist/index.js
vendored
7
dist/index.js
vendored
@ -1,7 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
function __export(m) {
|
|
||||||
for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
|
|
||||||
}
|
|
||||||
// import modules
|
|
||||||
__export(require("./lik.stringmap"));
|
|
||||||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7O0FBRUEsaUJBQWlCO0FBRWpCLGlCQUFjLGlCQUFpQixDQUFDLEVBQUEifQ==
|
|
2
dist/lik.plugins.d.ts
vendored
2
dist/lik.plugins.d.ts
vendored
@ -1,2 +0,0 @@
|
|||||||
import "typings-global";
|
|
||||||
export import q = require("q");
|
|
4
dist/lik.plugins.js
vendored
4
dist/lik.plugins.js
vendored
@ -1,4 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
require("typings-global");
|
|
||||||
exports.q = require("q");
|
|
||||||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibGlrLnBsdWdpbnMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9saWsucGx1Z2lucy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsUUFBTyxnQkFBZ0IsQ0FBQyxDQUFBO0FBQ1YsU0FBQyxXQUFXLEdBQUcsQ0FBQyxDQUFDIn0=
|
|
19
dist/lik.stringmap.d.ts
vendored
19
dist/lik.stringmap.d.ts
vendored
@ -1,19 +0,0 @@
|
|||||||
/**
|
|
||||||
* allows you to easily keep track of a bunch of strings;
|
|
||||||
*/
|
|
||||||
export declare class Stringmap {
|
|
||||||
private _stringArray;
|
|
||||||
constructor();
|
|
||||||
/**
|
|
||||||
* add a string to the Stringmap
|
|
||||||
*/
|
|
||||||
addString(stringArg: string): void;
|
|
||||||
/**
|
|
||||||
* removes a string from Stringmap
|
|
||||||
*/
|
|
||||||
removeString(stringArg: string): void;
|
|
||||||
/**
|
|
||||||
* check if string is in Stringmap
|
|
||||||
*/
|
|
||||||
checkString(stringArg: string): boolean;
|
|
||||||
}
|
|
36
dist/lik.stringmap.js
vendored
36
dist/lik.stringmap.js
vendored
@ -1,36 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
/**
|
|
||||||
* allows you to easily keep track of a bunch of strings;
|
|
||||||
*/
|
|
||||||
class Stringmap {
|
|
||||||
constructor() {
|
|
||||||
this._stringArray = [];
|
|
||||||
}
|
|
||||||
;
|
|
||||||
/**
|
|
||||||
* add a string to the Stringmap
|
|
||||||
*/
|
|
||||||
addString(stringArg) {
|
|
||||||
this._stringArray.push(stringArg);
|
|
||||||
}
|
|
||||||
;
|
|
||||||
/**
|
|
||||||
* removes a string from Stringmap
|
|
||||||
*/
|
|
||||||
removeString(stringArg) {
|
|
||||||
for (let keyArg in this._stringArray) {
|
|
||||||
if (this._stringArray[keyArg] == stringArg) {
|
|
||||||
this._stringArray.splice(parseInt(keyArg), 1);
|
|
||||||
}
|
|
||||||
;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
/**
|
|
||||||
* check if string is in Stringmap
|
|
||||||
*/
|
|
||||||
checkString(stringArg) {
|
|
||||||
return this._stringArray.indexOf(stringArg) != -1;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
exports.Stringmap = Stringmap;
|
|
||||||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibGlrLnN0cmluZ21hcC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL2xpay5zdHJpbmdtYXAudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUVBOztHQUVHO0FBQ0g7SUFFSTtRQURRLGlCQUFZLEdBQVksRUFBRSxDQUFDO0lBR25DLENBQUM7O0lBQ0Q7O09BRUc7SUFDSCxTQUFTLENBQUMsU0FBZ0I7UUFDdEIsSUFBSSxDQUFDLFlBQVksQ0FBQyxJQUFJLENBQUMsU0FBUyxDQUFDLENBQUM7SUFDdEMsQ0FBQzs7SUFFRDs7T0FFRztJQUNILFlBQVksQ0FBQyxTQUFnQjtRQUN6QixHQUFHLENBQUMsQ0FBQyxJQUFJLE1BQU0sSUFBSSxJQUFJLENBQUMsWUFBWSxDQUFDLENBQUEsQ0FBQztZQUNsQyxFQUFFLENBQUEsQ0FBQyxJQUFJLENBQUMsWUFBWSxDQUFDLE1BQU0sQ0FBQyxJQUFJLFNBQVMsQ0FBQyxDQUFBLENBQUM7Z0JBQ3ZDLElBQUksQ0FBQyxZQUFZLENBQUMsTUFBTSxDQUFDLFFBQVEsQ0FBQyxNQUFNLENBQUMsRUFBQyxDQUFDLENBQUMsQ0FBQztZQUNqRCxDQUFDO1lBQUEsQ0FBQztRQUNOLENBQUM7SUFDTCxDQUFDO0lBRUQ7O09BRUc7SUFDSCxXQUFXLENBQUMsU0FBZ0I7UUFDeEIsTUFBTSxDQUFDLElBQUksQ0FBQyxZQUFZLENBQUMsT0FBTyxDQUFDLFNBQVMsQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFDO0lBQ3RELENBQUM7QUFDTCxDQUFDO0FBN0JZLGlCQUFTLFlBNkJyQixDQUFBIn0=
|
|
46
docs/index.md
Normal file
46
docs/index.md
Normal file
@ -0,0 +1,46 @@
|
|||||||
|
# lik
|
||||||
|
|
||||||
|
light little helpers for node
|
||||||
|
|
||||||
|
## Availabililty
|
||||||
|
|
||||||
|
[](https://www.npmjs.com/package/lik)
|
||||||
|
[](https://GitLab.com/pushrocks/lik)
|
||||||
|
[](https://github.com/pushrocks/lik)
|
||||||
|
[](https://pushrocks.gitlab.io/lik/)
|
||||||
|
|
||||||
|
## Status for master
|
||||||
|
|
||||||
|
[](https://GitLab.com/pushrocks/lik/commits/master)
|
||||||
|
[](https://GitLab.com/pushrocks/lik/commits/master)
|
||||||
|
[](https://www.npmjs.com/package/lik)
|
||||||
|
[](https://david-dm.org/pushrocks/lik)
|
||||||
|
[](https://www.bithound.io/github/pushrocks/lik/master/dependencies/npm)
|
||||||
|
[](https://www.bithound.io/github/pushrocks/lik)
|
||||||
|
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
||||||
|
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
||||||
|
[](http://standardjs.com/)
|
||||||
|
|
||||||
|
## Usage
|
||||||
|
|
||||||
|
Use TypeScript for best in class instellisense.
|
||||||
|
|
||||||
|
```javascript
|
||||||
|
// import any tool that you need from lik
|
||||||
|
import { Stringmap, Objectmap, Observablemap } from 'lik';
|
||||||
|
```
|
||||||
|
|
||||||
|
### class Stringmap
|
||||||
|
|
||||||
|
Stringmap allows you to keep track of strings. It allows you to register triggers for certain events
|
||||||
|
like when a certain string is removed or added to the map
|
||||||
|
|
||||||
|
### class Objectmap
|
||||||
|
|
||||||
|
Sometimes you need to keep track of objects, but implementing logic for removing, finding or updating is tedious.
|
||||||
|
Objectmap takes care of keeping track of objects for you.
|
||||||
|
|
||||||
|
> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
|
||||||
|
> | By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy.html)
|
||||||
|
|
||||||
|
[](https://push.rocks)
|
16
npmextra.json
Normal file
16
npmextra.json
Normal file
@ -0,0 +1,16 @@
|
|||||||
|
{
|
||||||
|
"npmci": {
|
||||||
|
"npmGlobalTools": [],
|
||||||
|
"npmAccessLevel": "public"
|
||||||
|
},
|
||||||
|
"gitzone": {
|
||||||
|
"module": {
|
||||||
|
"githost": "gitlab.com",
|
||||||
|
"gitscope": "pushrocks",
|
||||||
|
"gitrepo": "lik",
|
||||||
|
"shortDescription": "light little helpers for node",
|
||||||
|
"npmPackagename": "@pushrocks/lik",
|
||||||
|
"license": "MIT"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
1576
package-lock.json
generated
Normal file
1576
package-lock.json
generated
Normal file
File diff suppressed because it is too large
Load Diff
40
package.json
40
package.json
@ -1,11 +1,13 @@
|
|||||||
{
|
{
|
||||||
"name": "lik",
|
"name": "@pushrocks/lik",
|
||||||
"version": "1.0.2",
|
"version": "3.0.7",
|
||||||
|
"private": false,
|
||||||
"description": "light little helpers for node",
|
"description": "light little helpers for node",
|
||||||
"main": "dist/index.js",
|
"main": "dist/index.js",
|
||||||
"typings": "dist/index.d.ts",
|
"typings": "dist/index.d.ts",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"test": "(npmts)"
|
"test": "(tstest test/)",
|
||||||
|
"build": "(tsbuild)"
|
||||||
},
|
},
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@ -18,12 +20,32 @@
|
|||||||
},
|
},
|
||||||
"homepage": "https://gitlab.com/pushrocks/lik#README",
|
"homepage": "https://gitlab.com/pushrocks/lik#README",
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"npmts-g": "^5.2.6",
|
"@gitzone/tsbuild": "^2.1.3",
|
||||||
"should": "^10.0.0",
|
"@gitzone/tsrun": "^1.1.17",
|
||||||
"typings-test": "^1.0.1"
|
"@gitzone/tstest": "^1.0.18",
|
||||||
|
"@pushrocks/tapbundle": "^3.0.7",
|
||||||
|
"@types/node": "^10.12.12",
|
||||||
|
"tslint": "^5.11.0",
|
||||||
|
"tslint-config-prettier": "^1.17.0"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@types/q": "^0.0.27",
|
"@pushrocks/smartdelay": "^2.0.2",
|
||||||
"q": "^1.4.1"
|
"@pushrocks/smartpromise": "^2.0.5",
|
||||||
}
|
"@pushrocks/smartrx": "^2.0.3",
|
||||||
|
"@pushrocks/smarttime": "^3.0.5",
|
||||||
|
"@types/minimatch": "^3.0.3",
|
||||||
|
"minimatch": "^3.0.4",
|
||||||
|
"symbol-tree": "^3.2.2"
|
||||||
|
},
|
||||||
|
"files": [
|
||||||
|
"ts/*",
|
||||||
|
"ts_web/*",
|
||||||
|
"dist/*",
|
||||||
|
"dist_web/*",
|
||||||
|
"dist_ts_web/*",
|
||||||
|
"assets/*",
|
||||||
|
"cli.js",
|
||||||
|
"npmextra.json",
|
||||||
|
"readme.md"
|
||||||
|
]
|
||||||
}
|
}
|
||||||
|
2
test/test.d.ts
vendored
2
test/test.d.ts
vendored
@ -1,2 +0,0 @@
|
|||||||
import "typings-test";
|
|
||||||
import "should";
|
|
25
test/test.interestmap.ts
Normal file
25
test/test.interestmap.ts
Normal file
@ -0,0 +1,25 @@
|
|||||||
|
import { tap, expect } from '@pushrocks/tapbundle';
|
||||||
|
import * as lik from '../ts/index';
|
||||||
|
|
||||||
|
let testInterestmap: lik.InterestMap<number, number>;
|
||||||
|
|
||||||
|
tap.test('should create an interestmap', async () => {
|
||||||
|
testInterestmap = new lik.InterestMap(numberArg => {
|
||||||
|
return numberArg.toString();
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should create an interest', async () => {
|
||||||
|
testInterestmap.addInterest(3);
|
||||||
|
testInterestmap.addInterest(4);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should return an already existing interest', async () => {
|
||||||
|
await testInterestmap.addInterest(3);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should be able to inform about a lost interest', async () => {
|
||||||
|
testInterestmap.informLostInterest(3);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.start();
|
32
test/test.js
32
test/test.js
@ -1,32 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
require("typings-test");
|
|
||||||
const lik = require("../dist/index");
|
|
||||||
require("should");
|
|
||||||
describe("lik", function () {
|
|
||||||
describe("Stringmap", function () {
|
|
||||||
let testStringmap;
|
|
||||||
let testString1 = "testString1";
|
|
||||||
let testString2 = "testString2";
|
|
||||||
let testString3 = "testString3";
|
|
||||||
it("should create an instance of Stringmap", function () {
|
|
||||||
testStringmap = new lik.Stringmap();
|
|
||||||
testStringmap.should.be.instanceof(lik.Stringmap);
|
|
||||||
});
|
|
||||||
it("should return false for an string not in Stringmap", function () {
|
|
||||||
testStringmap.checkString(testString1).should.be.false();
|
|
||||||
});
|
|
||||||
it("should add an string to Stringmap", function () {
|
|
||||||
testStringmap.addString(testString1);
|
|
||||||
testStringmap.addString(testString2);
|
|
||||||
testStringmap.addString(testString3);
|
|
||||||
testStringmap.checkString(testString1).should.be.true();
|
|
||||||
testStringmap.checkString(testString2).should.be.true();
|
|
||||||
testStringmap.checkString(testString3).should.be.true();
|
|
||||||
});
|
|
||||||
it("should remove a string from Stringmap", function () {
|
|
||||||
testStringmap.removeString(testString2);
|
|
||||||
testStringmap.checkString(testString2).should.be.false();
|
|
||||||
});
|
|
||||||
});
|
|
||||||
});
|
|
||||||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbInRlc3QudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLFFBQU8sY0FBYyxDQUFDLENBQUE7QUFDdEIsTUFBTyxHQUFHLFdBQVcsZUFBZSxDQUFDLENBQUM7QUFDdEMsUUFBTyxRQUFRLENBQUMsQ0FBQTtBQUVoQixRQUFRLENBQUMsS0FBSyxFQUFDO0lBQ1gsUUFBUSxDQUFDLFdBQVcsRUFBQztRQUNqQixJQUFJLGFBQTJCLENBQUM7UUFDaEMsSUFBSSxXQUFXLEdBQUcsYUFBYSxDQUFDO1FBQ2hDLElBQUksV0FBVyxHQUFHLGFBQWEsQ0FBQztRQUNoQyxJQUFJLFdBQVcsR0FBRyxhQUFhLENBQUM7UUFDaEMsRUFBRSxDQUFDLHdDQUF3QyxFQUFDO1lBQ3hDLGFBQWEsR0FBRyxJQUFJLEdBQUcsQ0FBQyxTQUFTLEVBQUUsQ0FBQztZQUNwQyxhQUFhLENBQUMsTUFBTSxDQUFDLEVBQUUsQ0FBQyxVQUFVLENBQUMsR0FBRyxDQUFDLFNBQVMsQ0FBQyxDQUFDO1FBQ3RELENBQUMsQ0FBQyxDQUFDO1FBQ0gsRUFBRSxDQUFDLG9EQUFvRCxFQUFDO1lBQ3BELGFBQWEsQ0FBQyxXQUFXLENBQUMsV0FBVyxDQUFDLENBQUMsTUFBTSxDQUFDLEVBQUUsQ0FBQyxLQUFLLEVBQUUsQ0FBQztRQUM3RCxDQUFDLENBQUMsQ0FBQztRQUNILEVBQUUsQ0FBQyxtQ0FBbUMsRUFBQztZQUNuQyxhQUFhLENBQUMsU0FBUyxDQUFDLFdBQVcsQ0FBQyxDQUFDO1lBQ3JDLGFBQWEsQ0FBQyxTQUFTLENBQUMsV0FBVyxDQUFDLENBQUM7WUFDckMsYUFBYSxDQUFDLFNBQVMsQ0FBQyxXQUFXLENBQUMsQ0FBQztZQUNyQyxhQUFhLENBQUMsV0FBVyxDQUFDLFdBQVcsQ0FBQyxDQUFDLE1BQU0sQ0FBQyxFQUFFLENBQUMsSUFBSSxFQUFFLENBQUM7WUFDeEQsYUFBYSxDQUFDLFdBQVcsQ0FBQyxXQUFXLENBQUMsQ0FBQyxNQUFNLENBQUMsRUFBRSxDQUFDLElBQUksRUFBRSxDQUFDO1lBQ3hELGFBQWEsQ0FBQyxXQUFXLENBQUMsV0FBVyxDQUFDLENBQUMsTUFBTSxDQUFDLEVBQUUsQ0FBQyxJQUFJLEVBQUUsQ0FBQztRQUM1RCxDQUFDLENBQUMsQ0FBQztRQUNILEVBQUUsQ0FBQyx1Q0FBdUMsRUFBQztZQUN2QyxhQUFhLENBQUMsWUFBWSxDQUFDLFdBQVcsQ0FBQyxDQUFDO1lBQ3hDLGFBQWEsQ0FBQyxXQUFXLENBQUMsV0FBVyxDQUFDLENBQUMsTUFBTSxDQUFDLEVBQUUsQ0FBQyxLQUFLLEVBQUUsQ0FBQztRQUM3RCxDQUFDLENBQUMsQ0FBQztJQUNQLENBQUMsQ0FBQyxDQUFBO0FBQ04sQ0FBQyxDQUFDLENBQUMifQ==
|
|
17
test/test.limitedarray.ts
Normal file
17
test/test.limitedarray.ts
Normal file
@ -0,0 +1,17 @@
|
|||||||
|
import { tap, expect } from '@pushrocks/tapbundle';
|
||||||
|
|
||||||
|
import { LimitedArray } from '../ts/index';
|
||||||
|
|
||||||
|
let testLimitedArray: LimitedArray<string>;
|
||||||
|
|
||||||
|
tap.test('should create a LimitedArray', async () => {
|
||||||
|
testLimitedArray = new LimitedArray(6);
|
||||||
|
expect(testLimitedArray).to.be.instanceof(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);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.start();
|
26
test/test.looptracker.ts
Normal file
26
test/test.looptracker.ts
Normal file
@ -0,0 +1,26 @@
|
|||||||
|
// 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';
|
||||||
|
|
||||||
|
let object1 = {};
|
||||||
|
let object2 = {};
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should add objects once and return true', async () => {
|
||||||
|
expect(myLoopTracker.checkAndTrack(object1)).to.be.true;
|
||||||
|
expect(myLoopTracker.checkAndTrack(object1)).to.be.false;
|
||||||
|
expect(myLoopTracker.checkAndTrack(object2)).to.be.true;
|
||||||
|
expect(myLoopTracker.checkAndTrack(object2)).to.be.false;
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.start();
|
78
test/test.objectmap.ts
Normal file
78
test/test.objectmap.ts
Normal file
@ -0,0 +1,78 @@
|
|||||||
|
// 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';
|
||||||
|
|
||||||
|
// Objectmap
|
||||||
|
interface ITestObject {
|
||||||
|
propOne: string;
|
||||||
|
propTwo: string;
|
||||||
|
}
|
||||||
|
let testObjectmap: lik.Objectmap<ITestObject>;
|
||||||
|
let testObject1: ITestObject = {
|
||||||
|
propOne: 'hello',
|
||||||
|
propTwo: 'hello2'
|
||||||
|
};
|
||||||
|
let testObject2: ITestObject = {
|
||||||
|
propOne: 'hello',
|
||||||
|
propTwo: 'hello2'
|
||||||
|
};
|
||||||
|
|
||||||
|
tap.test('new lik.Objectmap() -> should correctly instantiate an Objectmap', async () => {
|
||||||
|
testObjectmap = new lik.Objectmap<ITestObject>();
|
||||||
|
expect(testObjectmap).be.instanceof(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;
|
||||||
|
// tslint:disable-next-line:no-unused-expression
|
||||||
|
expect(testObjectmap.checkForObject(testObject2)).be.false;
|
||||||
|
});
|
||||||
|
|
||||||
|
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;
|
||||||
|
// tslint:disable-next-line:no-unused-expression
|
||||||
|
expect(testObjectmap.checkForObject(testObject2)).be.true;
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('Objectmap.forEach -> should correctly run a function forEach map object', async () => {
|
||||||
|
testObjectmap.forEach(itemArg => {
|
||||||
|
expect(itemArg).to.have.property('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 => {
|
||||||
|
return itemArg.propOne === 'helloThere';
|
||||||
|
});
|
||||||
|
// tslint:disable-next-line:no-unused-expression
|
||||||
|
expect(myObject === referenceObject).be.true;
|
||||||
|
});
|
||||||
|
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
|
||||||
|
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(testObjectmap.getArray().length).equal(originalLength - 1);
|
||||||
|
expect(testObjectmap.getArray()).to.not.contain(oneObject);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.start();
|
88
test/test.stringmap.ts
Normal file
88
test/test.stringmap.ts
Normal file
@ -0,0 +1,88 @@
|
|||||||
|
// 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';
|
||||||
|
|
||||||
|
// testData
|
||||||
|
let testStringmap: lik.Stringmap;
|
||||||
|
let testString1 = 'testString1';
|
||||||
|
let testString2 = 'testString2';
|
||||||
|
let testString3 = 'testString3';
|
||||||
|
let testString4 = 'testString4';
|
||||||
|
let testString5 = 'testString5';
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
|
||||||
|
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;
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
|
tap.test('lik.Stringmap.addString -> should add an string to Stringmap', async () => {
|
||||||
|
testStringmap.addString(testString1);
|
||||||
|
testStringmap.addString(testString2);
|
||||||
|
testStringmap.addString(testString3);
|
||||||
|
// tslint:disable-next-line:no-unused-expression
|
||||||
|
expect(testStringmap.checkString(testString1)).be.true;
|
||||||
|
// tslint:disable-next-line:no-unused-expression
|
||||||
|
expect(testStringmap.checkString(testString2)).be.true;
|
||||||
|
// tslint:disable-next-line:no-unused-expression
|
||||||
|
expect(testStringmap.checkString(testString3)).be.true;
|
||||||
|
// tslint:disable-next-line:no-unused-expression
|
||||||
|
expect(testStringmap.checkMinimatch('*String1')).be.true;
|
||||||
|
// tslint:disable-next-line:no-unused-expression
|
||||||
|
expect(testStringmap.checkMinimatch('*String2')).be.true;
|
||||||
|
// tslint:disable-next-line:no-unused-expression
|
||||||
|
expect(testStringmap.checkMinimatch('*String4')).be.false;
|
||||||
|
});
|
||||||
|
|
||||||
|
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;
|
||||||
|
});
|
||||||
|
|
||||||
|
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;
|
||||||
|
});
|
||||||
|
|
||||||
|
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;
|
||||||
|
// tslint:disable-next-line:no-unused-expression
|
||||||
|
expect(clonedArray[0] === testString1).be.true;
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test(
|
||||||
|
'lik.Stringmap.checkIsEmpty() -> should register a function to trigger when empty',
|
||||||
|
async () => {
|
||||||
|
testStringmap.registerUntilTrue(
|
||||||
|
() => {
|
||||||
|
return testStringmap.checkIsEmpty();
|
||||||
|
},
|
||||||
|
() => {
|
||||||
|
console.log('Stringmap now is empty');
|
||||||
|
}
|
||||||
|
);
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
|
tap.test('lik.Stringmap.empty() -> should remove wipe and then notify', async () => {
|
||||||
|
testStringmap.wipe();
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.start();
|
25
test/test.timedaggregator.ts
Normal file
25
test/test.timedaggregator.ts
Normal file
@ -0,0 +1,25 @@
|
|||||||
|
// 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';
|
||||||
|
|
||||||
|
let testTimedAggregator: lik.TimedAggregtor<string>;
|
||||||
|
|
||||||
|
tap.test('should create a timed aggregaotor', async tools => {
|
||||||
|
testTimedAggregator = new lik.TimedAggregtor<string>({
|
||||||
|
aggregationIntervalInMillis: 1000,
|
||||||
|
functionForAggregation: aggregation => {
|
||||||
|
console.log(aggregation);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
testTimedAggregator.add('This');
|
||||||
|
testTimedAggregator.add('is a whole sentence.');
|
||||||
|
await tools.delayFor(1001);
|
||||||
|
testTimedAggregator.add('This one is another.');
|
||||||
|
await tools.delayFor(2000);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.start();
|
40
test/test.tree.ts
Normal file
40
test/test.tree.ts
Normal file
@ -0,0 +1,40 @@
|
|||||||
|
import { tap, expect } from '@pushrocks/tapbundle';
|
||||||
|
import * as lik from '../ts/index';
|
||||||
|
|
||||||
|
class TestClass {
|
||||||
|
constructor(public hey: string) {
|
||||||
|
// nothing here
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
let testTree = new lik.Tree<TestClass>();
|
||||||
|
|
||||||
|
let testInstance = new TestClass('first');
|
||||||
|
let testInstance2 = new TestClass('second');
|
||||||
|
let testInstance3 = new TestClass('third');
|
||||||
|
let testInstance4 = new TestClass('fourth');
|
||||||
|
let testInstance5 = new TestClass('fifth');
|
||||||
|
let testInstance6 = new TestClass('sixth');
|
||||||
|
|
||||||
|
tap.test('create a valid tree instance', async () => {
|
||||||
|
testTree = new lik.Tree();
|
||||||
|
expect(testTree).to.be.instanceOf(lik.Tree);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should insert an object', async () => {
|
||||||
|
testTree.initialize(testInstance);
|
||||||
|
let resultArray = testTree.treeToArray(testInstance, {});
|
||||||
|
expect(resultArray).to.contain(testInstance);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should add other objects in a hierachy', async () => {
|
||||||
|
testTree.appendChild(testInstance, testInstance2);
|
||||||
|
testTree.appendChild(testInstance, testInstance3);
|
||||||
|
testTree.appendChild(testInstance, testInstance4);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test("should create a JSON object that reflects a tree's hierachy", async () => {
|
||||||
|
const jsonTreet = testTree.toJsonWithHierachy(testInstance);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.start();
|
32
test/test.ts
32
test/test.ts
@ -1,31 +1 @@
|
|||||||
import "typings-test";
|
import './test.objectmap';
|
||||||
import lik = require("../dist/index");
|
|
||||||
import "should";
|
|
||||||
|
|
||||||
describe("lik",function(){
|
|
||||||
describe("Stringmap",function(){
|
|
||||||
let testStringmap:lik.Stringmap;
|
|
||||||
let testString1 = "testString1";
|
|
||||||
let testString2 = "testString2";
|
|
||||||
let testString3 = "testString3";
|
|
||||||
it("should create an instance of Stringmap",function(){
|
|
||||||
testStringmap = new lik.Stringmap();
|
|
||||||
testStringmap.should.be.instanceof(lik.Stringmap);
|
|
||||||
});
|
|
||||||
it("should return false for an string not in Stringmap",function(){
|
|
||||||
testStringmap.checkString(testString1).should.be.false();
|
|
||||||
});
|
|
||||||
it("should add an string to Stringmap",function(){
|
|
||||||
testStringmap.addString(testString1);
|
|
||||||
testStringmap.addString(testString2);
|
|
||||||
testStringmap.addString(testString3);
|
|
||||||
testStringmap.checkString(testString1).should.be.true();
|
|
||||||
testStringmap.checkString(testString2).should.be.true();
|
|
||||||
testStringmap.checkString(testString3).should.be.true();
|
|
||||||
});
|
|
||||||
it("should remove a string from Stringmap",function(){
|
|
||||||
testStringmap.removeString(testString2);
|
|
||||||
testStringmap.checkString(testString2).should.be.false();
|
|
||||||
});
|
|
||||||
})
|
|
||||||
});
|
|
||||||
|
10
ts/index.ts
10
ts/index.ts
@ -1,5 +1,11 @@
|
|||||||
import * as plugins from "./lik.plugins";
|
import * as plugins from './lik.plugins';
|
||||||
|
|
||||||
// import modules
|
// import modules
|
||||||
|
|
||||||
export * from "./lik.stringmap";
|
export * from './lik.interestmap';
|
||||||
|
export * from './lik.limitedarray';
|
||||||
|
export * from './lik.looptracker';
|
||||||
|
export * from './lik.objectmap';
|
||||||
|
export * from './lik.stringmap';
|
||||||
|
export * from './lik.timedaggregator';
|
||||||
|
export * from './lik.tree';
|
||||||
|
78
ts/lik.interestmap.interest.ts
Normal file
78
ts/lik.interestmap.interest.ts
Normal file
@ -0,0 +1,78 @@
|
|||||||
|
import * as plugins from './lik.plugins';
|
||||||
|
|
||||||
|
import { InterestMap, IInterestComparisonFunc } from './lik.interestmap';
|
||||||
|
|
||||||
|
export class Interest<DTInterestId, DTInterestFullfillment> {
|
||||||
|
private interestMapRef: InterestMap<DTInterestId, DTInterestFullfillment>;
|
||||||
|
public originalInterest: DTInterestId;
|
||||||
|
public comparisonFunc: IInterestComparisonFunc<DTInterestId>;
|
||||||
|
public destructionTimer = new plugins.smarttime.Timer(10000);
|
||||||
|
public isFullfilled = false;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* a generic store to store objects in that are needed for fullfillment;
|
||||||
|
*/
|
||||||
|
public fullfillmentStore: any[] = [];
|
||||||
|
|
||||||
|
/**
|
||||||
|
* quick access to a string that makes the interest comparable for checking for similar interests
|
||||||
|
*/
|
||||||
|
public get comparisonString() {
|
||||||
|
return this.comparisonFunc(this.originalInterest);
|
||||||
|
}
|
||||||
|
|
||||||
|
private interestDeferred: plugins.smartpromise.Deferred<
|
||||||
|
DTInterestFullfillment
|
||||||
|
> = new plugins.smartpromise.Deferred();
|
||||||
|
public interestFullfilled = this.interestDeferred.promise;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* fullfill the interest
|
||||||
|
*/
|
||||||
|
public fullfillInterest(objectArg: DTInterestFullfillment) {
|
||||||
|
this.isFullfilled = true;
|
||||||
|
this.fullfillmentStore = [];
|
||||||
|
this.interestDeferred.resolve(objectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
constructor(
|
||||||
|
interestMapArg: InterestMap<DTInterestId, DTInterestFullfillment>,
|
||||||
|
interestArg: DTInterestId,
|
||||||
|
comparisonFuncArg: IInterestComparisonFunc<DTInterestId>
|
||||||
|
) {
|
||||||
|
this.originalInterest = interestArg;
|
||||||
|
this.comparisonFunc = comparisonFuncArg;
|
||||||
|
this.interestMapRef = interestMapArg;
|
||||||
|
this.destructionTimer.completed.then(() => {
|
||||||
|
this.destroy();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
// ===============================
|
||||||
|
// LIFECYCLE MANAGEMENT
|
||||||
|
// ===============================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* self destructs the interest
|
||||||
|
*/
|
||||||
|
public destroy() {
|
||||||
|
this.interestMapRef.removeInterest(this);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* notifies the interest that the interest in it has been lost
|
||||||
|
*/
|
||||||
|
public markLost() {
|
||||||
|
this.destructionTimer.start();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* notifies the interest that the interest in it has been restored
|
||||||
|
*/
|
||||||
|
public renew() {
|
||||||
|
this.destructionTimer.reset();
|
||||||
|
}
|
||||||
|
}
|
114
ts/lik.interestmap.ts
Normal file
114
ts/lik.interestmap.ts
Normal file
@ -0,0 +1,114 @@
|
|||||||
|
import * as plugins from './lik.plugins';
|
||||||
|
import { Objectmap } from './lik.objectmap';
|
||||||
|
|
||||||
|
import { Observable } from 'rxjs';
|
||||||
|
|
||||||
|
import { Interest } from './lik.interestmap.interest';
|
||||||
|
|
||||||
|
export type IInterestComparisonFunc<T> = (objectArg: T) => string;
|
||||||
|
|
||||||
|
export class InterestMap<DTInterestId, DTInterestFullfillment> {
|
||||||
|
/**
|
||||||
|
* stores interests that are currently fullfilled by the cache
|
||||||
|
*/
|
||||||
|
private interestObjectMap = new Objectmap<Interest<DTInterestId, DTInterestFullfillment>>();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* a function to compare interests
|
||||||
|
*/
|
||||||
|
private comparisonFunc: IInterestComparisonFunc<DTInterestId>;
|
||||||
|
|
||||||
|
constructor(comparisonFuncArg: IInterestComparisonFunc<DTInterestId>) {
|
||||||
|
this.comparisonFunc = comparisonFuncArg;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* adds an interest to the InterestMap
|
||||||
|
* @param objectArg
|
||||||
|
*/
|
||||||
|
public async addInterest(
|
||||||
|
objectArg: DTInterestId
|
||||||
|
): Promise<Interest<DTInterestId, DTInterestFullfillment>> {
|
||||||
|
const comparisonString = this.comparisonFunc(objectArg);
|
||||||
|
let returnInterest: Interest<DTInterestId, DTInterestFullfillment>;
|
||||||
|
const newInterest = new Interest<DTInterestId, DTInterestFullfillment>(
|
||||||
|
this,
|
||||||
|
objectArg,
|
||||||
|
this.comparisonFunc
|
||||||
|
);
|
||||||
|
let interestExists = false;
|
||||||
|
await this.interestObjectMap.forEach(interestArg => {
|
||||||
|
if (!interestExists && interestArg.comparisonString === newInterest.comparisonString) {
|
||||||
|
console.log('info', `interest already exists for ${newInterest.comparisonString}`);
|
||||||
|
interestExists = true;
|
||||||
|
returnInterest = interestArg;
|
||||||
|
returnInterest.renew();
|
||||||
|
}
|
||||||
|
});
|
||||||
|
if (!returnInterest) {
|
||||||
|
returnInterest = newInterest;
|
||||||
|
this.interestObjectMap.add(returnInterest);
|
||||||
|
}
|
||||||
|
this.interestObservable.push(returnInterest);
|
||||||
|
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 => {
|
||||||
|
return interestArg.comparisonString === interestArg2.comparisonString;
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* check interest
|
||||||
|
*/
|
||||||
|
public checkInterest(objectArg: DTInterestId): boolean {
|
||||||
|
const comparisonString = this.comparisonFunc(objectArg);
|
||||||
|
return this.checkInterestByString(comparisonString);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* checks an interest
|
||||||
|
* @param comparisonStringArg
|
||||||
|
*/
|
||||||
|
public checkInterestByString(comparisonStringArg: string): boolean {
|
||||||
|
const foundInterest = this.interestObjectMap.find(interest => {
|
||||||
|
return interest.comparisonString === comparisonStringArg;
|
||||||
|
});
|
||||||
|
if (foundInterest) {
|
||||||
|
return true;
|
||||||
|
} else {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* inform lost interest
|
||||||
|
* @param interestId
|
||||||
|
*/
|
||||||
|
public informLostInterest(interestId: DTInterestId) {
|
||||||
|
const wantedInterest = this.findInterest(interestId);
|
||||||
|
if (wantedInterest) {
|
||||||
|
wantedInterest.markLost();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* finds an interest
|
||||||
|
* @param objectArg
|
||||||
|
*/
|
||||||
|
public findInterest(objectArg: DTInterestId): Interest<DTInterestId, DTInterestFullfillment> {
|
||||||
|
const comparableString = this.comparisonFunc(objectArg);
|
||||||
|
const interest = this.interestObjectMap.find(interest => {
|
||||||
|
return interest.comparisonString === comparableString;
|
||||||
|
});
|
||||||
|
return interest; // if an interest is found, the interest is returned, otherwise interest is null
|
||||||
|
}
|
||||||
|
}
|
42
ts/lik.limitedarray.ts
Normal file
42
ts/lik.limitedarray.ts
Normal file
@ -0,0 +1,42 @@
|
|||||||
|
import * as plugins from './lik.plugins';
|
||||||
|
|
||||||
|
export class LimitedArray<T> {
|
||||||
|
array: T[] = [];
|
||||||
|
arrayLimit: number;
|
||||||
|
constructor(limitArg: number) {
|
||||||
|
this.arrayLimit = limitArg;
|
||||||
|
}
|
||||||
|
|
||||||
|
addOne(objectArg: T) {
|
||||||
|
this.array.unshift(objectArg);
|
||||||
|
if (this.array.length > this.arrayLimit) {
|
||||||
|
this.array.length = this.arrayLimit;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
addMany(objectArrayArg: T[]) {
|
||||||
|
for (let objectArg of objectArrayArg) {
|
||||||
|
this.addOne(objectArg);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
setLimit(limitArg: number) {
|
||||||
|
this.arrayLimit = limitArg;
|
||||||
|
if (this.array.length > this.arrayLimit) {
|
||||||
|
this.array.length = this.arrayLimit;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
getAverage(): number {
|
||||||
|
if (typeof this.array[0] === 'number') {
|
||||||
|
let sum = 0;
|
||||||
|
for (let localNumber of this.array) {
|
||||||
|
let localNumberAny: any = localNumber;
|
||||||
|
sum = sum + localNumberAny;
|
||||||
|
}
|
||||||
|
return sum / this.array.length;
|
||||||
|
} else {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
18
ts/lik.looptracker.ts
Normal file
18
ts/lik.looptracker.ts
Normal file
@ -0,0 +1,18 @@
|
|||||||
|
import * as plugins from './lik.plugins';
|
||||||
|
|
||||||
|
import { Objectmap } from './lik.objectmap';
|
||||||
|
|
||||||
|
export class LoopTracker<T> {
|
||||||
|
referenceObjectMap = new Objectmap<any>();
|
||||||
|
constructor() {
|
||||||
|
// nothing here
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* checks and tracks an object
|
||||||
|
* @param objectArg
|
||||||
|
*/
|
||||||
|
checkAndTrack(objectArg: T) {
|
||||||
|
return this.referenceObjectMap.add(objectArg);
|
||||||
|
}
|
||||||
|
}
|
136
ts/lik.objectmap.ts
Normal file
136
ts/lik.objectmap.ts
Normal file
@ -0,0 +1,136 @@
|
|||||||
|
import * as plugins from './lik.plugins';
|
||||||
|
|
||||||
|
export interface IObjectmapForEachFunction<T> {
|
||||||
|
(itemArg: T): void;
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface IObjectmapFindFunction<T> {
|
||||||
|
(itemArg: T): boolean;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* allows keeping track of objects
|
||||||
|
*/
|
||||||
|
export class Objectmap<T> {
|
||||||
|
private objectArray: T[] = [];
|
||||||
|
|
||||||
|
/**
|
||||||
|
* returns a new instance
|
||||||
|
*/
|
||||||
|
constructor() {
|
||||||
|
// nothing here
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* add object to Objectmap
|
||||||
|
* returns false if the object is already in the map
|
||||||
|
* returns true if the object was added successfully
|
||||||
|
*/
|
||||||
|
public add(objectArg: T): boolean {
|
||||||
|
if (this.checkForObject(objectArg)) {
|
||||||
|
// the object is already in the objectmap
|
||||||
|
return false;
|
||||||
|
} else {
|
||||||
|
// the object is not yet in the objectmap
|
||||||
|
this.objectArray.push(objectArg);
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* like .add but adds an whole array of objects
|
||||||
|
*/
|
||||||
|
public addArray(objectArrayArg: T[]) {
|
||||||
|
for (let item of objectArrayArg) {
|
||||||
|
this.add(item);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* check if object is in Objectmap
|
||||||
|
*/
|
||||||
|
public checkForObject(objectArg: T) {
|
||||||
|
return this.objectArray.indexOf(objectArg) !== -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* find object
|
||||||
|
*/
|
||||||
|
public find(findFunction: IObjectmapFindFunction<T>) {
|
||||||
|
const resultArray = this.objectArray.filter(findFunction);
|
||||||
|
if (resultArray.length > 0) {
|
||||||
|
return resultArray[0];
|
||||||
|
} else {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* finds a specific element and then removes it
|
||||||
|
*/
|
||||||
|
public findOneAndRemove(findFunction: IObjectmapFindFunction<T>): T {
|
||||||
|
const foundElement = this.find(findFunction);
|
||||||
|
if (foundElement) {
|
||||||
|
this.remove(foundElement);
|
||||||
|
}
|
||||||
|
return foundElement;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* run function for each item in Objectmap
|
||||||
|
*/
|
||||||
|
public async forEach(functionArg: IObjectmapForEachFunction<T>) {
|
||||||
|
for (let object of this.objectArray) {
|
||||||
|
await functionArg(object);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* gets an object in the Observablemap and removes it, so it can't be retrieved again
|
||||||
|
*/
|
||||||
|
public getOneAndRemove(): T {
|
||||||
|
return this.objectArray.shift();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* returns a cloned array of all the objects currently in the Objectmap
|
||||||
|
*/
|
||||||
|
public getArray(): T[] {
|
||||||
|
const returnArray: any[] = [];
|
||||||
|
for (const objectItem of this.objectArray) {
|
||||||
|
returnArray.push(objectItem);
|
||||||
|
}
|
||||||
|
return returnArray;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* check if Objectmap ist empty
|
||||||
|
*/
|
||||||
|
public isEmpty(): boolean {
|
||||||
|
if (this.objectArray.length === 0) {
|
||||||
|
return true;
|
||||||
|
} else {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* remove object from Objectmap
|
||||||
|
*/
|
||||||
|
public remove(objectArg: T) {
|
||||||
|
let replacementArray = [];
|
||||||
|
for (let item of this.objectArray) {
|
||||||
|
if (item !== objectArg) {
|
||||||
|
replacementArray.push(item);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
this.objectArray = replacementArray;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* wipe Objectmap
|
||||||
|
*/
|
||||||
|
public wipe() {
|
||||||
|
this.objectArray = [];
|
||||||
|
}
|
||||||
|
}
|
@ -1,2 +1,25 @@
|
|||||||
import "typings-global";
|
// ==============
|
||||||
export import q = require("q");
|
// native
|
||||||
|
// ==============
|
||||||
|
|
||||||
|
import * as events from 'events';
|
||||||
|
|
||||||
|
export { events };
|
||||||
|
|
||||||
|
// ==============
|
||||||
|
// @pushrocks
|
||||||
|
// ==============
|
||||||
|
import * as smartdelay from '@pushrocks/smartdelay';
|
||||||
|
import * as smartpromise from '@pushrocks/smartpromise';
|
||||||
|
import * as smartrx from '@pushrocks/smartrx';
|
||||||
|
import * as smarttime from '@pushrocks/smarttime';
|
||||||
|
|
||||||
|
export { smartdelay, smartpromise, smartrx, smarttime };
|
||||||
|
|
||||||
|
// ==============
|
||||||
|
// third party
|
||||||
|
// ==============
|
||||||
|
import minimatch from 'minimatch';
|
||||||
|
const symbolTree = require('symbol-tree');
|
||||||
|
|
||||||
|
export { minimatch, symbolTree };
|
||||||
|
@ -1,35 +1,115 @@
|
|||||||
import * as plugins from "./lik.plugins";
|
import * as plugins from './lik.plugins';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* allows you to easily keep track of a bunch of strings;
|
* allows you to easily keep track of a bunch of strings
|
||||||
*/
|
*/
|
||||||
export class Stringmap {
|
|
||||||
private _stringArray:string[] = [];
|
|
||||||
constructor(){
|
|
||||||
|
|
||||||
};
|
export interface ITriggerFunction {
|
||||||
|
(): boolean;
|
||||||
|
}
|
||||||
|
|
||||||
|
export class Stringmap {
|
||||||
|
private _stringArray: string[] = [];
|
||||||
|
private _triggerUntilTrueFunctionArray: ITriggerFunction[] = [];
|
||||||
|
constructor() {}
|
||||||
/**
|
/**
|
||||||
* add a string to the Stringmap
|
* add a string to the Stringmap
|
||||||
*/
|
*/
|
||||||
addString(stringArg:string){
|
addString(stringArg: string) {
|
||||||
this._stringArray.push(stringArg);
|
this._stringArray.push(stringArg);
|
||||||
};
|
this.notifyTrigger();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* like addString, but accepts an array of strings
|
||||||
|
*/
|
||||||
|
addStringArray(stringArrayArg: string[]) {
|
||||||
|
for (let stringItem of stringArrayArg) {
|
||||||
|
this.addString(stringItem);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* removes a string from Stringmap
|
* removes a string from Stringmap
|
||||||
*/
|
*/
|
||||||
removeString(stringArg:string){
|
removeString(stringArg: string) {
|
||||||
for (let keyArg in this._stringArray){
|
for (let keyArg in this._stringArray) {
|
||||||
if(this._stringArray[keyArg] == stringArg){
|
if (this._stringArray[keyArg] === stringArg) {
|
||||||
this._stringArray.splice(parseInt(keyArg),1);
|
this._stringArray.splice(parseInt(keyArg), 1);
|
||||||
};
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
this.notifyTrigger();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* wipes the Stringmap
|
||||||
|
*/
|
||||||
|
wipe() {
|
||||||
|
this._stringArray = [];
|
||||||
|
this.notifyTrigger();
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* check if string is in Stringmap
|
* check if string is in Stringmap
|
||||||
*/
|
*/
|
||||||
checkString(stringArg:string):boolean{
|
public checkString(stringArg: string): boolean {
|
||||||
return this._stringArray.indexOf(stringArg) != -1;
|
return this._stringArray.indexOf(stringArg) !== -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* checks stringPresence with minimatch
|
||||||
|
*/
|
||||||
|
public checkMinimatch(miniMatchStringArg: string): boolean {
|
||||||
|
let foundMatch: boolean = false;
|
||||||
|
for (let stringItem of this._stringArray) {
|
||||||
|
if (plugins.minimatch(stringItem, miniMatchStringArg)) {
|
||||||
|
foundMatch = true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return foundMatch;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* checks if the Stringmap is empty
|
||||||
|
*/
|
||||||
|
public checkIsEmpty() {
|
||||||
|
return this._stringArray.length === 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* gets a cloned copy of the current string Array
|
||||||
|
*/
|
||||||
|
public getStringArray() {
|
||||||
|
const returnArray: string[] = [];
|
||||||
|
for (const stringItem of this._stringArray) {
|
||||||
|
returnArray.push(stringItem);
|
||||||
|
}
|
||||||
|
return returnArray;
|
||||||
|
}
|
||||||
|
|
||||||
|
// trigger registering
|
||||||
|
|
||||||
|
/**
|
||||||
|
* register a new trigger
|
||||||
|
*/
|
||||||
|
public registerUntilTrue(functionArg: ITriggerFunction, doFunctionArg) {
|
||||||
|
this._triggerUntilTrueFunctionArray.push(() => {
|
||||||
|
let result = functionArg();
|
||||||
|
if (result === true) {
|
||||||
|
doFunctionArg();
|
||||||
|
}
|
||||||
|
return result;
|
||||||
|
});
|
||||||
|
this.notifyTrigger();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* notifies triggers
|
||||||
|
*/
|
||||||
|
private notifyTrigger() {
|
||||||
|
let filteredArray = this._triggerUntilTrueFunctionArray.filter(functionArg => {
|
||||||
|
return !functionArg();
|
||||||
|
});
|
||||||
|
this._triggerUntilTrueFunctionArray = filteredArray;
|
||||||
}
|
}
|
||||||
}
|
}
|
41
ts/lik.timedaggregator.ts
Normal file
41
ts/lik.timedaggregator.ts
Normal file
@ -0,0 +1,41 @@
|
|||||||
|
import * as plugins from './lik.plugins';
|
||||||
|
|
||||||
|
export interface ITimedAggregatorOptions<T> {
|
||||||
|
aggregationIntervalInMillis: number;
|
||||||
|
functionForAggregation: (input: T[]) => void;
|
||||||
|
}
|
||||||
|
|
||||||
|
export class TimedAggregtor<T> {
|
||||||
|
public options: ITimedAggregatorOptions<T>;
|
||||||
|
private storageArray: T[] = [];
|
||||||
|
|
||||||
|
constructor(optionsArg: ITimedAggregatorOptions<T>) {
|
||||||
|
this.options = optionsArg;
|
||||||
|
}
|
||||||
|
|
||||||
|
private aggregationTimer: plugins.smarttime.Timer;
|
||||||
|
private checkAggregationStatus() {
|
||||||
|
const addAggregationTimer = () => {
|
||||||
|
this.aggregationTimer = new plugins.smarttime.Timer(this.options.aggregationIntervalInMillis);
|
||||||
|
this.aggregationTimer.completed.then(() => {
|
||||||
|
const aggregateForProcessing = this.storageArray;
|
||||||
|
if (aggregateForProcessing.length === 0) {
|
||||||
|
this.aggregationTimer = null;
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
this.storageArray = [];
|
||||||
|
addAggregationTimer();
|
||||||
|
this.options.functionForAggregation(aggregateForProcessing);
|
||||||
|
});
|
||||||
|
this.aggregationTimer.start();
|
||||||
|
};
|
||||||
|
if (!this.aggregationTimer) {
|
||||||
|
addAggregationTimer();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public add(aggregationArg: T) {
|
||||||
|
this.storageArray.push(aggregationArg);
|
||||||
|
this.checkAggregationStatus();
|
||||||
|
}
|
||||||
|
}
|
141
ts/lik.tree.ts
Normal file
141
ts/lik.tree.ts
Normal file
@ -0,0 +1,141 @@
|
|||||||
|
import * as plugins from './lik.plugins';
|
||||||
|
|
||||||
|
export class Tree<T> {
|
||||||
|
symbolTree: any;
|
||||||
|
constructor() {
|
||||||
|
this.symbolTree = new plugins.symbolTree();
|
||||||
|
}
|
||||||
|
|
||||||
|
// =======================================
|
||||||
|
// Functions that map to the functionality of symbol-tree
|
||||||
|
// =======================================
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* @param objectArg
|
||||||
|
*/
|
||||||
|
initialize(objectArg: T): T {
|
||||||
|
return this.symbolTree.initialize(objectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
hasChildren(objectArg: T): boolean {
|
||||||
|
return this.symbolTree.hasChildren(objectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
firstChild(objectArg: T): T {
|
||||||
|
return this.symbolTree.firstChild(objectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
lastChild(objectArg: T): T {
|
||||||
|
return this.symbolTree.lastChild(objectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
previousSibling(objectArg: T): T {
|
||||||
|
return this.symbolTree.previousSibling(objectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
nextSibling(objectArg: T): T {
|
||||||
|
return this.symbolTree.nextSibling(objectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
parent(objectArg: T): T {
|
||||||
|
return this.symbolTree.parent(objectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
lastInclusiveDescendant(objectArg: T): T {
|
||||||
|
return this.symbolTree.lastInclusiveDescendant(objectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
preceding(objectArg: T, optionsArg?: any): T {
|
||||||
|
return this.symbolTree.preceding(objectArg, optionsArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
following(object: T, optionsArg: any) {
|
||||||
|
return this.symbolTree.following(object, optionsArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
childrenToArray(parentArg: T, optionsArg: any): T[] {
|
||||||
|
return this.symbolTree.childrenToArray(parentArg, optionsArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
ancestorsToArray(objectArg: T, optionsArg: any): T[] {
|
||||||
|
return this.symbolTree.ancestorsToArray(objectArg, optionsArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
treeToArray(rootArg, optionsArg: any): T[] {
|
||||||
|
return this.symbolTree.treeToArray(rootArg, optionsArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
childrenIterator(parentArg: T, optionsArg): T {
|
||||||
|
return this.symbolTree.childrenIterator(parentArg, optionsArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
previousSiblingsIterator(objectArg): T {
|
||||||
|
return this.symbolTree.previousSiblingsIterator(objectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
nextSiblingsIterator(objectArg: T) {
|
||||||
|
return this.symbolTree.nextSiblingsIterator();
|
||||||
|
}
|
||||||
|
|
||||||
|
ancestorsIterator(objectArg) {
|
||||||
|
this.symbolTree.ancestorsIterator();
|
||||||
|
}
|
||||||
|
|
||||||
|
treeIterator(rootArg: T, optionsArg): Iterable<T> {
|
||||||
|
return this.symbolTree.treeIterator(rootArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
index(childArg: T): number {
|
||||||
|
return this.symbolTree.index(childArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
childrenCount(parentArg: T): number {
|
||||||
|
return this.symbolTree.childrenCount(parentArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
compareTreePosition(leftArg: T, rightArg: T): number {
|
||||||
|
return this.compareTreePosition(leftArg, rightArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
remove(removeObjectArg: T): T {
|
||||||
|
return this.symbolTree.remove(removeObjectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
insertBefore(referenceObjectArg: T, newObjectArg: T): T {
|
||||||
|
return this.symbolTree.insertBefore(referenceObjectArg, newObjectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
insertAfter(referenceObject: T, newObjectArg: T) {
|
||||||
|
return this.symbolTree.insertAfter(referenceObject, newObjectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
prependChild(referenceObjectArg: T, newObjectArg: T): T {
|
||||||
|
return this.symbolTree.prependChild(referenceObjectArg, newObjectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
appendChild(referenceObjectArg, newObjectArg) {
|
||||||
|
return this.symbolTree.appendChild(referenceObjectArg, newObjectArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
// ===========================================
|
||||||
|
// Functionionality that extends symbol-tree
|
||||||
|
// ===========================================
|
||||||
|
|
||||||
|
/**
|
||||||
|
* returns a branch of the tree as JSON
|
||||||
|
* can be user
|
||||||
|
*/
|
||||||
|
toJsonWithHierachy(rootElement) {
|
||||||
|
const treeIterable = this.treeIterator(rootElement, {});
|
||||||
|
for (const treeItem of treeIterable) {
|
||||||
|
console.log(treeItem);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* builds a tree from a JSON with hierachy
|
||||||
|
* @param rootElement
|
||||||
|
*/
|
||||||
|
fromJsonWithHierachy(rootElement) {}
|
||||||
|
}
|
17
tslint.json
Normal file
17
tslint.json
Normal file
@ -0,0 +1,17 @@
|
|||||||
|
{
|
||||||
|
"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"
|
||||||
|
}
|
Reference in New Issue
Block a user