Refactor and fix error hydration message socket io

- Position message send will be on format :
message :
                    userId : user identification
                    roomId: room identification
                    position: position of user in map
                        x: user x position on map
                        y: user y position on map
 - Create Point object and interface to have position x and y of user in map.
This commit is contained in:
gparant 2020-04-04 16:25:03 +02:00
parent ba47d8b1d4
commit e8da727cae
5 changed files with 49 additions and 17 deletions

View File

@ -1,8 +1,8 @@
import socketIO = require('socket.io'); import socketIO = require('socket.io');
import {Socket} from "socket.io"; import {Socket} from "socket.io";
import * as http from "http"; import * as http from "http";
import {MessageUserPosition} from "@Model/Websocket/MessageUserPosition"; import {MessageUserPosition} from "../Model/Websocket/MessageUserPosition"; //TODO fix to use "_Model/.."
import {ExSocketInterface} from "@Model/Websocket/ExSocketInterface"; import {ExSocketInterface} from "../Model/Websocket/ExSocketInterface"; //TODO fix to use "_Model/.."
import Jwt, {JsonWebTokenError} from "jsonwebtoken"; import Jwt, {JsonWebTokenError} from "jsonwebtoken";
const SECRET_KEY = process.env.SECRET_KEY || "THECODINGMACHINE_SECRET_KEY"; const SECRET_KEY = process.env.SECRET_KEY || "THECODINGMACHINE_SECRET_KEY";
@ -35,19 +35,29 @@ export class IoSocketController{
message : message :
userId : user identification userId : user identification
roomId: room identification roomId: room identification
positionXUser: user x position map position: position of user in map
positionYUser: user y position on map x: user x position on map
y: user y position on map
*/ */
socket.on('join-room', (message : MessageUserPosition) => { socket.on('join-room', (message : string) => {
socket.join(message.roomId); let messageUserPosition = new MessageUserPosition(message);
socket.join(messageUserPosition.roomId);
// sending to all clients in room except sender // sending to all clients in room except sender
socket.to(message.roomId).emit('join-room', message.toString()); this.saveUserPosition((socket as ExSocketInterface), messageUserPosition);
socket.to(messageUserPosition.roomId).emit('join-room', messageUserPosition.toString());
}); });
socket.on('user-position', (message : MessageUserPosition) => { socket.on('user-position', (message : string) => {
let messageUserPosition = new MessageUserPosition(message);
// sending to all clients in room except sender // sending to all clients in room except sender
socket.to(message.roomId).emit('join-room', message.toString()); this.saveUserPosition((socket as ExSocketInterface), messageUserPosition);
socket.to(messageUserPosition.roomId).emit('join-room', messageUserPosition.toString());
}); });
}); });
} }
//permit to save user position in socket
saveUserPosition(socket : ExSocketInterface, message : MessageUserPosition){
socket.position = message.position;
}
} }

View File

@ -1,5 +1,7 @@
import {Socket} from "socket.io"; import {Socket} from "socket.io";
import {PointInterface} from "./PointInterface";
export interface ExSocketInterface extends Socket { export interface ExSocketInterface extends Socket {
token: object; token: object;
position: PointInterface;
} }

View File

@ -1,14 +1,30 @@
import {Message} from "./Message"; import {Message} from "./Message";
import {PointInterface} from "./PointInterface";
export class Point implements PointInterface{
x: number;
y: number;
constructor(x : number, y : number) {
this.x = x;
this.y = y;
}
toJson(){
return {
x : this.x,
y: this.y
}
}
}
export class MessageUserPosition extends Message{ export class MessageUserPosition extends Message{
positionXUser: string; position: PointInterface
positionYUser: string;
constructor(message: string) { constructor(message: string) {
super(message); super(message);
let data = JSON.parse(message); let data = JSON.parse(message);
this.positionXUser = data.positionXUser; this.position = new Point(data.position.x, data.position.y);
this.positionYUser = data.positionYUser;
} }
toString() { toString() {
@ -16,8 +32,7 @@ export class MessageUserPosition extends Message{
Object.assign( Object.assign(
super.toJson(), super.toJson(),
{ {
positionXUser: this.positionXUser, position: this.position.toJson()
positionYUser: this.positionYUser
}) })
); );
} }

View File

@ -0,0 +1,5 @@
export interface PointInterface {
x: number;
y: number;
toJson() : object;
}

View File

@ -43,8 +43,8 @@
"moduleResolution": "node", /* Specify module resolution strategy: 'node' (Node.js) or 'classic' (TypeScript pre-1.6). */ "moduleResolution": "node", /* Specify module resolution strategy: 'node' (Node.js) or 'classic' (TypeScript pre-1.6). */
"baseUrl": ".", /* Base directory to resolve non-absolute module names. */ "baseUrl": ".", /* Base directory to resolve non-absolute module names. */
"paths": { "paths": {
"@Controller/*": ["src/Controller/*"], "_Controller/*": ["src/Controller/*"],
"@Model/*": ["src/Model/*"] "_Model/*": ["src/Model/*"]
}, /* A series of entries which re-map imports to lookup locations relative to the 'baseUrl'. */ }, /* A series of entries which re-map imports to lookup locations relative to the 'baseUrl'. */
// "rootDirs": [], /* List of root folders whose combined content represents the structure of the project at runtime. */ // "rootDirs": [], /* List of root folders whose combined content represents the structure of the project at runtime. */
// "typeRoots": [], /* List of folders to include type definitions from. */ // "typeRoots": [], /* List of folders to include type definitions from. */