|
|
@ -36,33 +36,37 @@ function createServer(port, sslopts) { |
|
|
|
}); |
|
|
|
} |
|
|
|
|
|
|
|
function getCommand(socket, sshuser, sshhost, sshport, sshauth) { |
|
|
|
function getCommand(socket, sshuser, sshhost, sshport, sshauth, sshkey) { |
|
|
|
const { request } = socket; |
|
|
|
const match = request.headers.referer.match('.+/ssh/.+$'); |
|
|
|
const sshAddress = sshuser ? `${sshuser}@${sshhost}` : sshhost; |
|
|
|
const ssh = match ? `${match[0].split('/ssh/').pop()}@${sshhost}` : sshAddress; |
|
|
|
const sshRemoteOptsBase = [ |
|
|
|
path.join(__dirname, 'bin/ssh'), |
|
|
|
ssh, |
|
|
|
'-p', |
|
|
|
sshport, |
|
|
|
'-o', |
|
|
|
`PreferredAuthentications=${sshauth}`, |
|
|
|
] |
|
|
|
const sshRemoteOpts = sshkey ? sshRemoteOptsBase.concat(['-i', sshkey]) |
|
|
|
: sshRemoteOptsBase |
|
|
|
|
|
|
|
return [ |
|
|
|
process.getuid() === 0 && sshhost === 'localhost' |
|
|
|
? ['login', '-h', socket.client.conn.remoteAddress.split(':')[3]] |
|
|
|
: [ |
|
|
|
path.join(__dirname, 'bin/ssh'), |
|
|
|
ssh, |
|
|
|
'-p', |
|
|
|
sshport, |
|
|
|
'-o', |
|
|
|
`PreferredAuthentications=${sshauth}`, |
|
|
|
], |
|
|
|
: sshRemoteOpts |
|
|
|
, |
|
|
|
ssh, |
|
|
|
]; |
|
|
|
} |
|
|
|
|
|
|
|
export default function start(port, sshuser, sshhost, sshport, sshauth, sslopts) { |
|
|
|
export default function start(port, sshuser, sshhost, sshport, sshauth, sshkey, sslopts) { |
|
|
|
const events = new EventEmitter(); |
|
|
|
const io = server(createServer(port, sslopts), { path: '/wetty/socket.io' }); |
|
|
|
io.on('connection', socket => { |
|
|
|
console.log(`${new Date()} Connection accepted.`); |
|
|
|
const [args, ssh] = getCommand(socket, sshuser, sshhost, sshport, sshauth); |
|
|
|
const [args, ssh] = getCommand(socket, sshuser, sshhost, sshport, sshauth, sshkey); |
|
|
|
const term = spawn('/usr/bin/env', args, { |
|
|
|
name: 'xterm-256color', |
|
|
|
cols: 80, |
|
|
|