Skip to content

Pull Request #2

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Tanachi wants to merge 11 commits into
base: master
Choose a base branch
from
Open

Pull Request #2

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
b7b618f
Able to communicate with other clients
Tanachi Jun 30, 2016
0d00377
fixed server messages
Tanachi Jun 30, 2016
d6f3c38
Clients are able to leave now
Tanachi Jun 30, 2016
df9b9a0
Added server broadcast
Tanachi Jun 30, 2016
d671f22
Added username entry for array
Tanachi Jun 30, 2016
1bae171
Added username function
Tanachi Jun 30, 2016
b45e478
added name checking functions
Tanachi Jun 30, 2016
e7e6f19
Added kick function
Tanachi Jun 30, 2016
9bda27c
Added message limit to server
Tanachi Jul 1, 2016
32664ad
add flood function and fixed message limit kick function
Tanachi Jul 1, 2016
282817d
fixed typo
Tanachi Jul 1, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
34 changes: 34 additions & 0 deletions client.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,34 @@
var net = require('net');
var Stream = require('stream');
var WriteableStream = Stream.Writable;
var ReadableStream = Stream.Readable;
var CONFIG = require('./config');
var socket = new net.Socket();

var a = process.stdin;
var b = process.stdout;

a.setEncoding('utf-8');

socket.connect({port:CONFIG.PORT});


a.on('data', function(chunk){
var myRegexp = /(\\flood) (\w*)/;
var match = myRegexp.exec(chunk);
if(match !== null){
console.log('hello');
if(match.length === 3){
for(var i = 0; i < 99; i++)
socket.write(match[2],'utf8');
}
}
else{
socket.write(chunk,'utf8');
}
});


socket.on('data', function(chunk){
b.write(chunk, 'utf8');
});
3 changes: 3 additions & 0 deletions config.json
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
{
"PORT":7979
}
21 changes: 21 additions & 0 deletions package.json
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,21 @@
{
"name": "Network-Broadcast-News",
"version": "1.0.0",
"description": "A NodeJS broadcast server for the largest media conglomerate in the world",
"main": "client.js",
"scripts": {
"test": "echo \"Error: no test specified\" && exit 1",
"start": "node server.js"
},
"repository": {
"type": "git",
"url": "git+https://github.com/Tanachi/Network-Broadcast-News.git"
},
"keywords": [],
"author": "",
"license": "ISC",
"bugs": {
"url": "https://github.com/Tanachi/Network-Broadcast-News/issues"
},
"homepage": "https://github.com/Tanachi/Network-Broadcast-News#readme"
}
143 changes: 143 additions & 0 deletions server.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,143 @@
var net = require('net');
var a = process.stdin;
a.setEncoding('utf-8');
var b = process.stdout;
var CONFIG = require('./config');

var PORT = 6969;
var connections = [];
var userCount = 0;



var server = net.createServer(function(socket){
b.write( socket.remoteAddress + ': ' + socket.remotePort + ' connected \n');
connections.push({socket:socket, userName:'', writeLimit: 3});
socket.write('Connected to ' + CONFIG.PORT + '\n', 'utf8');
socket.write('Please enter username \n', 'utf8');
socket.writeLimit = 3;
socket.startMessage = null;
socket.endMessage = null;
socket.totalTime = 0;
socket.on('data', function(chunk){
if(connections.length > userCount){
var validName = 1;
if(chunk.toString() === '[ADMIN]\n'){
validName = 0;
socket.write('Not allowed to set username as admin \n', 'utf8');
}
for(var k = 0; k < userCount; k++){
if(chunk.toString() === connections[k].userName.toString()){
validName = 0;
socket.write('Username is already taken \n', 'utf8');
}
}
if(validName === 1){
connections[userCount].userName = chunk;
userCount++;
}
}
else{
var isSpam = 0;
if(socket.writeLimit === 3){
socket.startMessage = new Date();
}
socket.writeLimit--;
if(socket.writeLimit < 0){
if(socket.totalTime < 1000){
for(var t = 0; t < connections.length; t++){
if(connections[t].socket.remotePort === socket.remotePort){
console.log('Someone got kicked');
connections.splice(t, 1);
userCount--;
socket.end();
isSpam = 1;
}
}
}
else{
socket.startMessage = new Date();
socket.writeLimit = 3;
socket.totalTime = 0;
}
}
if(isSpam === 0){
var senderName;
for(var y = 0; y < connections.length; y++){
if(connections[y].socket.remotePort === socket.remotePort)
senderName = connections[y].userName.toString().replace(/(\r\n|\n|\r)/gm,"");
}
b.write('Server Bcast from' + socket.remoteAddress + ': ' + socket.remotePort + ': ' + chunk + '\n','utf8');
for(var i = 0; i < connections.length; i++){
connections[i].socket.write( senderName + ': ' + chunk + '\n','utf8');
}
socket.endMessage = new Date();
var spamTime = socket.endMessage.getTime() - socket.startMessage.getTime();
socket.totalTime += spamTime;
}
}
});

socket.on('close', function(){
var closedPort;
for(var z = 0; z < connections.length; z++){
if(connections[z].socket.remotePort === socket.remotePort){
closedPort = connections[z].socket.remotePort;
b.write('Closed ' + connections[z].socket.remotePort + '\n');
connections.splice(z, 1);
userCount--;
}
}
for(var x = 0; x < connections.length;x++){
connections[x].socket.write( closedPort + ' left \n','utf8');
}
});
});


a.on('data', function(chunk){
var myRegexp = /(\\kick) (.*)/;
var match = myRegexp.exec(chunk);
if(match !== null){
if(match.length === 3){
for(var k = 0; k < connections.length; k++){
if(isNaN(match[2])){
var checkName = connections[k].userName.toString().replace(/(\r\n|\n|\r)/gm,"");
console.log(match[2]);
if(match[2].toString() === checkName){
console.log('User got kicked');
connections[k].socket.end();
connections.splice(k,1);
userCount--;
}
}
else{
if(parseInt(match[2]) === connections[k].socket.remotePort){
console.log('User got kicked');
connections[k].socket.end();
connections.splice(k,1);
userCount--;
}
}
}
}
}
else{
for(var i = 0; i < connections.length; i++){
connections[i].socket.write('[ADMIN]' + ': ' + chunk + '\n','utf8');
}
b.write('[ADMIN]' + ': ' + chunk);
}
});

server.listen(CONFIG.PORT, function(){
var finalPort = server.address().port;
console.log('listening on port \n', finalPort);
});

server.on('error', function(err){
this.listen(CONFIG.PORT, function(){
var finalPort = server.address().port;
console.log('listening on port \n', finalPort);
});
});