resolve-eventstore-base - npm Package Compare versions

Comparing version 0.27.8-alpha to 0.27.9-alpha

es/create-adapter.js

@@ -127,4 +127,4 @@ import getLog from './get-log';
     incrementalImport: wrapMethod(adapterPool, incrementalImport),
-    loadSecrets: loadSecrets === undefined ? undefined : wrapMethod(adapterPool, loadSecrets),
-    injectSecret: injectSecret === undefined ? undefined : wrapMethod(adapterPool, injectSecret),
+    loadSecrets: wrapMethod(adapterPool, loadSecrets),
+    injectSecret: wrapMethod(adapterPool, injectSecret),
     importSecrets: importSecretsStream.bind(null, adapterPool),
@@ -131,0 +131,0 @@ exportSecrets: exportSecretsStream.bind(null, adapterPool)

es/drop.js

@@ -12,6 +12,6 @@ const drop = async ({
   for (const errorsArray of errorsArrays) {
-    errors.concat(errorsArray);
+    errors.push(...errorsArray);
   }
 
-  errors.concat(finalErrors);
+  errors.push(...finalErrors);
   maybeThrowResourceError(errors);
@@ -18,0 +18,0 @@ };

es/index.js

@@ -20,3 +20,3 @@ import createAdapter from './create-adapter';
 import drop from './drop';
-import { CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, AdapterPoolConnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord } from './types';
+import { CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, AdapterPoolConnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord, InputEvent } from './types';
 
@@ -44,3 +44,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 };
+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 };
 //# sourceMappingURL=index.js.map

es/init.js

@@ -12,6 +12,6 @@ const init = async ({
   for (const errorsArray of errorsArrays) {
-    errors.concat(errorsArray);
+    errors.push(...errorsArray);
   }
 
-  errors.concat(finalErrors);
+  errors.push(...finalErrors);
   maybeThrowResourceError(errors);
@@ -18,0 +18,0 @@ };

es/wrap-method.js

@@ -12,5 +12,5 @@ const connectOnDemandAndCall = async (pool, method, ...args) => {
 
-const wrapMethod = (pool, method) => typeof method !== 'undefined' ? connectOnDemandAndCall.bind(null, pool, method) : null;
+const wrapMethod = (pool, method) => typeof method !== 'undefined' ? connectOnDemandAndCall.bind(null, pool, method) : undefined;
 
 export default wrapMethod;
 //# sourceMappingURL=wrap-method.js.map

lib/create-adapter.js

@@ -137,4 +137,4 @@ "use strict";
     incrementalImport: wrapMethod(adapterPool, incrementalImport),
-    loadSecrets: loadSecrets === undefined ? undefined : wrapMethod(adapterPool, loadSecrets),
-    injectSecret: injectSecret === undefined ? undefined : wrapMethod(adapterPool, injectSecret),
+    loadSecrets: wrapMethod(adapterPool, loadSecrets),
+    injectSecret: wrapMethod(adapterPool, injectSecret),
     importSecrets: importSecretsStream.bind(null, adapterPool),
@@ -141,0 +141,0 @@ exportSecrets: exportSecretsStream.bind(null, adapterPool)

lib/drop.js

@@ -19,6 +19,6 @@ "use strict";
   for (const errorsArray of errorsArrays) {
-    errors.concat(errorsArray);
+    errors.push(...errorsArray);
   }
 
-  errors.concat(finalErrors);
+  errors.push(...finalErrors);
   maybeThrowResourceError(errors);
@@ -25,0 +25,0 @@ };

lib/index.js

@@ -150,2 +150,8 @@ "use strict";
 });
+Object.defineProperty(exports, "InputEvent", {
+  enumerable: true,
+  get: function () {
+    return _types.InputEvent;
+  }
+});
 exports.default = void 0;
@@ -152,0 +158,0 @@

lib/init.js

@@ -19,6 +19,6 @@ "use strict";
   for (const errorsArray of errorsArrays) {
-    errors.concat(errorsArray);
+    errors.push(...errorsArray);
   }
 
-  errors.concat(finalErrors);
+  errors.push(...finalErrors);
   maybeThrowResourceError(errors);
