quidproquo-core - npm Package Compare versions

Comparing version 0.0.163 to 0.0.164

lib/commonjs/actions/system/SystemBatchActionTypes.d.ts

@@ -10,3 +10,3 @@ import { SystemActionType } from './SystemActionType';
 }
-export type SystemBatchActionProcessor<TReturn extends Array<any>> = ActionProcessor<SystemBatchAction | Action<any>, TReturn>;
+export type SystemBatchActionProcessor<TReturn extends Array<any>> = ActionProcessor<SystemBatchAction, TReturn>;
 export type SystemBatchActionRequester<TReturn extends Array<any>> = ActionRequester<SystemBatchAction | Action<any>, TReturn>;

lib/commonjs/config/settings/storageDrive.d.ts

@@ -55,6 +55,2 @@ import { QpqSourceEntry } from './queue';
 }
-export declare enum StorageDriveEvent {
-    CREATED = "CREATED",
-    DELETED = "DELETED"
-}
 export type StorageDriveTransition = {
@@ -61,0 +57,0 @@ storageDriveTier: StorageDriveTier;

lib/commonjs/config/settings/storageDrive.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.defineStorageDrive = exports.StorageDriveEvent = exports.StorageDriveTier = void 0;
+exports.defineStorageDrive = exports.StorageDriveTier = void 0;
 const QPQConfig_1 = require("../QPQConfig");
@@ -58,7 +58,2 @@ const qpqCoreUtils_1 = require("../../qpqCoreUtils");
 })(StorageDriveTier = exports.StorageDriveTier || (exports.StorageDriveTier = {}));
-var StorageDriveEvent;
-(function (StorageDriveEvent) {
-    StorageDriveEvent["CREATED"] = "CREATED";
-    StorageDriveEvent["DELETED"] = "DELETED";
-})(StorageDriveEvent = exports.StorageDriveEvent || (exports.StorageDriveEvent = {}));
 const defineStorageDrive = (storageDrive, options) => {
@@ -65,0 +60,0 @@ var _a;

lib/commonjs/qpqExecuteLog.js

@@ -20,3 +20,7 @@ "use strict";
         get: (target, property) => {
-            return () => __awaiter(void 0, void 0, void 0, function* () { return storyResult.history[logIndex++].res; });
+            return () => __awaiter(void 0, void 0, void 0, function* () {
+                const res = storyResult.history[logIndex].res;
+                logIndex = logIndex + 1;
+                return res;
+            });
         },
@@ -27,3 +31,3 @@ });
         correlation: storyResult.fromCorrelation,
-        depth: 0,
+        depth: storyResult.session.depth,
         context: storyResult.session.context,
@@ -30,0 +34,0 @@ }, storyActionProcessor, () => new Date().toISOString(), () => __awaiter(void 0, void 0, void 0, function* () { }), storyResult.correlation, storyResult.runtimeType);

lib/commonjs/qpqRuntime.d.ts

@@ -1,4 +0,5 @@
-import { Action, ActionProcessorList } from './types/Action';
-import { StoryResult, StorySession, QpqRuntimeType } from './types/StorySession';
+import { Action, ActionProcessorList, ActionProcessorResult } from './types/Action';
+import { StoryResult, StorySession, QpqRuntimeType, StorySessionUpdater } from './types/StorySession';
 import { QPQConfig } from './config';
+export declare function processAction(action: Action<any>, actionProcessors: ActionProcessorList, session: StorySession, logger: (res: StoryResult<any>) => Promise<void>, updateSession: StorySessionUpdater): Promise<ActionProcessorResult<any>>;
 export declare const createRuntime: (qpqConfig: QPQConfig, callerSession: StorySession, actionProcessors: ActionProcessorList, getTimeNow: () => string, logger: (res: StoryResult<any>) => Promise<void>, runtimeCorrelation: string, runtimeType: QpqRuntimeType, initialTags?: string[]) => <TArgs extends any[]>(story: (...args: TArgs) => Generator<any, any, Action<any>>, args: TArgs) => Promise<StoryResult<any>>;

lib/commonjs/qpqRuntime.js

@@ -12,5 +12,4 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.createRuntime = void 0;
+exports.createRuntime = exports.processAction = void 0;
 const ErrorTypeEnum_1 = require("./types/ErrorTypeEnum");
-const SystemActionType_1 = require("./actions/system/SystemActionType");
 const actionLogic_1 = require("./logic/actionLogic");
@@ -22,16 +21,2 @@ const qpqCoreUtils_1 = require("./qpqCoreUtils");
         try {
-            // Special action ~ batch - needs access to the processAction / actionProcessor context
-            if (action.type === SystemActionType_1.SystemActionType.Batch) {
-                const batchRes = yield Promise.all(action.payload.actions.map((a) => {
-                    return a ? processAction(a, actionProcessors, session, logger, updateSession) : null;
-                }));
-                // If there was an error, throw that error back
-                const erroredBatchItem = batchRes.find((br) => (0, actionLogic_1.isErroredActionResult)(br));
-                if (erroredBatchItem) {
-                    const error = (0, actionLogic_1.resolveActionResultError)(erroredBatchItem);
-                    return (0, actionLogic_1.actionResultError)(ErrorTypeEnum_1.ErrorTypeEnum.GenericError, error.errorText, error.errorStack);
-                }
-                // unwrap the values
-                return (0, actionLogic_1.actionResult)(batchRes.map((br) => (0, actionLogic_1.resolveActionResult)(br)));
-            }
             const processor = actionProcessors === null || actionProcessors === void 0 ? void 0 : actionProcessors[action === null || action === void 0 ? void 0 : action.type];
@@ -51,2 +36,3 @@ if (!processor) {
 }
+exports.processAction = processAction;
 const createRuntime = (qpqConfig, callerSession, actionProcessors, getTimeNow, logger, runtimeCorrelation, runtimeType, initialTags) => {
@@ -53,0 +39,0 @@ function resolveStory(story, args) {

lib/commonjs/stories/array/index.d.ts

@@ -5,1 +5,2 @@ export * from './askFilter';
 export * from './askMapParallel';
+export * from './askMapParallelBatch';

lib/commonjs/stories/array/index.js

@@ -21,1 +21,2 @@ "use strict";
 __exportStar(require("./askMapParallel"), exports);
+__exportStar(require("./askMapParallelBatch"), exports);

package.json

 {
   "name": "quidproquo-core",
-  "version": "0.0.163",
+  "version": "0.0.164",
   "description": "",
   "main": "./lib/commonjs/index.js",
-  "types": "./lib/commonjs/index.d.js",
+  "types": "./lib/commonjs/index.d.ts",
   "files": [
@@ -8,0 +8,0 @@ "lib/**/*"

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

273161

increased by0.22%

Number of package files

442

increased by0.45%

Lines of code

5337

increased by0.23%

No dependency changes