Socket
Socket
Sign inDemoInstall

resolve-eventstore-base

Package Overview
Dependencies
7
Maintainers
1
Versions
63
Alerts
File Explorer

Advanced tools

npm Scripts
License

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 0.27.9-alpha to 0.27.10-alpha

es/frozen-errors.js
es/frozen-errors.js.map
lib/frozen-errors.js
lib/frozen-errors.js.map
types/frozen-errors.d.ts

2

es/create-adapter.js

@@ -91,2 +91,3 @@ import getLog from './get-log';

injectEvent: wrapMethod(adapterPool, injectEvent),
injectSecret: wrapMethod(adapterPool, injectSecret),
loadEventsByCursor: wrapMethod(adapterPool, loadEventsByCursor),

@@ -129,3 +130,2 @@ loadEventsByTimestamp: wrapMethod(adapterPool, loadEventsByTimestamp),

loadSecrets: wrapMethod(adapterPool, loadSecrets),
injectSecret: wrapMethod(adapterPool, injectSecret),
importSecrets: importSecretsStream.bind(null, adapterPool),

@@ -132,0 +132,0 @@ exportSecrets: exportSecretsStream.bind(null, adapterPool)

28

es/export-secrets.js

@@ -18,4 +18,22 @@ function _awaitAsyncGenerator(value) { return new _AwaitValue(value); }

