Aliza tcp

aliza/gulpfile.js

@@ -0,0 +1,21 @@
+const gulp = require('gulp');
+const eslint = require('gulp-eslint');
+const mocha = require ('gulp-mocha');
+
+gulp.task('default', ['lint', 'mocha'], () => {
+  console.log('default for lint and mocha');
+});
+
+
+gulp.task('lint', () => {
+  gulp.src('/*.js')
+    .pipe(eslint({}))
+    .pipe(eslint.format())
+});
+
+gulp.task('mocha', () => {
+	gulp.src('test/test.js')
+		.pipe(mocha());
+});
+
+gulp.watch('./*.js', ['lint', 'mocha']);

aliza/package.json

@@ -0,0 +1,19 @@
+{
+  "name": "aliza",
+  "version": "1.0.0",
+  "description": "tcp server lab",
+  "main": "tcp_server.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "ISC",
+  "devDependencies": {
+    "chai": "^3.5.0",
+    "eslint": "^2.10.2",
+    "gulp": "^3.9.1",
+    "gulp-eslint": "^2.0.0",
+    "gulp-mocha": "^2.2.0",
+    "mocha": "^2.4.5"
+  }
+}

aliza/tcp_client.js

@@ -0,0 +1,8 @@
+const net = require('net');
+
+const client = net.connect(3000, () => {
+  // client.on('data', (data) => {
+  //   client.write('MESSAGE RECEIVED');
+  // })
+  client.write('HERE IS MESSAGE');
+})

aliza/tcp_server.js

@@ -0,0 +1,18 @@
+const net = require('net');
+
+const clients = [];
+
+module.exports = exports = net.createServer((socket) => {
+  socket.name = socket.remotePort;
+  clients.push(socket);
+  socket.on('data', (chunk) => {
+    console.log(chunk.toString());
+    socket.write('Sending message\n');
+    clients.forEach((s) => {
+      if (socket.name !== s.name)
+      s.write(socket.name + ': ' + chunk.toString());
+    });
+  });
+}).listen(3000, () => {
+  console.log('Up on 3000');
+});

aliza/test/test.js

@@ -0,0 +1,26 @@
+const net = require('net');
+const expect = require('chai').expect;
+const server = require('../tcp_server');
+
+describe('tcp tests', () => {
+  it('should send message to all clients, but not to sender', (done) => {
+    var result;
+    var wroteBack = false;
+    var firstClient = net.connect(3000, () => {
+      firstClient.on('data', (data) => {
+        if (data.toString() !== 'Sending message\n') wroteBack = true;
+      })
+      firstClient.write('message');
+    })
+    var secondClient = net.connect(3000, () => {
+      secondClient.on('data', (data) => {
+        result = data.toString();
+      })
+    });
+    setTimeout(() => {
+      expect(result.slice(-7)).to.eql('message');
+      expect(wroteBack).to.eql(false);
+      done();
+    }, 200)
+  })
+});