@@ -68,9 +68,9 @@ export class Database extends events.EventEmitter {
6868 this . pgPool = new pg . Pool ( buildPgPoolOptions ( connectionSettings , poolOptions ) ) ;
6969
7070 this . pgPool . on ( 'error' , ( error ) => {
71- this . logger && this . logger . warn ( 'pg.pool error: ' + error . message ) ;
72- // turn off error emitter because pgPool emits duplicate errors when client creation fails
73- // this.emit(ERROR_EVENT, error);
71+ // this.logger && this.logger.warn('pg.pool error: ' + error.message);
72+ //turn off error emitter because pgPool emits duplicate errors when client creation fails
73+ this . emit ( ERROR_EVENT , error ) ;
7474 } ) ;
7575 }
7676
@@ -99,13 +99,13 @@ export class Database extends events.EventEmitter {
9999 // --------------------------------------------------------------------------------------------
100100 getPoolState ( ) : PoolState {
101101 return {
102- size : this . pgPool . pool . getPoolSize ( ) ,
103- available : this . pgPool . pool . availableObjectsCount ( )
102+ size : this . pgPool . totalCount ,
103+ available : this . pgPool . idleCount
104104 } ;
105105 }
106106
107107 getPoolDescription ( ) : string {
108- return `{ size: ${ this . pgPool . pool . getPoolSize ( ) } , available: ${ this . pgPool . pool . availableObjectsCount ( ) } }` ;
108+ return `{ size: ${ this . pgPool . totalCount } , available: ${ this . pgPool . idleCount } }` ;
109109 }
110110}
111111
0 commit comments