From bb74d631c19f9874a07fdacf04e3123ac28f10ca Mon Sep 17 00:00:00 2001
From: nk <lopeyskusikgjr3@outlook.com>
Date: Wed, 3 Jun 2026 14:39:13 +0300
Subject: [PATCH] =?UTF-8?q?feat(enrich):=20=D0=BA=D1=80=D0=BE=D0=BD=20?=
 =?UTF-8?q?=E2=80=94=20=D0=B3=D0=B0=D1=80=D0=B0=D0=BD=D1=82=D0=B8=D1=80?=
 =?UTF-8?q?=D0=BE=D0=B2=D0=B0=D1=82=D1=8C=20=D0=BE=D0=B1=D0=BB=D0=BE=D0=B6?=
 =?UTF-8?q?=D0=BA=D1=83=20=D0=B8=D0=B3=D1=80=D0=B0=D1=8E=D1=89=D0=B8=D0=BC?=
 =?UTF-8?q?=20=D1=81=D0=B5=D0=B9=D1=87=D0=B0=D1=81=20=D1=82=D1=80=D0=B5?=
 =?UTF-8?q?=D0=BA=D0=B0=D0=BC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Раз в минуту проходим now_playing: создаём Track при отсутствии (без записи
проигрывания) и приоритетно обогащаем тех, у кого нет обложки. Now-playing-обложки
(DFM и др.) появляются быстро у всех станций, не дожидаясь смены трека/бэкафилла.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
---
 src/enrich/enrichment.service.ts | 32 ++++++++++++++++++++++++++++++++
 1 file changed, 32 insertions(+)

diff --git a/src/enrich/enrichment.service.ts b/src/enrich/enrichment.service.ts
index 8262a46..2497f6e 100644
--- a/src/enrich/enrichment.service.ts
+++ b/src/enrich/enrichment.service.ts
@@ -57,6 +57,38 @@ export class EnrichmentService {
     for (const t of pending) this.enqueue(t.id);
   }
 
+  // Раз в минуту гарантируем обложку у играющих СЕЙЧАС треков: создаём Track
+  // при отсутствии (без записи проигрывания) и приоритетно обогащаем тех, у кого
+  // ещё нет обложки. Так now-playing-обложки появляются быстро у всех сетей.
+  @Cron(CronExpression.EVERY_MINUTE)
+  async enrichNowPlaying(): Promise<void> {
+    const rows = await this.prisma.nowPlaying.findMany({
+      select: { artist: true, song: true },
+    });
+    for (const r of rows) {
+      const artist = (r.artist ?? '').trim();
+      const song = (r.song ?? '').trim();
+      if (!artist || !song) continue;
+      const normKey = this.buildNormKey(artist, song);
+      const track = await this.prisma.track.upsert({
+        where: { normKey },
+        create: { normKey, artist, song },
+        update: {},
+        select: { id: true, coverUrl: true },
+      });
+      if (!track.coverUrl) this.enqueue(track.id, { priority: true });
+    }
+  }
+
+  // Нормализованный ключ — как в ChartsService.recordPlay
+  private buildNormKey(artist: string, song: string): string {
+    return (
+      artist.toLowerCase().replace(/\s+/g, ' ') +
+      '|' +
+      song.toLowerCase().replace(/\s+/g, ' ')
+    );
+  }
+
   private async drain(): Promise<void> {
     if (this.running) return;
     this.running = true;