jhalitaksoy/mancala
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

implement on_user_connection_change

Browse Source
This commit is contained in:
Halit Aksoy 2022-07-23 00:32:55 +03:00
parent 5e242ca9ba
commit 228fd8cef7
2 changed files with 31 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/consts/channel_names.ts
View File

@ -7,4 +7,5 @@ export const channel_on_game_end = "on_game_end"
export const channel_on_game_crashed = "on_game_crashed"
export const channel_on_game_user_leave = "on_game_user_leave"
export const channel_ping = "ping"
export const channel_pong = "pong"
export const channel_pong = "pong"
export const channel_on_user_connection_change = "channel_on_user_connection_change"

32
src/game/GameManager.ts
View File

@ -9,17 +9,19 @@ import {
channel_on_game_crashed,
channel_on_game_start,
channel_on_game_update,
channel_on_game_user_leave
channel_on_game_user_leave,
channel_on_user_connection_change
} from "../consts/channel_names";
import { GameMove } from "../models/GameMove";
import { GameCrashManager } from "./GameCrashManager";
import { MatchMaker } from "../matchmaker/MatchMaker";
import { UserConnectionInfo } from "../models/UserConnectionInfo";
export class GameManager {
gameStore: GameStore;
rtmt: RTMT;
matchMaker: MatchMaker;
constructor(params: { gameStore: GameStore, rtmt: RTMT, matchMaker: MatchMaker }) {
this.gameStore = params.gameStore;
this.rtmt = params.rtmt;
@ -30,6 +32,7 @@ export class GameManager {
private initialize() {
this.listenOnPlayersPaired();
this.listenRtmtMessages();
this.listenUserConnectionChange();
}
private listenRtmtMessages() {
@ -43,7 +46,7 @@ export class GameManager {
this.rtmt.listenMessage(channel_leave_game, (userKey: string, message: Object) => {
this.onPlayerLeave(userKey)
});
});
}
private onGameMove(userKey: string, gameMove: GameMove) {
@ -108,6 +111,16 @@ export class GameManager {
public startGame(game: MancalaGame) {
this.rtmt.sendMessage(game.player1Id, channel_on_game_start, game);
this.rtmt.sendMessage(game.player2Id, channel_on_game_start, game);
this.sendUserConnectionInfo(game, game.player1Id);
this.sendUserConnectionInfo(game, game.player2Id);
}
public sendUserConnectionInfo(game: MancalaGame, playerId: string, isOnline?: boolean) {
//todo: reimplement when watch game feature added
const _isOnline = isOnline === undefined ? this.rtmt.isClientOnline(playerId) : isOnline;
const otherUser = game.player1Id === playerId ? game.player2Id : game.player1Id;
const userConnectionInfo: UserConnectionInfo = { userId: playerId, isOnline: _isOnline };
this.rtmt.sendMessage(otherUser, channel_on_user_connection_change, userConnectionInfo);
}
public deleteGame(game: MancalaGame) {
@ -116,4 +129,17 @@ export class GameManager {
this.gameStore.remove(game.player2Id);
}
}
private listenUserConnectionChange() {
this.rtmt.listenOnClientConnectionChange((clientId: string, isOnline: boolean) => {
const game = this.gameStore.get(clientId);
if (game) {
this.sendUserConnectionInfo(game, clientId, isOnline);
if (isOnline) {
const otherUser = game.player1Id === clientId ? game.player2Id : game.player1Id;
this.sendUserConnectionInfo(game, otherUser);
}
}
});
}
}