bakery-ia/frontend/src/api/services/data.service.ts

// frontend/src/api/services/data.service.ts
/**
 * Data Management Service
 * Handles sales data operations
 */

import { apiClient } from '../client';
import { RequestTimeouts } from '../client/config';
import type {
  SalesData,
  SalesValidationResult,
  SalesDataQuery,
  SalesDataImport,
  SalesImportResult,
  DashboardStats,
  PaginatedResponse,
  ActivityItem,
} from '../types';

export class DataService {
  /**
   * Upload Sales History File
   */
  async uploadSalesHistory(
    tenantId: string,
    file: File,
    additionalData?: Record<string, any>
  ): Promise<SalesImportResult> {
    // Determine file format
    const fileName = file.name.toLowerCase();
    let fileFormat: string;

    if (fileName.endsWith('.csv')) {
      fileFormat = 'csv';
    } else if (fileName.endsWith('.json')) {
      fileFormat = 'json';
    } else if (fileName.endsWith('.xlsx') || fileName.endsWith('.xls')) {
      fileFormat = 'excel';
    } else {
      fileFormat = 'csv'; // Default fallback
    }

    const uploadData = {
      file_format: fileFormat,
      ...additionalData,
    };

    return apiClient.upload(
      `/tenants/${tenantId}/sales/import`,
      file,
      uploadData,
      {
        timeout: RequestTimeouts.LONG,
      }
    );
  }

  /**
   * Validate Sales Data
   */
  async validateSalesData(
    tenantId: string,
    file: File
  ): Promise<SalesValidationResult> {
    const fileName = file.name.toLowerCase();
    let fileFormat: string;

    if (fileName.endsWith('.csv')) {
      fileFormat = 'csv';
    } else if (fileName.endsWith('.json')) {
      fileFormat = 'json';
    } else if (fileName.endsWith('.xlsx') || fileName.endsWith('.xls')) {
      fileFormat = 'excel';
    } else {
      fileFormat = 'csv';
    }

    return apiClient.upload(
      `/tenants/${tenantId}/sales/import/validate`,
      file,
      {
        file_format: fileFormat,
        validate_only: true,
        source: 'onboarding_upload',
      },
      {
        timeout: RequestTimeouts.MEDIUM,
      }
    );
  }

  /**
   * Get Sales Data
   */
  async getSalesData(
    tenantId: string,
    query?: SalesDataQuery
  ): Promise<PaginatedResponse<SalesData>> {
    return apiClient.get(`/tenants/${tenantId}/sales`, { params: query });
  }

  /**
   * Get Single Sales Record
   */
  async getSalesRecord(tenantId: string, recordId: string): Promise<SalesData> {
    return apiClient.get(`/tenants/${tenantId}/sales/${recordId}`);
  }

  /**
   * Update Sales Record
   */
  async updateSalesRecord(
    tenantId: string,
    recordId: string,
    data: Partial<SalesData>
  ): Promise<SalesData> {
    return apiClient.put(`/tenants/${tenantId}/sales/${recordId}`, data);
  }

  /**
   * Delete Sales Record
   */
  async deleteSalesRecord(tenantId: string, recordId: string): Promise<{ message: string }> {
    return apiClient.delete(`/tenants/${tenantId}/sales/${recordId}`);
  }

  /**
   * Get Dashboard Statistics
   */
  async getDashboardStats(tenantId: string): Promise<DashboardStats> {
    return apiClient.get(`/tenants/${tenantId}/sales/stats`);
  }

  /**
   * Get Analytics Data
   */
  async getAnalytics(
    tenantId: string,
    params?: {
      start_date?: string;
      end_date?: string;
      product_names?: string[];
      metrics?: string[];
    }
  ): Promise<any> {
    return apiClient.get(`/tenants/${tenantId}/analytics`, { params });
  }

  /**
   * Export Sales Data
   */
  async exportSalesData(
    tenantId: string,
    format: 'csv' | 'excel' | 'json',
    query?: SalesDataQuery
  ): Promise<Blob> {
    const response = await apiClient.request(`/tenants/${tenantId}/sales/export`, {
      method: 'GET',
      params: { ...query, format },
      headers: {
        'Accept': format === 'csv' ? 'text/csv' : 
                format === 'excel' ? 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet' :
                'application/json',
      },
    });

    return new Blob([response], {
      type: format === 'csv' ? 'text/csv' : 
           format === 'excel' ? 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet' :
           'application/json',
    });
  }

  /**
   * Get Recent Activity
   */
  async getRecentActivity(tenantId: string, limit?: number): Promise<ActivityItem[]> {
    return apiClient.get(`/tenants/${tenantId}/activity`, {
      params: { limit },
    });
  }
}

export const dataService = new DataService();