diff options
| author | Hazelnoot <acomputerdog@gmail.com> | 2025-02-25 20:52:14 -0500 |
|---|---|---|
| committer | Hazelnoot <acomputerdog@gmail.com> | 2025-02-25 20:52:14 -0500 |
| commit | 019e60d9a43fc442252cb3ecb0e86b3d425ae37d (patch) | |
| tree | 8c7648e59727306efdde1bf9066ef30e06a78950 /packages/backend/src/server/api/stream/channels/queue-stats.ts | |
| parent | check mutes and blocks of renote target in streaming API (diff) | |
| download | sharkey-019e60d9a43fc442252cb3ecb0e86b3d425ae37d.tar.gz sharkey-019e60d9a43fc442252cb3ecb0e86b3d425ae37d.tar.bz2 sharkey-019e60d9a43fc442252cb3ecb0e86b3d425ae37d.zip | |
pass NoteEntityService through Channel constructor instead of method args
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 | 7 |
1 files changed, 5 insertions, 2 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 91b62255b4..a4006ab752 100644 --- a/packages/backend/src/server/api/stream/channels/queue-stats.ts +++ b/packages/backend/src/server/api/stream/channels/queue-stats.ts @@ -8,6 +8,7 @@ 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 { NoteEntityService } from '@/core/entities/NoteEntityService.js'; import Channel, { type MiChannelService } from '../channel.js'; const ev = new Xev(); @@ -17,8 +18,8 @@ class QueueStatsChannel extends Channel { public static shouldShare = true; public static requireCredential = false as const; - constructor(id: string, connection: Channel['connection']) { - super(id, connection); + constructor(id: string, connection: Channel['connection'], noteEntityService: NoteEntityService) { + super(id, connection, noteEntityService); //this.onStats = this.onStats.bind(this); //this.onMessage = this.onMessage.bind(this); } @@ -64,6 +65,7 @@ export class QueueStatsChannelService implements MiChannelService<false> { public readonly kind = QueueStatsChannel.kind; constructor( + private readonly noteEntityService: NoteEntityService, ) { } @@ -72,6 +74,7 @@ export class QueueStatsChannelService implements MiChannelService<false> { return new QueueStatsChannel( id, connection, + this.noteEntityService, ); } } |