Compare commits

...

8 Commits

Author SHA1 Message Date
e7883f5997 5.0.0 2024-02-12 19:16:44 +01:00
39ab01b4af BREAKING CHANGE(core): update 2024-02-12 19:16:43 +01:00
bb9de1b13b 4.0.16 2024-02-12 18:40:01 +01:00
080e133e9f fix(core): update 2024-02-12 18:40:01 +01:00
a284c58a68 4.0.15 2024-02-10 04:55:51 +01:00
18bb54831d fix(core): update 2024-02-10 04:55:50 +01:00
141c7ed8a7 4.0.14 2024-02-10 04:54:01 +01:00
037481f195 fix(core): update 2024-02-10 04:54:00 +01:00
5 changed files with 42 additions and 25 deletions

View File

@ -1,6 +1,6 @@
{ {
"name": "@push.rocks/npmextra", "name": "@push.rocks/npmextra",
"version": "4.0.13", "version": "5.0.0",
"private": false, "private": false,
"description": "do more with npm", "description": "do more with npm",
"main": "dist_ts/index.js", "main": "dist_ts/index.js",

10
pnpm-lock.yaml generated
View File

@ -87,7 +87,7 @@ packages:
'@push.rocks/smartstream': 3.0.30 '@push.rocks/smartstream': 3.0.30
'@push.rocks/smarttime': 4.0.6 '@push.rocks/smarttime': 4.0.6
'@push.rocks/webstore': 2.0.13 '@push.rocks/webstore': 2.0.13
'@tsclass/tsclass': 4.0.46 '@tsclass/tsclass': 4.0.50
'@types/express': 4.17.21 '@types/express': 4.17.21
body-parser: 1.20.2 body-parser: 1.20.2
cors: 2.8.5 cors: 2.8.5
@ -830,7 +830,7 @@ packages:
'@push.rocks/smartpromise': 4.0.3 '@push.rocks/smartpromise': 4.0.3
'@push.rocks/smartpuppeteer': 2.0.2 '@push.rocks/smartpuppeteer': 2.0.2
'@push.rocks/smartunique': 3.0.6 '@push.rocks/smartunique': 3.0.6
'@tsclass/tsclass': 4.0.46 '@tsclass/tsclass': 4.0.50
'@types/express': 4.17.21 '@types/express': 4.17.21
express: 4.18.2 express: 4.18.2
pdf-merger-js: 3.4.0 pdf-merger-js: 3.4.0
@ -892,7 +892,7 @@ packages:
'@push.rocks/smartxml': 1.0.8 '@push.rocks/smartxml': 1.0.8
'@push.rocks/smartyaml': 2.0.5 '@push.rocks/smartyaml': 2.0.5
'@push.rocks/webrequest': 3.0.34 '@push.rocks/webrequest': 3.0.34
'@tsclass/tsclass': 4.0.46 '@tsclass/tsclass': 4.0.50
dev: true dev: true
/@push.rocks/smartsocket@2.0.24: /@push.rocks/smartsocket@2.0.24:
@ -1335,8 +1335,8 @@ packages:
type-fest: 2.19.0 type-fest: 2.19.0
dev: true dev: true
/@tsclass/tsclass@4.0.46: /@tsclass/tsclass@4.0.50:
resolution: {integrity: sha512-UovPUvlozv1ftJp4KW5tt4MP/LQCNP3lSCinjyIrLkopOymczyzONUGvSAAwOBf1XBE9bO0tI4KtRuXWN9XBXQ==} resolution: {integrity: sha512-ICUe4hfebpvbn8JkReGP1m3DCTq6S5FIhLJzbFx9F7tx6dn909fA9YIEHkFeMj2X7fT5aGvAXOZRlT52GsnSUw==}
dependencies: dependencies:
type-fest: 4.10.2 type-fest: 4.10.2
dev: true dev: true

View File

@ -3,6 +3,6 @@
*/ */
export const commitinfo = { export const commitinfo = {
name: '@push.rocks/npmextra', name: '@push.rocks/npmextra',
version: '4.0.13', version: '5.0.0',
description: 'do more with npm' description: 'do more with npm'
} }

View File

@ -1,6 +1,7 @@
import * as plugins from './npmextra.plugins.js'; import * as plugins from './npmextra.plugins.js';
import * as paths from './npmextra.paths.js'; import * as paths from './npmextra.paths.js';
import { KeyValueStore } from './npmextra.classes.keyvaluestore.js'; import { KeyValueStore } from './npmextra.classes.keyvaluestore.js';
import { env } from 'process';
export interface IAppDataOptions { export interface IAppDataOptions {
dirPath?: string; dirPath?: string;
@ -58,18 +59,21 @@ export class AppData {
this.options.dirPath = nogitAppData; this.options.dirPath = nogitAppData;
} }
} }
this.kvStore = new KeyValueStore( this.kvStore = new KeyValueStore({
'custom', typeArg: 'custom',
'appkv', identityArg: 'appkv',
this.options.dirPath, customPath: this.options.dirPath,
this.options.requiredKeys mandatoryKeys: this.options.requiredKeys
); });
if (this.options.envMapping) { if (this.options.envMapping) {
const qenvInstance = new plugins.qenv.Qenv(process.cwd(), '~/.cloudlyrc'); const qenvInstance = new plugins.qenv.Qenv(process.cwd(), '~/.cloudlyrc');
for (const key in this.options.envMapping) { for (const key in this.options.envMapping) {
const envValue = await qenvInstance.getEnvVarOnDemand(key); let envValue = await qenvInstance.getEnvVarOnDemand(key);
if (envValue) { if (envValue) {
if (key.endsWith('_JSON')) {
envValue = JSON.parse(envValue);
}
await this.kvStore.writeKey(key, envValue); await this.kvStore.writeKey(key, envValue);
} }
} }
@ -99,4 +103,10 @@ export class AppData {
console.log('All mandatory keys are present in the appdata'); console.log('All mandatory keys are present in the appdata');
} }
} }
public async waitForAndGetKey(keyArg: string) {
await this.readyDeferred.promise;
await this.kvStore.waitForKeysPresent([keyArg]);
return this.kvStore.readKey[keyArg];
}
} }

