7nieznajomy/czat.js at master · polishere/7nieznajomy · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
module.exports = function(io){

var queue = [];
var rooms = {};
var allUsers = {};
var userCount = 0;


var findStranger = function(socket){
	if(queue.length>0)
	{
		var stranger = queue.pop();
		var room=socket.id+'#'+stranger.id;

		stranger.join(room);
		socket.join(room);

		rooms[stranger.id] = room;
		rooms[socket.id] = room;

		stranger.emit('chat start', {room: room, data: 'Ktoś się połączył'})
		socket.emit('chat start', {room: room, data: 'Ktoś się połączył'})
	}
	else
		{
			queue.push(socket);
		}

}

io.on('connection', function (socket) {

	console.log ('User '+socket.id+' connected')

	socket.on('new client', function () {
		allUsers[socket.id] = socket;
		findStranger(socket);
		socket.emit('userCount', ++userCount);
	});

	socket.on('typing', function(){

	});

	socket.on('message', function (data) {
		var room = rooms[socket.id];
		currentTime = new Date();

		if (currentTime.getHours()<10)
			hours='0'+currentTime.getHours();
		else
			hours=currentTime.getHours();

		if (currentTime.getMinutes()<10)
			minutes='0'+currentTime.getMinutes();
		else
			minutes=currentTime.getMinutes();

		time=hours+':'+minutes;

		socket.broadcast.to(room).emit('message', {data:data, time:time});
		socket.emit('userCount', userCount)

    });

	socket.on('typing', function () {
		var room = rooms[socket.id];
		socket.broadcast.to(room).emit('typing');
		console.log('typing emitted');
    });

	socket.on('disconnect', function(){

		if(rooms[socket.id]){
			var room = rooms[socket.id];
			socket.broadcast.to(room).emit('chat end');
		}

		socket.emit('userCount', --userCount);
		delete allUsers[socket.id];
		console.log ('User '+socket.id+' disconnected')
	});

});

}