@@ -25,0 +25,0 @@ };

lib/wrap-method.js

@@ -19,3 +19,3 @@ "use strict";
 
-const wrapMethod = (pool, method) => typeof method !== 'undefined' ? connectOnDemandAndCall.bind(null, pool, method) : null;
+const wrapMethod = (pool, method) => typeof method !== 'undefined' ? connectOnDemandAndCall.bind(null, pool, method) : undefined;
 
@@ -22,0 +22,0 @@ var _default = wrapMethod;

package.json

 {
   "name": "resolve-eventstore-base",
-  "version": "0.27.8-alpha",
+  "version": "0.27.9-alpha",
   "description": "A base for reSolve eventstore adapters",
@@ -27,4 +27,4 @@ "keywords": [
     "@babel/runtime": "7.9.6",
-    "resolve-debug-levels": "0.27.8-alpha",
-    "resolve-core": "0.27.8-alpha"
+    "resolve-debug-levels": "0.27.9-alpha",
+    "resolve-core": "0.27.9-alpha"
   },
@@ -31,0 +31,0 @@ "devDependencies": {

types/create-adapter.d.ts

@@ -1,3 +0,3 @@
-import { AdapterPoolConnected, AdapterPoolConnectedProps, Adapter, AdapterFunctions, CommonAdapterFunctions, AdapterConfig } from './types';
-declare const createAdapter: <ConnectedProps extends AdapterPoolConnectedProps, ConnectionDependencies extends unknown, Config extends AdapterConfig>({ maybeThrowResourceError, wrapMethod, wrapEventFilter, wrapDispose, validateEventFilter, loadEvents, importEventsStream, exportEventsStream, incrementalImport, getNextCursor, importSecretsStream, exportSecretsStream, init, drop, }: CommonAdapterFunctions<ConnectedProps>, { connect, loadEventsByCursor, loadEventsByTimestamp, getLatestEvent, saveEvent, initEvents, initSecrets, initFinal, dropEvents, dropSecrets, dropFinal, dispose, injectEvent, freeze, unfreeze, shapeEvent, loadSnapshot, saveSnapshot, dropSnapshot, beginIncrementalImport, commitIncrementalImport, rollbackIncrementalImport, pushIncrementalImport, getSecret, setSecret, deleteSecret, loadSecrets, injectSecret, }: AdapterFunctions<ConnectedProps, ConnectionDependencies, Config, AdapterPoolConnected<ConnectedProps>>, connectionDependencies: ConnectionDependencies, options: Config) => Adapter;
+import { AdapterPoolConnectedProps, Adapter, AdapterFunctions, CommonAdapterFunctions, AdapterConfig } from './types';
+declare const createAdapter: <ConnectedProps extends AdapterPoolConnectedProps, ConnectionDependencies extends unknown, Config extends AdapterConfig>({ maybeThrowResourceError, wrapMethod, wrapEventFilter, wrapDispose, validateEventFilter, loadEvents, importEventsStream, exportEventsStream, incrementalImport, getNextCursor, importSecretsStream, exportSecretsStream, init, drop, }: CommonAdapterFunctions<ConnectedProps>, { connect, loadEventsByCursor, loadEventsByTimestamp, getLatestEvent, saveEvent, initEvents, initSecrets, initFinal, dropEvents, dropSecrets, dropFinal, dispose, injectEvent, freeze, unfreeze, shapeEvent, loadSnapshot, saveSnapshot, dropSnapshot, beginIncrementalImport, commitIncrementalImport, rollbackIncrementalImport, pushIncrementalImport, getSecret, setSecret, deleteSecret, loadSecrets, injectSecret, }: AdapterFunctions<ConnectedProps, ConnectionDependencies, Config>, connectionDependencies: ConnectionDependencies, options: Config) => Adapter;
 export default createAdapter;

types/index.d.ts

@@ -7,5 +7,5 @@ import { MAINTENANCE_MODE_AUTO, MAINTENANCE_MODE_MANUAL } from './constants';
 import snapshotTrigger from './snapshot-trigger';
-import { CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterFunctions, AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, AdapterPoolConnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord } from './types';
-declare const wrappedCreateAdapter: <ConnectedProps extends AdapterPoolConnectedProps, ConnectionDependencies extends unknown, Config extends AdapterConfig>(adapterFunctions: AdapterFunctions<ConnectedProps, ConnectionDependencies, Config, AdapterPoolConnected<ConnectedProps>>, connectionDependencies: ConnectionDependencies, options: Config) => Adapter;
+import { CursorFilter, TimestampFilter, isTimestampFilter, isCursorFilter, EventsWithCursor, EventFilter, Adapter, AdapterFunctions, AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, AdapterPoolConnected, AdapterConfig, ImportOptions, ExportOptions, SecretFilter, SecretsWithIdx, SecretRecord, InputEvent } 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, };
+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, };

