summaryrefslogtreecommitdiff
path: root/packages/backend/src/server/api/stream
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2024-01-23 10:51:59 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2024-01-23 10:51:59 +0900
commite8ba0b3f54c2f25566f467d27c45c66139cbf102 (patch)
treec45b699d83806eb2086efef6c0efa482f76c4212 /packages/backend/src/server/api/stream
parent:art: (diff)
downloadsharkey-e8ba0b3f54c2f25566f467d27c45c66139cbf102.tar.gz
sharkey-e8ba0b3f54c2f25566f467d27c45c66139cbf102.tar.bz2
sharkey-e8ba0b3f54c2f25566f467d27c45c66139cbf102.zip
enhance(reversi): improve desync handling
Diffstat (limited to 'packages/backend/src/server/api/stream')
-rw-r--r--packages/backend/src/server/api/stream/channels/reversi-game.ts16
1 files changed, 1 insertions, 15 deletions
diff --git a/packages/backend/src/server/api/stream/channels/reversi-game.ts b/packages/backend/src/server/api/stream/channels/reversi-game.ts
index 820c80006b..fb24a29b75 100644
--- a/packages/backend/src/server/api/stream/channels/reversi-game.ts
+++ b/packages/backend/src/server/api/stream/channels/reversi-game.ts
@@ -4,7 +4,7 @@
*/
import { Inject, Injectable } from '@nestjs/common';
-import type { MiReversiGame, ReversiGamesRepository } from '@/models/_.js';
+import type { MiReversiGame } from '@/models/_.js';
import { DI } from '@/di-symbols.js';
import { bindThis } from '@/decorators.js';
import { ReversiService } from '@/core/ReversiService.js';
@@ -19,7 +19,6 @@ class ReversiGameChannel extends Channel {
constructor(
private reversiService: ReversiService,
- private reversiGamesRepository: ReversiGamesRepository,
private reversiGameEntityService: ReversiGameEntityService,
id: string,
@@ -42,7 +41,6 @@ class ReversiGameChannel extends Channel {
case 'updateSettings': this.updateSettings(body.key, body.value); break;
case 'cancel': this.cancelGame(); break;
case 'putStone': this.putStone(body.pos, body.id); break;
- case 'resync': this.resync(body.crc32); break;
case 'claimTimeIsUp': this.claimTimeIsUp(); break;
}
}
@@ -76,14 +74,6 @@ class ReversiGameChannel extends Channel {
}
@bindThis
- private async resync(crc32: string | number) {
- const game = await this.reversiService.checkCrc(this.gameId!, crc32);
- if (game) {
- this.send('resynced', game);
- }
- }
-
- @bindThis
private async claimTimeIsUp() {
if (this.user == null) return;
@@ -104,9 +94,6 @@ export class ReversiGameChannelService implements MiChannelService<false> {
public readonly kind = ReversiGameChannel.kind;
constructor(
- @Inject(DI.reversiGamesRepository)
- private reversiGamesRepository: ReversiGamesRepository,
-
private reversiService: ReversiService,
private reversiGameEntityService: ReversiGameEntityService,
) {
@@ -116,7 +103,6 @@ export class ReversiGameChannelService implements MiChannelService<false> {
public create(id: string, connection: Channel['connection']): ReversiGameChannel {
return new ReversiGameChannel(
this.reversiService,
- this.reversiGamesRepository,
this.reversiGameEntityService,
id,
connection,