index.js 960 B

123456789101112131415161718192021222324252627282930313233343536
  1. var net = require('net');
  2. var debug = require('debug')('tunnel-ssh:test-server-client');
  3. function createServer(port, addr, callback) {
  4. var handleConnection = function (socket) {
  5. socket.on('data', function (data) {
  6. debug('server::data', data);
  7. });
  8. debug('server::write');
  9. socket.write('Echo server\r\n');
  10. };
  11. return net.createServer(handleConnection).listen(port, addr, callback);
  12. }
  13. function createClient(port, addr, callback) {
  14. var client = new net.Socket();
  15. client.on('error', function (e) {
  16. debug('clientError', e);
  17. });
  18. client.connect(port, addr, function () {
  19. debug('client::write');
  20. client.write('alive !');
  21. setTimeout(function () {
  22. client.end();
  23. debug('client::end');
  24. callback(null, true);
  25. }, 300);
  26. });
  27. return client;
  28. }
  29. exports.createServer = createServer;
  30. exports.createClient = createClient;