diff options
Diffstat (limited to 'src/server/api/stream')
| -rw-r--r-- | src/server/api/stream/channels/games/reversi-game.ts | 4 | ||||
| -rw-r--r-- | src/server/api/stream/channels/hashtag.ts | 3 | ||||
| -rw-r--r-- | src/server/api/stream/index.ts | 17 |
3 files changed, 7 insertions, 17 deletions
diff --git a/src/server/api/stream/channels/games/reversi-game.ts b/src/server/api/stream/channels/games/reversi-game.ts index f287ad0107..1cb077c8c4 100644 --- a/src/server/api/stream/channels/games/reversi-game.ts +++ b/src/server/api/stream/channels/games/reversi-game.ts @@ -242,9 +242,9 @@ export default class extends Channel { loopedBoard: game.settings.loopedBoard }); - game.logs.forEach(log => { + for (const log of game.logs) { o.put(log.color, log.pos); - }); + } const myColor = (game.user1Id.equals(this.user._id) && game.black == 1) || (game.user2Id.equals(this.user._id) && game.black == 2) diff --git a/src/server/api/stream/channels/hashtag.ts b/src/server/api/stream/channels/hashtag.ts index 052240c18c..c8b6c578de 100644 --- a/src/server/api/stream/channels/hashtag.ts +++ b/src/server/api/stream/channels/hashtag.ts @@ -20,7 +20,8 @@ export default class extends Channel { // Subscribe stream this.subscriber.on('hashtag', async note => { - const matched = q.some(tags => tags.every(tag => note.tags.map((t: string) => t.toLowerCase()).includes(tag.toLowerCase()))); + const noteTags = note.tags.map((t: string) => t.toLowerCase()); + const matched = q.some(tags => tags.every(tag => noteTags.includes(tag.toLowerCase()))); if (!matched) return; // Renoteなら再pack diff --git a/src/server/api/stream/index.ts b/src/server/api/stream/index.ts index 58dbacd688..22f7646cb9 100644 --- a/src/server/api/stream/index.ts +++ b/src/server/api/stream/index.ts @@ -46,7 +46,6 @@ export default class Connection { switch (type) { case 'api': this.onApiRequest(body); break; - case 'alive': this.onAlive(); break; case 'readNotification': this.onReadNotification(body); break; case 'subNote': this.onSubscribeNote(body); break; case 'sn': this.onSubscribeNote(body); break; // alias @@ -78,16 +77,6 @@ export default class Connection { } @autobind - private onAlive() { - // Update lastUsedAt - User.update({ _id: this.user._id }, { - $set: { - 'lastUsedAt': new Date() - } - }); - } - - @autobind private onReadNotification(payload: any) { if (!payload.id) return; readNotification(this.user._id, payload.id); @@ -224,8 +213,8 @@ export default class Connection { */ @autobind public dispose() { - this.channels.forEach(c => { - if (c.dispose) c.dispose(); - }); + for (const c of this.channels.filter(c => c.dispose)) { + c.dispose(); + } } } |