2020-04-08 20:40:44 +02:00
|
|
|
import {MessageUserPosition, Point} from "./Websocket/MessageUserPosition";
|
2020-04-07 10:08:04 +02:00
|
|
|
import {PointInterface} from "./Websocket/PointInterface";
|
|
|
|
import {Group} from "./Group";
|
2020-04-08 20:40:44 +02:00
|
|
|
import {Distance} from "./Distance";
|
2020-04-09 23:26:19 +02:00
|
|
|
import {UserInterface} from "./UserInterface";
|
2020-04-29 01:40:32 +02:00
|
|
|
import {ExSocketInterface} from "_Model/Websocket/ExSocketInterface";
|
2020-04-29 22:41:48 +02:00
|
|
|
import {PositionInterface} from "_Model/PositionInterface";
|
2020-04-07 10:08:04 +02:00
|
|
|
|
|
|
|
export class World {
|
2020-05-03 16:56:19 +02:00
|
|
|
private minDistance: number;
|
|
|
|
private groupRadius: number;
|
2020-04-08 20:40:44 +02:00
|
|
|
|
2020-04-07 10:08:04 +02:00
|
|
|
// Users, sorted by ID
|
2020-04-09 23:26:19 +02:00
|
|
|
private users: Map<string, UserInterface>;
|
2020-04-08 20:40:44 +02:00
|
|
|
private groups: Group[];
|
|
|
|
|
2020-04-07 10:08:04 +02:00
|
|
|
private connectCallback: (user1: string, user2: string) => void;
|
|
|
|
private disconnectCallback: (user1: string, user2: string) => void;
|
|
|
|
|
2020-05-03 16:56:19 +02:00
|
|
|
constructor(connectCallback: (user1: string, user2: string) => void, disconnectCallback: (user1: string, user2: string) => void,
|
|
|
|
minDistance: number,
|
|
|
|
groupRadius: number)
|
2020-04-07 10:08:04 +02:00
|
|
|
{
|
2020-04-09 23:26:19 +02:00
|
|
|
this.users = new Map<string, UserInterface>();
|
2020-04-07 10:08:04 +02:00
|
|
|
this.groups = [];
|
|
|
|
this.connectCallback = connectCallback;
|
|
|
|
this.disconnectCallback = disconnectCallback;
|
2020-05-03 16:56:19 +02:00
|
|
|
this.minDistance = minDistance;
|
|
|
|
this.groupRadius = groupRadius;
|
2020-04-28 23:23:50 +02:00
|
|
|
}
|
2020-04-07 10:08:04 +02:00
|
|
|
|
|
|
|
public join(userPosition: MessageUserPosition): void {
|
2020-04-09 23:26:19 +02:00
|
|
|
this.users.set(userPosition.userId, {
|
|
|
|
id: userPosition.userId,
|
|
|
|
position: userPosition.position
|
|
|
|
});
|
2020-04-29 23:12:55 +02:00
|
|
|
// Let's call update position to trigger the join / leave room
|
|
|
|
this.updatePosition(userPosition);
|
2020-04-07 10:08:04 +02:00
|
|
|
}
|
|
|
|
|
2020-04-29 01:40:32 +02:00
|
|
|
public leave(user : ExSocketInterface){
|
2020-04-29 23:18:42 +02:00
|
|
|
let userObj = this.users.get(user.id);
|
|
|
|
if (userObj !== undefined && typeof userObj.group !== 'undefined') {
|
|
|
|
this.leaveGroup(user);
|
|
|
|
}
|
2020-04-29 01:40:32 +02:00
|
|
|
this.users.delete(user.userId);
|
|
|
|
}
|
|
|
|
|
2020-04-07 10:08:04 +02:00
|
|
|
public updatePosition(userPosition: MessageUserPosition): void {
|
2020-04-09 23:26:19 +02:00
|
|
|
let user = this.users.get(userPosition.userId);
|
|
|
|
if(typeof user === 'undefined') {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
user.position.x = userPosition.position.x;
|
|
|
|
user.position.y = userPosition.position.y;
|
|
|
|
|
|
|
|
if (typeof user.group === 'undefined') {
|
|
|
|
// If the user is not part of a group:
|
|
|
|
// should he join a group?
|
2020-04-29 22:41:48 +02:00
|
|
|
let closestItem: UserInterface|Group|null = this.searchClosestAvailableUserOrGroup(user);
|
2020-04-09 23:26:19 +02:00
|
|
|
|
2020-04-29 22:41:48 +02:00
|
|
|
if (closestItem !== null) {
|
|
|
|
if (closestItem instanceof Group) {
|
|
|
|
// Let's join the group!
|
|
|
|
closestItem.join(user);
|
|
|
|
} else {
|
|
|
|
let closestUser : UserInterface = closestItem;
|
2020-04-09 23:26:19 +02:00
|
|
|
let group: Group = new Group([
|
|
|
|
user,
|
|
|
|
closestUser
|
|
|
|
], this.connectCallback, this.disconnectCallback);
|
2020-04-29 23:12:55 +02:00
|
|
|
this.groups.push(group);
|
2020-04-09 23:26:19 +02:00
|
|
|
}
|
|
|
|
}
|
2020-04-28 23:23:50 +02:00
|
|
|
|
|
|
|
} else {
|
|
|
|
// If the user is part of a group:
|
2020-04-29 23:12:55 +02:00
|
|
|
// should he leave the group?
|
|
|
|
let distance = World.computeDistanceBetweenPositions(user.position, user.group.getPosition());
|
2020-05-03 16:56:19 +02:00
|
|
|
if (distance > this.groupRadius) {
|
2020-04-29 23:12:55 +02:00
|
|
|
this.leaveGroup(user);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2020-04-28 23:23:50 +02:00
|
|
|
|
2020-04-29 23:12:55 +02:00
|
|
|
/**
|
|
|
|
* Makes a user leave a group and closes and destroy the group if the group contains only one remaining person.
|
|
|
|
*
|
|
|
|
* @param user
|
|
|
|
*/
|
|
|
|
private leaveGroup(user: UserInterface): void {
|
|
|
|
let group = user.group;
|
|
|
|
if (typeof group === 'undefined') {
|
|
|
|
throw new Error("The user is part of no group");
|
|
|
|
}
|
|
|
|
group.leave(user);
|
2020-04-28 23:23:50 +02:00
|
|
|
|
2020-04-29 23:12:55 +02:00
|
|
|
if (group.isEmpty()) {
|
|
|
|
group.destroy();
|
|
|
|
const index = this.groups.indexOf(group, 0);
|
|
|
|
if (index === -1) {
|
|
|
|
throw new Error("Could not find group");
|
|
|
|
}
|
|
|
|
this.groups.splice(index, 1);
|
2020-04-09 23:26:19 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Looks for the closest user that is:
|
2020-05-03 16:56:19 +02:00
|
|
|
* - close enough (distance <= minDistance)
|
|
|
|
* - not in a group
|
|
|
|
* OR
|
|
|
|
* - close enough to a group (distance <= groupRadius)
|
2020-04-09 23:26:19 +02:00
|
|
|
*/
|
2020-04-29 22:41:48 +02:00
|
|
|
private searchClosestAvailableUserOrGroup(user: UserInterface): UserInterface|Group|null
|
2020-04-09 23:26:19 +02:00
|
|
|
{
|
2020-05-03 16:56:19 +02:00
|
|
|
let minimumDistanceFound: number = Math.max(this.minDistance, this.groupRadius);
|
2020-04-29 22:41:48 +02:00
|
|
|
let matchingItem: UserInterface | Group | null = null;
|
2020-05-03 16:56:19 +02:00
|
|
|
this.users.forEach((currentUser, userId) => {
|
2020-04-29 22:41:48 +02:00
|
|
|
// Let's only check users that are not part of a group
|
|
|
|
if (typeof currentUser.group !== 'undefined') {
|
|
|
|
return;
|
|
|
|
}
|
2020-04-09 23:26:19 +02:00
|
|
|
if(currentUser === user) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
let distance = World.computeDistance(user, currentUser); // compute distance between peers.
|
2020-04-28 23:23:50 +02:00
|
|
|
|
2020-05-03 16:56:19 +02:00
|
|
|
if(distance <= minimumDistanceFound && distance <= this.minDistance) {
|
2020-04-29 22:41:48 +02:00
|
|
|
minimumDistanceFound = distance;
|
|
|
|
matchingItem = currentUser;
|
|
|
|
}
|
|
|
|
/*if (typeof currentUser.group === 'undefined' || !currentUser.group.isFull()) {
|
2020-04-09 23:26:19 +02:00
|
|
|
// We found a user we can bind to.
|
|
|
|
return;
|
2020-04-29 22:41:48 +02:00
|
|
|
}*/
|
2020-04-09 23:26:19 +02:00
|
|
|
/*
|
2020-04-08 20:40:44 +02:00
|
|
|
if(context.groups.length > 0) {
|
2020-04-28 23:23:50 +02:00
|
|
|
|
2020-04-08 20:40:44 +02:00
|
|
|
context.groups.forEach(group => {
|
|
|
|
if(group.isPartOfGroup(userPosition)) { // Is the user in a group ?
|
|
|
|
if(group.isStillIn(userPosition)) { // Is the user leaving the group ? (is the user at more than max distance of each player)
|
2020-04-28 23:23:50 +02:00
|
|
|
|
2020-04-08 20:40:44 +02:00
|
|
|
// Should we split the group? (is each player reachable from the current player?)
|
|
|
|
// This is needed if
|
|
|
|
// A <==> B <==> C <===> D
|
|
|
|
// becomes A <==> B <=====> C <> D
|
|
|
|
// If C moves right, the distance between B and C is too great and we must form 2 groups
|
|
|
|
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
// If the user is in no group
|
|
|
|
// Is there someone in a group close enough and with room in the group ?
|
|
|
|
}
|
|
|
|
});
|
|
|
|
|
|
|
|
} else {
|
|
|
|
// Aucun groupe n'existe donc je stock les users assez proches de moi
|
2020-04-09 23:26:19 +02:00
|
|
|
let dist: Distance = {
|
2020-04-08 20:40:44 +02:00
|
|
|
distance: distance,
|
|
|
|
first: userPosition,
|
|
|
|
second: user // TODO: convertir en messageUserPosition
|
|
|
|
}
|
|
|
|
usersToBeGroupedWith.push(dist);
|
|
|
|
}
|
2020-04-09 23:26:19 +02:00
|
|
|
*/
|
2020-04-29 22:41:48 +02:00
|
|
|
});
|
|
|
|
|
2020-05-03 16:56:19 +02:00
|
|
|
this.groups.forEach((group: Group) => {
|
2020-04-29 22:41:48 +02:00
|
|
|
if (group.isFull()) {
|
|
|
|
return;
|
2020-04-08 20:40:44 +02:00
|
|
|
}
|
2020-04-29 22:41:48 +02:00
|
|
|
let distance = World.computeDistanceBetweenPositions(user.position, group.getPosition());
|
2020-05-03 16:56:19 +02:00
|
|
|
if(distance <= minimumDistanceFound && distance <= this.groupRadius) {
|
2020-04-29 22:41:48 +02:00
|
|
|
minimumDistanceFound = distance;
|
|
|
|
matchingItem = group;
|
|
|
|
}
|
|
|
|
});
|
2020-04-08 20:40:44 +02:00
|
|
|
|
2020-04-29 22:41:48 +02:00
|
|
|
return matchingItem;
|
2020-04-08 20:40:44 +02:00
|
|
|
}
|
|
|
|
|
2020-04-09 23:26:19 +02:00
|
|
|
public static computeDistance(user1: UserInterface, user2: UserInterface): number
|
2020-04-08 20:40:44 +02:00
|
|
|
{
|
2020-04-09 23:26:19 +02:00
|
|
|
return Math.sqrt(Math.pow(user2.position.x - user1.position.x, 2) + Math.pow(user2.position.y - user1.position.y, 2));
|
2020-04-08 20:40:44 +02:00
|
|
|
}
|
2020-04-07 10:08:04 +02:00
|
|
|
|
2020-04-29 22:41:48 +02:00
|
|
|
public static computeDistanceBetweenPositions(position1: PositionInterface, position2: PositionInterface): number
|
|
|
|
{
|
|
|
|
return Math.sqrt(Math.pow(position2.x - position1.x, 2) + Math.pow(position2.y - position1.y, 2));
|
|
|
|
}
|
|
|
|
|
2020-04-09 23:26:19 +02:00
|
|
|
/*getDistancesBetweenGroupUsers(group: Group): Distance[]
|
2020-04-08 20:40:44 +02:00
|
|
|
{
|
|
|
|
let i = 0;
|
|
|
|
let users = group.getUsers();
|
|
|
|
let distances: Distance[] = [];
|
|
|
|
users.forEach(function(user1, key1) {
|
|
|
|
users.forEach(function(user2, key2) {
|
|
|
|
if(key1 < key2) {
|
|
|
|
distances[i] = {
|
2020-04-09 23:26:19 +02:00
|
|
|
distance: World.computeDistance(user1, user2),
|
2020-04-08 20:40:44 +02:00
|
|
|
first: user1,
|
|
|
|
second: user2
|
|
|
|
};
|
|
|
|
i++;
|
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
2020-04-28 23:23:50 +02:00
|
|
|
|
2020-04-08 20:40:44 +02:00
|
|
|
distances.sort(World.compareDistances);
|
2020-04-07 10:08:04 +02:00
|
|
|
|
2020-04-08 20:40:44 +02:00
|
|
|
return distances;
|
|
|
|
}
|
|
|
|
|
|
|
|
filterGroup(distances: Distance[], group: Group): void
|
|
|
|
{
|
|
|
|
let users = group.getUsers();
|
|
|
|
let usersToRemove = false;
|
|
|
|
let groupTmp: MessageUserPosition[] = [];
|
|
|
|
distances.forEach(dist => {
|
|
|
|
if(dist.distance <= World.MIN_DISTANCE) {
|
|
|
|
let users = [dist.first];
|
|
|
|
let usersbis = [dist.second]
|
|
|
|
groupTmp.push(dist.first);
|
|
|
|
groupTmp.push(dist.second);
|
|
|
|
} else {
|
|
|
|
usersToRemove = true;
|
|
|
|
}
|
|
|
|
});
|
2020-04-07 10:08:04 +02:00
|
|
|
|
2020-04-08 20:40:44 +02:00
|
|
|
if(usersToRemove) {
|
|
|
|
// Detecte le ou les users qui se sont fait sortir du groupe
|
|
|
|
let difference = users.filter(x => !groupTmp.includes(x));
|
2020-04-07 10:08:04 +02:00
|
|
|
|
2020-04-28 23:23:50 +02:00
|
|
|
// TODO : Notify users un difference that they have left the group
|
2020-04-08 20:40:44 +02:00
|
|
|
}
|
2020-04-07 10:08:04 +02:00
|
|
|
|
2020-04-08 20:40:44 +02:00
|
|
|
let newgroup = new Group(groupTmp);
|
|
|
|
this.groups.push(newgroup);
|
2020-04-07 10:08:04 +02:00
|
|
|
}
|
|
|
|
|
2020-04-08 20:40:44 +02:00
|
|
|
private static compareDistances(distA: Distance, distB: Distance): number
|
|
|
|
{
|
|
|
|
if (distA.distance < distB.distance) {
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
if (distA.distance > distB.distance) {
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
return 0;
|
2020-04-09 23:26:19 +02:00
|
|
|
}*/
|
2020-04-28 23:23:50 +02:00
|
|
|
}
|