veza/apps/web/src/services/uploadService.ts

import { apiClient } from '@/services/api/client';
import { logger } from '@/utils/logger';

const CHUNK_SIZE = 1024 * 1024 * 2; // 2MB chunks

export interface UploadMetadata {
  title: string;
  artist?: string;
  album?: string;
  genre?: string;
}

export const uploadService = {
  /**
   * Effectue un upload partitionné (chunked) d'un fichier audio
   */
  uploadTrack: async (
    file: File,
    metadata: UploadMetadata,
    onProgress?: (progress: number) => void,
  ) => {
    const totalChunks = Math.ceil(file.size / CHUNK_SIZE);

    // 1. Initier l'upload
    const initiateResponse = await apiClient.post<{ upload_id: string }>(
      '/tracks/initiate',
      {
        filename: file.name,
        total_chunks: totalChunks,
        file_size: file.size,
        title: metadata.title,
        artist: metadata.artist,
        album: metadata.album,
        genre: metadata.genre,
      },
    );

    const { upload_id } = initiateResponse.data;
    logger.info(`[UPLOAD] Upload initiated with ID: ${upload_id}`, {
      filename: file.name,
      totalChunks,
    });

    // 2. Envoyer les morceaux (chunks)
    for (let i = 0; i < totalChunks; i++) {
      const start = i * CHUNK_SIZE;
      const end = Math.min(start + CHUNK_SIZE, file.size);
      const chunk = file.slice(start, end);

      const formData = new FormData();
      formData.append('chunk', chunk);
      formData.append('index', i.toString());
      formData.append('upload_id', upload_id);

      try {
        await apiClient.post('/tracks/chunk', formData, {
          // Utiliser le timeout long pour les uploads
          timeout: 300000,
          // Pas besoin de logger chaque chunk en détail (trop verbeux)
          _enableLogging: false,
        } as any);

        const progress = ((i + 1) / totalChunks) * 100;
        if (onProgress) onProgress(progress);
      } catch (error) {
        logger.error(`[UPLOAD] Failed to upload chunk ${i} for ${upload_id}`, {
          error,
        });
        throw error;
      }
    }

    // 3. Compléter l'upload
    const completeResponse = await apiClient.post<{ track_id: string }>(
      '/tracks/complete',
      {
        upload_id,
      },
    );

    logger.info(
      `[UPLOAD] Upload completed. Track ID: ${completeResponse.data.track_id}`,
    );
    return completeResponse.data;
  },

  /**
   * Récupère le statut d'une track en cours de traitement
   */
  getTrackStatus: async (trackId: string) => {
    const response = await apiClient.get<{ status: string; progress: number }>(
      `/tracks/${trackId}/status`,
    );
    return response.data;
  },
};