Compare commits
8 Commits
Author | SHA1 | Date | |
---|---|---|---|
e7883f5997 | |||
39ab01b4af | |||
bb9de1b13b | |||
080e133e9f | |||
a284c58a68 | |||
18bb54831d | |||
141c7ed8a7 | |||
037481f195 |
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@push.rocks/npmextra",
|
||||
"version": "4.0.13",
|
||||
"version": "5.0.0",
|
||||
"private": false,
|
||||
"description": "do more with npm",
|
||||
"main": "dist_ts/index.js",
|
||||
|
10
pnpm-lock.yaml
generated
10
pnpm-lock.yaml
generated
@ -87,7 +87,7 @@ packages:
|
||||
'@push.rocks/smartstream': 3.0.30
|
||||
'@push.rocks/smarttime': 4.0.6
|
||||
'@push.rocks/webstore': 2.0.13
|
||||
'@tsclass/tsclass': 4.0.46
|
||||
'@tsclass/tsclass': 4.0.50
|
||||
'@types/express': 4.17.21
|
||||
body-parser: 1.20.2
|
||||
cors: 2.8.5
|
||||
@ -830,7 +830,7 @@ packages:
|
||||
'@push.rocks/smartpromise': 4.0.3
|
||||
'@push.rocks/smartpuppeteer': 2.0.2
|
||||
'@push.rocks/smartunique': 3.0.6
|
||||
'@tsclass/tsclass': 4.0.46
|
||||
'@tsclass/tsclass': 4.0.50
|
||||
'@types/express': 4.17.21
|
||||
express: 4.18.2
|
||||
pdf-merger-js: 3.4.0
|
||||
@ -892,7 +892,7 @@ packages:
|
||||
'@push.rocks/smartxml': 1.0.8
|
||||
'@push.rocks/smartyaml': 2.0.5
|
||||
'@push.rocks/webrequest': 3.0.34
|
||||
'@tsclass/tsclass': 4.0.46
|
||||
'@tsclass/tsclass': 4.0.50
|
||||
dev: true
|
||||
|
||||
/@push.rocks/smartsocket@2.0.24:
|
||||
@ -1335,8 +1335,8 @@ packages:
|
||||
type-fest: 2.19.0
|
||||
dev: true
|
||||
|
||||
/@tsclass/tsclass@4.0.46:
|
||||
resolution: {integrity: sha512-UovPUvlozv1ftJp4KW5tt4MP/LQCNP3lSCinjyIrLkopOymczyzONUGvSAAwOBf1XBE9bO0tI4KtRuXWN9XBXQ==}
|
||||
/@tsclass/tsclass@4.0.50:
|
||||
resolution: {integrity: sha512-ICUe4hfebpvbn8JkReGP1m3DCTq6S5FIhLJzbFx9F7tx6dn909fA9YIEHkFeMj2X7fT5aGvAXOZRlT52GsnSUw==}
|
||||
dependencies:
|
||||
type-fest: 4.10.2
|
||||
dev: true
|
||||
|
@ -3,6 +3,6 @@
|
||||
*/
|
||||
export const commitinfo = {
|
||||
name: '@push.rocks/npmextra',
|
||||
version: '4.0.13',
|
||||
version: '5.0.0',
|
||||
description: 'do more with npm'
|
||||
}
|
||||
|
@ -1,6 +1,7 @@
|
||||
import * as plugins from './npmextra.plugins.js';
|
||||
import * as paths from './npmextra.paths.js';
|
||||
import { KeyValueStore } from './npmextra.classes.keyvaluestore.js';
|
||||
import { env } from 'process';
|
||||
|
||||
export interface IAppDataOptions {
|
||||
dirPath?: string;
|
||||
@ -58,18 +59,21 @@ export class AppData {
|
||||
this.options.dirPath = nogitAppData;
|
||||
}
|
||||
}
|
||||
this.kvStore = new KeyValueStore(
|
||||
'custom',
|
||||
'appkv',
|
||||
this.options.dirPath,
|
||||
this.options.requiredKeys
|
||||
);
|
||||
this.kvStore = new KeyValueStore({
|
||||
typeArg: 'custom',
|
||||
identityArg: 'appkv',
|
||||
customPath: this.options.dirPath,
|
||||
mandatoryKeys: this.options.requiredKeys
|
||||
});
|
||||
|
||||
if (this.options.envMapping) {
|
||||
const qenvInstance = new plugins.qenv.Qenv(process.cwd(), '~/.cloudlyrc');
|
||||
for (const key in this.options.envMapping) {
|
||||
const envValue = await qenvInstance.getEnvVarOnDemand(key);
|
||||
let envValue = await qenvInstance.getEnvVarOnDemand(key);
|
||||
if (envValue) {
|
||||
if (key.endsWith('_JSON')) {
|
||||
envValue = JSON.parse(envValue);
|
||||
}
|
||||
await this.kvStore.writeKey(key, envValue);
|
||||
}
|
||||
}
|
||||
@ -99,4 +103,10 @@ export class 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];
|
||||
}
|
||||
}
|
||||
|
@ -5,11 +5,18 @@ import { Task } from '@push.rocks/taskbuffer';
|
||||
|
||||
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
|
||||
*/
|
||||
export class KeyValueStore {
|
||||
private dataObject: any = {};
|
||||
export class KeyValueStore<T = any> {
|
||||
private dataObject: Partial<T> = {};
|
||||
private deletedObject: any = {};
|
||||
private mandatoryKeys: Set<string> = new Set();
|
||||
public changeSubject = new plugins.smartrx.rxjs.Subject();
|
||||
@ -82,19 +89,19 @@ export class KeyValueStore {
|
||||
* @param identityArg
|
||||
* @param customPath Optional custom path for the keyValue store
|
||||
*/
|
||||
constructor(typeArg: TKeyValueStore, identityArg: string, customPath?: string, mandatoryKeys?: string[]) {
|
||||
if (customPath && typeArg !== 'custom') {
|
||||
constructor(optionsArg: IKvStoreConstructorOptions) {
|
||||
if (optionsArg.customPath && optionsArg.typeArg !== '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');
|
||||
}
|
||||
this.type = typeArg;
|
||||
this.identity = identityArg;
|
||||
this.customPath = customPath; // Store custom path if provided
|
||||
this.type = optionsArg.typeArg;
|
||||
this.identity = optionsArg.identityArg;
|
||||
this.customPath = optionsArg.customPath; // Store custom path if provided
|
||||
this.initFilePath();
|
||||
if (mandatoryKeys) {
|
||||
this.setMandatoryKeys(mandatoryKeys);
|
||||
if (optionsArg.mandatoryKeys) {
|
||||
this.setMandatoryKeys(optionsArg.mandatoryKeys);
|
||||
}
|
||||
}
|
||||
|
||||
@ -167,7 +174,7 @@ export class KeyValueStore {
|
||||
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]);
|
||||
if (missingKeys.length === 0) {
|
||||
return;
|
||||
|
Reference in New Issue
Block a user