diff options
| author | syuilo <4439005+syuilo@users.noreply.github.com> | 2026-01-22 10:28:03 +0900 |
|---|---|---|
| committer | syuilo <4439005+syuilo@users.noreply.github.com> | 2026-01-22 10:28:03 +0900 |
| commit | d4fcc694a6166868b1374504cd177bb7b288784e (patch) | |
| tree | 4c993af843d00a46930b9794a96bf60a5319f0e6 /packages/backend/src/core | |
| parent | refactor(frontend): fix invalid self-closing tags (#17103) (diff) | |
| download | misskey-d4fcc694a6166868b1374504cd177bb7b288784e.tar.gz misskey-d4fcc694a6166868b1374504cd177bb7b288784e.tar.bz2 misskey-d4fcc694a6166868b1374504cd177bb7b288784e.zip | |
enhance(backend): remove redis-info dep
Diffstat (limited to 'packages/backend/src/core')
| -rw-r--r-- | packages/backend/src/core/QueueService.ts | 14 |
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( |