Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
const getSocket = function(protocol, options) {
switch (protocol) {
case 'tcp':
return new net.Socket();
case 'tls':
// todo
case 'ssl':
return new tls.TLSSocket(options);
}
throw new Error('unknown protocol');
}
var client = netlib.connect(PORT_NUMBER, function(){
var sslcontext = crypto.createCredentials();
var pair = tlslib.createSecurePair(sslcontext, false);
pair.encrypted.pipe(client);
client.pipe(pair.encrypted);
pair.fd = client.fd;
pair.on("secure", function(){
pair.cleartext.on("data", function(chunk){
test.equal(chunk.toString(), "TEST\r\n");
pair.cleartext.end();
});
});
});
var client = netlib.connect(PORT_NUMBER, function(){
var sslcontext = crypto.createCredentials();
var pair = tlslib.createSecurePair(sslcontext, false);
pair.encrypted.pipe(client);
client.pipe(pair.encrypted);
pair.fd = client.fd;
pair.on("secure", function(){
test.ok(1, "secure connection");
});
});
const server = net.Server(common.mustCall(function(raw) {
const pair = tls.createSecurePair(null, true, false, false);
pair.on('error', function() {});
pair.ssl.setSNICallback(common.mustCall(function() {
raw.destroy();
server.close();
}));
require('_tls_legacy').pipe(pair, raw);
})).listen(0, function() {
tls.connect({
var initSocket = function(){
_socket = tls.connect(4000,"localhost", options, startSuccess);
_socket.on('error',function(){
console.log('error connecting susi...');
setTimeout(initSocket,500);
});
_socket.on('close',function(){
console.log('error connecting susi...');
setTimeout(initSocket,500);
});
};
initSocket();
this.ssl_load (function (options) {
connection = tls.connect (this.port, this.host, options);
setup (connection);
});
} else {
function connectSslSocket(fulfill, reject, conn) {
var sslOpts = transport.sslOpts();
var options = sslSocketOpts(sslOpts, reject);
var localSock = tls.connect(addr.port, addr.host, options, function() {
logger.debugf('Connecting via SSL to %s, socket is %s, server name is: `%s`', show(),
localSock.authorized ? 'authorized' : 'unauthorized',
localSock.servername);
fulfill(conn);
});
return localSock;
}
function getSocket(context) {
var socket = tls.connect({ port: DD_PORT, host: DD_URL });
socket.on('error', err => {
context.log.error(err.toString());
socket.end();
});
return socket;
}
function getSocket(context) {
var socket = tls.connect({ port: DD_PORT, host: DD_URL });
socket.on('error', err => {
context.log.error(err.toString());
socket.end();
});
return socket;
}
function main(conf) {
dur = conf.dur;
concurrency = conf.concurrency;
const options = {
key: fixtures.readKey('rsa_private.pem'),
cert: fixtures.readKey('rsa_cert.crt'),
ca: fixtures.readKey('rsa_ca.crt'),
ciphers: 'AES256-GCM-SHA384'
};
const server = tls.createServer(options, onConnection);
server.listen(common.PORT, onListening);
}