refactor: all in one

Author: BogdanPryadko4853

README.md

@@ -0,0 +1,170 @@
+# 🎵 Audio Recognition System (Shazam-like) 🎶
+
+![Microservices Architecture Diagram](https://d3mxt5v3yxgcsr.cloudfront.net/courses/14946/course_14946_image.jpg)
+
+## Table of Contents
+- [Technology Stack](#-technology-stack)
+- [System Components](#-system-components)
+- [Prerequisites](#-prerequisites)
+- [Quick Start](#-quick-start)
+- [API Documentation](#-api-documentation)
+- [Environment Variables](#-environment-variables)
+- [Service Architecture](#-service-architecture)
+- [License](#-license)
+
+## 🚀 Technology Stack
+
+**Core Components:**
+- ☕ Java 17
+- 🌱 Spring Boot 3
+- ☁️ Spring Cloud
+- 🐳 Docker Compose
+
+**Data Layer:**
+- 🐘 PostgreSQL (Metadata)
+- 🔴 Redis (Caching)
+- 🔍 Elasticsearch (Fingerprints)
+
+**Infrastructure:**
+- 📨 Apache Kafka (Events)
+- 🗄️ MinIO (Audio Storage)
+- 📊 Kibana (Monitoring)
+
+## 🏗 System Architecture
+
+```mermaid
+graph TD
+    %% Clients
+    A[📱 Client] --> B[🚪 API Gateway]
+    
+    %% Services
+    B --> C[📤 Ingestion Service]
+    B --> D[📝 Metadata Service]
+    B --> E[🔍 Fingerprint Service]
+    
+    %% Data Stores
+    C --> F[🪣 MinIO]
+    C --> G[📨 Kafka]
+    D --> H[🐘 PostgreSQL]
+    D --> J[🔴 Redis]
+    E --> I[🔎 Elasticsearch]
+    
+    %% Connections
+    G --> E
+    C -.-> D
+    J -.-> D
+    
+    %% Styling
+    classDef client fill:#f9f,stroke:#333,color:#000;
+    classDef gateway fill:#7af,stroke:#333,color:#000;
+    classDef service fill:#aef,stroke:#333,color:#000;
+    classDef storage fill:#fea,stroke:#333,color:#000;
+    classDef queue fill:#afa,stroke:#333,color:#000;
+    
+    class A client;
+    class B gateway;
+    class C,D,E service;
+    class F,H,I storage;
+    class G,J queue;
+    
+    linkStyle 0,1,2,3,4,5,6,7,8 stroke:#666,stroke-width:2px;
+```
+
+
+## 📦 System Components
+
+| Service              | Port  | Description                          |
+|----------------------|-------|--------------------------------------|
+| Gateway Service      | 8081  | API Gateway                          |
+| Service Registry     | 8761  | Eureka Discovery Server              |
+| Config Service       | 8888  | Centralized Configuration            |
+| Audio Ingestion      | 8000  | Audio Upload Processing              |
+| Metadata Service     | 8010  | Track Metadata Management            |
+| Fingerprint Service  | 8080  | Audio Fingerprint Matching           |
+
+## ⚙️ Supporting Services
+
+| Service       | Port  | Description                |
+|--------------|-------|----------------------------|
+| PostgreSQL   | 5432  | Metadata Storage           |
+| Redis        | 6379  | Caching                    |
+| MinIO        | 9000  | Audio File Storage         |
+| Kafka        | 9092  | Event Streaming            |
+| Elasticsearch| 9200  | Fingerprint Storage        |
+| Kibana       | 5601  | Monitoring Dashboard       |
+
+## 📋 Prerequisites
+
+- Docker 20.10+
+- Docker Compose 2.0+
+- 8GB+ RAM recommended
+
+Вот красивый, отформатированный Markdown текст, который можно скопировать одним кликом:
+
+```markdown
+## 🚀 Quick Start
+
+1. **Clone the repository**:
+```bash
+git clone https://github.com/BogdanPryadko4853/audio-shazam.git
+cd audio-shazam
+```
+
+2. **Start all services**:
+```bash
+docker-compose up -d
+```
+
+3. **Verify services are running**:
+```bash
+docker-compose ps
+```
+
+## 📚 API Documentation
+
+All APIs are available through the Gateway:
+
+### 🎵 Ingestion Service
+```
+POST /api/v1/audio     - Upload audio file
+GET  /api/v1/audio/{id} - Get audio metadata
+```
+
+### 📝 Metadata Service
+```
+GET    /api/v1/tracks      - List all tracks
+POST   /api/v1/tracks      - Create track metadata
+GET    /api/v1/tracks/{id} - Get track details
+```
+
+### 🔍 Fingerprint Service
+```
+POST /api/v1/fingerprints/search - Search by audio sample
+GET  /api/v1/fingerprints/{id}   - Get fingerprint details
+```
+
+## 🔧 Environment Variables
+
+Key configuration options:
+```ini
+# Database Configuration
+SPRING_DATASOURCE_URL=jdbc:postgresql://db:5432/audio_metadata
+SPRING_DATASOURCE_USERNAME=audio_admin
+SPRING_DATASOURCE_PASSWORD=securepass
+
+# Storage Configuration
+MINIO_ENDPOINT=http://minio:9000
+MINIO_ACCESS_KEY=minioadmin
+MINIO_SECRET_KEY=minioadmin
+MINIO_BUCKET=audio-bucket
+
+# Messaging Configuration
+SPRING_KAFKA_BOOTSTRAP_SERVERS=kafka:9092
+```
+
+### 💡 Access Points
+- **API Gateway**: `http://localhost:8081`
+- **Swagger UI**: `http://localhost:8081/swagger-ui.html`
+- **MinIO Console**: `http://localhost:9001` (credentials: minioadmin/minioadmin)
+```
+

audio-commons/pom.xml

@@ -58,6 +58,13 @@
             <version>8.5.2</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.springdoc</groupId>
+            <artifactId>springdoc-openapi-starter-webflux-ui</artifactId>
+            <version>2.5.0</version>
+        </dependency>
+
+
         <dependency>
             <groupId>commons-io</groupId>
             <artifactId>commons-io</artifactId>

audio-commons/src/main/java/com/audio/AudioUploadEvent.java

@@ -1,6 +1,6 @@
-package com.audio.audiofingerprintservice.service;
+package com.audio.audiofingerprintservice.client;
 
-import com.audio.audiofingerprintservice.dto.TrackMetadataResponse;
+import com.audio.audiofingerprintservice.dto.response.TrackMetadataResponse;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.web.client.RestTemplate;

audio-fingerprint-service/pom.xml

@@ -0,0 +1,18 @@
+package com.audio.audiofingerprintservice.config;
+
+import io.swagger.v3.oas.models.OpenAPI;
+import io.swagger.v3.oas.models.info.Info;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class OpenApiConfig {
+    @Bean
+    public OpenAPI customOpenAPI() {
+        return new OpenAPI()
+                .info(new Info()
+                        .title("Audio Fingerprint Service API")
+                        .version("1.0")
+                        .description("API для работы с аудио отпечатками"));
+    }
+}

…rvice/service/MetadataServiceClient.java …ervice/client/MetadataServiceClient.javaaudio-fingerprint-service/src/main/java/com/audio/audiofingerprintservice/service/MetadataServiceClient.java renamed to audio-fingerprint-service/src/main/java/com/audio/audiofingerprintservice/client/MetadataServiceClient.java audio-fingerprint-service/src/main/java/com/audio/audiofingerprintservice/service/MetadataServiceClient.java renamed to audio-fingerprint-service/src/main/java/com/audio/audiofingerprintservice/client/MetadataServiceClient.java

@@ -5,7 +5,7 @@
 import org.springframework.web.client.RestTemplate;
 
 @Configuration
-public class AppConfig {
+public class RestConfig {
 
     @Bean
     public RestTemplate restTemplate() {

audio-fingerprint-service/src/main/java/com/audio/audiofingerprintservice/config/OpenApiConfig.java

@@ -1,7 +1,8 @@
 package com.audio.audiofingerprintservice.controller;
 
-import com.audio.audiofingerprintservice.dto.FingerprintMatchResponse;
+import com.audio.audiofingerprintservice.dto.response.FingerprintMatchResponse;
 import com.audio.audiofingerprintservice.service.FingerprintService;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -10,18 +11,48 @@
 import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.multipart.MultipartFile;
 
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.media.Content;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import io.swagger.v3.oas.annotations.tags.Tag;
+
 @RestController
 @RequestMapping("/api/v1/fingerprints")
+@Tag(name = "Fingerprint API", description = "API для работы с аудио отпечатками")
 @Slf4j
+@RequiredArgsConstructor
 public class FingerprintController {
-    private final FingerprintService fingerprintService;
 
-    public FingerprintController(FingerprintService fingerprintService) {
-        this.fingerprintService = fingerprintService;
-    }
+    private final FingerprintService fingerprintService;
 
+    @Operation(
+            summary = "Поиск аудио по отпечатку",
+            description = "Принимает аудио файл и возвращает найденные совпадения",
+            responses = {
+                    @ApiResponse(
+                            responseCode = "200",
+                            description = "Успешный поиск",
+                            content = @Content(
+                                    mediaType = "application/json",
+                                    schema = @Schema(implementation = FingerprintMatchResponse.class)
+                            )
+                    ),
+                    @ApiResponse(
+                            responseCode = "400",
+                            description = "Неверный формат файла"
+                    ),
+                    @ApiResponse(
+                            responseCode = "500",
+                            description = "Ошибка обработки аудио"
+                    )
+            }
+    )
     @PostMapping(value = "/search", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
-    public FingerprintMatchResponse searchFingerprint(@RequestPart("audio") MultipartFile audioFile) {
+    public FingerprintMatchResponse searchFingerprint(
+            @RequestPart("audio")
+            @Schema(description = "Аудио файл в формате MP3 или WAV", format = "binary")
+            MultipartFile audioFile) {
         log.info("Received file: {} ({} bytes)", audioFile.getOriginalFilename(), audioFile.getSize());
         return fingerprintService.searchMatch(audioFile);
     }