Permit to dissociate data by room

- Update share room id.
 - Join room when a scene is loaded.
 - Add a room in constant variable.
This commit is contained in:
gparant 2020-05-10 13:58:32 +02:00
parent 27c6034661
commit 5f11b065e1
7 changed files with 46 additions and 27 deletions

View File

@ -1,7 +1,7 @@
import {Application, Request, Response} from "express"; import {Application, Request, Response} from "express";
import Jwt from "jsonwebtoken"; import Jwt from "jsonwebtoken";
import {BAD_REQUEST, OK} from "http-status-codes"; import {BAD_REQUEST, OK} from "http-status-codes";
import {SECRET_KEY, ROOM} from "../Enum/EnvironmentVariable"; //TODO fix import by "_Enum/..." import {SECRET_KEY, ROOM_STARTED, URL_ROOM_STARTED} from "../Enum/EnvironmentVariable"; //TODO fix import by "_Enum/..."
import { uuid } from 'uuidv4'; import { uuid } from 'uuidv4';
export class AuthenticateController{ export class AuthenticateController{
@ -23,15 +23,11 @@ export class AuthenticateController{
} }
//TODO check user email for The Coding Machine game //TODO check user email for The Coding Machine game
let userId = uuid(); let userId = uuid();
let token = Jwt.sign({email: param.email, roomId: ROOM, userId: userId}, SECRET_KEY, {expiresIn: '24h'}); let token = Jwt.sign({email: param.email, userId: userId}, SECRET_KEY, {expiresIn: '24h'});
return res.status(OK).send({ return res.status(OK).send({
token: token, token: token,
roomId: ROOM, startedRoom: {key: ROOM_STARTED, url: URL_ROOM_STARTED},
userId: userId, userId: userId,
maps: [
"floor0",
"floor1"
]
}); });
}); });
} }

View File

