rsesot/misskey
1
0
Fork 0
forked from mirrors/misskey
Code Pull Requests Activity

fix(backend): handle leave message

Browse Source
This commit is contained in:
zyoshoka
2025-04-18 23:21:03 +09:00
parent dc55fba800
commit b71e299c8f
2 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/backend/src/server/api/stream/channels/mahjong-room.ts
View File

@@ -56,6 +56,7 @@ class MahjongRoomChannel extends Channel {
case 'ready': this.ready(body); break; case 'ready': this.ready(body); break;
case 'updateSettings': this.updateSettings(body.key, body.value); break; case 'updateSettings': this.updateSettings(body.key, body.value); break;
case 'addAi': this.addAi(); break; case 'addAi': this.addAi(); break;
case 'leave': this.leaveRoom(); break;
case 'confirmNextKyoku': this.confirmNextKyoku(); break; case 'confirmNextKyoku': this.confirmNextKyoku(); break;
case 'dahai': this.dahai(body.tile, body.riichi); break; case 'dahai': this.dahai(body.tile, body.riichi); break;
case 'tsumoHora': this.tsumoHora(); break; case 'tsumoHora': this.tsumoHora(); break;
@@ -98,6 +99,13 @@ class MahjongRoomChannel extends Channel {
this.mahjongService.addAi(this.roomId!, this.user); this.mahjongService.addAi(this.roomId!, this.user);
} }
@bindThis
private async leaveRoom() {
if (this.user == null) return;
this.mahjongService.leaveRoom(this.roomId!, this.user);
}
@bindThis @bindThis
private async dahai(tile: number, riichi = false) { private async dahai(tile: number, riichi = false) {
if (this.user == null) return; if (this.user == null) return;

1
packages/misskey-js/src/streaming.types.ts
View File

@@ -358,6 +358,7 @@ export type Channels = {
body: unknown; body: unknown;
}; };
addAi: Record<string, never>; addAi: Record<string, never>;
leave: Record<string, never>;
confirmNextKyoku: Record<string, never>; confirmNextKyoku: Record<string, never>;
dahai: { dahai: {
tile: number; tile: number;