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

import 'package:injectable/injectable.dart';
import 'package:superport/core/constants/api_endpoints.dart';
import 'package:superport/core/errors/exceptions.dart';
import 'package:superport/data/datasources/remote/api_client.dart';
import 'package:superport/data/models/license/license_dto.dart';
import 'package:superport/data/models/license/license_request_dto.dart';
import 'package:superport/data/models/license/license_query_dto.dart';

abstract class LicenseRemoteDataSource {
  Future<LicenseListResponseDto> getLicenses({
    int page = 1,
    int perPage = 20,
    bool? isActive,
    int? companyId,
    int? assignedUserId,
    String? licenseType,
  });

  Future<LicenseDto> getLicenseById(int id);
  Future<LicenseDto> createLicense(CreateLicenseRequest request);
  Future<LicenseDto> updateLicense(int id, UpdateLicenseRequest request);
  Future<void> deleteLicense(int id);
  Future<LicenseDto> assignLicense(int id, AssignLicenseRequest request);
  Future<LicenseDto> unassignLicense(int id);
  Future<ExpiringLicenseListDto> getExpiringLicenses({
    int days = 30,
    int page = 1,
    int perPage = 20,
  });
}

@LazySingleton(as: LicenseRemoteDataSource)
class LicenseRemoteDataSourceImpl implements LicenseRemoteDataSource {
  final ApiClient _apiClient;

  LicenseRemoteDataSourceImpl({
    required ApiClient apiClient,
  }) : _apiClient = apiClient;

  @override
  Future<LicenseListResponseDto> getLicenses({
    int page = 1,
    int perPage = 20,
    bool? isActive,
    int? companyId,
    int? assignedUserId,
    String? licenseType,
  }) async {
    try {
      final queryParams = <String, dynamic>{
        'page': page,
        'per_page': perPage,
      };

      if (isActive != null) queryParams['is_active'] = isActive;
      if (companyId != null) queryParams['company_id'] = companyId;
      if (assignedUserId != null) queryParams['assigned_user_id'] = assignedUserId;
      if (licenseType != null) queryParams['license_type'] = licenseType;

      final response = await _apiClient.get(
        ApiEndpoints.licenses,
        queryParameters: queryParams,
      );

      if (response.data != null && response.data['success'] == true && response.data['data'] != null) {
        return LicenseListResponseDto.fromJson(response.data['data']);
      } else {
        throw ApiException(
          message: response.data?['error']?['message'] ?? 'Failed to fetch licenses',
        );
      }
    } catch (e) {
      throw _handleError(e);
    }
  }

  @override
  Future<LicenseDto> getLicenseById(int id) async {
    try {
      final response = await _apiClient.get(
        '${ApiEndpoints.licenses}/$id',
      );

      if (response.data != null && response.data['success'] == true && response.data['data'] != null) {
        return LicenseDto.fromJson(response.data['data']);
      } else {
        throw ApiException(
          message: response.data?['error']?['message'] ?? 'Failed to fetch license',
        );
      }
    } catch (e) {
      throw _handleError(e);
    }
  }

  @override
  Future<LicenseDto> createLicense(CreateLicenseRequest request) async {
    try {
      final response = await _apiClient.post(
        ApiEndpoints.licenses,
        data: request.toJson(),
      );

      if (response.data != null && response.data['success'] == true && response.data['data'] != null) {
        return LicenseDto.fromJson(response.data['data']);
      } else {
        throw ApiException(
          message: response.data?['error']?['message'] ?? 'Failed to fetch license',
        );
      }
    } catch (e) {
      throw _handleError(e);
    }
  }

  @override
  Future<LicenseDto> updateLicense(int id, UpdateLicenseRequest request) async {
    try {
      final response = await _apiClient.put(
        '${ApiEndpoints.licenses}/$id',
        data: request.toJson(),
      );

      if (response.data != null && response.data['success'] == true && response.data['data'] != null) {
        return LicenseDto.fromJson(response.data['data']);
      } else {
        throw ApiException(
          message: response.data?['error']?['message'] ?? 'Failed to fetch license',
        );
      }
    } catch (e) {
      throw _handleError(e);
    }
  }

  @override
  Future<void> deleteLicense(int id) async {
    try {
      await _apiClient.delete(
        '${ApiEndpoints.licenses}/$id',
      );
    } catch (e) {
      throw _handleError(e);
    }
  }

  @override
  Future<LicenseDto> assignLicense(int id, AssignLicenseRequest request) async {
    try {
      final response = await _apiClient.patch(
        '${ApiEndpoints.licenses}/$id/assign',
        data: request.toJson(),
      );

      if (response.data != null && response.data['success'] == true && response.data['data'] != null) {
        return LicenseDto.fromJson(response.data['data']);
      } else {
        throw ApiException(
          message: response.data?['error']?['message'] ?? 'Failed to fetch license',
        );
      }
    } catch (e) {
      throw _handleError(e);
    }
  }

  @override
  Future<LicenseDto> unassignLicense(int id) async {
    try {
      final response = await _apiClient.patch(
        '${ApiEndpoints.licenses}/$id/unassign',
      );

      if (response.data != null && response.data['success'] == true && response.data['data'] != null) {
        return LicenseDto.fromJson(response.data['data']);
      } else {
        throw ApiException(
          message: response.data?['error']?['message'] ?? 'Failed to fetch license',
        );
      }
    } catch (e) {
      throw _handleError(e);
    }
  }

  @override
  Future<ExpiringLicenseListDto> getExpiringLicenses({
    int days = 30,
    int page = 1,
    int perPage = 20,
  }) async {
    try {
      final queryParams = <String, dynamic>{
        'days': days,
        'page': page,
        'per_page': perPage,
      };

      final response = await _apiClient.get(
        '${ApiEndpoints.licenses}/expiring',
        queryParameters: queryParams,
      );

      if (response.data != null && response.data['success'] == true && response.data['data'] != null) {
        return ExpiringLicenseListDto.fromJson(response.data['data']);
      } else {
        throw ApiException(
          message: response.data?['error']?['message'] ?? 'Failed to fetch expiring licenses',
        );
      }
    } catch (e) {
      throw _handleError(e);
    }
  }

  Exception _handleError(dynamic error) {
    if (error is ApiException) {
      return error;
    }
    return ApiException(
      message: error.toString(),
    );
  }
}