diff options
| author | anatawa12 <anatawa12@icloud.com> | 2024-08-09 16:04:41 +0900 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-09 16:04:41 +0900 |
| commit | f50941389d8724442ce2d7326afe9fbdadd3b58e (patch) | |
| tree | 852abb54937b8c04a4a8436e07bba2f226616a17 /packages/backend/src/server/api/stream/channels/queue-stats.ts | |
| parent | fix(backend): check visibility of following/followers of remote users / feat:... (diff) | |
| download | sharkey-f50941389d8724442ce2d7326afe9fbdadd3b58e.tar.gz sharkey-f50941389d8724442ce2d7326afe9fbdadd3b58e.tar.bz2 sharkey-f50941389d8724442ce2d7326afe9fbdadd3b58e.zip | |
fix: readAllNotifications message not working (#14374)
* refactor: add and use isJsonObject
* fix: readNotification message without body is not working
* docs(changelog): WSの`readAllNotifications` メッセージが `body` を持たない場合に動作しない問題
* Update CHANGELOG.md
Co-authored-by: Sayamame-beans <61457993+Sayamame-beans@users.noreply.github.com>
---------
Co-authored-by: Sayamame-beans <61457993+Sayamame-beans@users.noreply.github.com>
Diffstat (limited to 'packages/backend/src/server/api/stream/channels/queue-stats.ts')
| -rw-r--r-- | packages/backend/src/server/api/stream/channels/queue-stats.ts | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/packages/backend/src/server/api/stream/channels/queue-stats.ts b/packages/backend/src/server/api/stream/channels/queue-stats.ts index ff7e740226..91b62255b4 100644 --- a/packages/backend/src/server/api/stream/channels/queue-stats.ts +++ b/packages/backend/src/server/api/stream/channels/queue-stats.ts @@ -6,6 +6,7 @@ import Xev from 'xev'; import { Injectable } from '@nestjs/common'; import { bindThis } from '@/decorators.js'; +import { isJsonObject } from '@/misc/json-value.js'; import type { JsonObject, JsonValue } from '@/misc/json-value.js'; import Channel, { type MiChannelService } from '../channel.js'; @@ -36,7 +37,7 @@ class QueueStatsChannel extends Channel { public onMessage(type: string, body: JsonValue) { switch (type) { case 'requestLog': - if (typeof body !== 'object' || body === null || Array.isArray(body)) return; + if (!isJsonObject(body)) return; if (typeof body.id !== 'string') return; if (typeof body.length !== 'number') return; ev.once(`queueStatsLog:${body.id}`, statsLog => { |