diff --git a/lab-brian/.eslintrc b/lab-brian/.eslintrc new file mode 100644 index 0000000..8dc6807 --- /dev/null +++ b/lab-brian/.eslintrc @@ -0,0 +1,21 @@ +{ + "rules": { + "no-console": "off", + "indent": [ "error", 2 ], + "quotes": [ "error", "single" ], + "semi": ["error", "always"], + "linebreak-style": [ "error", "unix" ] + }, + "env": { + "es6": true, + "node": true, + "mocha": true, + "jasmine": true + }, + "ecmaFeatures": { + "modules": true, + "experimentalObjectRestSpread": true, + "impliedStrict": true + }, + "extends": "eslint:recommended" +} diff --git a/lab-brian/.gitignore b/lab-brian/.gitignore new file mode 100644 index 0000000..0992345 --- /dev/null +++ b/lab-brian/.gitignore @@ -0,0 +1,117 @@ +# Created by https://www.gitignore.io/api/node,vim,osx,macos,linux + +*node_modules + +### Node ### +# Logs +logs +*.log +npm-debug.log* + +# Runtime data +pids +*.pid +*.seed +*.pid.lock + +# Directory for instrumented libs generated by jscoverage/JSCover +lib-cov + +# Coverage directory used by tools like istanbul +coverage + +# nyc test coverage +.nyc_output + +# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files) +.grunt + +# node-waf configuration +.lock-wscript + +# Compiled binary addons (http://nodejs.org/api/addons.html) +build/Release + +# Dependency directories +node_modules +jspm_packages + +# Optional npm cache directory +.npm + +# Optional eslint cache +.eslintcache + +# Optional REPL history +.node_repl_history + +# Output of 'npm pack' +*.tgz + +# Yarn Integrity file +.yarn-integrity + + + +### Vim ### +# swap +[._]*.s[a-v][a-z] +[._]*.sw[a-p] +[._]s[a-v][a-z] +[._]sw[a-p] +# session +Session.vim +# temporary +.netrwhist +*~ +# auto-generated tag files +tags + + +### OSX ### +*.DS_Store +.AppleDouble +.LSOverride + +# Icon must end with two \r +Icon +# Thumbnails +._* +# Files that might appear in the root of a volume +.DocumentRevisions-V100 +.fseventsd +.Spotlight-V100 +.TemporaryItems +.Trashes +.VolumeIcon.icns +.com.apple.timemachine.donotpresent +# Directories potentially created on remote AFP share +.AppleDB +.AppleDesktop +Network Trash Folder +Temporary Items +.apdisk + + +### macOS ### +# Icon must end with two \r +# Thumbnails +# Files that might appear in the root of a volume +# Directories potentially created on remote AFP share + + +### Linux ### + +# temporary files which can be created if a process still has a handle open of a deleted file +.fuse_hidden* + +# KDE directory preferences +.directory + +# Linux trash folder which might appear on any partition or disk +.Trash-* + +# .nfs files are created when an open file is removed but is still being accessed +.nfs* + +# End of https://www.gitignore.io/api/node,vim,osx,macos,linux diff --git a/lab-brian/gulpfile.js b/lab-brian/gulpfile.js new file mode 100644 index 0000000..e394a1a --- /dev/null +++ b/lab-brian/gulpfile.js @@ -0,0 +1,23 @@ +'use strict'; + +const gulp = require('gulp'); +const eslint = require('gulp-eslint'); +const mocha = require('gulp-mocha'); + +gulp.task('test', function(){ + gulp.src('./test/*-test.js', {read: false}) + .pipe(mocha({reporter:'nyan'})); +}); + +gulp.task('lint', function(){ + return gulp.src(['**/*.js', '!node_modules/**']) + .pipe(eslint()) + .pipe(eslint.format()) + .pipe(eslint.failAfterError()); +}); + +gulp.task('dev', function(){ + gulp.watch(['**/*.js', '!node_modules/**'], ['lint', 'test']); +}); + +gulp.task('default', ['dev']); diff --git a/lab-brian/model/client.js b/lab-brian/model/client.js new file mode 100644 index 0000000..6be346b --- /dev/null +++ b/lab-brian/model/client.js @@ -0,0 +1,9 @@ +'use strict'; + +const uuid = require('node-uuid'); + +const Client = module.exports = function(socket){ //eslint-disable-line + this.socket = socket; + this.nickname = `user_${Math.random()}`; + this.userId = uuid.v4(); +}; diff --git a/lab-brian/package.json b/lab-brian/package.json new file mode 100644 index 0000000..a6b3fc7 --- /dev/null +++ b/lab-brian/package.json @@ -0,0 +1,15 @@ +{ + "name": "lab-brian", + "version": "1.0.0", + "description": "", + "main": "index.js", + "scripts": { + "test": "echo \"Error: no test specified\" && exit 1" + }, + "keywords": [], + "author": "", + "license": "ISC", + "dependencies": { + "node-uuid": "^1.4.7" + } +} diff --git a/lab-brian/server.js b/lab-brian/server.js new file mode 100644 index 0000000..c98f112 --- /dev/null +++ b/lab-brian/server.js @@ -0,0 +1,103 @@ +'use strict'; + +const net = require('net'); +const EE = require('events'); +const Client = require('./model/client.js'); +const server = net.createServer(); +const PORT = process.env.PORT || 3000; +const ee = new EE(); + +let pool = []; + +ee.on('@all', function(client, msgArr){ + pool.forEach(c =>{ + c.socket.write(`${c.nickname}: ${msgArr.join(' ')}`); + }); +}); + +ee.on('@dm', function(client, msgArr){ + pool.forEach(c => { + if(msgArr[0] === c.nickname) { + msgArr = msgArr.splice(1); + console.log(msgArr); + c.socket.write(`${client.nickname}: ${msgArr.join(' ')}`); + } + }); +}); + +ee.on('@nickname', function(client, msgArr){ + client.nickname = msgArr[0]; +}); + +ee.on('@table', function(){ + pool.forEach(c =>{ + c.socket.write('(╯°□°)╯︵ ┻━┻'); + }); + console.log('(╯°□°)╯︵ ┻━┻'); +}); + +ee.on('@calm', function(){ + pool.forEach(c =>{ + c.socket.write('┬──┬ ノ( ゜-゜ノ)'); + }); + console.log('┬──┬ ノ( ゜-゜ノ)'); +}); + +ee.on('@rage', function(){ + pool.forEach(c =>{ + c.socket.write('(┛◉Д◉)┛彡┻━┻'); + }); + console.log('(┛◉Д◉)┛彡┻━┻'); +}); + +ee.on('@herc', function(){ + pool.forEach(c =>{ + c.socket.write('┻━┻ ︵ヽ(`Д´)ノ︵ ┻━┻'); + }); + console.log('┻━┻ ︵ヽ(`Д´)ノ︵ ┻━┻'); +}); + +ee.on('@bear', function(){ + pool.forEach(c =>{ + c.socket.write('ʕノ•ᴥ•ʔノ ︵ ┻━┻'); + }); + console.log('ʕノ•ᴥ•ʔノ ︵ ┻━┻'); +}); + +ee.on('default', function(client){ + client.socket.write('Please begin with a command!'); +}); + +server.on('connection', function(socket){ + let client = new Client(socket); + pool.push(client); + + socket.on('data', function(data){ + const command = data.toString().split(' '); + command[command.length-1] = command[command.length-1].trim(); + if(command[0].startsWith('@')) { + ee.emit(command[0], client, command.splice(1)); + return; + } + }); + + socket.on('close', function(){ + console.log(`${client.nickname}: has left`); + pool.forEach((c,index) => { + if(c.nickname === client.nickname){ + pool.splice(index, 1); + } + }); + return; + }); + + socket.on('error', function(error){ + throw error; + }); + + ee.emit('default', client); +}); + +server.listen(PORT, function(){ + console.log('Server is up for all your needs on port ', PORT); +});