66 lines
2.2 KiB
Dart
66 lines
2.2 KiB
Dart
import 'package:dartz/dartz.dart';
|
|
import '../../core/error/exceptions.dart';
|
|
import '../../core/error/failures.dart';
|
|
import '../datasources/auth_remote_data_source.dart';
|
|
import '../datasources/user_local_data_source.dart';
|
|
import '../dto/login_dto.dart';
|
|
import '../dto/login_response_dto.dart';
|
|
import '../../domain/models/login_request.dart';
|
|
import '../../domain/models/login_response_model.dart';
|
|
import '../../domain/repositories/auth_repository.dart';
|
|
|
|
class AuthRepositoryImpl implements AuthRepository {
|
|
final AuthRemoteDataSource remoteDataSource;
|
|
final UserLocalDataSource localDataSource;
|
|
|
|
AuthRepositoryImpl({
|
|
required this.remoteDataSource,
|
|
required this.localDataSource,
|
|
});
|
|
|
|
@override
|
|
Future<Either<Failure, LoginResponseModel>> login(LoginRequest request) async {
|
|
try {
|
|
final dto = LoginDto(
|
|
phoneNumber: request.phoneNumber,
|
|
password: request.password,
|
|
);
|
|
|
|
final responseDto = await remoteDataSource.login(dto);
|
|
|
|
// Cache the token locally
|
|
if (responseDto.data?.token != null) {
|
|
await localDataSource.cacheUserToken(responseDto.data!.token!);
|
|
}
|
|
|
|
// Convert DTO to Model
|
|
final responseModel = LoginResponseModel(
|
|
statusCode: responseDto.statusCode,
|
|
isSuccess: responseDto.isSuccess,
|
|
message: responseDto.message,
|
|
data: responseDto.data != null
|
|
? LoginDataModel(
|
|
token: responseDto.data!.token,
|
|
id: responseDto.data!.id,
|
|
employeeId: responseDto.data!.employeeId,
|
|
username: responseDto.data!.username,
|
|
fullName: responseDto.data!.fullName,
|
|
role: responseDto.data!.role,
|
|
email: responseDto.data!.email,
|
|
phoneNumber: responseDto.data!.phoneNumber,
|
|
permissions: responseDto.data!.permissions,
|
|
)
|
|
: null,
|
|
);
|
|
|
|
return Right(responseModel);
|
|
} on ServerException catch (e) {
|
|
return Left(ServerFailure(e.message));
|
|
} on NetworkException catch (e) {
|
|
return Left(NetworkFailure(e.message));
|
|
} catch (e) {
|
|
return Left(ServerFailure('خطأ غير متوقع: $e'));
|
|
}
|
|
}
|
|
}
|