@ -104,6 +104,15 @@ export class IoSocketController {
return socket.emit(SockerIoEvent.MESSAGE_ERROR, JSON.stringify({message: messageUserPosition.message})) return socket.emit(SockerIoEvent.MESSAGE_ERROR, JSON.stringify({message: messageUserPosition.message}))
} }
if((socket as ExSocketInterface).roomId === messageUserPosition.roomId){
return;
}
//lease previous room
if((socket as ExSocketInterface).roomId){
socket.leave((socket as ExSocketInterface).roomId);
}
//join user in room //join user in room
socket.join(messageUserPosition.roomId); socket.join(messageUserPosition.roomId);
@ -308,7 +317,7 @@ export class IoSocketController {
} }
arrayMap.forEach((value: any) => { arrayMap.forEach((value: any) => {
let roomId = value[0]; let roomId = value[0];
this.Io.in(roomId).emit(SockerIoEvent.USER_POSITION, JSON.stringify(arrayMap)); this.Io.in(roomId).emit(SockerIoEvent.USER_POSITION, JSON.stringify(value));
}); });
this.seTimeOutInProgress = setTimeout(() => { this.seTimeOutInProgress = setTimeout(() => {
this.shareUsersPosition(); this.shareUsersPosition();

View File

@ -2,6 +2,7 @@ import express from "express";
import path from "path"; import path from "path";
import {Application, Request, Response} from "express"; import {Application, Request, Response} from "express";
import {OK} from "http-status-codes"; import {OK} from "http-status-codes";
import {ROOM_STARTED, ROOMS, URL_ROOM_STARTED} from "../Enum/EnvironmentVariable";
export class MapController { export class MapController {
App: Application; App: Application;
@ -20,11 +21,8 @@ export class MapController {
getMpas() { getMpas() {
this.App.get("/maps", (req: Request, res: Response) => { this.App.get("/maps", (req: Request, res: Response) => {
return res.status(OK).send({ return res.status(OK).send({
mapStart: {key: "floor0", url: "/map/files/Floor0"}, mapStart: {key: ROOM_STARTED, url: URL_ROOM_STARTED},
maps: [ maps: ROOMS
{key: "floor0", url: "/map/files/Floor0"},
{key: "floor1", url: "/map/files/Floor1"},
]
}); });
}); });
} }

View File

@ -1,11 +1,18 @@
const SECRET_KEY = process.env.SECRET_KEY || "THECODINGMACHINE_SECRET_KEY"; const SECRET_KEY = process.env.SECRET_KEY || "THECODINGMACHINE_SECRET_KEY";
const ROOM = process.env.ROOM || "THECODINGMACHINE"; const ROOM_STARTED = "floor0";
const URL_ROOM_STARTED = "/map/files/Floor0";
const ROOMS = [
{key: "floor0", url: "/map/files/Floor0"},
{key: "floor1", url: "/map/files/Floor1"},
]
const MINIMUM_DISTANCE = process.env.MINIMUM_DISTANCE ? Number(process.env.MINIMUM_DISTANCE) : 64; const MINIMUM_DISTANCE = process.env.MINIMUM_DISTANCE ? Number(process.env.MINIMUM_DISTANCE) : 64;
const GROUP_RADIUS = process.env.GROUP_RADIUS ? Number(process.env.GROUP_RADIUS) : 48; const GROUP_RADIUS = process.env.GROUP_RADIUS ? Number(process.env.GROUP_RADIUS) : 48;
export { export {
SECRET_KEY, SECRET_KEY,
ROOM, ROOM_STARTED,
URL_ROOM_STARTED,
ROOMS,
MINIMUM_DISTANCE, MINIMUM_DISTANCE,
GROUP_RADIUS GROUP_RADIUS
} }

View File

@ -147,7 +147,7 @@ export interface ConnexionInterface {
joinARoom(roomId: string, character: string): void; joinARoom(roomId: string, character: string): void;
sharePosition(x: number, y: number, direction: string, character: string): void; sharePosition(x: number, y: number, direction: string, roomId: string, character: string): void;
positionOfAllUser(): void; positionOfAllUser(): void;
@ -182,7 +182,7 @@ export class Connexion implements ConnexionInterface {
return Axios.post(`${API_URL}/login`, {email: this.email}) return Axios.post(`${API_URL}/login`, {email: this.email})
.then((res) => { .then((res) => {
this.token = res.data.token; this.token = res.data.token;
this.startedRoom = res.data.roomId; this.startedRoom = res.data.startedRoom.key;
this.userId = res.data.userId; this.userId = res.data.userId;
this.socket = SocketIo(`${API_URL}`, { this.socket = SocketIo(`${API_URL}`, {
@ -195,7 +195,7 @@ export class Connexion implements ConnexionInterface {
this.joinARoom(this.startedRoom, characterSelected); this.joinARoom(this.startedRoom, characterSelected);
//share your first position //share your first position
this.sharePosition(0, 0, characterSelected); this.sharePosition(0, 0, characterSelected, this.startedRoom);
this.positionOfAllUser(); this.positionOfAllUser();
@ -229,7 +229,7 @@ export class Connexion implements ConnexionInterface {
joinARoom(roomId: string, character: string): void { joinARoom(roomId: string, character: string): void {
let messageUserPosition = new MessageUserPosition( let messageUserPosition = new MessageUserPosition(
this.userId, this.userId,
this.startedRoom, roomId,
new Point(0, 0), new Point(0, 0),
this.email, this.email,
character character
@ -242,15 +242,16 @@ export class Connexion implements ConnexionInterface {
* @param x * @param x
* @param y * @param y
* @param character * @param character
* @param roomId
* @param direction * @param direction
*/ */
sharePosition(x : number, y : number, character : string, direction : string = "none") : void{ sharePosition(x : number, y : number, character : string, roomId : string, direction : string = "none") : void{
if(!this.socket){ if(!this.socket){
return; return;
} }
let messageUserPosition = new MessageUserPosition( let messageUserPosition = new MessageUserPosition(
this.userId, this.userId,
ROOM[0], roomId,
new Point(x, y, direction), new Point(x, y, direction),
this.email, this.email,
character character
@ -276,10 +277,9 @@ export class Connexion implements ConnexionInterface {
positionOfAllUser(): void { positionOfAllUser(): void {
this.socket.on(EventMessage.USER_POSITION, (message: string) => { this.socket.on(EventMessage.USER_POSITION, (message: string) => {
let dataList = JSON.parse(message); let dataList = JSON.parse(message);
dataList.forEach((UserPositions: any) => { let UserPositions : Array<any> = Object.values(dataList);
let listMessageUserPosition = new ListMessageUserPosition(UserPositions[0], UserPositions[1]); let listMessageUserPosition = new ListMessageUserPosition(UserPositions[0], UserPositions[1]);
this.GameManager.shareUserPosition(listMessageUserPosition); this.GameManager.shareUserPosition(listMessageUserPosition);
});
}); });
} }

View File

@ -71,6 +71,10 @@ export class GameManager {
this.status = StatusGameManagerEnum.CURRENT_USER_CREATED; this.status = StatusGameManagerEnum.CURRENT_USER_CREATED;
} }
joinRoom(sceneKey : string, character: string){
this.ConnexionInstance.joinARoom(sceneKey, character);
}
/** /**
* Share position in game * Share position in game
* @param ListMessageUserPosition * @param ListMessageUserPosition
@ -120,7 +124,7 @@ export class GameManager {
} }
pushPlayerPosition(event: HasMovedEvent) { pushPlayerPosition(event: HasMovedEvent) {
this.ConnexionInstance.sharePosition(event.x, event.y, event.character, event.direction); this.ConnexionInstance.sharePosition(event.x, event.y, event.character, this.currentGameScene.scene.key, event.direction);
} }
} }

View File

@ -139,7 +139,7 @@ export class GameScene extends Phaser.Scene implements GameSceneInterface, Creat
// Let's generate the circle for the group delimiter // Let's generate the circle for the group delimiter
//TODO they are error with cercle
this.circleTexture = this.textures.createCanvas('circleSprite', 96, 96); this.circleTexture = this.textures.createCanvas('circleSprite', 96, 96);
if(!this.circleTexture || this.circleTexture.context){ if(!this.circleTexture || this.circleTexture.context){
return; return;
@ -268,6 +268,11 @@ export class GameScene extends Phaser.Scene implements GameSceneInterface, Creat
//create collision //create collision
this.createCollisionWithPlayer(); this.createCollisionWithPlayer();
this.createCollisionObject(); this.createCollisionObject();
//join room
this.GameManager.joinRoom(this.scene.key, this.CurrentPlayer.PlayerTexture);
//listen event to share position of user
this.CurrentPlayer.on(hasMovedEventName, this.pushPlayerPosition.bind(this)) this.CurrentPlayer.on(hasMovedEventName, this.pushPlayerPosition.bind(this))
} }