|
|
|
@ -2,7 +2,6 @@ import * as plugins from './npmextra.plugins.js';
|
|
|
|
|
import * as paths from './npmextra.paths.js';
|
|
|
|
|
import { KeyValueStore } from './npmextra.classes.keyvaluestore.js';
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
export interface IAppDataOptions<T = any> {
|
|
|
|
|
dirPath?: string;
|
|
|
|
|
requiredKeys?: Array<keyof T>;
|
|
|
|
@ -15,7 +14,7 @@ export interface IAppDataOptions<T = any> {
|
|
|
|
|
/**
|
|
|
|
|
* kvStoreKey: 'MY_ENV_VAR'
|
|
|
|
|
*/
|
|
|
|
|
envMapping?: plugins.tsclass.typeFest.PartialDeep<T>
|
|
|
|
|
envMapping?: plugins.tsclass.typeFest.PartialDeep<T>;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
export class AppData<T = any> {
|
|
|
|
@ -25,7 +24,9 @@ export class AppData<T = any> {
|
|
|
|
|
* @param pathArg
|
|
|
|
|
* @returns
|
|
|
|
|
*/
|
|
|
|
|
public static async createAndInit<T = any>(optionsArg: IAppDataOptions<T> = {}): Promise<AppData<T>> {
|
|
|
|
|
public static async createAndInit<T = any>(
|
|
|
|
|
optionsArg: IAppDataOptions<T> = {}
|
|
|
|
|
): Promise<AppData<T>> {
|
|
|
|
|
const appData = new AppData<T>(optionsArg);
|
|
|
|
|
await appData.readyDeferred.promise;
|
|
|
|
|
return appData;
|
|
|
|
@ -68,41 +69,81 @@ export class AppData<T = any> {
|
|
|
|
|
typeArg: this.options.ephermal ? 'ephemeral' : 'custom',
|
|
|
|
|
identityArg: 'appkv',
|
|
|
|
|
customPath: this.options.dirPath,
|
|
|
|
|
mandatoryKeys: this.options.requiredKeys as Array<keyof T>
|
|
|
|
|
mandatoryKeys: this.options.requiredKeys as Array<keyof T>,
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
if (this.options.envMapping) {
|
|
|
|
|
const qenvInstance = new plugins.qenv.Qenv(process.cwd(), plugins.path.join(process.cwd(), '.nogit'));
|
|
|
|
|
const qenvInstance = new plugins.qenv.Qenv(
|
|
|
|
|
process.cwd(),
|
|
|
|
|
plugins.path.join(process.cwd(), '.nogit')
|
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
// Recursive function to handle nested objects, now includes key parameter
|
|
|
|
|
const processEnvMapping = async (key: keyof T, mappingValue: any, parentKey: keyof T | '' = ''): Promise<any> => {
|
|
|
|
|
const processEnvMapping = async (
|
|
|
|
|
key: keyof T,
|
|
|
|
|
mappingValue: any,
|
|
|
|
|
parentKey: keyof T | '' = ''
|
|
|
|
|
): Promise<any> => {
|
|
|
|
|
if (typeof mappingValue === 'string') {
|
|
|
|
|
let envValue: string | boolean | T[keyof T];
|
|
|
|
|
let convert: 'none' | 'json' | 'base64' | 'boolean' = 'none'
|
|
|
|
|
if (mappingValue.startsWith('hard:')) {
|
|
|
|
|
envValue = mappingValue.replace('hard:', '') as T[keyof T];
|
|
|
|
|
} else if (mappingValue.startsWith('boolean:')) {
|
|
|
|
|
envValue = await qenvInstance.getEnvVarOnDemand(mappingValue.replace('boolean:', '')) as T[keyof T];
|
|
|
|
|
convert = 'boolean';
|
|
|
|
|
} else if(mappingValue.startsWith('json')) {
|
|
|
|
|
envValue = await qenvInstance.getEnvVarOnDemand(mappingValue.replace('json:', '')) as T[keyof T];
|
|
|
|
|
convert = 'json';
|
|
|
|
|
} else if (mappingValue.startsWith('base64')) {
|
|
|
|
|
envValue = await qenvInstance.getEnvVarOnDemand(mappingValue.replace('base64:', '')) as T[keyof T];
|
|
|
|
|
convert = 'base64';
|
|
|
|
|
} else {
|
|
|
|
|
envValue = await qenvInstance.getEnvVarOnDemand(mappingValue) as T[keyof T];
|
|
|
|
|
let convert: 'none' | 'json' | 'base64' | 'boolean' = 'none';
|
|
|
|
|
switch (true) {
|
|
|
|
|
case mappingValue.startsWith('hard:'):
|
|
|
|
|
envValue = mappingValue.replace('hard:', '') as T[keyof T];
|
|
|
|
|
break;
|
|
|
|
|
case mappingValue.startsWith('hard_boolean:'):
|
|
|
|
|
envValue = mappingValue.replace('hard_boolean:', '') === 'true';
|
|
|
|
|
convert = 'boolean';
|
|
|
|
|
break;
|
|
|
|
|
case mappingValue.startsWith('hard_json:'):
|
|
|
|
|
envValue = JSON.parse(mappingValue.replace('hard_json:', '')) as T[keyof T];
|
|
|
|
|
convert = 'json';
|
|
|
|
|
break;
|
|
|
|
|
case mappingValue.startsWith('hard_base64:'):
|
|
|
|
|
envValue = Buffer.from(
|
|
|
|
|
mappingValue.replace('hard_base64:', ''),
|
|
|
|
|
'base64'
|
|
|
|
|
).toString() as T[keyof T];
|
|
|
|
|
convert = 'base64';
|
|
|
|
|
break;
|
|
|
|
|
case mappingValue.startsWith('boolean:'):
|
|
|
|
|
envValue = (await qenvInstance.getEnvVarOnDemand(
|
|
|
|
|
mappingValue.replace('boolean:', '')
|
|
|
|
|
)) as T[keyof T];
|
|
|
|
|
convert = 'boolean';
|
|
|
|
|
break;
|
|
|
|
|
case mappingValue.startsWith('json:'):
|
|
|
|
|
envValue = (await qenvInstance.getEnvVarOnDemand(
|
|
|
|
|
mappingValue.replace('json:', '')
|
|
|
|
|
)) as T[keyof T];
|
|
|
|
|
convert = 'json';
|
|
|
|
|
break;
|
|
|
|
|
case mappingValue.startsWith('base64:'):
|
|
|
|
|
envValue = (await qenvInstance.getEnvVarOnDemand(
|
|
|
|
|
mappingValue.replace('base64:', '')
|
|
|
|
|
)) as T[keyof T];
|
|
|
|
|
convert = 'base64';
|
|
|
|
|
break;
|
|
|
|
|
default:
|
|
|
|
|
envValue = (await qenvInstance.getEnvVarOnDemand(mappingValue)) as T[keyof T];
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// lets format the env value
|
|
|
|
|
if (envValue) {
|
|
|
|
|
if (convert === 'boolean') {
|
|
|
|
|
if (typeof envValue === 'string' && convert === 'boolean') {
|
|
|
|
|
envValue = envValue === 'true';
|
|
|
|
|
}
|
|
|
|
|
if (typeof envValue === 'string' && (mappingValue.endsWith('_JSON') || convert === 'json')) {
|
|
|
|
|
if (
|
|
|
|
|
typeof envValue === 'string' &&
|
|
|
|
|
(mappingValue.endsWith('_JSON') || convert === 'json')
|
|
|
|
|
) {
|
|
|
|
|
envValue = JSON.parse(envValue as string) as T[keyof T];
|
|
|
|
|
}
|
|
|
|
|
if (typeof envValue === 'string' && (mappingValue.endsWith('_BASE64') || convert === 'base64')) {
|
|
|
|
|
if (
|
|
|
|
|
typeof envValue === 'string' &&
|
|
|
|
|
(mappingValue.endsWith('_BASE64') || convert === 'base64')
|
|
|
|
|
) {
|
|
|
|
|
envValue = Buffer.from(envValue as string, 'base64').toString();
|
|
|
|
|
}
|
|
|
|
|
if (!parentKey) {
|
|
|
|
@ -167,4 +208,4 @@ export class AppData<T = any> {
|
|
|
|
|
await this.kvStore.waitForKeysPresent([keyArg]);
|
|
|
|
|
return this.kvStore.readKey(keyArg);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|