X-Git-Url: https://git.auder.net/?a=blobdiff_plain;f=sockets.js;h=30beb32373834bf152ae4863746a0f83e425b937;hb=20c96143f3ef4e652b4968bb994b0f70e008a861;hp=2ce8ae9ad7f352b33c761ddcacd501282a808723;hpb=71d1ca9c594b64d959c608a2abbff926480abad5;p=qomet.git

diff --git a/sockets.js b/sockets.js
index 2ce8ae9..30beb32 100644
--- a/sockets.js
+++ b/sockets.js
@@ -5,19 +5,15 @@ const ObjectId = require("bson-objectid");
 
 module.exports = function(io)
 {
-	io.of("/").on("connection", socket => {
+	io.of("/").on("connection", socket => { //student or monitor connexion
 		const aid = socket.handshake.query.aid;
-		socket.join(aid);
-		// Student or monitor connexion
 		const isTeacher = !!socket.handshake.query.secret && socket.handshake.query.secret == params.secret;
 
 		if (isTeacher)
 		{
-			socket.on(message.newAnswer, m => { //got answer from student
-				socket.emit(message.newAnswer, m);
-			});
+			socket.join(aid + "_teacher");
 			socket.on(message.allAnswers, m => { //send feedback to student (answers)
-				socket.broadcast.to(aid).emit(message.allAnswers, m);
+				socket.broadcast.to(aid + "_student").emit(message.allAnswers, m);
 			});
 		}
 		else //student
@@ -27,9 +23,27 @@ module.exports = function(io)
 			AssessmentModel.checkPassword(ObjectId(aid), number, password, (err,ret) => {
 				if (!!err || !ret)
 					return; //wrong password, or some unexpected error...
-				socket.on("disconnect", () => {
-					//TODO: notify monitor (grey low opacity background)
-					//Also send to server: discoTime in assessment.papers ...
+				AssessmentModel.newConnection(ObjectId(aid), number);
+				socket.broadcast.to(aid + "_teacher").emit(message.studentConnect, {number: number});
+				socket.join(aid + "_student");
+				socket.on(message.newAnswer, m => { //got answer from student client
+					socket.broadcast.to(aid + "_teacher").emit(message.newAnswer, m);
+				});
+				socket.on(message.studentBlur, m => {
+					socket.broadcast.to(aid + "_teacher").emit(message.studentBlur, m);
+				});
+				socket.on(message.studentFocus, m => {
+					socket.broadcast.to(aid + "_teacher").emit(message.studentFocus, m);
+				});
+				socket.on(message.studentResize, m => {
+					socket.broadcast.to(aid + "_teacher").emit(message.studentResize, m);
+				});
+				socket.on(message.studentFullscreen, m => {
+					socket.broadcast.to(aid + "_teacher").emit(message.studentFullscreen, m);
+				});
+				socket.on("disconnect", () => { //notify monitor + server
+					AssessmentModel.setDiscoTime(ObjectId(aid), number);
+					socket.broadcast.to(aid + "_teacher").emit(message.studentDisconnect, {number: number});
 				});
 			});
 		}