+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 +132 +133 +134 +135 +136 +137 +138 +139 +140 +141 +142 +143 +144 +145 +146 +147 +148 +149 +150 +151 +152 +153 +154 +155 +156 +157 +158 +159 +160 +161 +162 +163 +164 +165 +166 +167 +168 +169 +170 +171 +172 +173 +174 +175 +176 +177 +178 +179 +180 +181 +182 +183 +184 +185 +186 +187 +188 +189 +190 +191 +192 +193 +194 +195 +196 +197 +198 +199 +200 +201 +202 +203 +204 +205 | + +1x +1x +1x +1x +1x + +1x + +1x +1x +1x +1x +1x + +12x + + +1x +1x +1x + + +7x + +7x +6x +6x + + + +1x + +7x + + +9x + + + +1x +5x +5x +5x + + +1x +10x + +10x + +10x + + +1x +15x +2x + + +13x +1x + + +12x + +12x +4x +4x + + +8x + +2x +2x + + +6x + + +1x +24x +96x + +24x +1x + + +95x + + + +1x + +7x + + +44x +44x +5x +5x + + + +7x +6x +6x + + +7x +1x +1x +1x + + +7x +7x + + +1x +51x +19x + + +32x +32x +32x +32x +32x +32x +32x +135x + +135x +110x + + +135x + + +32x +681x +681x + +681x + +681x +26x +26x + + +655x +109x + +109x +109x + + + +32x + +32x + + +1x +29x + + +29x + + + +28x +15x + +13x +13x + + + +27x + + + +27x + + + +27x + + + +29x +138x +138x + +138x +138x +3x + + + +26x + + | 'use strict'
+
+const path = require('path'),
+ Stream = require('stream').Stream,
+ split = require('split2'),
+ util = require('util'),
+ defaultPort = 5432
+
+let warnStream = process.stderr
+
+let isWin = process.platform === 'win32'
+const S_IRWXG = 56, // 00070(8)
+ S_IRWXO = 7, // 00007(8)
+ S_IFMT = 61440, // 00170000(8)
+ S_IFREG = 32768 // 0100000(8)
+function isRegFile(mode) {
+ return (mode & S_IFMT) == S_IFREG
+}
+
+const fieldNames = ['host', 'port', 'database', 'user', 'password']
+const nrOfFields = fieldNames.length
+const passKey = fieldNames[nrOfFields - 1]
+
+function warn() {
+ const isWritable = warnStream instanceof Stream && true === warnStream.writable
+
+ if (isWritable) {
+ const args = Array.prototype.slice.call(arguments).concat('\n')
+ warnStream.write(util.format.apply(util, args))
+ }
+}
+
+Object.defineProperty(module.exports, 'isWin', {
+ get: function () {
+ return isWin
+ },
+ set: function (val) {
+ isWin = val
+ },
+})
+
+module.exports.warnTo = function (stream) {
+ const old = warnStream
+ warnStream = stream
+ return old
+}
+
+module.exports.getFileName = function (rawEnv) {
+ const env = rawEnv || process.env
+ const file =
+ env.PGPASSFILE ||
+ (isWin ? path.join(env.APPDATA || './', 'postgresql', 'pgpass.conf') : path.join(env.HOME || './', '.pgpass'))
+ return file
+}
+
+module.exports.usePgPass = function (stats, fname) {
+ if (Object.prototype.hasOwnProperty.call(process.env, 'PGPASSWORD')) {
+ return false
+ }
+
+ if (isWin) {
+ return true
+ }
+
+ fname = fname || '<unkn>'
+
+ if (!isRegFile(stats.mode)) {
+ warn('WARNING: password file "%s" is not a plain file', fname)
+ return false
+ }
+
+ if (stats.mode & (S_IRWXG | S_IRWXO)) {
+ /* If password file is insecure, alert the user and ignore it. */
+ warn('WARNING: password file "%s" has group or world access; permissions should be u=rw (0600) or less', fname)
+ return false
+ }
+
+ return true
+}
+
+const matcher = (module.exports.match = function (connInfo, entry) {
+ return fieldNames.slice(0, -1).reduce(function (prev, field, idx) {
+ if (idx == 1) {
+ // the port
+ if (Number(connInfo[field] || defaultPort) === Number(entry[field])) {
+ return prev && true
+ }
+ }
+ return prev && (entry[field] === '*' || entry[field] === connInfo[field])
+ }, true)
+})
+
+module.exports.getPassword = function (connInfo, stream, cb) {
+ let pass
+ const lineStream = stream.pipe(split())
+
+ function onLine(line) {
+ const entry = parseLine(line)
+ if (entry && isValidEntry(entry) && matcher(connInfo, entry)) {
+ pass = entry[passKey]
+ lineStream.end() // -> calls onEnd(), but pass is set now
+ }
+ }
+
+ const onEnd = function () {
+ stream.destroy()
+ cb(pass)
+ }
+
+ const onErr = function (err) {
+ stream.destroy()
+ warn('WARNING: error on reading file: %s', err)
+ cb(undefined)
+ }
+
+ stream.on('error', onErr)
+ lineStream.on('data', onLine).on('end', onEnd).on('error', onErr)
+}
+
+const parseLine = (module.exports.parseLine = function (line) {
+ if (line.length < 11 || line.match(/^\s+#/)) {
+ return null
+ }
+
+ let curChar = ''
+ let prevChar = ''
+ let fieldIdx = 0
+ let startIdx = 0
+ let obj = {}
+ let isLastField = false
+ const addToObj = function (idx, i0, i1) {
+ let field = line.substring(i0, i1)
+
+ if (!Object.hasOwnProperty.call(process.env, 'PGPASS_NO_DEESCAPE')) {
+ field = field.replace(/\\([:\\])/g, '$1')
+ }
+
+ obj[fieldNames[idx]] = field
+ }
+
+ for (let i = 0; i < line.length - 1; i += 1) {
+ curChar = line.charAt(i + 1)
+ prevChar = line.charAt(i)
+
+ isLastField = fieldIdx == nrOfFields - 1
+
+ if (isLastField) {
+ addToObj(fieldIdx, startIdx)
+ break
+ }
+
+ if (i >= 0 && curChar == ':' && prevChar !== '\\') {
+ addToObj(fieldIdx, startIdx, i + 1)
+
+ startIdx = i + 2
+ fieldIdx += 1
+ }
+ }
+
+ obj = Object.keys(obj).length === nrOfFields ? obj : null
+
+ return obj
+})
+
+const isValidEntry = (module.exports.isValidEntry = function (entry) {
+ const rules = {
+ // host
+ 0: function (x) {
+ return x.length > 0
+ },
+ // port
+ 1: function (x) {
+ if (x === '*') {
+ return true
+ }
+ x = Number(x)
+ return isFinite(x) && x > 0 && x < 9007199254740992 && Math.floor(x) === x
+ },
+ // database
+ 2: function (x) {
+ return x.length > 0
+ },
+ // username
+ 3: function (x) {
+ return x.length > 0
+ },
+ // password
+ 4: function (x) {
+ return x.length > 0
+ },
+ }
+
+ for (let idx = 0; idx < fieldNames.length; idx += 1) {
+ const rule = rules[idx]
+ const value = entry[fieldNames[idx]] || ''
+
+ const res = rule(value)
+ if (!res) {
+ return false
+ }
+ }
+
+ return true
+})
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ ++ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 | + +1x +1x +1x +6x + +6x +6x +2x + + +4x + +4x + + + +1x + | 'use strict'
+
+const fs = require('fs'),
+ helper = require('./helper.js')
+module.exports = function (connInfo, cb) {
+ const file = helper.getFileName()
+
+ fs.stat(file, function (err, stat) {
+ if (err || !helper.usePgPass(stat, file)) {
+ return cb(undefined)
+ }
+
+ const st = fs.createReadStream(file)
+
+ helper.getPassword(connInfo, st, cb)
+ })
+}
+
+module.exports.warnTo = helper.warnTo
+ |