quidproquo-core
Advanced tools
Comparing version 0.0.22 to 0.0.24
export declare enum ConfigActionType { | ||
GetSecret = "@quidproquo-core/Config/GetSecret" | ||
GetSecret = "@quidproquo-core/Config/GetSecret", | ||
GetParameter = "@quidproquo-core/Config/GetParameter", | ||
GetParameters = "@quidproquo-core/Config/GetParameters" | ||
} |
@@ -7,2 +7,4 @@ "use strict"; | ||
ConfigActionType["GetSecret"] = "@quidproquo-core/Config/GetSecret"; | ||
ConfigActionType["GetParameter"] = "@quidproquo-core/Config/GetParameter"; | ||
ConfigActionType["GetParameters"] = "@quidproquo-core/Config/GetParameters"; | ||
})(ConfigActionType = exports.ConfigActionType || (exports.ConfigActionType = {})); |
export * from './ConfigActionType'; | ||
export * from './ConfigGetParameterActionRequester'; | ||
export * from './ConfigGetParameterActionTypes'; | ||
export * from './ConfigGetParametersActionRequester'; | ||
export * from './ConfigGetParametersActionTypes'; | ||
export * from './ConfigGetSecretActionRequester'; | ||
export * from './ConfigGetSecretActionTypes'; |
@@ -18,3 +18,7 @@ "use strict"; | ||
__exportStar(require("./ConfigActionType"), exports); | ||
__exportStar(require("./ConfigGetParameterActionRequester"), exports); | ||
__exportStar(require("./ConfigGetParameterActionTypes"), exports); | ||
__exportStar(require("./ConfigGetParametersActionRequester"), exports); | ||
__exportStar(require("./ConfigGetParametersActionTypes"), exports); | ||
__exportStar(require("./ConfigGetSecretActionRequester"), exports); | ||
__exportStar(require("./ConfigGetSecretActionTypes"), exports); |
@@ -5,3 +5,4 @@ export declare enum QPQCoreConfigSettingType { | ||
schedule = "@quidproquo-core/config/schedule", | ||
secret = "@quidproquo-core/config/secret" | ||
secret = "@quidproquo-core/config/secret", | ||
parameter = "@quidproquo-core/config/parameter" | ||
} | ||
@@ -8,0 +9,0 @@ export interface QPQConfigSetting { |
@@ -10,2 +10,3 @@ "use strict"; | ||
QPQCoreConfigSettingType["secret"] = "@quidproquo-core/config/secret"; | ||
QPQCoreConfigSettingType["parameter"] = "@quidproquo-core/config/parameter"; | ||
})(QPQCoreConfigSettingType = exports.QPQCoreConfigSettingType || (exports.QPQCoreConfigSettingType = {})); |
export * from './appName'; | ||
export * from './parameter'; | ||
export * from './schedule'; | ||
export * from './secret'; | ||
export * from './storageDrive'; |
@@ -18,4 +18,5 @@ "use strict"; | ||
__exportStar(require("./appName"), exports); | ||
__exportStar(require("./parameter"), exports); | ||
__exportStar(require("./schedule"), exports); | ||
__exportStar(require("./secret"), exports); | ||
__exportStar(require("./storageDrive"), exports); |
import { QPQConfig, QPQConfigSetting } from './config/QPQConfig'; | ||
import { ScheduleQPQConfigSetting, SecretQPQConfigSetting } from './config/settings'; | ||
import { ScheduleQPQConfigSetting, SecretQPQConfigSetting, ParameterQPQConfigSetting } from './config/settings'; | ||
export declare const getConfigSettings: <T extends QPQConfigSetting>(configs: QPQConfig, configSettingType: string) => T[]; | ||
@@ -10,2 +10,3 @@ export declare const getConfigSetting: <T extends QPQConfigSetting>(configs: QPQConfig, serviceInfrastructureConfigType: string) => T | undefined; | ||
export declare const getOwnedSecrets: (configs: QPQConfig) => SecretQPQConfigSetting[]; | ||
export declare const getOwnedParameters: (configs: QPQConfig) => ParameterQPQConfigSetting[]; | ||
export declare const getSharedSecrets: (configs: QPQConfig) => SecretQPQConfigSetting[]; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.getSharedSecrets = exports.getOwnedSecrets = exports.getAllSrcEntries = exports.getScheduleEvents = exports.getStorageDriveNames = exports.getAppName = exports.getConfigSetting = exports.getConfigSettings = void 0; | ||
exports.getSharedSecrets = exports.getOwnedParameters = exports.getOwnedSecrets = exports.getAllSrcEntries = exports.getScheduleEvents = exports.getStorageDriveNames = exports.getAppName = exports.getConfigSetting = exports.getConfigSettings = void 0; | ||
const QPQConfig_1 = require("./config/QPQConfig"); | ||
@@ -43,2 +43,7 @@ const getConfigSettings = (configs, configSettingType) => { | ||
exports.getOwnedSecrets = getOwnedSecrets; | ||
const getOwnedParameters = (configs) => { | ||
const secrets = (0, exports.getConfigSettings)(configs, QPQConfig_1.QPQCoreConfigSettingType.parameter); | ||
return secrets.filter((s) => s.owned); | ||
}; | ||
exports.getOwnedParameters = getOwnedParameters; | ||
const getSharedSecrets = (configs) => { | ||
@@ -45,0 +50,0 @@ const secrets = (0, exports.getConfigSettings)(configs, QPQConfig_1.QPQCoreConfigSettingType.secret); |
@@ -1,5 +0,3 @@ | ||
import { Action, ActionProcessor } from './types/Action'; | ||
import { Action, ActionProcessorList } from './types/Action'; | ||
import { StoryResult, StorySession } from './types/StorySession'; | ||
export declare const createRuntime: (session: StorySession, actionProcessors: { | ||
[key: string]: ActionProcessor<any, any, any>; | ||
}, getTimeNow: () => string, logger: (res: StoryResult<any>) => void, newGuid: () => string) => <TArgs extends any[]>(story: (...args: TArgs) => Generator<any, any, Action<any>>, args: TArgs) => Promise<StoryResult<any>>; | ||
export declare const createRuntime: (session: StorySession, actionProcessors: ActionProcessorList, getTimeNow: () => string, logger: (res: StoryResult<any>) => void, newGuid: () => string) => <TArgs extends any[]>(story: (...args: TArgs) => Generator<any, any, Action<any>>, args: TArgs) => Promise<StoryResult<any>>; |
@@ -29,3 +29,3 @@ "use strict"; | ||
} | ||
return yield processor(action.payload, session); | ||
return yield processor(action.payload, session, actionProcessors); | ||
}); | ||
@@ -51,3 +51,3 @@ } | ||
const actionResult = yield processAction(action.value, actionProcessors, session); | ||
response.history.push({ | ||
const history = { | ||
act: action.value, | ||
@@ -57,3 +57,5 @@ res: actionResult, | ||
finishedAt: getTimeNow(), | ||
}); | ||
}; | ||
console.log(`${action.value.type}: took ${new Date(history.finishedAt).getTime() - new Date(history.startedAt).getTime()}ms`); | ||
response.history.push(history); | ||
if ((0, actionLogic_1.isErroredActionResult)(actionResult)) { | ||
@@ -81,2 +83,3 @@ return Object.assign(Object.assign({}, response), { finishedAt: getTimeNow(), error: (0, actionLogic_1.resolveActionResultError)(actionResult) }); | ||
yield logger(storyResult); | ||
console.log(`story took took ${new Date(storyResult.finishedAt).getTime() - new Date(storyResult.startedAt).getTime()}ms`); | ||
return storyResult; | ||
@@ -83,0 +86,0 @@ }); |
@@ -8,3 +8,6 @@ import { QPQError } from './ErrorTypeEnum'; | ||
export type ActionProcessorResult<T> = [T?, QPQError?]; | ||
export type ActionProcessor<TAction extends Action<any>, TReturn = any, TActionPayload = TAction['payload']> = (payload: TActionPayload, session: StorySession) => Promise<ActionProcessorResult<TReturn>>; | ||
export type ActionProcessor<TAction extends Action<any>, TReturn = any, TActionPayload = TAction['payload']> = (payload: TActionPayload, session: StorySession, actionProcessors: ActionProcessorList) => Promise<ActionProcessorResult<TReturn>>; | ||
export type ActionRequester<TAction extends Action<any>, TReturn = undefined, TQPQReturn = TReturn> = Generator<TAction, TReturn, TQPQReturn>; | ||
export type ActionProcessorList = { | ||
[key: string]: ActionProcessor<any, any, any>; | ||
}; |
@@ -12,3 +12,4 @@ export declare enum ErrorTypeEnum { | ||
NoContent = "NoContent", | ||
BadRequest = "BadRequest" | ||
BadRequest = "BadRequest", | ||
Invalid = "Invalid" | ||
} | ||
@@ -15,0 +16,0 @@ export interface QPQError { |
@@ -31,2 +31,4 @@ "use strict"; | ||
ErrorTypeEnum["BadRequest"] = "BadRequest"; | ||
// Bad data from client / invalid payload? | ||
ErrorTypeEnum["Invalid"] = "Invalid"; | ||
})(ErrorTypeEnum = exports.ErrorTypeEnum || (exports.ErrorTypeEnum = {})); |
{ | ||
"name": "quidproquo-core", | ||
"version": "0.0.22", | ||
"version": "0.0.24", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "./lib/index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
85114
174
1728