Compare commits

...

10 Commits

Author SHA1 Message Date
9a55303978 5.0.4 2024-02-13 00:50:51 +01:00
224125fb8e fix(core): update 2024-02-13 00:50:50 +01:00
df9d197508 5.0.3 2024-02-13 00:48:45 +01:00
ae33716af4 fix(core): update 2024-02-13 00:48:44 +01:00
31b64eda5e 5.0.2 2024-02-12 20:09:27 +01:00
7f3437e3cd fix(core): update 2024-02-12 20:09:26 +01:00
8903bee78d 5.0.1 2024-02-12 19:16:58 +01:00
a02b45a673 fix(core): update 2024-02-12 19:16:57 +01:00
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
5 changed files with 69 additions and 35 deletions

View File

@ -1,6 +1,6 @@
{
"name": "@push.rocks/npmextra",
"version": "4.0.16",
"version": "5.0.4",
"private": false,
"description": "do more with npm",
"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/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

View File

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

View File

@ -11,19 +11,19 @@ export interface IAppDataOptions {
* kvStoreKey: 'MY_ENV_VAR'
*/
envMapping?: {
[key: string]: string;
[key: string]: string | object;
};
}
export class AppData {
export class AppData<T = any> {
/**
* creates appdata. If no pathArg is given, data will be stored here:
* ${PWD}/.nogit/appdata
* @param pathArg
* @returns
*/
public static async createAndInit(optionsArg: IAppDataOptions = {}) {
const appData = new AppData(optionsArg);
public static async createAndInit<T = any>(optionsArg: IAppDataOptions = {}): Promise<AppData<T>> {
const appData = new AppData<T>(optionsArg);
await appData.readyDeferred.promise;
return appData;
}
@ -31,7 +31,7 @@ export class AppData {
// instance
public readyDeferred = plugins.smartpromise.defer();
public options: IAppDataOptions;
private kvStore: KeyValueStore;
private kvStore: KeyValueStore<T>;
constructor(optionsArg: IAppDataOptions = {}) {
this.options = optionsArg;
this.init();
@ -59,25 +59,52 @@ 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) {
let envValue = await qenvInstance.getEnvVarOnDemand(key);
const qenvInstance = new plugins.qenv.Qenv();
// Recursive function to handle nested objects, now includes key parameter
const processEnvMapping = async (key: string, mappingValue: any, parentKey: string = ''): Promise<any> => {
if (typeof mappingValue === 'string') {
let envValue = await qenvInstance.getEnvVarOnDemand(mappingValue);
if (envValue) {
if (key.endsWith('_JSON')) {
if (mappingValue.endsWith('_JSON')) {
envValue = JSON.parse(envValue);
}
await this.kvStore.writeKey(key, envValue);
// Determine the correct key to use (top-level or nested)
const effectiveKey = parentKey || key;
this.kvStore.writeKey(effectiveKey, envValue);
}
} else if (typeof mappingValue === 'object' && mappingValue !== null) {
const resultObject = {};
for (const innerKey in mappingValue) {
const nestedValue = mappingValue[innerKey];
// For nested objects, call recursively but do not immediately write to kvStore
const nestedResult = await processEnvMapping(innerKey, nestedValue, key);
resultObject[innerKey] = nestedResult;
}
if (parentKey === '') {
// Only write to kvStore if at the top level
this.kvStore.writeKey(key, resultObject);
} else {
// For nested objects, return the constructed object instead of writing to kvStore
return resultObject;
}
}
};
for (const key in this.options.envMapping) {
await processEnvMapping(key, this.options.envMapping[key]);
}
}
this.readyDeferred.resolve();
}

View File

@ -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);
}
}