import { Readable } from 'stream';
import { BATCH_SIZE } from './constants';
import { BATCH_SIZE, MAINTENANCE_MODE_AUTO } from './constants';
async function startProcessSecrets({
pool,
maintenanceMode
}) {
if (maintenanceMode === MAINTENANCE_MODE_AUTO) {
await pool.freeze();
}
}
async function endProcessSecrets({
pool,
maintenanceMode
}) {
if (maintenanceMode === MAINTENANCE_MODE_AUTO) {
await pool.unfreeze();
}
}
function generator(_x) {

@@ -31,2 +49,3 @@ return _generator.apply(this, arguments);

yield _awaitAsyncGenerator(pool.waitConnect());
yield _awaitAsyncGenerator(startProcessSecrets(context));

@@ -49,2 +68,3 @@ while (true) {

if (secrets.length === 0) {
yield _awaitAsyncGenerator(endProcessSecrets(context));
return;

@@ -58,3 +78,4 @@ }

const exportSecretsStream = (pool, {
idx = null
idx = null,
maintenanceMode = MAINTENANCE_MODE_AUTO
} = {}) => {

@@ -64,3 +85,4 @@ if (pool.loadSecrets === undefined) throw new Error('loadSecrets is not defined for this adapter');

pool,
idx
idx,
maintenanceMode
};

@@ -67,0 +89,0 @@ const stream = Readable.from(generator(context));

29

es/import-secrets.js
import stream from 'stream';
import { EOL } from 'os';
import { BUFFER_SIZE, PARTIAL_SECRET_FLAG, BATCH_SIZE } from './constants';
import { BUFFER_SIZE, PARTIAL_SECRET_FLAG, BATCH_SIZE, MAINTENANCE_MODE_AUTO, MAINTENANCE_MODE_MANUAL } from './constants';
import { ResourceNotExistError } from './resource-errors';
const SecretsStream = function ({
pool
pool,
maintenanceMode
}) {

@@ -21,2 +22,3 @@ stream.Writable.call(this, {

this.maxIdx = 0;
this.maintenanceMode = maintenanceMode;
this.isMaintenanceInProgress = false;

@@ -49,3 +51,3 @@ this.parsedRecordCount = 0;

if (this.isMaintenanceInProgress === false) {
if (this.maintenanceMode === MAINTENANCE_MODE_AUTO && this.isMaintenanceInProgress === false) {
this.isMaintenanceInProgress = true;

@@ -185,3 +187,3 @@

if (this.isMaintenanceInProgress === true) {
if (this.maintenanceMode === MAINTENANCE_MODE_AUTO && this.isMaintenanceInProgress === true) {
this.isMaintenanceInProgress = false;

@@ -209,7 +211,18 @@ await unfreeze();

const importSecretsStream = pool => {
const importSecretsStream = (pool, {
maintenanceMode = MAINTENANCE_MODE_AUTO
} = {}) => {
if (pool.injectSecret === undefined) throw new Error('injectSecret is not defined for this adapter');
return new SecretsStream({
pool
});
switch (maintenanceMode) {
case MAINTENANCE_MODE_AUTO:
case MAINTENANCE_MODE_MANUAL:
return new SecretsStream({
pool,
maintenanceMode
});
default:
throw new Error(`Wrong maintenance mode ${String(maintenanceMode)}`);
}
};

@@ -216,0 +229,0 @@

5

es/index.js

@@ -11,2 +11,3 @@ import createAdapter from './create-adapter';

import { ResourceAlreadyExistError, ResourceNotExistError, maybeThrowResourceError } from './resource-errors';
import { EventstoreFrozenError, AlreadyFrozenError, AlreadyUnfrozenError } from './frozen-errors';
import loadEvents from './load-events';

@@ -21,3 +22,3 @@ import getNextCursor from './get-next-cursor';

import drop from './drop';
import { CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, AdapterPoolConnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord, InputEvent } from './types';
import { CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, AdapterPoolConnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord, InputEvent, SavedEvent } from './types';

@@ -45,3 +46,3 @@ const wrappedCreateAdapter = (adapterFunctions, connectionDependencies, options) => {

export default wrappedCreateAdapter;
export { ResourceAlreadyExistError as EventstoreResourceAlreadyExistError, ResourceNotExistError as EventstoreResourceNotExistError, ConcurrentError, MAINTENANCE_MODE_AUTO, MAINTENANCE_MODE_MANUAL, throwBadCursor, getNextCursor, snapshotTrigger, CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterPoolConnectedProps, AdapterPoolConnected, AdapterPoolPossiblyUnconnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord, InputEvent };
export { ResourceAlreadyExistError as EventstoreResourceAlreadyExistError, ResourceNotExistError as EventstoreResourceNotExistError, ConcurrentError, EventstoreFrozenError, AlreadyFrozenError as EventstoreAlreadyFrozenError, AlreadyUnfrozenError as EventstoreAlreadyUnfrozenError, MAINTENANCE_MODE_AUTO, MAINTENANCE_MODE_MANUAL, throwBadCursor, getNextCursor, snapshotTrigger, CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterPoolConnectedProps, AdapterPoolConnected, AdapterPoolPossiblyUnconnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord, InputEvent, SavedEvent };
//# sourceMappingURL=index.js.map

2

lib/create-adapter.js

@@ -101,2 +101,3 @@ "use strict";

injectEvent: wrapMethod(adapterPool, injectEvent),
injectSecret: wrapMethod(adapterPool, injectSecret),
loadEventsByCursor: wrapMethod(adapterPool, loadEventsByCursor),

@@ -139,3 +140,2 @@ loadEventsByTimestamp: wrapMethod(adapterPool, loadEventsByTimestamp),

loadSecrets: wrapMethod(adapterPool, loadSecrets),
injectSecret: wrapMethod(adapterPool, injectSecret),
importSecrets: importSecretsStream.bind(null, adapterPool),

@@ -142,0 +142,0 @@ exportSecrets: exportSecretsStream.bind(null, adapterPool)

26

lib/export-secrets.js

@@ -28,2 +28,20 @@ "use strict";

async function startProcessSecrets({
pool,
maintenanceMode
}) {
if (maintenanceMode === _constants.MAINTENANCE_MODE_AUTO) {
await pool.freeze();
}
}
async function endProcessSecrets({
pool,
maintenanceMode
}) {
if (maintenanceMode === _constants.MAINTENANCE_MODE_AUTO) {
await pool.unfreeze();
}
}
function generator(_x) {

@@ -39,2 +57,3 @@ return _generator.apply(this, arguments);

yield _awaitAsyncGenerator(pool.waitConnect());
yield _awaitAsyncGenerator(startProcessSecrets(context));

@@ -57,2 +76,3 @@ while (true) {

if (secrets.length === 0) {
yield _awaitAsyncGenerator(endProcessSecrets(context));
return;

@@ -66,3 +86,4 @@ }

const exportSecretsStream = (pool, {
idx = null
idx = null,
maintenanceMode = _constants.MAINTENANCE_MODE_AUTO
} = {}) => {

@@ -72,3 +93,4 @@ if (pool.loadSecrets === undefined) throw new Error('loadSecrets is not defined for this adapter');

pool,
idx
idx,
maintenanceMode
};

@@ -75,0 +97,0 @@

27

lib/import-secrets.js

@@ -19,3 +19,4 @@ "use strict";

const SecretsStream = function ({
pool
pool,
maintenanceMode
}) {

@@ -35,2 +36,3 @@ _stream.default.Writable.call(this, {

this.maxIdx = 0;
this.maintenanceMode = maintenanceMode;
this.isMaintenanceInProgress = false;

@@ -63,3 +65,3 @@ this.parsedRecordCount = 0;

if (this.isMaintenanceInProgress === false) {
if (this.maintenanceMode === _constants.MAINTENANCE_MODE_AUTO && this.isMaintenanceInProgress === false) {
this.isMaintenanceInProgress = true;

@@ -199,3 +201,3 @@

if (this.isMaintenanceInProgress === true) {
if (this.maintenanceMode === _constants.MAINTENANCE_MODE_AUTO && this.isMaintenanceInProgress === true) {
this.isMaintenanceInProgress = false;

@@ -223,7 +225,18 @@ await unfreeze();

const importSecretsStream = pool => {
const importSecretsStream = (pool, {
maintenanceMode = _constants.MAINTENANCE_MODE_AUTO
} = {}) => {
if (pool.injectSecret === undefined) throw new Error('injectSecret is not defined for this adapter');
return new SecretsStream({
pool
});
switch (maintenanceMode) {
case _constants.MAINTENANCE_MODE_AUTO:
case _constants.MAINTENANCE_MODE_MANUAL:
return new SecretsStream({
pool,
maintenanceMode
});
default:
throw new Error(`Wrong maintenance mode ${String(maintenanceMode)}`);
}
};

@@ -230,0 +243,0 @@

26

lib/index.js

@@ -36,2 +36,20 @@ "use strict";

});
Object.defineProperty(exports, "EventstoreFrozenError", {
enumerable: true,
get: function () {
return _frozenErrors.EventstoreFrozenError;
}
});
Object.defineProperty(exports, "EventstoreAlreadyFrozenError", {
enumerable: true,
get: function () {
return _frozenErrors.AlreadyFrozenError;
}
});
Object.defineProperty(exports, "EventstoreAlreadyUnfrozenError", {
enumerable: true,
get: function () {
return _frozenErrors.AlreadyUnfrozenError;
}
});
Object.defineProperty(exports, "getNextCursor", {

@@ -157,2 +175,8 @@ enumerable: true,

});
Object.defineProperty(exports, "SavedEvent", {
enumerable: true,
get: function () {
return _types.SavedEvent;
}
});
exports.default = void 0;

@@ -180,2 +204,4 @@

var _frozenErrors = require("./frozen-errors");
var _loadEvents = _interopRequireDefault(require("./load-events"));

@@ -182,0 +208,0 @@

6

package.json
{
"name": "resolve-eventstore-base",
"version": "0.27.9-alpha",
"version": "0.27.10-alpha",
"description": "A base for reSolve eventstore adapters",

@@ -27,4 +27,4 @@ "keywords": [

"@babel/runtime": "7.9.6",
"resolve-debug-levels": "0.27.9-alpha",
"resolve-core": "0.27.9-alpha"
"resolve-debug-levels": "0.27.10-alpha",
"resolve-core": "0.27.10-alpha"
},

@@ -31,0 +31,0 @@ "devDependencies": {

2

types/export-secrets.d.ts
import { Readable } from 'stream';
import { AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, ExportSecretsOptions } from './types';
declare const exportSecretsStream: <ConnectedProps extends AdapterPoolConnectedProps>(pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, { idx }?: Partial<ExportSecretsOptions>) => Readable;
declare const exportSecretsStream: <ConnectedProps extends AdapterPoolConnectedProps>(pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, { idx, maintenanceMode, }?: Partial<ExportSecretsOptions>) => Readable;
export default exportSecretsStream;

4

types/import-secrets.d.ts
import stream from 'stream';
import { AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected } from './types';
declare const importSecretsStream: <ConnectedProps extends AdapterPoolConnectedProps>(pool: AdapterPoolPossiblyUnconnected<ConnectedProps>) => stream.Writable;
import { AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, ImportSecretsOptions } from './types';
declare const importSecretsStream: <ConnectedProps extends AdapterPoolConnectedProps>(pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, { maintenanceMode, }?: Partial<ImportSecretsOptions>) => stream.Writable;
export default importSecretsStream;

4

types/incremental-import.d.ts

@@ -1,3 +0,3 @@

import { AdapterPoolConnected, AdapterPoolConnectedProps } from './types';
declare const incrementalImport: <ConnectedProps extends AdapterPoolConnectedProps>(pool: AdapterPoolConnected<ConnectedProps>, events: any[]) => Promise<void>;
import { AdapterPoolConnected, AdapterPoolConnectedProps, InputEvent } from './types';
declare const incrementalImport: <ConnectedProps extends AdapterPoolConnectedProps>(pool: AdapterPoolConnected<ConnectedProps>, events: InputEvent[]) => Promise<void>;
export default incrementalImport;

5

types/index.d.ts
import { MAINTENANCE_MODE_AUTO, MAINTENANCE_MODE_MANUAL } from './constants';
import ConcurrentError from './concurrent-error';
import { ResourceAlreadyExistError, ResourceNotExistError } from './resource-errors';
import { EventstoreFrozenError, AlreadyFrozenError, AlreadyUnfrozenError } from './frozen-errors';
import getNextCursor from './get-next-cursor';
import throwBadCursor from './throw-bad-cursor';
import snapshotTrigger from './snapshot-trigger';
import { CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterFunctions, AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, AdapterPoolConnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord, InputEvent } from './types';
import { CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterFunctions, AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, AdapterPoolConnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord, InputEvent, SavedEvent } from './types';
declare const wrappedCreateAdapter: <ConnectedProps extends AdapterPoolConnectedProps, ConnectionDependencies extends unknown, Config extends AdapterConfig>(adapterFunctions: AdapterFunctions<ConnectedProps, ConnectionDependencies, Config>, connectionDependencies: ConnectionDependencies, options: Config) => Adapter;
export default wrappedCreateAdapter;
export { ResourceAlreadyExistError as EventstoreResourceAlreadyExistError, ResourceNotExistError as EventstoreResourceNotExistError, ConcurrentError, MAINTENANCE_MODE_AUTO, MAINTENANCE_MODE_MANUAL, throwBadCursor, getNextCursor, snapshotTrigger, CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterPoolConnectedProps, AdapterPoolConnected, AdapterPoolPossiblyUnconnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord, InputEvent, };
export { ResourceAlreadyExistError as EventstoreResourceAlreadyExistError, ResourceNotExistError as EventstoreResourceNotExistError, ConcurrentError, EventstoreFrozenError, AlreadyFrozenError as EventstoreAlreadyFrozenError, AlreadyUnfrozenError as EventstoreAlreadyUnfrozenError, MAINTENANCE_MODE_AUTO, MAINTENANCE_MODE_MANUAL, throwBadCursor, getNextCursor, snapshotTrigger, CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterPoolConnectedProps, AdapterPoolConnected, AdapterPoolPossiblyUnconnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord, InputEvent, SavedEvent, };

28

types/types.d.ts
/// <reference types="node" />
import { SecretsManager, Event } from 'resolve-core';
import { SecretsManager, Event, SerializableMap } from 'resolve-core';
import stream from 'stream';
import { MAINTENANCE_MODE_AUTO, MAINTENANCE_MODE_MANUAL } from './constants';
export declare type InputEvent = Event;
export declare type SavedEvent = Event & {
threadCounter: number;
threadId: number;
} & SerializableMap;
export declare type CheckForResourceError = (errors: Error[]) => void;

@@ -10,3 +14,3 @@ declare type DeleteSecret = SecretsManager['deleteSecret'];

declare type SetSecret = SecretsManager['setSecret'];
declare type ShapeEvent = (event: any, additionalFields?: any) => any;
declare type ShapeEvent = (event: any, additionalFields?: any) => SavedEvent;
export declare type ValidateEventFilter = (filter: any) => void;

@@ -16,3 +20,3 @@ export declare type GetNextCursor = (prevCursor: string | null, events: any[]) => string;

cursor: string | null;
events: any[];
events: SavedEvent[];
};

@@ -67,3 +71,4 @@ declare type EventFilterCommon = {

export declare type AdapterPoolConnectedProps = Adapter & {
injectEvent: (event: any) => Promise<any>;
injectEvent: (event: SavedEvent) => Promise<void>;
injectSecret?: (secretRecord: SecretRecord) => Promise<void>;
loadEventsByTimestamp: (filter: TimestampFilter) => Promise<EventsWithCursor>;

@@ -89,3 +94,3 @@ loadEventsByCursor: (filter: CursorFilter) => Promise<EventsWithCursor>;

export declare type WrapDispose<ConnectedProps extends AdapterPoolConnectedProps> = (pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, dispose: PoolMethod<ConnectedProps, Adapter['dispose']>) => () => Promise<void>;
declare type MAINTENANCE_MODE = typeof MAINTENANCE_MODE_AUTO | typeof MAINTENANCE_MODE_MANUAL;
export declare type MAINTENANCE_MODE = typeof MAINTENANCE_MODE_AUTO | typeof MAINTENANCE_MODE_MANUAL;
export declare type ImportOptions = {

@@ -100,4 +105,8 @@ byteOffset: number;

};
export declare type ImportSecretsOptions = {
maintenanceMode: MAINTENANCE_MODE;
};
export declare type ExportSecretsOptions = {
idx: number | null;
maintenanceMode: MAINTENANCE_MODE;
};

@@ -142,3 +151,3 @@ export interface CommonAdapterFunctions<ConnectedProps extends AdapterPoolConnectedProps> {

loadSecrets?: PoolMethod<ConnectedProps, NonNullable<Adapter['loadSecrets']>>;
injectSecret?: PoolMethod<ConnectedProps, NonNullable<Adapter['injectSecret']>>;
injectSecret?: PoolMethod<ConnectedProps, NonNullable<AdapterPoolConnectedProps['injectSecret']>>;
initEvents: PoolMethod<ConnectedProps, AdapterPoolConnectedProps['initEvents']>;

@@ -167,12 +176,11 @@ initSecrets: PoolMethod<ConnectedProps, AdapterPoolConnectedProps['initSecrets']>;

dropSnapshot: (snapshotKey: string) => Promise<any>;
pushIncrementalImport: (events: any[], importId: string) => Promise<void>;
pushIncrementalImport: (events: InputEvent[], importId: string) => Promise<void>;
beginIncrementalImport: () => Promise<string>;
commitIncrementalImport: (importId: string, validateAfterCommit?: any) => Promise<void>;
rollbackIncrementalImport: () => Promise<void>;
incrementalImport: (events: any[]) => Promise<void>;
incrementalImport: (events: InputEvent[]) => Promise<void>;
loadSecrets?: (filter: SecretFilter) => Promise<SecretsWithIdx>;
injectSecret?: (secretRecord: SecretRecord) => Promise<void>;
importSecrets: () => stream.Writable;
importSecrets: (options?: Partial<ImportSecretsOptions>) => stream.Writable;
exportSecrets: (options?: Partial<ExportSecretsOptions>) => stream.Readable;
}
export {};
es/create-adapter.js.map

Sorry, the diff of this file is not supported yet

es/export-secrets.js.map

Sorry, the diff of this file is not supported yet

es/import-secrets.js.map

Sorry, the diff of this file is not supported yet

es/incremental-import.js.map

Sorry, the diff of this file is not supported yet

es/index.js.map

Sorry, the diff of this file is not supported yet

es/types.js.map

Sorry, the diff of this file is not supported yet

lib/create-adapter.js.map

Sorry, the diff of this file is not supported yet

lib/export-secrets.js.map

Sorry, the diff of this file is not supported yet

lib/import-secrets.js.map

Sorry, the diff of this file is not supported yet

lib/incremental-import.js.map

Sorry, the diff of this file is not supported yet

lib/index.js.map

Sorry, the diff of this file is not supported yet

lib/types.js.map

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap

About

Packages

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc