feat: add notify and listen functions

fix: dedicatedConnectionBegin always start new connection, not just give back the previous one

Author: Laszlo Radics

lib/bin/generateInterface.d.ts

@@ -1 +0,0 @@
-export {};

lib/bin/generateInterface.js.map

@@ -7,15 +7,21 @@ export declare enum FieldType {
     JSON = 0,
     ARRAY = 1,
     TIME = 2,
-    TSVECTOR = 3
+    TSVECTOR = 3,
 }
 export declare type PostProcessResultFunc = (res: any[], fields: ResultFieldType[], logger: PgDbLogger) => void;
+export interface Notification {
+    processId: number;
+    channel: string;
+    payload?: string;
+}
 export declare class PgDb extends QueryAble {
     protected static instances: {
         [index: string]: Promise<PgDb>;
     };
     pool: any;
     connection: any;
+    protected connectionForListen: any;
     config: ConnectionOptions;
     defaultSchemas: any;
     db: any;
@@ -26,7 +32,7 @@ export declare class PgDb extends QueryAble {
         [name: string]: PgTable<any>;
     };
     fn: {
-        [name: string]: (...any: any[]) => any;
+        [name: string]: (...any) => any;
     };
     [name: string]: any | PgSchema;
     pgdbTypeParsers: {};
@@ -36,19 +42,23 @@ export declare class PgDb extends QueryAble {
     static getInstance(config: ConnectionOptions): Promise<PgDb>;
     close(): Promise<void>;
     static connect(config: ConnectionOptions): Promise<PgDb>;
-    private init;
+    private init();
     reload(): Promise<void>;
-    private initSchemasAndTables;
-    private setDefaultTablesAndFunctions;
-    private initFieldTypes;
-    setTypeParser(typeName: string, parser: (string: any) => any, schemaName?: string): Promise<void>;
-    setPgDbTypeParser(typeName: string, parser: (string: any) => any, schemaName?: string): Promise<void>;
+    private initSchemasAndTables();
+    private setDefaultTablesAndFunctions();
+    private initFieldTypes();
+    setTypeParser(typeName: string, parser: (string) => any, schemaName?: string): Promise<void>;
+    setPgDbTypeParser(typeName: string, parser: (string) => any, schemaName?: string): Promise<void>;
     dedicatedConnectionBegin(): Promise<PgDb>;
     dedicatedConnectionEnd(): Promise<PgDb>;
     transactionBegin(): Promise<PgDb>;
     transactionCommit(): Promise<PgDb>;
     transactionRollback(): Promise<PgDb>;
     isTransactionActive(): boolean;
-    execute(fileName: any, statementTransformerFunction?: (string: any) => string): Promise<void>;
+    execute(fileName: any, statementTransformerFunction?: (string) => string): Promise<void>;
+    private listeners;
+    listen(channel: string, callback: (notification: Notification) => void): Promise<void>;
+    unlisten(channel: string, callback?: (Notification) => void): Promise<void>;
+    notify(channel: string, payload?: string): Promise<any>;
 }
 export default PgDb;