1.0.15

.gitlab-ci.yml

@@ -19,23 +19,35 @@ mirror:
   stage: security
   script:
     - npmci git mirror
+  only:
+    - tags
   tags:
     - lossless
     - docker
     - 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
   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
+    - npmci command npm audit --audit-level=high --only=dev
   tags:
-    - lossless
     - docker
-    - notpriv
+  allow_failure: true
 
 # ====================
 # test stage
@@ -50,9 +62,7 @@ testStable:
     - npmci npm test
   coverage: /\d+.?\d+?\%\s*coverage/
   tags:
-    - lossless
     - docker
-    - priv
 
 testBuild:
   stage: test
@@ -63,9 +73,7 @@ testBuild:
     - npmci command npm run build
   coverage: /\d+.?\d+?\%\s*coverage/
   tags:
-    - lossless
     - docker
-    - notpriv
 
 release:
   stage: release
@@ -85,6 +93,8 @@ release:
 codequality:
   stage: metadata
   allow_failure: true
+  only:
+    - tags
   script:
     - npmci command npm install -g tslint typescript
     - npmci npm prepare

.vscode/settings.json

@@ -15,7 +15,7 @@
             "properties": {
               "projectType": {
                 "type": "string",
-                "enum": ["website", "element", "service", "npm"]
+                "enum": ["website", "element", "service", "npm", "wcc"]
               }
             }
           }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/webstore",
-  "version": "1.0.6",
+  "version": "1.0.15",
   "private": false,
   "description": "high performance storage in the browser using indexed db",
   "main": "dist_ts/index.js",
@@ -9,19 +9,23 @@
   "license": "MIT",
   "scripts": {
     "test": "(tstest test/ --web)",
-    "build": "(tsbuild --web)",
-    "format": "(gitzone format)"
+    "build": "(tsbuild --web)"
   },
   "devDependencies": {
-    "@gitzone/tsbuild": "^2.0.22",
-    "@gitzone/tstest": "^1.0.39",
-    "@pushrocks/tapbundle": "^3.0.7",
-    "@types/node": "^14.0.20",
-    "tslint": "^6.1.2",
+    "@gitzone/tsbuild": "^2.1.25",
+    "@gitzone/tstest": "^1.0.52",
+    "@pushrocks/tapbundle": "^3.2.9",
+    "@types/node": "^14.11.10",
+    "tslint": "^6.1.3",
     "tslint-config-prettier": "^1.15.0"
   },
   "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": [
     "last 1 chrome versions"

test/test.browser.ts

@@ -5,21 +5,36 @@ let testWebstore: webstore.WebStore;
 
 tap.test('first test', async () => {
   testWebstore = new webstore.WebStore({
-    dbName: 'mytestdb',
-    storeName: 'myteststore'
+    dbName: 'mytest-db',
+    storeName: 'mytest-store',
   });
   expect(testWebstore).to.be.instanceOf(webstore.WebStore);
 });
 
-tap.test('should init the database', async () => {
-  await testWebstore.init();
+tap.test('should allow storing a string', async () => {
+  await testWebstore.set('mystring', 'heythere');
+  expect(await testWebstore.get('mystring')).to.equal('heythere');
 });
 
-tap.test('should store a value', async () => {
+tap.test('should allow storing an object', async () => {
   await testWebstore.set('testProp1', {
-    wow: 'wowVal'
+    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();

ts/index.ts

@@ -1 +1 @@
-export * from './webstiore.classes.webstore';
+export * from './webstore.classes.webstore';

ts/webstore.classes.typedrequestcache.ts

@@ -0,0 +1,43 @@
+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 = new WebStore<plugins.typedrequestInterfaces.ITypedRequest>({
+    dbName: 'trStore',
+    storeName: 'trStore',
+  });
+
+  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;
+  }
+}

ts/webstore.classes.webstore.ts

@@ -9,37 +9,56 @@ 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 () {
+  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) {
+  async get(key: string): Promise<T> {
+    await this.init();
     return this.db.get(this.options.storeName, key);
   }
 
-  async set(key, val) {
+  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) {
+  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);
   }
 }

ts/webstore.plugins.ts

@@ -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';
 
-export {
-  idb
-}
+export { idb };