Upgrade to latest edge demux

Author: Julien Heller

package.json

@@ -33,11 +33,11 @@
   },
   "dependencies": {
     "@types/express": "^4.16.1",
-    "demux": "5.0.2-500",
+    "demux": "5.0.2-533",
     "massive": "5.11.0"
   },
   "peerDependencies": {
-    "demux": "^5.0.0"
+    "demux": "5.0.2-533"
   },
   "scripts": {
     "build": "tsc && cp -R src/cyanaudit dist",

src/MassiveActionHandler.test.ts

@@ -66,8 +66,8 @@ describe('TestMassiveActionHandler', () => {
         effects: [],
       }],
       massiveInstance,
-      schemaName,
       [migrationSequence],
+      { dbSchema: schemaName, logLevel: 'error' }
     )
     await actionHandler.initialize()
     await massiveInstance.reload()

src/MassiveActionHandler.ts

@@ -13,7 +13,7 @@ import {
   NonExistentMigrationError,
   NonUniqueMigrationSequenceError,
 } from './errors'
-import { MigrationSequence } from './interfaces'
+import { MassiveActionHandlerOptions, MigrationSequence } from './interfaces'
 import { Migration } from './Migration'
 import { MigrationRunner } from './MigrationRunner'
 
@@ -38,14 +38,16 @@ export class MassiveActionHandler extends AbstractActionHandler {
   protected allMigrations: Migration[] = []
   protected migrationSequenceByName: { [key: string]: MigrationSequence } = {}
   protected cyanauditEnabled: boolean = false
+  protected dbSchema: string
 
   constructor(
     protected handlerVersions: HandlerVersion[],
     protected massiveInstance: Database,
-    protected dbSchema: string = 'public',
     protected migrationSequences: MigrationSequence[] = [],
+    options: MassiveActionHandlerOptions,
   ) {
-    super(handlerVersions)
+    super(handlerVersions, options)
+    this.dbSchema = options.dbSchema ? options.dbSchema : 'public'
     for (const migrationSequence of migrationSequences) {
       if (this.migrationSequenceByName.hasOwnProperty(migrationSequence.sequenceName)) {
         throw new NonUniqueMigrationSequenceError()

src/interfaces.ts

@@ -1,6 +1,11 @@
+import { ActionHandlerOptions } from 'demux'
 import { Migration } from './Migration'
 
 export interface MigrationSequence {
   migrations: Migration[]
   sequenceName: string
 }
+
+export interface MassiveActionHandlerOptions extends ActionHandlerOptions {
+  dbSchema?: string
+}

yarn.lock

@@ -1239,10 +1239,10 @@ delegates@^1.0.0:
   resolved "https://registry.yarnpkg.com/delegates/-/delegates-1.0.0.tgz#84c6e159b81904fdca59a0ef44cd870d31250f9a"
   integrity sha1-hMbhWbgZBP3KWaDvRM2HDTElD5o=
 
-[email protected]500:
-  version "5.0.2-500"
-  resolved "https://registry.yarnpkg.com/demux/-/demux-5.0.2-%3Cspan%20class="x x-first x-last">500.tgz#08de57b202b4d5a27ca4cb597cdf14d3d73be6c8"
-  integrity sha512-B+FETCu3Oi6Saw7Bcu6gG+sbWsz381cwvzF3MqyaTzlnwufib9MipeaZQI6FHPDqqTCMxgupXC6Rg/YRFm4TjQ==
+[email protected]533:
+  version "5.0.2-533"
+  resolved "https://registry.yarnpkg.com/demux/-/demux-5.0.2-%3Cspan%20class="x x-first x-last">533.tgz#181c997eef688b30b17e09e45d6114d4863a8e2e"
+  integrity sha512-FnPE7rlVmYePOrAAtrBR2NUZ0bPu75SrPBgKdeckBnvA6XmMelVYuH+LArv15Bo5Df7DZb9YVePwH3gjriGcyQ==
   dependencies:
     bunyan "1.8.12"
     express "4.16.4"