-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #24 from gelic-idealab/dev
v1.1.0: Private and message-based state catch-up, Sync namespace, Session.js, Connection Info, Socket Repair Center
- Loading branch information
Showing
13 changed files
with
3,710 additions
and
1,935 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,231 @@ | ||
| class Session { | ||
| constructor(id) { | ||
| this.id = id; | ||
| this.sockets = {}; // socket.id -> client_id | ||
| this.clients = []; | ||
| this.entities = []; | ||
| this.scene = null; | ||
| this.isRecording = false; | ||
| this.start = Date.now(); | ||
| this.recordingStart = 0; | ||
| this.seq = 0; | ||
| // NOTE(rob) = DEPRECATED; use message_buffer. 8/3/2021 | ||
| // writers = { | ||
| // pos = { | ||
| // buffer = Buffer.alloc(this.positionWriteBufferSize()); | ||
| // cursor = 0 | ||
| // }; | ||
| // int = { | ||
| // buffer = Buffer.alloc(this.interactionWriteBufferSize()); | ||
| // cursor = 0 | ||
| // } | ||
| // }; | ||
| this.message_buffer = []; | ||
| } | ||
|
|
||
| getId() { | ||
| return this.id; | ||
| } | ||
|
|
||
| getSockets() { | ||
| return this.sockets; | ||
| } | ||
|
|
||
| addSocket(socket, client_id) { | ||
| this.sockets[socket.id] = { client_id: client_id, socket: socket }; | ||
| } | ||
|
|
||
| // Returns success = true if operation succeeded or false if socket or session with id were null. | ||
| // Returns isInSession if socket is in this.sockets. | ||
| hasSocket(socket) { | ||
| return socket.id in this.sockets; | ||
| } | ||
|
|
||
| removeSocket(socket) { | ||
| let isInSession = this.hasSocket(socket); | ||
|
|
||
| if (!isInSession) { | ||
| return false; | ||
| } | ||
|
|
||
| delete this.sockets[socket.id]; | ||
|
|
||
| return true; | ||
| } | ||
|
|
||
| getSocketsFromClientId(client_id, excluded_socket_id) { | ||
| if (this.sockets == null) { | ||
| this.logErrorSessionClientSocketAction( | ||
| this.id, | ||
| client_id, | ||
| null, | ||
| `tried to get session sockets from client ID, but this.sockets was null` | ||
| ); | ||
|
|
||
| return null; | ||
| } | ||
|
|
||
| var result = []; | ||
|
|
||
| for (var candidate_socket_id in this.sockets) { | ||
| let isCorrectId = | ||
| this.sockets[candidate_socket_id].client_id == client_id; | ||
|
|
||
| let doExclude = | ||
| this.sockets[candidate_socket_id].socket.id == excluded_socket_id; | ||
|
|
||
| if (isCorrectId && !doExclude) { | ||
| result.push(this.sockets[candidate_socket_id].socket); | ||
| } | ||
| } | ||
|
|
||
| return result; | ||
| } | ||
|
|
||
| getClients() { | ||
| return this.clients; | ||
| } | ||
|
|
||
| addClient(client_id) { | ||
| if ( | ||
| this.clients == null || | ||
| typeof this.clients === "undefined" || | ||
| this.clients.length == 0 | ||
| ) { | ||
| this.clients = [client_id]; | ||
|
|
||
| return true; | ||
| } | ||
|
|
||
| this.clients.push(client_id); | ||
|
|
||
| return true; | ||
| } | ||
|
|
||
| removeClient(client_id) { | ||
| if (this.clients == null) { | ||
| return false; | ||
| } | ||
|
|
||
| let index = this.clients.indexOf(client_id); | ||
|
|
||
| if (this.clients.length == 0 || this.clients.indexOf(client_id) == -1) { | ||
| //client_id is not in the array, so we don't need to remove it. | ||
| return false; | ||
| } | ||
|
|
||
| this.clients.splice(index, 1); | ||
| } | ||
|
|
||
| removeDuplicateClients(client_id) { | ||
| if (this.clients == null) { | ||
| this.logErrorSessionClientSocketAction( | ||
| this.id, | ||
| client_id, | ||
| null, | ||
| `tried to remove duplicate client from session, but this.clients was null` | ||
| ); | ||
|
|
||
| return; | ||
| } | ||
|
|
||
| if (this.clients.length == 0) { | ||
| return; | ||
| } | ||
|
|
||
| const first_instance = this.clients.indexOf(client_id); | ||
|
|
||
| for (let i = 0; i < this.clients.length; i += 1) { | ||
| if (i != first_instance && this.clients[i] == client_id) { | ||
| this.clients.splice(i, 1); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| hasClient (client_id) { | ||
| const numInstances = this.getNumClientInstances(client_id); | ||
|
|
||
| if (numInstances >= 1) { | ||
| return true; | ||
| } | ||
|
|
||
| return false; | ||
| } | ||
|
|
||
| getNumClientInstances(client_id) { | ||
| if (this.clients == null) { | ||
| this.logErrorSessionClientSocketAction( | ||
| this.id, | ||
| client_id, | ||
| null, | ||
| `Could not get number of client instances -- session was null or session.clients was null.` | ||
| ); | ||
|
|
||
| return -1; | ||
| } | ||
|
|
||
| var count = 0; | ||
|
|
||
| this.clients.forEach((value) => { | ||
| if (value == client_id) { | ||
| count += 1; | ||
| } | ||
| }); | ||
|
|
||
| return count; | ||
| } | ||
|
|
||
| getTotalNumInstancesForAllClients () { | ||
| if (this.clients == null) { | ||
| this.logWarningSessionClientSocketAction( | ||
| this.id, | ||
| null, | ||
| null, | ||
| `the session's session.clients was null.` | ||
| ); | ||
|
|
||
| return -1; | ||
| } | ||
|
|
||
| return session.clients.length; | ||
| } | ||
|
|
||
| getClientIdFromSocket(socket) { | ||
| if (this.sockets == null) { | ||
| this.logErrorSessionClientSocketAction( | ||
| this.id, | ||
| client_id, | ||
| null, | ||
| `tried to get client ID from session socket, but this.sockets was null` | ||
| ); | ||
|
|
||
| return null; | ||
| } | ||
|
|
||
| if (socket.id == null) { | ||
| this.logErrorSessionClientSocketAction( | ||
| this.id, | ||
| client_id, | ||
| null, | ||
| `tried to get client ID from session socket, but socket.id was null` | ||
| ); | ||
|
|
||
| return null; | ||
| } | ||
|
|
||
| if (this.sockets[socket.id] == null) { | ||
| this.logErrorSessionClientSocketAction( | ||
| this.id, | ||
| client_id, | ||
| null, | ||
| `tried to get client ID from session socket, but this.sockets[socket.id] was null` | ||
| ); | ||
|
|
||
| return null; | ||
| } | ||
|
|
||
| return this.sockets[socket.id].client_id; | ||
| } | ||
| } | ||
|
|
||
| module.exports = Session; |
Oops, something went wrong.