summaryrefslogtreecommitdiff
path: root/packages/backend/src
diff options
context:
space:
mode:
authorsyuilo <4439005+syuilo@users.noreply.github.com>2026-01-22 10:28:03 +0900
committersyuilo <4439005+syuilo@users.noreply.github.com>2026-01-22 10:28:03 +0900
commitd4fcc694a6166868b1374504cd177bb7b288784e (patch)
tree4c993af843d00a46930b9794a96bf60a5319f0e6 /packages/backend/src
parentrefactor(frontend): fix invalid self-closing tags (#17103) (diff)
downloadmisskey-d4fcc694a6166868b1374504cd177bb7b288784e.tar.gz
misskey-d4fcc694a6166868b1374504cd177bb7b288784e.tar.bz2
misskey-d4fcc694a6166868b1374504cd177bb7b288784e.zip
enhance(backend): remove redis-info dep
Diffstat (limited to 'packages/backend/src')
-rw-r--r--packages/backend/src/core/QueueService.ts14
1 files changed, 13 insertions, 1 deletions
diff --git a/packages/backend/src/core/QueueService.ts b/packages/backend/src/core/QueueService.ts
index 42782167bb..8ef235b238 100644
--- a/packages/backend/src/core/QueueService.ts
+++ b/packages/backend/src/core/QueueService.ts
@@ -6,7 +6,6 @@
import { randomUUID } from 'node:crypto';
import { Inject, Injectable } from '@nestjs/common';
import { MetricsTime, type JobType } from 'bullmq';
-import { parse as parseRedisInfo } from 'redis-info';
import type { IActivity } from '@/core/activitypub/type.js';
import type { MiDriveFile } from '@/models/DriveFile.js';
import type { MiWebhook, WebhookEventTypes } from '@/models/Webhook.js';
@@ -86,6 +85,19 @@ const REPEATABLE_SYSTEM_JOB_DEF = [{
pattern: '0 4 * * *',
}];
+function parseRedisInfo(infoText: string): Record<string, string> {
+ const fields = infoText
+ .split('\n')
+ .filter(line => line.length > 0 && !line.startsWith('#'))
+ .map(line => line.trim().split(':'));
+
+ const result: Record<string, string> = {};
+ for (const [key, value] of fields) {
+ result[key] = value;
+ }
+ return result;
+}
+
@Injectable()
export class QueueService {
constructor(