summaryrefslogtreecommitdiff
path: root/packages/backend/src/server/api/stream/channels/queue-stats.ts
diff options
context:
space:
mode:
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.ts20
1 files changed, 19 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 b67600474b..1802c6723b 100644
--- a/packages/backend/src/server/api/stream/channels/queue-stats.ts
+++ b/packages/backend/src/server/api/stream/channels/queue-stats.ts
@@ -1,9 +1,10 @@
import Xev from 'xev';
+import { Inject, Injectable } from '@nestjs/common';
import Channel from '../channel.js';
const ev = new Xev();
-export default class extends Channel {
+class QueueStatsChannel extends Channel {
public readonly chName = 'queueStats';
public static shouldShare = true;
public static requireCredential = false;
@@ -40,3 +41,20 @@ export default class extends Channel {
ev.removeListener('queueStats', this.onStats);
}
}
+
+@Injectable()
+export class QueueStatsChannelService {
+ public readonly shouldShare = QueueStatsChannel.shouldShare;
+ public readonly requireCredential = QueueStatsChannel.requireCredential;
+
+ constructor(
+ ) {
+ }
+
+ public create(id: string, connection: Channel['connection']): QueueStatsChannel {
+ return new QueueStatsChannel(
+ id,
+ connection,
+ );
+ }
+}