From 791156f81458f3feb7c4335362692acc82ca0518 Mon Sep 17 00:00:00 2001
From: nk <lopeyskusikgjr3@outlook.com>
Date: Sun, 7 Jun 2026 18:47:25 +0300
Subject: [PATCH] =?UTF-8?q?feat(shazam):=20=D0=B3=D0=BB=D0=BE=D0=B1=D0=B0?=
 =?UTF-8?q?=D0=BB=D1=8C=D0=BD=D1=8B=D0=B9=20=D0=BB=D0=B8=D0=BC=D0=B8=D1=82?=
 =?UTF-8?q?=20=D1=80=D0=B0=D1=81=D0=BF=D0=BE=D0=B7=D0=BD=D0=B0=D0=B2=D0=B0?=
 =?UTF-8?q?=D0=BD=D0=B8=D0=B9=20(=D0=B7=D0=B0=D1=89=D0=B8=D1=82=D0=B0=20?=
 =?UTF-8?q?=D0=B1=D0=B0=D0=BB=D0=B0=D0=BD=D1=81=D0=B0=20=D0=BA=D0=BE=D0=B8?=
 =?UTF-8?q?=D0=BD=D0=BE=D0=B2)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Скользящее окно 60с, максимум 30 реальных вызовов Shazam/мин (кэш-хиты не в счёт).
Превышение → 429. Защищает платный баланс от перебора станций.

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

diff --git a/src/shazam/shazam.service.ts b/src/shazam/shazam.service.ts
index 3e7642c..c7608c1 100644
--- a/src/shazam/shazam.service.ts
+++ b/src/shazam/shazam.service.ts
@@ -4,6 +4,8 @@ import {
   NotFoundException,
   BadRequestException,
   ServiceUnavailableException,
+  HttpException,
+  HttpStatus,
 } from '@nestjs/common';
 import { PrismaService } from '../prisma/prisma.service';
 import { ShazamClient } from './shazam.client';
@@ -30,6 +32,10 @@ export class ShazamService {
   // когда несколько клиентов распознают одну станцию почти одновременно.
   private readonly cache = new Map<number, CacheEntry>();
   private readonly CACHE_TTL_MS = 15000;
+  // Глобальный лимит реальных вызовов Shazam (платные коины) — защита баланса
+  // от перебора станций. Кэш-хиты сюда не считаются.
+  private readonly recentCalls: number[] = [];
+  private readonly MAX_PER_MIN = 30;
 
   constructor(
     private readonly prisma: PrismaService,
@@ -58,6 +64,8 @@ export class ShazamService {
       throw new BadRequestException('На этой станции нет музыки');
     }
 
+    this.checkRateLimit(now);
+
     let result: RecognizeResponse;
     try {
       const audio = await fetchStreamChunk(station.streamUrl);
@@ -87,6 +95,21 @@ export class ShazamService {
     return result;
   }
 
+  // Скользящее окно 60с по реальным (не кэшированным) вызовам Shazam.
+  private checkRateLimit(now: number): void {
+    const cutoff = now - 60000;
+    while (this.recentCalls.length && this.recentCalls[0] < cutoff) {
+      this.recentCalls.shift();
+    }
+    if (this.recentCalls.length >= this.MAX_PER_MIN) {
+      throw new HttpException(
+        'Слишком много запросов на распознавание, попробуйте позже',
+        HttpStatus.TOO_MANY_REQUESTS,
+      );
+    }
+    this.recentCalls.push(now);
+  }
+
   // Если у распознанного трека нет обложки от Shazam — пробуем взять обложку
   // уже обогащённого трека из нашей БД (по тому же normKey, что и чарты).
   private async resolveCover(