types/types.d.ts

 /// <reference types="node" />
-import { SecretsManager } from 'resolve-core';
+import { SecretsManager, Event } from 'resolve-core';
 import stream from 'stream';
 import { MAINTENANCE_MODE_AUTO, MAINTENANCE_MODE_MANUAL } from './constants';
+export declare type InputEvent = Event;
 export declare type CheckForResourceError = (errors: Error[]) => void;
-declare type PropType<TObj, TProp extends keyof TObj> = TObj[TProp];
-declare type DeleteSecret = PropType<SecretsManager, 'deleteSecret'>;
-declare type GetSecret = PropType<SecretsManager, 'getSecret'>;
-declare type SetSecret = PropType<SecretsManager, 'setSecret'>;
+declare type DeleteSecret = SecretsManager['deleteSecret'];
+declare type GetSecret = SecretsManager['getSecret'];
+declare type SetSecret = SecretsManager['setSecret'];
 declare type ShapeEvent = (event: any, additionalFields?: any) => any;
@@ -48,2 +48,4 @@ export declare type ValidateEventFilter = (filter: any) => void;
 export declare type PromiseResultType<T extends any> = T extends Promise<infer R> ? R : T;
+export declare type PoolMethod<ConnectedProps extends AdapterPoolConnectedProps, M extends (...args: any) => any> = (pool: AdapterPoolConnected<ConnectedProps>, ...args: Parameters<M>) => ReturnType<M>;
+export declare type UnconnectedPoolMethod<ConnectedProps extends AdapterPoolConnectedProps, M extends (...args: any) => any> = (pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, ...args: Parameters<M>) => ReturnType<M>;
 export declare type AdapterConfig = {
@@ -79,13 +81,8 @@ snapshotBucketSize?: number;
 };
-export declare type AdapterPoolPossiblyUnconnected<ConnectedProps> = AdapterPoolPrimalProps & Partial<ConnectedProps>;
-export declare type AdapterPoolConnected<ConnectedProps> = AdapterPoolPrimalProps & ConnectedProps;
+export declare type AdapterPoolPossiblyUnconnected<ConnectedProps extends AdapterPoolConnectedProps> = AdapterPoolPrimalProps & Partial<ConnectedProps>;
+export declare type AdapterPoolConnected<ConnectedProps extends AdapterPoolConnectedProps> = AdapterPoolPrimalProps & ConnectedProps;
 export declare type WrappedConnectOnDemandAndCall<ConnectedProps extends AdapterPoolConnectedProps, M extends (pool: AdapterPoolConnected<ConnectedProps>, ...args: any) => any> = (...args: RemoveFirstType<Parameters<M>>) => Promise<PromiseResultType<ReturnType<M>>>;
