feat(base): Fixed logic for websockets and added GameStateEvent. Might've caused instability on other feature branches!
This commit is contained in:
@@ -1,10 +1,7 @@
|
||||
type EventHandler = (data: any) => any | Promise<any>;
|
||||
|
||||
// javascript
|
||||
let ws = null; // will be created by connectWebSocket()
|
||||
const pending: Map<string, any> = new Map(); // id -> { resolve, reject, timer }
|
||||
const handlers: Map<string, EventHandler> = new Map(); // eventType -> handler(data) -> (value|Promise)
|
||||
|
||||
const pending = new Map(); // id -> { resolve, reject, timer }
|
||||
const handlers = new Map(); // eventType -> handler(data) -> (value|Promise)
|
||||
|
||||
let timer = null;
|
||||
|
||||
@@ -39,6 +36,8 @@ function setupSocketHandlers(socket) {
|
||||
return;
|
||||
}
|
||||
|
||||
console.log("Received event:", eventType, "data:", data);
|
||||
|
||||
if (id && eventType) {
|
||||
const handler = handlers.get(eventType);
|
||||
const sendResponse = (result) => {
|
||||
@@ -52,6 +51,7 @@ function setupSocketHandlers(socket) {
|
||||
|
||||
if (!handler) {
|
||||
// no handler: respond with an error object in data so server can fail it
|
||||
console.warn("No handler for event:", eventType);
|
||||
sendResponse({error: "No handler for event: " + eventType});
|
||||
return;
|
||||
}
|
||||
@@ -182,7 +182,7 @@ function sendEventAndWait(eventType, eventData, timeoutMs = 10000) {
|
||||
return p;
|
||||
}
|
||||
|
||||
function onEvent(eventType: string, handler: EventHandler) {
|
||||
function onEvent(eventType, handler) {
|
||||
handlers.set(eventType, handler);
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user