diff options
| author | syuilo <syuilotan@yahoo.co.jp> | 2018-10-11 02:48:19 +0900 |
|---|---|---|
| committer | syuilo <syuilotan@yahoo.co.jp> | 2018-10-11 02:48:19 +0900 |
| commit | 4b08677839b2441f634f015e33c3f80da1c266d9 (patch) | |
| tree | f6432d2eea73ee6debe37b6465dac8b25227ab74 /src/server/api/stream | |
| parent | Improve error logs (diff) | |
| download | sharkey-4b08677839b2441f634f015e33c3f80da1c266d9.tar.gz sharkey-4b08677839b2441f634f015e33c3f80da1c266d9.tar.bz2 sharkey-4b08677839b2441f634f015e33c3f80da1c266d9.zip | |
:v:
Diffstat (limited to 'src/server/api/stream')
| -rw-r--r-- | src/server/api/stream/channels/games/reversi-game.ts | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/server/api/stream/channels/games/reversi-game.ts b/src/server/api/stream/channels/games/reversi-game.ts index 54d9d1ae19..d3d3c0f5ab 100644 --- a/src/server/api/stream/channels/games/reversi-game.ts +++ b/src/server/api/stream/channels/games/reversi-game.ts @@ -1,5 +1,6 @@ import autobind from 'autobind-decorator'; import * as CRC32 from 'crc-32'; +import * as mongo from 'mongodb'; import ReversiGame, { pack } from '../../../../../models/games/reversi/game'; import { publishReversiGameStream } from '../../../../../stream'; import Reversi from '../../../../../games/reversi/core'; @@ -7,11 +8,11 @@ import * as maps from '../../../../../games/reversi/maps'; import Channel from '../../channel'; export default class extends Channel { - private gameId: string; + private gameId: mongo.ObjectID; @autobind public async init(params: any) { - this.gameId = params.gameId as string; + this.gameId = new mongo.ObjectID(params.gameId as string); // Subscribe game stream this.subscriber.on(`reversiGameStream:${this.gameId}`, data => { |