Connect using pg.ClientConfig (#3)

andywer · Nov 5, 2018 · 7a2ee43 · 7a2ee43
1 parent 1e9b3c2
commit 7a2ee43
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -63,11 +63,11 @@ export interface Options {
   retryTimeout?: number
 }
 
-function connect (connectionConfig: pg.ConnectionConfig | undefined, options: Options) {
+function connect (connectionConfig: pg.ClientConfig | undefined, options: Options) {
   connectionLogger("Creating PostgreSQL client for notification streaming")
 
   const { retryInterval = 500, retryLimit = Infinity, retryTimeout = 3000 } = options
-  const effectiveConnectionConfig: pg.ConnectionConfig = { ...connectionConfig, keepAlive: true }
+  const effectiveConnectionConfig: pg.ClientConfig = { ...connectionConfig, keepAlive: true }
 
   const Client = options.native && pg.native ? pg.native.Client : pg.Client
   const dbClient = new Client(effectiveConnectionConfig)
@@ -145,7 +145,7 @@ function scheduleParanoidChecking (dbClient: pg.Client, intervalTime: number, re
   }
 }
 
-function createPostgresSubscriber (connectionConfig?: pg.ConnectionConfig, options: Options = {}) {
+function createPostgresSubscriber (connectionConfig?: pg.ClientConfig, options: Options = {}) {
   const { paranoidChecking = 30000 } = options
 
   const emitter = new EventEmitter() as TypedEventEmitter<PgListenEvents>