-export declare type WrapMethod<ConnectedProps extends AdapterPoolConnectedProps> = {
-    <M extends (pool: AdapterPoolPrimalProps & ConnectedProps, ...args: any) => any>(pool: AdapterPoolPrimalProps & Partial<ConnectedProps>, method: M): WrappedConnectOnDemandAndCall<ConnectedProps, M>;
-    (pool: AdapterPoolPrimalProps & Partial<ConnectedProps>, method: undefined): null;
-};
-export declare type WrapDispose<ConnectedProps extends AdapterPoolConnectedProps> = (pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, dispose: Dispose<ConnectedProps>) => () => Promise<void>;
-export declare type LoadEvents<ConnectedProps extends AdapterPoolConnectedProps> = (pool: AdapterPoolConnected<ConnectedProps>, filter: EventFilter) => Promise<EventsWithCursor>;
-export declare type IncrementImport<ConnectedProps extends AdapterPoolConnectedProps> = (pool: AdapterPoolConnected<ConnectedProps>, events: any[]) => Promise<void>;
-export declare type Dispose<ConnectedProps extends AdapterPoolConnectedProps> = (pool: AdapterPoolConnected<ConnectedProps>) => Promise<void>;
+declare type IfEquals<T, U, Y = unknown, N = never> = (<G>() => G extends T ? 1 : 2) extends <G>() => G extends U ? 1 : 2 ? Y : N;
+export declare type WrapMethod<ConnectedProps extends AdapterPoolConnectedProps> = <M extends undefined | ((pool: AdapterPoolConnected<ConnectedProps>, ...args: any) => any)>(pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, method: M) => IfEquals<M, undefined, undefined, WrappedConnectOnDemandAndCall<ConnectedProps, Exclude<M, undefined>>>;
+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;
@@ -104,50 +101,47 @@ export declare type ImportOptions = {
 };
-export declare type GetImportStream<ConnectedProps extends AdapterPoolConnectedProps> = (pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, options?: Partial<ImportOptions>) => stream.Writable;
-export declare type GetExportStream<ConnectedProps extends AdapterPoolConnectedProps> = (pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, options?: Partial<ExportOptions>) => stream.Readable;
 export interface CommonAdapterFunctions<ConnectedProps extends AdapterPoolConnectedProps> {
     maybeThrowResourceError: CheckForResourceError;
     wrapMethod: WrapMethod<ConnectedProps>;
-    wrapEventFilter: (loadEvents: LoadEvents<ConnectedProps>) => LoadEvents<ConnectedProps>;
+    wrapEventFilter: (loadEvents: PoolMethod<ConnectedProps, Adapter['loadEvents']>) => PoolMethod<ConnectedProps, Adapter['loadEvents']>;
     wrapDispose: WrapDispose<ConnectedProps>;
     validateEventFilter: ValidateEventFilter;
-    loadEvents: LoadEvents<ConnectedProps>;
-    importEventsStream: GetImportStream<ConnectedProps>;
-    exportEventsStream: GetExportStream<ConnectedProps>;
-    incrementalImport: IncrementImport<ConnectedProps>;
+    loadEvents: PoolMethod<ConnectedProps, Adapter['loadEvents']>;
+    importEventsStream: UnconnectedPoolMethod<ConnectedProps, Adapter['importEvents']>;
+    exportEventsStream: UnconnectedPoolMethod<ConnectedProps, Adapter['exportEvents']>;
+    incrementalImport: PoolMethod<ConnectedProps, Adapter['incrementalImport']>;
     getNextCursor: GetNextCursor;
-    importSecretsStream: (pool: AdapterPoolPossiblyUnconnected<ConnectedProps>) => stream.Writable;
-    exportSecretsStream: (pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, options?: Partial<ExportSecretsOptions>) => stream.Readable;
-    init: (pool: AdapterPoolConnected<ConnectedProps>) => Promise<void>;
-    drop: (pool: AdapterPoolConnected<ConnectedProps>) => Promise<void>;
+    importSecretsStream: UnconnectedPoolMethod<ConnectedProps, Adapter['importSecrets']>;
+    exportSecretsStream: UnconnectedPoolMethod<ConnectedProps, Adapter['exportSecrets']>;
+    init: PoolMethod<ConnectedProps, Adapter['init']>;
+    drop: PoolMethod<ConnectedProps, Adapter['drop']>;
 }
