quidproquo-core
Advanced tools
Comparing version 0.0.161 to 0.0.162
@@ -1,3 +0,3 @@ | ||
import { KeyValueStoreQueryActionRequester } from './KeyValueStoreQueryActionTypes'; | ||
import { KeyValueStoreQueryActionRequester, KeyValueStoreQueryOptions } from './KeyValueStoreQueryActionTypes'; | ||
import { KvsQueryOperation } from './types'; | ||
export declare function askKeyValueStoreQuery<KvsItem>(keyValueStoreName: string, keyCondition: KvsQueryOperation, filterCondition?: KvsQueryOperation, nextPageKey?: string): KeyValueStoreQueryActionRequester<KvsItem>; | ||
export declare function askKeyValueStoreQuery<KvsItem>(keyValueStoreName: string, keyCondition: KvsQueryOperation, options?: KeyValueStoreQueryOptions): KeyValueStoreQueryActionRequester<KvsItem>; |
@@ -5,3 +5,3 @@ "use strict"; | ||
const KeyValueStoreActionType_1 = require("./KeyValueStoreActionType"); | ||
function* askKeyValueStoreQuery(keyValueStoreName, keyCondition, filterCondition, nextPageKey) { | ||
function* askKeyValueStoreQuery(keyValueStoreName, keyCondition, options) { | ||
return yield { | ||
@@ -12,4 +12,3 @@ type: KeyValueStoreActionType_1.KeyValueStoreActionType.Query, | ||
keyCondition, | ||
filterCondition, | ||
nextPageKey, | ||
options, | ||
}, | ||
@@ -16,0 +15,0 @@ }; |
@@ -7,2 +7,6 @@ import { KeyValueStoreActionType } from './KeyValueStoreActionType'; | ||
ttlInSeconds?: number; | ||
sortAscending?: boolean; | ||
limit?: number; | ||
nextPageKey?: string; | ||
filter?: KvsQueryOperation; | ||
} | ||
@@ -12,4 +16,3 @@ export interface KeyValueStoreQueryActionPayload { | ||
keyCondition: KvsQueryOperation; | ||
filterCondition?: KvsQueryOperation; | ||
nextPageKey?: string; | ||
options?: KeyValueStoreQueryOptions; | ||
} | ||
@@ -16,0 +19,0 @@ export interface KeyValueStoreQueryAction extends Action<KeyValueStoreQueryActionPayload> { |
@@ -7,4 +7,10 @@ "use strict"; | ||
function* askBatch(actions) { | ||
// If we only have one action, just execute it directly | ||
// No need to batch it | ||
if (actions.length === 1) { | ||
return [yield actions[0]]; | ||
} | ||
// Otherwise, batch the actions | ||
return yield { type: SystemActionType_1.SystemActionType.Batch, payload: { actions } }; | ||
} | ||
exports.askBatch = askBatch; |
@@ -10,3 +10,3 @@ import { SystemActionType } from './SystemActionType'; | ||
} | ||
export type SystemBatchActionProcessor<TReturn extends Array<any>> = ActionProcessor<SystemBatchAction, TReturn>; | ||
export type SystemBatchActionRequester<TReturn extends Array<any>> = ActionRequester<SystemBatchAction, TReturn>; | ||
export type SystemBatchActionProcessor<TReturn extends Array<any>> = ActionProcessor<SystemBatchAction | Action<any>, TReturn>; | ||
export type SystemBatchActionRequester<TReturn extends Array<any>> = ActionRequester<SystemBatchAction | Action<any>, TReturn>; |
@@ -11,1 +11,2 @@ export * from './actions'; | ||
export * from './serviceConfig'; | ||
export * from './utils'; |
@@ -40,1 +40,2 @@ "use strict"; | ||
__exportStar(require("./serviceConfig"), exports); | ||
__exportStar(require("./utils"), exports); |
@@ -6,6 +6,2 @@ "use strict"; | ||
function* askRunParallel(storyRuntimes) { | ||
// No need to batch if we only have one story | ||
if (storyRuntimes.length === 1) { | ||
return [yield* storyRuntimes[0]]; | ||
} | ||
// Begin executing the stories | ||
@@ -12,0 +8,0 @@ const storyProgress = storyRuntimes.map((input) => ({ |
@@ -14,1 +14,3 @@ export * from './Action'; | ||
export * from './FullyQualifiedResource'; | ||
export * from './BoundLogicStory'; | ||
export * from './UnboundLogicStory'; |
@@ -30,1 +30,3 @@ "use strict"; | ||
__exportStar(require("./FullyQualifiedResource"), exports); | ||
__exportStar(require("./BoundLogicStory"), exports); | ||
__exportStar(require("./UnboundLogicStory"), exports); |
{ | ||
"name": "quidproquo-core", | ||
"version": "0.0.161", | ||
"version": "0.0.162", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "./lib/commonjs/index.js", |
272502
440
5325