104 lines
2.4 KiB
JavaScript
104 lines
2.4 KiB
JavaScript
|
export class SocketHandler {
|
||
|
|
constructor(url) {
|
||
|
|
this.url = url;
|
||
|
|
this.socket = new WebSocket(url);
|
||
|
|
|
||
|
|
this.socket.addEventListener('open', (e) => {
|
||
|
|
this.callbacks.open.forEach(cb => cb(e));
|
||
|
|
})
|
||
|
|
this.socket.addEventListener('message', (e) => {
|
||
|
|
const data = JSON.parse(e.data);
|
||
|
|
this.callbacks.message.forEach((listener, index) => {
|
||
|
|
if (listener.type && listener.type !== data.type) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
listener.cb(data.type, data.data, e);
|
||
|
|
if (listener.once) {
|
||
|
|
this.callbacks.message.splice(index, 1);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
});
|
||
|
|
|
||
|
|
this.callbacks = {
|
||
|
|
open: [],
|
||
|
|
message: [],
|
||
|
|
close: [],
|
||
|
|
};
|
||
|
|
|
||
|
|
this.initialized = false;
|
||
|
|
this.gameToken = null;
|
||
|
|
}
|
||
|
|
|
||
|
|
async initGame() {
|
||
|
|
this.initialized = false;
|
||
|
|
this.gameToken = null;
|
||
|
|
return this.sendAndWaitForResult('game.init', {
|
||
|
|
playerCount: 4,
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
async joinGame(gameId) {
|
||
|
|
this.initialized = false;
|
||
|
|
this.gameToken = null;
|
||
|
|
return this.sendAndWaitForResult('game.join', {
|
||
|
|
gameID: gameId,
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
playCard(card) {
|
||
|
|
if (!this.initialized) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
this.send('card.play', {
|
||
|
|
color: card.color,
|
||
|
|
value: card.value,
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
drawCard() {
|
||
|
|
if (!this.initialized) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
this.send('card.draw', {})
|
||
|
|
}
|
||
|
|
|
||
|
|
selectColor(color) {
|
||
|
|
if (!this.initialized) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
this.send('card.color', {
|
||
|
|
color
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
send(type, data) {
|
||
|
|
this.socket.send(JSON.stringify({
|
||
|
|
type,
|
||
|
|
data,
|
||
|
|
}));
|
||
|
|
}
|
||
|
|
|
||
|
|
async sendAndWaitForResult(type, data) {
|
||
|
|
return new Promise((resolve, reject) => {
|
||
|
|
this.send(type, data);
|
||
|
|
this.callbacks.message.push({
|
||
|
|
type: type + '.result',
|
||
|
|
once: true,
|
||
|
|
cb: (type, data) => {
|
||
|
|
resolve(data);
|
||
|
|
},
|
||
|
|
});
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
onOpen(callback) {
|
||
|
|
this.callbacks.open.push(callback);
|
||
|
|
}
|
||
|
|
|
||
|
|
onMessage(callback) {
|
||
|
|
this.callbacks.message.push(callback);
|
||
|
|
}
|
||
|
|
}
|