瀏覽代碼

Worked on sockethandler a bit and added some socket support in main.js.

KrisVos130 7 年之前
父節點
當前提交
0c79e9c464
共有 2 個文件被更改,包括 15 次插入10 次删除
  1. 5 0
      public/js/main.js
  2. 10 10
      src/logic/socketHandler.js

+ 5 - 0
public/js/main.js

@@ -82,6 +82,7 @@ window.onload = function () {
 		leaveRoom: function () {
 			data.room.visible = false;
 			window.setTimeout(function () { data.home.visible = true; }, 500);
+			socket.leave("/" + data.room.id);
 		},
 		enterRoom: function (room) {
 			data.home.visible = false;
@@ -89,6 +90,10 @@ window.onload = function () {
 			data.room.id = room.id;
 			data.room.displayName = room.displayName;
 			data.room.description = room.description;
+			socket.join("/" + room.id);
+			socket.emit("/stations/join/:id", room.id, function(result) {
+				console.log(result);
+			});
 		},
 		modalVisibilityChange: function (name) {
 			var modal = data.modals[name];

+ 10 - 10
src/logic/socketHandler.js

@@ -17,33 +17,33 @@ module.exports = function (core, io) {
 			console.log('User has disconnected');
 		});
 
-		socket.on('/users/login', function (user) {
+		socket.on('/users/login', function (user, cb) {
 			core['/users/login'](user, function (result) {
-				socket.emit('/users/login', result);
+				cb(result);
 			});
 		});
 
-		socket.on('/users/register', function (user) {
+		socket.on('/users/register', function (user, cb) {
 			core['/users/register'](user, function (result) {
-				socket.emit('/users/register', result);
+				cb(result);
 			});
 		});
 
-		socket.on('/stations', function () {
+		socket.on('/stations', function (cb) {
 			core['/stations'](function (result) {
-				socket.emit('/stations', result);
+				cb(result);
 			});
 		});
 
-		socket.on('/stations/join/:id', function (id) {
+		socket.on('/stations/join/:id', function (id, cb) {
 			core['/stations/join/:id'](id, function (result) {
-				socket.emit('/stations/join/:id', result);
+				cb(result);
 			});
 		});
 
-		socket.on('/stations/search/:query', function (query) {
+		socket.on('/stations/search/:query', function (query, cb) {
 			core['/stations/search/:query'](query, function (result) {
-				socket.emit('/stations/search/:query', result);
+				cb(result);
 			});
 		});