feat: API 통합 2차 작업 완료

- 자동 로그인 구현: 앱 시작 시 토큰 확인 후 적절한 화면으로 라우팅
- AuthInterceptor 개선: AuthService와 통합하여 토큰 관리 일원화
- 로그아웃 기능 개선: AuthService를 사용한 API 로그아웃 처리
- 대시보드 API 연동: MockDataService에서 실제 API로 완전 전환
  - Dashboard DTO 모델 생성 (OverviewStats, RecentActivity 등)
  - DashboardRemoteDataSource 및 DashboardService 구현
  - OverviewController를 ChangeNotifier 패턴으로 개선
  - OverviewScreenRedesign에 Provider 패턴 적용
- API 통합 진행 상황 문서 업데이트
This commit is contained in:
JiWoong Sul
2025-07-24 15:55:05 +09:00
parent c573096d84
commit a13c485302
24 changed files with 2138 additions and 206 deletions

View File

@@ -0,0 +1,132 @@
import 'package:dartz/dartz.dart';
import 'package:dio/dio.dart';
import 'package:injectable/injectable.dart';
import 'package:superport/core/constants/api_endpoints.dart';
import 'package:superport/core/errors/exceptions.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('응답 데이터가 없습니다'));
}
} on DioException catch (e) {
return Left(_handleDioError(e));
} catch (e) {
return Left(ServerFailure('통계 데이터를 가져오는 중 오류가 발생했습니다'));
}
}
@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('응답 데이터가 올바르지 않습니다'));
}
} on DioException catch (e) {
return Left(_handleDioError(e));
} catch (e) {
return Left(ServerFailure('최근 활동을 가져오는 중 오류가 발생했습니다'));
}
}
@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('응답 데이터가 없습니다'));
}
} on DioException catch (e) {
return Left(_handleDioError(e));
} catch (e) {
return Left(ServerFailure('장비 상태 분포를 가져오는 중 오류가 발생했습니다'));
}
}
@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('응답 데이터가 올바르지 않습니다'));
}
} on DioException catch (e) {
return Left(_handleDioError(e));
} catch (e) {
return Left(ServerFailure('만료 예정 라이선스를 가져오는 중 오류가 발생했습니다'));
}
}
Failure _handleDioError(DioException error) {
switch (error.type) {
case DioExceptionType.connectionTimeout:
case DioExceptionType.sendTimeout:
case DioExceptionType.receiveTimeout:
return NetworkFailure('네트워크 연결 시간이 초과되었습니다');
case DioExceptionType.connectionError:
return NetworkFailure('서버에 연결할 수 없습니다');
case DioExceptionType.badResponse:
final statusCode = error.response?.statusCode ?? 0;
final message = error.response?.data?['message'] ?? '서버 오류가 발생했습니다';
if (statusCode == 401) {
return AuthFailure('인증이 만료되었습니다');
} else if (statusCode == 403) {
return AuthFailure('접근 권한이 없습니다');
} else if (statusCode >= 400 && statusCode < 500) {
return ServerFailure(message);
} else {
return ServerFailure('서버 오류가 발생했습니다 ($statusCode)');
}
case DioExceptionType.cancel:
return ServerFailure('요청이 취소되었습니다');
default:
return ServerFailure('알 수 없는 오류가 발생했습니다');
}
}
}

View File

@@ -1,11 +1,15 @@
import 'package:dio/dio.dart';
import 'package:flutter_secure_storage/flutter_secure_storage.dart';
import '../../../../core/constants/app_constants.dart';
import 'package:get_it/get_it.dart';
import '../../../../core/constants/api_endpoints.dart';
import '../../../../services/auth_service.dart';
/// 인증 인터셉터
class AuthInterceptor extends Interceptor {
final _storage = const FlutterSecureStorage();
late final AuthService _authService;
AuthInterceptor() {
_authService = GetIt.instance<AuthService>();
}
@override
void onRequest(
@@ -19,7 +23,7 @@ class AuthInterceptor extends Interceptor {
}
// 저장된 액세스 토큰 가져오기
final accessToken = await _storage.read(key: AppConstants.accessTokenKey);
final accessToken = await _authService.getAccessToken();
if (accessToken != null) {
options.headers['Authorization'] = 'Bearer $accessToken';
@@ -36,12 +40,17 @@ class AuthInterceptor extends Interceptor {
// 401 Unauthorized 에러 처리
if (err.response?.statusCode == 401) {
// 토큰 갱신 시도
final refreshSuccess = await _refreshToken();
final refreshResult = await _authService.refreshToken();
final refreshSuccess = refreshResult.fold(
(failure) => false,
(tokenResponse) => true,
);
if (refreshSuccess) {
// 새로운 토큰으로 원래 요청 재시도
try {
final newAccessToken = await _storage.read(key: AppConstants.accessTokenKey);
final newAccessToken = await _authService.getAccessToken();
if (newAccessToken != null) {
err.requestOptions.headers['Authorization'] = 'Bearer $newAccessToken';
@@ -58,60 +67,13 @@ class AuthInterceptor extends Interceptor {
}
// 토큰 갱신 실패 시 로그인 화면으로 이동
await _clearTokens();
await _authService.clearSession();
// TODO: Navigate to login screen
}
handler.next(err);
}
/// 토큰 갱신
Future<bool> _refreshToken() async {
try {
final refreshToken = await _storage.read(key: AppConstants.refreshTokenKey);
if (refreshToken == null) {
return false;
}
final dio = Dio();
final response = await dio.post(
'${dio.options.baseUrl}${ApiEndpoints.refresh}',
data: {
'refresh_token': refreshToken,
},
);
if (response.statusCode == 200 && response.data != null) {
final data = response.data;
// 새로운 토큰 저장
await _storage.write(
key: AppConstants.accessTokenKey,
value: data['access_token'],
);
if (data['refresh_token'] != null) {
await _storage.write(
key: AppConstants.refreshTokenKey,
value: data['refresh_token'],
);
}
return true;
}
return false;
} catch (e) {
return false;
}
}
/// 토큰 삭제
Future<void> _clearTokens() async {
await _storage.delete(key: AppConstants.accessTokenKey);
await _storage.delete(key: AppConstants.refreshTokenKey);
}
/// 인증 관련 엔드포인트 확인
bool _isAuthEndpoint(String path) {