[Refactor] ViewModel에서 Flow를 사용할 수 있도록 수정 #343
Conversation
* 서버에서 BaseResponse 형태로 수신되고 있어서 불필요한 래핑 발생 * data 외의 값은 쓰지 않고 있어서 Interceptor를 통해 data만 추출
* 에러가 발생했을 때 러넥트 서버 에러 + 기본 에러를 같이 받을 수 있도록 처리
| @Serializable | ||
| data class ErrorResponse<T>( | ||
| @SerialName("status") | ||
| val status: Int, |
There was a problem hiding this comment.
@unam98 status가 null이 오는 경우는 없다고 생각하여 Non-Null로 지정하였습니다.
서버 에러, Http 에러 발생시에도 status 코드는 모두 포함 되어있고, status 코드도 안내려오는 상황이라면 Exception일 것이라고 생각하였습니다.
| RunnectException( | ||
| code = response.code(), | ||
| message = ERROR_MSG_RESPONSE_IS_NULL | ||
| ) |
There was a problem hiding this comment.
뷰모델에서 매번 반복되었던 로직을 여기서 처리해주니까 넘 좋네요! 👍
| code = errorBody.status, | ||
| message = message | ||
| ) | ||
| }.getOrElse { |
There was a problem hiding this comment.
Result에서 제공하는 다양한 확장함수들 덕분에 에러 핸들링 코드가 간결해진 거 같아요!
이 글 참고해서 저도 더 유연하게 사용해봐야겠어요 :)
| val originalResponse = chain.proceed(chain.request()) | ||
| if (!originalResponse.isSuccessful) return originalResponse | ||
|
|
||
| val bodyString = originalResponse.peekBody(Long.MAX_VALUE).string() |
There was a problem hiding this comment.
Long.MAX_VALUE 값을 인자로 넘겨주는 이유가 무엇인가요? 👀
There was a problem hiding this comment.
@leeeha 기존 응답에서 얼만큼을 읽어올 지 사이즈를 정해주는 값입니다!
저희는 모든 응답을 그대로 가져올 것이기 떄문에 Long.MAX_VALUE를 전달해주었습니다
| override suspend fun getMarathonCourse(): Flow<Result<List<MarathonCourse>>> { | ||
| return remoteCourseDataSource.getMarathonCourse().mapToFlowResult { | ||
| it.toMarathonCourses() | ||
| } |
| .baseUrl(baseUrl) | ||
| .client(client) | ||
| .addConverterFactory(GsonConverterFactory.create()) | ||
| .addCallAdapterFactory(ResultCallAdapterFactory.create()) |
| ): OkHttpClient = OkHttpClient.Builder() | ||
| .addInterceptor(logger) | ||
| .addInterceptor(appInterceptor) | ||
| .addInterceptor(responseInterceptor) |
There was a problem hiding this comment.
ResponseInterceptor 적용하는 건 처음 봅니다! 인터셉터 활용을 이렇게나 다양하게 할 수 있다니 👍
| import okhttp3.MultipartBody | ||
| import okhttp3.RequestBody | ||
| import retrofit2.Response | ||
|
|
||
| interface CourseRepository { | ||
| suspend fun getMarathonCourse(): Result<List<MarathonCourse>?> | ||
| suspend fun getMarathonCourse(): Flow<Result<List<MarathonCourse>>> |
| } | ||
| else -> { | ||
| Timber.e(throwable) | ||
| } |
There was a problem hiding this comment.
Timber.e(throwable) 를 똑같이 출력하는데 굳이 when문으로 구분하는 이유가 있을까요..?!
There was a problem hiding this comment.
@leeeha 추후 BaseViewModel에 공통 StateFlow or SharedFlow를 선언해두고, 예외 타입에 따라 UiState를 방출 시킬 예정입니다.
아직 정확한 방향이 안정해져서 임시로 구분만 해놨습니다~!
| block: suspend CoroutineScope.() -> Unit | ||
| ) { | ||
| viewModelScope.launch(dispatcher + exceptionHandler, start, block) | ||
| } |
There was a problem hiding this comment.
우와 이제까지 launch로 코루틴 블록 만드는 정도밖에 안 해봤는데.. 이렇게 커스텀 할 수 있다는 게 넘 신기하네요!
코루틴에 대해서도 자세히 알아봐야겠어요 🙏
| result.onSuccess { | ||
| _marathonCourseGetState.value = UiStateV2.Success(it) | ||
| }.onFailure { | ||
| _marathonCourseGetState.value = UiStateV2.Failure(it.toLog()) | ||
| } |
There was a problem hiding this comment.
크으... 깔끔하다!!! flow에서 제공하는 다양한 연산자들 알아봐야겠어요! 혹시 자료 추천해주실 수 있을까요?!
There was a problem hiding this comment.
@leeeha 답변 남기는걸 까먹었었네요..ㅎ
flow 연산자에 대한 내용은 아니지만 아래 블로그 글 추천합니다.
flow가 어떻게 동작하는지 잘 보여주는 글인 것 같아요
📌 개요
✨ 작업 내용
RetrofitV2를 만들어서 마라톤 코스 요청 메소드에만 예시로 적용 해두었습니다.
(CourseV2Service, DiscoverViewModel 참고)
✨ PR 포인트
CallAdapter 추가
BaseReseponse 제거 + ResponseInterceptor 추가
BaseViewModel + exceptionHandler 추가
📸 스크린샷/동영상