source: trip-planner-front/node_modules/getpass/lib/index.js

/*
 * Copyright 2016, Joyent, Inc. All rights reserved.
 * Author: Alex Wilson <alex.wilson@joyent.com>
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to
 * deal in the Software without restriction, including without limitation the
 * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
 * sell copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
 * IN THE SOFTWARE.
*/

module.exports = {
        getPass: getPass
};

const mod_tty = require('tty');
const mod_fs = require('fs');
const mod_assert = require('assert-plus');

var BACKSPACE = String.fromCharCode(127);
var CTRLC = '\u0003';
var CTRLD = '\u0004';

function getPass(opts, cb) {
        if (typeof (opts) === 'function' && cb === undefined) {
                cb = opts;
                opts = {};
        }
        mod_assert.object(opts, 'options');
        mod_assert.func(cb, 'callback');

        mod_assert.optionalString(opts.prompt, 'options.prompt');
        if (opts.prompt === undefined)
                opts.prompt = 'Password';

        openTTY(function (err, rfd, wfd, rtty, wtty) {
                if (err) {
                        cb(err);
                        return;
                }

                wtty.write(opts.prompt + ':');
                rtty.resume();
                rtty.setRawMode(true);
                rtty.resume();
                rtty.setEncoding('utf8');

                var pw = '';
                rtty.on('data', onData);

                function onData(data) {
                        var str = data.toString('utf8');
                        for (var i = 0; i < str.length; ++i) {
                                var ch = str[i];
                                switch (ch) {
                                case '\r':
                                case '\n':
                                case CTRLD:
                                        cleanup();
                                        cb(null, pw);
                                        return;
                                case CTRLC:
                                        cleanup();
                                        cb(new Error('Aborted'));
                                        return;
                                case BACKSPACE:
                                        pw = pw.slice(0, pw.length - 1);
                                        break;
                                default:
                                        pw += ch;
                                        break;
                                }
                        }
                }

                function cleanup() {
                        wtty.write('\r\n');
                        rtty.setRawMode(false);
                        rtty.pause();
                        rtty.removeListener('data', onData);
                        if (wfd !== undefined && wfd !== rfd) {
                                wtty.end();
                                mod_fs.closeSync(wfd);
                        }
                        if (rfd !== undefined) {
                                rtty.end();
                                mod_fs.closeSync(rfd);
                        }
                }
        });
}

function openTTY(cb) {
        mod_fs.open('/dev/tty', 'r+', function (err, rttyfd) {
                if ((err && (err.code === 'ENOENT' || err.code === 'EACCES')) ||
                    (process.version.match(/^v0[.][0-8][.]/))) {
                        cb(null, undefined, undefined, process.stdin,
                            process.stdout);
                        return;
                }
                var rtty = new mod_tty.ReadStream(rttyfd);
                mod_fs.open('/dev/tty', 'w+', function (err3, wttyfd) {
                        var wtty = new mod_tty.WriteStream(wttyfd);
                        if (err3) {
                                cb(err3);
                                return;
                        }
                        cb(null, rttyfd, wttyfd, rtty, wtty);
                });
        });
}