Use publications option - fixes #295

porsager · porsager · commit b5ceeccca76c · 2022-03-30T10:44:50.000+02:00
diff --git a/src/index.js b/src/index.js
@@ -399,7 +399,8 @@ function parseOptions(a, b) {
     debug           : o.debug,
     fetch_types     : 'fetch_types' in o ? o.fetch_types : true,
     parameters      : {},
-    shared          : { retries: 0, typeArrayMap: {} }
+    shared          : { retries: 0, typeArrayMap: {} },
+    publications    : o.publications || query.get('publications') || 'alltables'
   },
     mergeUserTypes(o.types)
   )
diff --git a/src/subscribe.js b/src/subscribe.js
@@ -46,7 +46,7 @@ export default function Subscribe(postgres, options) {
     }
   }
 
-  async function init(sql, slot, publications = 'alltables') {
+  async function init(sql, slot, publications) {
     if (!publications)
       throw new Error('Missing publication names')
 

Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ export default function Subscribe(postgres, options) {`
`46`	`46`	`}`
`47`	`47`	`}`
`48`	`48`
`49`		`- async function init(sql, slot, publications = 'alltables') {`
	`49`	`+ async function init(sql, slot, publications) {`
`50`	`50`	`if (!publications)`
`51`	`51`	`throw new Error('Missing publication names')`
`52`	`52`