View File

@ -5,11 +5,18 @@ import { Task } from '@push.rocks/taskbuffer';
export type TKeyValueStore = 'custom' | 'userHomeDir'; export type TKeyValueStore = 'custom' | 'userHomeDir';
export interface IKvStoreConstructorOptions {
typeArg: TKeyValueStore;
identityArg: string;
customPath?: string;
mandatoryKeys?: string[];
}
/** /**
* kvStore is a simple key value store to store data about projects between runs * kvStore is a simple key value store to store data about projects between runs
*/ */
export class KeyValueStore { export class KeyValueStore<T = any> {
private dataObject: any = {}; private dataObject: Partial<T> = {};
private deletedObject: any = {}; private deletedObject: any = {};
private mandatoryKeys: Set<string> = new Set(); private mandatoryKeys: Set<string> = new Set();
public changeSubject = new plugins.smartrx.rxjs.Subject(); public changeSubject = new plugins.smartrx.rxjs.Subject();
@ -82,19 +89,19 @@ export class KeyValueStore {
* @param identityArg * @param identityArg
* @param customPath Optional custom path for the keyValue store * @param customPath Optional custom path for the keyValue store
*/ */
constructor(typeArg: TKeyValueStore, identityArg: string, customPath?: string, mandatoryKeys?: string[]) { constructor(optionsArg: IKvStoreConstructorOptions) {
if (customPath && typeArg !== 'custom') { if (optionsArg.customPath && optionsArg.typeArg !== 'custom') {
throw new Error('customPath can only be provided if typeArg is custom'); throw new Error('customPath can only be provided if typeArg is custom');
} }
if (typeArg === 'custom' && !customPath) { if (optionsArg.typeArg === 'custom' && !optionsArg.customPath) {
throw new Error('customPath must be provided if typeArg is custom'); throw new Error('customPath must be provided if typeArg is custom');
} }
this.type = typeArg; this.type = optionsArg.typeArg;
this.identity = identityArg; this.identity = optionsArg.identityArg;
this.customPath = customPath; // Store custom path if provided this.customPath = optionsArg.customPath; // Store custom path if provided
this.initFilePath(); this.initFilePath();
if (mandatoryKeys) { if (optionsArg.mandatoryKeys) {
this.setMandatoryKeys(mandatoryKeys); this.setMandatoryKeys(optionsArg.mandatoryKeys);
} }
} }
@ -167,7 +174,7 @@ export class KeyValueStore {
return Array.from(this.mandatoryKeys).filter(key => !(key in this.dataObject)); return Array.from(this.mandatoryKeys).filter(key => !(key in this.dataObject));
} }
public async waitForKeysPresent(keysArg: []): Promise<void> { public async waitForKeysPresent(keysArg: string[]): Promise<void> {
const missingKeys = keysArg.filter(keyArg => !this.dataObject[keyArg]); const missingKeys = keysArg.filter(keyArg => !this.dataObject[keyArg]);
if (missingKeys.length === 0) { if (missingKeys.length === 0) {
return; return;