123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105 |
- var fs = require('fs'),
- tls = require('tls'),
- net = require('net'),
- crypto = require('crypto');
- exports.createSocket = function (options) {
- options = options || {};
- options.type = options.type || 'tcp4';
- return options.type === 'tls'
- ? exports.createTlsSocket(options)
- : new net.Socket(options);
- };
- exports.createTlsSocket = function(options) {
- var self = this;
-
-
-
-
-
-
-
-
- var socket = new net.Stream({ type: 'tcp4' });
- function setupTlsPipe () {
- var sslcontext = crypto.createCredentials(options),
- pair = tls.createSecurePair(sslcontext, false),
- cleartext = pipe(pair, socket);
- pair.on('secure', function() {
- var verifyError = pair.ssl.verifyError();
- if (verifyError) {
- cleartext.authorized = false;
- cleartext.authorizationError = verifyError;
- }
- else {
- cleartext.authorized = true;
- }
- });
-
-
-
-
- socket.cleartext = cleartext;
- cleartext._controlReleased = true;
- }
- socket.on('connect', setupTlsPipe);
- return socket;
- };
- function pipe(pair, socket) {
- pair.encrypted.pipe(socket);
- socket.pipe(pair.encrypted);
- pair.fd = socket.fd;
- var cleartext = pair.cleartext;
- cleartext.socket = socket;
- cleartext.encrypted = pair.encrypted;
- cleartext.authorized = false;
- function onerror(e) {
- if (cleartext._controlReleased) {
- cleartext.emit('error', e);
- }
- }
- function onclose() {
- socket.removeListener('error', onerror);
- socket.removeListener('close', onclose);
- socket.removeListener('timeout', ontimeout);
- }
- function ontimeout() {
- cleartext.emit('timeout');
- }
- socket.on('error', onerror);
- socket.on('close', onclose);
- socket.on('timeout', ontimeout);
- return cleartext;
- }
|