Compare commits
28 Commits
Author | SHA1 | Date | |
---|---|---|---|
ad95154284 | |||
7fb47d224e | |||
40175dc4de | |||
115d461d29 | |||
00964a7db1 | |||
b00db37bf4 | |||
995ae20502 | |||
5c805e57a2 | |||
938207f1c5 | |||
e810bd9473 | |||
10d1bb35ce | |||
8e97b51f1f | |||
7159b33425 | |||
5860066621 | |||
fca8c434f6 | |||
6bd3bd4f37 | |||
068199b5e9 | |||
0eb8193e4a | |||
34e898e0cf | |||
3530e376d6 | |||
ef141659e2 | |||
0b3dec53dd | |||
1d5cb914ac | |||
ce7a457509 | |||
89875393ef | |||
fe2c6f312b | |||
905238a962 | |||
e7cd65fbae |
@ -19,23 +19,35 @@ mirror:
|
|||||||
stage: security
|
stage: security
|
||||||
script:
|
script:
|
||||||
- npmci git mirror
|
- npmci git mirror
|
||||||
|
only:
|
||||||
|
- tags
|
||||||
tags:
|
tags:
|
||||||
- lossless
|
- lossless
|
||||||
- docker
|
- docker
|
||||||
- notpriv
|
- notpriv
|
||||||
|
|
||||||
audit:
|
auditProductionDependencies:
|
||||||
|
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
||||||
|
stage: security
|
||||||
|
script:
|
||||||
|
- npmci npm prepare
|
||||||
|
- npmci command npm install --production --ignore-scripts
|
||||||
|
- npmci command npm config set registry https://registry.npmjs.org
|
||||||
|
- npmci command npm audit --audit-level=high --only=prod --production
|
||||||
|
tags:
|
||||||
|
- docker
|
||||||
|
|
||||||
|
auditDevDependencies:
|
||||||
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
||||||
stage: security
|
stage: security
|
||||||
script:
|
script:
|
||||||
- npmci npm prepare
|
- npmci npm prepare
|
||||||
- npmci command npm install --ignore-scripts
|
- npmci command npm install --ignore-scripts
|
||||||
- npmci command npm config set registry https://registry.npmjs.org
|
- npmci command npm config set registry https://registry.npmjs.org
|
||||||
- npmci command npm audit --audit-level=high
|
- npmci command npm audit --audit-level=high --only=dev
|
||||||
tags:
|
tags:
|
||||||
- lossless
|
|
||||||
- docker
|
- docker
|
||||||
- notpriv
|
allow_failure: true
|
||||||
|
|
||||||
# ====================
|
# ====================
|
||||||
# test stage
|
# test stage
|
||||||
@ -50,9 +62,7 @@ testStable:
|
|||||||
- npmci npm test
|
- npmci npm test
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
coverage: /\d+.?\d+?\%\s*coverage/
|
||||||
tags:
|
tags:
|
||||||
- lossless
|
|
||||||
- docker
|
- docker
|
||||||
- priv
|
|
||||||
|
|
||||||
testBuild:
|
testBuild:
|
||||||
stage: test
|
stage: test
|
||||||
@ -63,9 +73,7 @@ testBuild:
|
|||||||
- npmci command npm run build
|
- npmci command npm run build
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
coverage: /\d+.?\d+?\%\s*coverage/
|
||||||
tags:
|
tags:
|
||||||
- lossless
|
|
||||||
- docker
|
- docker
|
||||||
- notpriv
|
|
||||||
|
|
||||||
release:
|
release:
|
||||||
stage: release
|
stage: release
|
||||||
@ -85,6 +93,8 @@ release:
|
|||||||
codequality:
|
codequality:
|
||||||
stage: metadata
|
stage: metadata
|
||||||
allow_failure: true
|
allow_failure: true
|
||||||
|
only:
|
||||||
|
- tags
|
||||||
script:
|
script:
|
||||||
- npmci command npm install -g tslint typescript
|
- npmci command npm install -g tslint typescript
|
||||||
- npmci npm prepare
|
- npmci npm prepare
|
||||||
|
2
.vscode/settings.json
vendored
2
.vscode/settings.json
vendored
@ -15,7 +15,7 @@
|
|||||||
"properties": {
|
"properties": {
|
||||||
"projectType": {
|
"projectType": {
|
||||||
"type": "string",
|
"type": "string",
|
||||||
"enum": ["website", "element", "service", "npm"]
|
"enum": ["website", "element", "service", "npm", "wcc"]
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
3011
package-lock.json
generated
3011
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
24
package.json
24
package.json
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/webstore",
|
"name": "@pushrocks/webstore",
|
||||||
"version": "1.0.2",
|
"version": "1.0.16",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "high performance storage in the browser using indexed db",
|
"description": "high performance storage in the browser using indexed db",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
@ -8,20 +8,24 @@
|
|||||||
"author": "Lossless GmbH",
|
"author": "Lossless GmbH",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"test": "(tstest test/)",
|
"test": "(tstest test/ --web)",
|
||||||
"build": "(tsbuild)",
|
"build": "(tsbuild --web)"
|
||||||
"format": "(gitzone format)"
|
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@gitzone/tsbuild": "^2.0.22",
|
"@gitzone/tsbuild": "^2.1.25",
|
||||||
"@gitzone/tstest": "^1.0.39",
|
"@gitzone/tstest": "^1.0.52",
|
||||||
"@pushrocks/tapbundle": "^3.0.7",
|
"@pushrocks/tapbundle": "^3.2.9",
|
||||||
"@types/node": "^14.0.20",
|
"@types/node": "^14.11.10",
|
||||||
"tslint": "^6.1.2",
|
"tslint": "^6.1.3",
|
||||||
"tslint-config-prettier": "^1.15.0"
|
"tslint-config-prettier": "^1.15.0"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"idb": "^5.0.4"
|
"@apiglobal/typedrequest-interfaces": "^1.0.15",
|
||||||
|
"@pushrocks/lik": "^4.0.17",
|
||||||
|
"@pushrocks/smartjson": "^4.0.5",
|
||||||
|
"@pushrocks/smartpromise": "^3.1.3",
|
||||||
|
"@pushrocks/smartrx": "^2.0.19",
|
||||||
|
"idb": "^5.0.7"
|
||||||
},
|
},
|
||||||
"browserslist": [
|
"browserslist": [
|
||||||
"last 1 chrome versions"
|
"last 1 chrome versions"
|
||||||
|
@ -1,11 +0,0 @@
|
|||||||
import { expect, tap } from '@pushrocks/tapbundle';
|
|
||||||
import * as webstore from '../ts/index';
|
|
||||||
|
|
||||||
let testWebstore = new webstore.WebStore();
|
|
||||||
|
|
||||||
tap.test('first test', async () => {
|
|
||||||
testWebstore = new webstore.WebStore();
|
|
||||||
expect(testWebstore).to.be.instanceOf(webstore.WebStore);
|
|
||||||
});
|
|
||||||
|
|
||||||
tap.start();
|
|
11
test/test.typedrequestcache.browser.ts
Normal file
11
test/test.typedrequestcache.browser.ts
Normal file
@ -0,0 +1,11 @@
|
|||||||
|
import { expect, tap } from '@pushrocks/tapbundle';
|
||||||
|
import * as webstore from '../ts/index';
|
||||||
|
|
||||||
|
let testTypedrequestcache: webstore.TypedrequestCache;
|
||||||
|
|
||||||
|
tap.test('first test', async () => {
|
||||||
|
testTypedrequestcache = new webstore.TypedrequestCache('https://test.lossless.com/typedrequest')
|
||||||
|
expect(testTypedrequestcache).to.be.instanceOf(webstore.TypedrequestCache);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.start();
|
40
test/test.webstore.browser.ts
Normal file
40
test/test.webstore.browser.ts
Normal file
@ -0,0 +1,40 @@
|
|||||||
|
import { expect, tap } from '@pushrocks/tapbundle';
|
||||||
|
import * as webstore from '../ts/index';
|
||||||
|
|
||||||
|
let testWebstore: webstore.WebStore;
|
||||||
|
|
||||||
|
tap.test('first test', async () => {
|
||||||
|
testWebstore = new webstore.WebStore({
|
||||||
|
dbName: 'mytest-db',
|
||||||
|
storeName: 'mytest-store',
|
||||||
|
});
|
||||||
|
expect(testWebstore).to.be.instanceOf(webstore.WebStore);
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should allow storing a string', async () => {
|
||||||
|
await testWebstore.set('mystring', 'heythere');
|
||||||
|
expect(await testWebstore.get('mystring')).to.equal('heythere');
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should allow storing an object', async () => {
|
||||||
|
await testWebstore.set('testProp1', {
|
||||||
|
wow: 'wowVal',
|
||||||
|
});
|
||||||
|
console.log(JSON.stringify(await testWebstore.get('testProp1')));
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should overwrite a value', async () => {
|
||||||
|
await testWebstore.set('testProp1', {
|
||||||
|
wow: 'wowVal2',
|
||||||
|
});
|
||||||
|
console.log(JSON.stringify(await testWebstore.get('testProp1')));
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.test('should correctly check the existence of keys', async () => {
|
||||||
|
const resultNotThere = await testWebstore.check('notThere');
|
||||||
|
const resultThere = await testWebstore.check('testProp1');
|
||||||
|
expect(resultNotThere).to.be.false;
|
||||||
|
expect(resultThere).to.be.true;
|
||||||
|
});
|
||||||
|
|
||||||
|
tap.start();
|
@ -1 +1,2 @@
|
|||||||
export * from './webstiore.classes.webstore';
|
export * from './webstore.classes.typedrequestcache';
|
||||||
|
export * from './webstore.classes.webstore';
|
||||||
|
@ -1,5 +0,0 @@
|
|||||||
import * as plugins from './webstore.plugins';
|
|
||||||
|
|
||||||
export class WebStore {
|
|
||||||
|
|
||||||
}
|
|
47
ts/webstore.classes.typedrequestcache.ts
Normal file
47
ts/webstore.classes.typedrequestcache.ts
Normal file
@ -0,0 +1,47 @@
|
|||||||
|
import { WebStore } from './webstore.classes.webstore';
|
||||||
|
import * as plugins from './webstore.plugins';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* a cache that can be used to store and retrieve typedrequests
|
||||||
|
*/
|
||||||
|
export class TypedrequestCache {
|
||||||
|
private webstore: WebStore;
|
||||||
|
|
||||||
|
constructor(domainArg = 'default') {
|
||||||
|
this.webstore = new WebStore<plugins.typedrequestInterfaces.ITypedRequest>({
|
||||||
|
dbName: 'trStore',
|
||||||
|
storeName: `trStore-${domainArg}`,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
private buildKey(requestArg: plugins.typedrequestInterfaces.ITypedRequest) {
|
||||||
|
return plugins.smartjson.stringify({
|
||||||
|
method: requestArg.method,
|
||||||
|
request: requestArg.request,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* stores by request
|
||||||
|
* @param typedrequestarg
|
||||||
|
*/
|
||||||
|
public async setByRequest(
|
||||||
|
typedrequestArg: plugins.typedrequestInterfaces.ITypedRequest
|
||||||
|
): Promise<void> {
|
||||||
|
if (!typedrequestArg.response) {
|
||||||
|
throw new Error('You cannot store requests without a response present');
|
||||||
|
}
|
||||||
|
await this.webstore.set(this.buildKey(typedrequestArg), typedrequestArg);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* get by full tyoedrequest by partial typedrequest
|
||||||
|
* @param typedrequestarg
|
||||||
|
*/
|
||||||
|
public async getByRequest(
|
||||||
|
typedrequestArg: plugins.typedrequestInterfaces.ITypedRequest
|
||||||
|
): Promise<plugins.typedrequestInterfaces.ITypedRequest> {
|
||||||
|
const result = await this.webstore.get(this.buildKey(typedrequestArg));
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
}
|
64
ts/webstore.classes.webstore.ts
Normal file
64
ts/webstore.classes.webstore.ts
Normal file
@ -0,0 +1,64 @@
|
|||||||
|
import * as plugins from './webstore.plugins';
|
||||||
|
|
||||||
|
export interface IWebStoreOptions {
|
||||||
|
dbName: string;
|
||||||
|
storeName: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export class WebStore<T = any> {
|
||||||
|
public db: plugins.idb.IDBPDatabase;
|
||||||
|
public objectStore: plugins.idb.IDBPObjectStore;
|
||||||
|
public options: IWebStoreOptions;
|
||||||
|
private initCalled: boolean = false;
|
||||||
|
private readyDeferred = plugins.smartpromise.defer();
|
||||||
|
|
||||||
|
constructor(optionsArg: IWebStoreOptions) {
|
||||||
|
this.options = optionsArg;
|
||||||
|
}
|
||||||
|
|
||||||
|
public async init() {
|
||||||
|
if (this.initCalled) {
|
||||||
|
await this.readyDeferred.promise;
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
this.initCalled = true;
|
||||||
|
this.db = await plugins.idb.openDB(this.options.dbName, 1, {
|
||||||
|
upgrade: (db) => {
|
||||||
|
db.createObjectStore(this.options.storeName);
|
||||||
|
},
|
||||||
|
});
|
||||||
|
this.readyDeferred.resolve();
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
async get(key: string): Promise<T> {
|
||||||
|
await this.init();
|
||||||
|
return this.db.get(this.options.storeName, key);
|
||||||
|
}
|
||||||
|
|
||||||
|
async check(keyArg: string): Promise<boolean> {
|
||||||
|
await this.init();
|
||||||
|
const result = await this.get(keyArg);
|
||||||
|
return !!result;
|
||||||
|
}
|
||||||
|
|
||||||
|
async set(key: string, val: T) {
|
||||||
|
await this.init();
|
||||||
|
return this.db.put(this.options.storeName, val, key);
|
||||||
|
}
|
||||||
|
|
||||||
|
async delete(key: string) {
|
||||||
|
await this.init();
|
||||||
|
return this.db.delete(this.options.storeName, key);
|
||||||
|
}
|
||||||
|
|
||||||
|
async clear() {
|
||||||
|
await this.init();
|
||||||
|
return this.db.clear(this.options.storeName);
|
||||||
|
}
|
||||||
|
|
||||||
|
async keys() {
|
||||||
|
await this.init();
|
||||||
|
return this.db.getAllKeys(this.options.storeName);
|
||||||
|
}
|
||||||
|
}
|
@ -1,5 +1,17 @@
|
|||||||
|
// pushrocks scope
|
||||||
|
import * as lik from '@pushrocks/lik';
|
||||||
|
import * as smartjson from '@pushrocks/smartjson';
|
||||||
|
import * as smartpromise from '@pushrocks/smartpromise';
|
||||||
|
import * as smartrx from '@pushrocks/smartrx';
|
||||||
|
|
||||||
|
export { lik, smartjson, smartpromise, smartrx };
|
||||||
|
|
||||||
|
// apiglobal scope
|
||||||
|
import * as typedrequestInterfaces from '@apiglobal/typedrequest-interfaces';
|
||||||
|
|
||||||
|
export { typedrequestInterfaces };
|
||||||
|
|
||||||
|
// thirdparty scope
|
||||||
import * as idb from 'idb';
|
import * as idb from 'idb';
|
||||||
|
|
||||||
export {
|
export { idb };
|
||||||
idb
|
|
||||||
}
|
|
||||||
|
Reference in New Issue
Block a user