fix: make transport chainable

Xstoudi · Mar 2, 2020 · 2347883 · 2347883
1 parent 19edb92
commit 2347883
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -65,12 +65,14 @@ function transporter(errConfig: string | null, config: PinoPgConfig) {
   if(errConfig !== null) return console.error(errConfig)
 
   const pgTransport = through.obj((chunk, encoding, callback) => {
+    console.log(chunk)
     const client = new Client(config.connection)
     client.connect((connectErr) => {
       if(connectErr !== null) {
         console.error(connectErr)
         return callback('Failed to connect to PostgreSQL server.')
       }
+
       client.query(buildInsertString(config), Object.values(JSON.parse(chunk)), (queryErr, result) => {
         if(queryErr !== null) {
           console.error(queryErr)