Add logging debug option

porsager · porsager · commit d53cb013a32d · 2019-12-11T01:01:41.000+01:00
diff --git a/lib/connection.js b/lib/connection.js
@@ -7,6 +7,8 @@ const { errors } = require('./types.js')
 
 module.exports = Connection
 
+let count = 1
+
 function Connection(options = {}) {
   const {
     onparameter,
@@ -21,12 +23,13 @@ function Connection(options = {}) {
   let length = 0
   let messages = []
   let timer
-  let id = 1
+  let statement_id = 1
   let ended
   let ready = false
   let statements = {}
 
   const queries = Queue()
+      , id = count++
       , connection = { send, end, destroy }
 
   const socket = postgresSocket(options, {
@@ -87,6 +90,7 @@ function Connection(options = {}) {
     query.result.count = null
     timeout && clearTimeout(timer)
 
+    options.debug && options.debug(id, str, args)
     const buffer = query.simple
       ? simple(str, query)
       : sig in statements
@@ -113,7 +117,7 @@ function Connection(options = {}) {
   }
 
   function prepare(sig, str, args, query) {
-    query.statement = { name: sig ? 'p' + id++ : '', sig }
+    query.statement = { name: sig ? 'p' + statement_id++ : '', sig }
     return Buffer.concat([
       frontend.Parse(query.statement.name, str, args),
       frontend.Bind(query.statement.name, args)
diff --git a/lib/index.js b/lib/index.js
@@ -470,6 +470,7 @@ function parseOptions(uri = {}, options) {
     nonce       : crypto.randomBytes(18).toString('base64'),
     transform   : { ...o.transform },
     connection  : { application_name: 'postgres.js', ...o.connection },
+    debug       : o.debug,
     ...mergeUserTypes(o.types)
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -470,6 +470,7 @@ function parseOptions(uri = {}, options) {`
`470`	`470`	`nonce : crypto.randomBytes(18).toString('base64'),`
`471`	`471`	`transform : { ...o.transform },`
`472`	`472`	`connection : { application_name: 'postgres.js', ...o.connection },`
	`473`	`+ debug : o.debug,`
`473`	`474`	`...mergeUserTypes(o.types)`
`474`	`475`	`}`
`475`	`476`	`}`