-export interface AdapterFunctions<ConnectedProps extends AdapterPoolConnectedProps, ConnectionDependencies extends any, Config extends AdapterConfig, AdapterPool = AdapterPoolConnected<ConnectedProps>> {
-    beginIncrementalImport: (pool: AdapterPool) => Promise<string>;
-    commitIncrementalImport: (pool: AdapterPool, importId: string, validateAfterCommit: any) => Promise<void>;
-    connect: (pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, connectionDependencies: ConnectionDependencies, config: Config) => Promise<any>;
-    dispose: Dispose<ConnectedProps>;
-    dropSnapshot: (pool: AdapterPool, snapshotKey: string) => Promise<any>;
-    freeze: (pool: AdapterPool) => Promise<void>;
-    getLatestEvent: (pool: AdapterPool, filter: EventFilter) => Promise<any>;
-    injectEvent: (pool: AdapterPool, event: any) => Promise<any>;
-    loadEventsByCursor: (pool: AdapterPool, filter: CursorFilter) => Promise<EventsWithCursor>;
-    loadEventsByTimestamp: (pool: AdapterPool, filter: TimestampFilter) => Promise<EventsWithCursor>;
-    loadSnapshot: (pool: AdapterPool, snapshotKey: string) => Promise<any>;
-    pushIncrementalImport: (pool: AdapterPool, events: any[], importId: string) => Promise<void>;
-    rollbackIncrementalImport: (pool: AdapterPool) => Promise<void>;
-    saveEvent: (pool: AdapterPool, event: any) => Promise<any>;
-    saveSnapshot: (pool: AdapterPool, snapshotKey: string, content: string) => Promise<any>;
+export interface AdapterFunctions<ConnectedProps extends AdapterPoolConnectedProps, ConnectionDependencies extends any, Config extends AdapterConfig> {
+    beginIncrementalImport: PoolMethod<ConnectedProps, Adapter['beginIncrementalImport']>;
+    commitIncrementalImport: PoolMethod<ConnectedProps, Adapter['commitIncrementalImport']>;
+    connect: (pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, connectionDependencies: ConnectionDependencies, config: Config) => Promise<void>;
+    dispose: PoolMethod<ConnectedProps, Adapter['dispose']>;
+    dropSnapshot: PoolMethod<ConnectedProps, Adapter['dropSnapshot']>;
+    freeze: PoolMethod<ConnectedProps, Adapter['freeze']>;
+    getLatestEvent: PoolMethod<ConnectedProps, Adapter['getLatestEvent']>;
+    injectEvent: PoolMethod<ConnectedProps, AdapterPoolConnectedProps['injectEvent']>;
+    loadEventsByCursor: PoolMethod<ConnectedProps, AdapterPoolConnectedProps['loadEventsByCursor']>;
+    loadEventsByTimestamp: PoolMethod<ConnectedProps, AdapterPoolConnectedProps['loadEventsByTimestamp']>;
+    loadSnapshot: PoolMethod<ConnectedProps, Adapter['loadSnapshot']>;
+    pushIncrementalImport: PoolMethod<ConnectedProps, Adapter['pushIncrementalImport']>;
+    rollbackIncrementalImport: PoolMethod<ConnectedProps, Adapter['rollbackIncrementalImport']>;
+    saveEvent: PoolMethod<ConnectedProps, Adapter['saveEvent']>;
+    saveSnapshot: PoolMethod<ConnectedProps, Adapter['saveSnapshot']>;
     shapeEvent: ShapeEvent;
-    unfreeze: (pool: AdapterPool) => Promise<void>;
-    isFrozen?: () => Promise<boolean>;
-    getSecret: (pool: AdapterPool, selector: string) => Promise<string | null>;
-    setSecret: (pool: AdapterPool, selector: string, secret: string) => Promise<void>;
-    deleteSecret: (pool: AdapterPool, selector: string) => Promise<void>;
-    loadSecrets?: (pool: AdapterPool, filter: SecretFilter) => Promise<SecretsWithIdx>;
-    injectSecret?: (pool: AdapterPool, secretRecord: SecretRecord) => Promise<void>;
-    initEvents: (pool: AdapterPool) => Promise<any[]>;
-    initSecrets: (pool: AdapterPool) => Promise<any[]>;
-    initFinal: (pool: AdapterPool) => Promise<any[]>;
-    dropEvents: (pool: AdapterPool) => Promise<any[]>;
-    dropSecrets: (pool: AdapterPool) => Promise<any[]>;
-    dropFinal: (pool: AdapterPool) => Promise<any[]>;
+    unfreeze: PoolMethod<ConnectedProps, Adapter['unfreeze']>;
+    getSecret: PoolMethod<ConnectedProps, GetSecret>;
+    setSecret: PoolMethod<ConnectedProps, SetSecret>;
+    deleteSecret: PoolMethod<ConnectedProps, DeleteSecret>;
+    loadSecrets?: PoolMethod<ConnectedProps, NonNullable<Adapter['loadSecrets']>>;
+    injectSecret?: PoolMethod<ConnectedProps, NonNullable<Adapter['injectSecret']>>;
+    initEvents: PoolMethod<ConnectedProps, AdapterPoolConnectedProps['initEvents']>;
+    initSecrets: PoolMethod<ConnectedProps, AdapterPoolConnectedProps['initSecrets']>;
+    initFinal: PoolMethod<ConnectedProps, AdapterPoolConnectedProps['initFinal']>;
+    dropEvents: PoolMethod<ConnectedProps, AdapterPoolConnectedProps['dropEvents']>;
+    dropSecrets: PoolMethod<ConnectedProps, AdapterPoolConnectedProps['dropSecrets']>;
+    dropFinal: PoolMethod<ConnectedProps, AdapterPoolConnectedProps['dropFinal']>;
 }
@@ -159,6 +153,6 @@ export interface Adapter {
     getLatestEvent: (filter: EventFilter) => Promise<any>;
-    saveEvent: (event: any) => Promise<any>;
+    saveEvent: (event: InputEvent) => Promise<void>;
     init: () => Promise<void>;
     drop: () => Promise<void>;
-    dispose: () => Promise<any>;
+    dispose: () => Promise<void>;
     freeze: () => Promise<void>;
@@ -165,0 +159,0 @@ unfreeze: () => Promise<void>;

types/wrap-dispose.d.ts

@@ -1,3 +0,3 @@
-import { AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, Dispose } from './types';
-declare const wrapDispose: <ConnectedProps extends AdapterPoolConnectedProps>(pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, dispose: Dispose<ConnectedProps>) => () => Promise<void>;
+import { AdapterPoolConnectedProps, AdapterPoolPossiblyUnconnected, PoolMethod, Adapter } from './types';
+declare const wrapDispose: <ConnectedProps extends AdapterPoolConnectedProps>(pool: AdapterPoolPossiblyUnconnected<ConnectedProps>, dispose: PoolMethod<ConnectedProps, () => Promise<void>>) => () => Promise<void>;
 export default wrapDispose;

types/wrap-event-filter.d.ts

@@ -1,3 +0,3 @@
-import { AdapterPoolConnectedProps, LoadEvents } from './types';
-declare const wrapEventFilter: <ConnectedProps extends AdapterPoolConnectedProps>(loadEvents: LoadEvents<ConnectedProps>) => LoadEvents<ConnectedProps>;
+import { AdapterPoolConnectedProps, EventFilter, EventsWithCursor, PoolMethod, Adapter } from './types';
+declare const wrapEventFilter: <ConnectedProps extends AdapterPoolConnectedProps>(loadEvents: PoolMethod<ConnectedProps, (filter: EventFilter) => Promise<EventsWithCursor>>) => PoolMethod<ConnectedProps, (filter: EventFilter) => Promise<EventsWithCursor>>;
 export default wrapEventFilter;

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

Lines of code

2559

increased by0.04%

Worsened metrics

Total package byte prevSize

295891

decreased by-0.13%

Dependency changes

• + Addedresolve-core@0.27.9-alpha(transitive)

• + Addedresolve-debug-levels@0.27.9-alpha(transitive)

• + Addeduuid@8.3.2(transitive)

• - Removedresolve-core@0.27.8-alpha(transitive)

• - Removedresolve-debug-levels@0.27.8-alpha(transitive)

• Updatedresolve-core@0.27.9-alpha

• Updatedresolve-debug-levels@0.27.9-alpha