superport/lib/data/datasources/remote/dashboard_remote_datasource.dart

import 'package:dartz/dartz.dart';
import 'package:dio/dio.dart';
import 'package:injectable/injectable.dart';
import 'package:superport/core/errors/failures.dart';
import 'package:superport/data/datasources/remote/api_client.dart';
import 'package:superport/data/models/dashboard/equipment_status_distribution.dart';
import 'package:superport/data/models/dashboard/expiring_license.dart';
import 'package:superport/data/models/dashboard/overview_stats.dart';
import 'package:superport/data/models/dashboard/recent_activity.dart';

abstract class DashboardRemoteDataSource {
  Future<Either<Failure, OverviewStats>> getOverviewStats();
  Future<Either<Failure, List<RecentActivity>>> getRecentActivities();
  Future<Either<Failure, EquipmentStatusDistribution>> getEquipmentStatusDistribution();
  Future<Either<Failure, List<ExpiringLicense>>> getExpiringLicenses({int days = 30});
}

@LazySingleton(as: DashboardRemoteDataSource)
class DashboardRemoteDataSourceImpl implements DashboardRemoteDataSource {
  final ApiClient _apiClient;

  DashboardRemoteDataSourceImpl(this._apiClient);

  @override
  Future<Either<Failure, OverviewStats>> getOverviewStats() async {
    try {
      final response = await _apiClient.get('/overview/stats');
      
      if (response.data != null) {
        final stats = OverviewStats.fromJson(response.data);
        return Right(stats);
      } else {
        return Left(ServerFailure(message: '응답 데이터가 없습니다'));
      }
    } on DioException catch (e) {
      return Left(_handleDioError(e));
    } catch (e) {
      return Left(ServerFailure(message: '통계 데이터를 가져오는 중 오류가 발생했습니다'));
    }
  }

  @override
  Future<Either<Failure, List<RecentActivity>>> getRecentActivities() async {
    try {
      final response = await _apiClient.get('/overview/recent-activities');
      
      if (response.data != null && response.data is List) {
        final activities = (response.data as List)
            .map((json) => RecentActivity.fromJson(json))
            .toList();
        return Right(activities);
      } else {
        return Left(ServerFailure(message: '응답 데이터가 올바르지 않습니다'));
      }
    } on DioException catch (e) {
      return Left(_handleDioError(e));
    } catch (e) {
      return Left(ServerFailure(message: '최근 활동을 가져오는 중 오류가 발생했습니다'));
    }
  }

  @override
  Future<Either<Failure, EquipmentStatusDistribution>> getEquipmentStatusDistribution() async {
    try {
      final response = await _apiClient.get('/equipment/status-distribution');
      
      if (response.data != null) {
        final distribution = EquipmentStatusDistribution.fromJson(response.data);
        return Right(distribution);
      } else {
        return Left(ServerFailure(message: '응답 데이터가 없습니다'));
      }
    } on DioException catch (e) {
      return Left(_handleDioError(e));
    } catch (e) {
      return Left(ServerFailure(message: '장비 상태 분포를 가져오는 중 오류가 발생했습니다'));
    }
  }

  @override
  Future<Either<Failure, List<ExpiringLicense>>> getExpiringLicenses({int days = 30}) async {
    try {
      final response = await _apiClient.get(
        '/licenses/expiring-soon',
        queryParameters: {'days': days},
      );
      
      if (response.data != null && response.data is List) {
        final licenses = (response.data as List)
            .map((json) => ExpiringLicense.fromJson(json))
            .toList();
        return Right(licenses);
      } else {
        return Left(ServerFailure(message: '응답 데이터가 올바르지 않습니다'));
      }
    } on DioException catch (e) {
      return Left(_handleDioError(e));
    } catch (e) {
      return Left(ServerFailure(message: '만료 예정 라이선스를 가져오는 중 오류가 발생했습니다'));
    }
  }

  Failure _handleDioError(DioException error) {
    switch (error.type) {
      case DioExceptionType.connectionTimeout:
      case DioExceptionType.sendTimeout:
      case DioExceptionType.receiveTimeout:
        return NetworkFailure(message: '네트워크 연결 시간이 초과되었습니다');
      case DioExceptionType.connectionError:
        return NetworkFailure(message: '서버에 연결할 수 없습니다');
      case DioExceptionType.badResponse:
        final statusCode = error.response?.statusCode ?? 0;
        final message = error.response?.data?['message'] ?? '서버 오류가 발생했습니다';
        
        if (statusCode == 401) {
          return AuthenticationFailure(message: '인증이 만료되었습니다');
        } else if (statusCode == 403) {
          return AuthenticationFailure(message: '접근 권한이 없습니다');
        } else if (statusCode >= 400 && statusCode < 500) {
          return ServerFailure(message: message);
        } else {
          return ServerFailure(message: '서버 오류가 발생했습니다 ($statusCode)');
        }
      case DioExceptionType.cancel:
        return ServerFailure(message: '요청이 취소되었습니다');
      default:
        return ServerFailure(message: '알 수 없는 오류가 발생했습니다');
    }
  }
}