TCP forwarding proxy over ssh

ssh_proxy.js

const net = require('net');
const child_process = require('child_process');

function makeProxy(port, jump, target) {
  const server = net.createServer(socket => {
    const subprocess = child_process.spawn(
      'ssh',
      [jump, '-W', target],
      { stdio: ['pipe', 'pipe', 'inherit'] }
    );
    socket.pipe(subprocess.stdin);
    subprocess.stdout.pipe(socket);
    socket.on('close', _ => subprocess.kill());
    socket.on('error', _ => subprocess.kill());
    subprocess.on('close', _ => socket.end());
  });

  server.listen(port, '127.0.0.1');
}

makeProxy(5433, 'ssh_user@ssh_host.com', 'db_host:5432');
makeProxy(5434, 'ssh_user_2@ssh_host_2.com', 'db_host_2:5432');