'use strict';

var net = require('net');
var tls = require('tls');

function listenForConns(opts) {
  var server = net.createServer(function (c) {
    var sclient = tls.connect({
      servername: opts.remoteAddr, host: opts.remoteAddr, port: opts.remotePort
    , rejectUnauthorized: opts.rejectUnauthorized
    }, function () {
      console.info('[connect] ' + sclient.localAddress.replace('::1', 'localhost') + ":" + sclient.localPort
        + " => " + opts.remoteAddr + ":" + opts.remotePort);
      c.pipe(sclient);
      sclient.pipe(c);
    });
    sclient.on('error', function (err) {
      console.error('[error] (remote) ' + err.toString());
    });
    c.on('error', function (err) {
      console.error('[error] (local) ' + err.toString());
    });
  });
  server.on('error', function (err) {
    console.error('[error] ' + err.toString());
  });
  server.listen({
    host: opts.localAddress
  , port: opts.localPort
  }, function () {
    console.info('[listening] ' + opts.remoteAddr + ":" + opts.remotePort
      + " <= " + opts.localAddress + ":" + opts.localPort);
  });
}

function testConn(opts) {
  // Test connection first
  var tlsSock = tls.connect({
    servername: opts.remoteAddr, host: opts.remoteAddr, port: opts.remotePort
  , rejectUnauthorized: opts.rejectUnauthorized
  }, function () {
    tlsSock.end();
    listenForConns(opts);
  });
  tlsSock.on('error', function (err) {
    console.warn("[warn] '" + opts.remoteAddr + ":" + opts.remotePort + "' may not be accepting connections: ", err.toString(), '\n');
    listenForConns(opts);
  });
}

module.exports = testConn;