<aside> ✅ Casual, Casual Power, Ladder 3개의 게임큐 존재

</aside>

1. Interval

• 게임큐에 2명 이상이 존재하는지 7초 간격으로 확인
• 게임큐에 2명 이상이 있을 경우 가장 앞선 2명의 상태를 확인
• Online을 제외한 모든 상태(InGame, OffLine, Wait)의 경우 게임 진행 불가 대기큐에서 삭제
• 두명이 모두 가능할 경우에만 게임 매칭 실행 및 InGame으로 멤버 상태 변경

@Interval('gameType', 7000)
async checkCasualGame() {
	if (this.gameQ[GAME_TYPE].getCount() < 2)
		return;
	const p1 = await this.checkPlayer(GameConstants.CASUAL, this.gameQ[GameConstants.CASUAL].peek(1), 1);
	if (p1 === null)
		return;
	const p2 = await this.checkPlayer(GameConstants.CASUAL, this.gameQ[GameConstants.CASUAL].peek(2), 2);
	if (p1 === null)
		return;
	if (p1.data.nickname === p2.data.nickname) {
		this.gameQ[GAME_TYPE].deQueue();
		return;
	}
	
 // p1, p2는 client의 socket
	this.gameQ[GAME_TYPE].deQueue();
	this.gameQ[GAME_TYPE].deQueue();
	this.memberRepository.updateStatus(p1.data.nickname, MemberConstants.INGAME);
	this.memberRepository.updateStatus(p2.data.nickname, MemberConstants.INGAME);
	const roomId = randomBytes(13).toString('hex');
	p1.emit("startGame", new GameInfoDto(GAME_TYPE, roomId, p1.data.nickname, p2.data.nickname, 0));
	p2.emit("startGame", new GameInfoDto(GAME_TYPE, roomId, p1.data.nickname, p2.data.nickname, 1));

}

2. Check Member Status

• 멤버의 상태가 online인지 확인
• online이 아닐 경우 대기큐에서 삭제 후 다음 멤버 체크를 위해 재귀적으로 함수 실행
• flag가 1일 경우 queue의 첫번째, 2일 경우 두번째 멤버를 체크
• 상태 체크가 완료되면 socket 체크로 이동

async checkPlayer(type: number, name: string, flag: number): Promise<Socket> {
	if (this.gameQ[type].getCount() < 2) // 게임 대기큐에 2명 이상일 경우만 실행
		return null;
	const { status } = await this.memberRepository.getStatus(name);
	if (status !== MemberConstants.ONLINE) { // 멤버의 상태가 온라인이 아닐 경우 대기큐에서 제거
		if (flag === 1) // 첫번째 player를 체크하는 경우
			this.gameQ[type].deQueue(); 
		else // 두번째 player를 체크하는 경우
			this.gameQ[type].deQueueSecond();
		this.checkPlayer(type, this.gameQ[type].peek(flag), flag);
	} // 가능한 player를 찾을 때까지 재귀적으로 함수 실행
	return this.checkSocket(type, name, flag);
} // 플레이어를 찾았을 경우 socekt 상태 확인

	waitGame(@MessageBody() type: number, @ConnectedSocket() socket: Socket): Promise<void> {
		if (!this.gameQ[type].enQueue(socket.data.nickname)) {
			socket.emit('errorMessage', "The waiting list is full. Please try again later.");
			socket.emit('failQueue');
			return; // 대기큐가 꽉 차있을 경우 Error 반환
		}
		socket.emit('addQueue', type);
	}

3. Check Member Socket

• DB 상의 멤버 상태는 올바르나 socket 연결이 끊어졌을 경우를 대비하여 socket을 확인
• socket이 연결되어있을 경우 해당 socket을 반환
• socket이 연결되어 있지 않을 경우 대기큐에서 삭제

async checkSocket(type: number, name: string, flag: number): Promise<Socket> {
	const socket = await this.findSocketByName(name);
	if (socket === null) {
		if (flag === 1)
			this.gameQ[type].deQueue();
		else
			this.gameQ[type].deQueueSecond();
		return null
	}
	return socket;
}