[SwiftUI] Service Layer to ViewModel with Combine

참고 및 출처 사이트

https://www.youtube.com/watch?v=TlJUMVKtUhc&list=PLwvDm4Vfkdphbc3bgy_LpLRQ9DDfFGcFu&index=7 

 

Service layer의 역활

- 데이터 베이스를 다루는 모든 로직을 포함한 네트워크 레이어

- 데이터를 디코딩 하고 뷰 모델로 전달하는 역활을 함

 

Services 생성

- New file > Swift 파일 선택 후 PrefixDataService.swift 파일 생성

 

Published 변수 선언

@Published var allCoins: [CoinModel] = []

- @Published 프로퍼티 랩퍼를 사용해서 퍼블리셔를 생성함

- subscriber가 퍼블리셔로 선언된 변수를 구독할 수 있음

 

Cancellable추가

- Rx에서 disposeBag의 역활. 메모리에서 해지

var coinSubscription: AnyCancellable?

- cancellable이 명확히 하나일 경우 이렇게 사용할 수 있으며 여러개일 경우 아래와 같이 선언해서 사용할 수 있음

var cancellables = Set<AnyCancellable>()

 

Initializer 정의

    init() {
        getCoints()
    }

- 이니셜라이저에서 해당 객체 생성시 호출될 함수를 지정해 줌

 

function to request data

guard let url = URL(string: "https://api.~~~~") else { return }

- api를 받아올 url이 유효한지 검증. url에 바인딩

 

coinSubscription = URLSession.shared.dataTaskPublisher(for: url)

- cancellable에 publisher를 넘겨줌. 

- URLSession shared에 dataTaskPublisher를 사용해서 퍼블리셔 기능을 사용할 수 있음

 

.subscribe(on: DispatchQueue.global(qos: .default))

- 백그라운드에서 데이터를 다운로드 받기 위해 스레드 정의. global default로 설정해서 백그라운드에서 작업하도록 설정

 

            .tryMap { (output) -> Data in
                
                guard let response = output.response as? HTTPURLResponse,
                      response.statusCode >= 200 && response.statusCode < 300 else {
                    throw URLError(.badServerResponse)
                }
                return output.data
            }

- tryMap을 사용해서 업스트림 퍼블리셔로 부터 전달 받은 데이터의 유효성을 검증하고 Data를 반환함

 

.receive(on: DispatchQueue.main)

- 백그라운드에서 다운로드 받은 데이터를 ui에서 사용할 수 있도록 main 스레드로 변경

 

.decode(type: [CoinModel].self, decoder: JSONDecoder())

- type에 Codable 객체를 지정해서 JSONDecoding해줌

 

            .sink { completion in
                switch completion {
                case .finished:
                    break
                case .failure(let error):
                    print(error.localizedDescription)
                }
            } receiveValue: { [weak self] returnedCoins in
                self?.allCoins = returnedCoins
                self?.coinSubscription?.cancel()
            }

- 방출된 데이터를 구독. error가 발생하면 failure 케이스를, 성공하면 receiveValue에 전달한 클로져를 타게 됨

- 해당 클래스와 강한참조가 걸리기 때문에 weak self로 약한 참조를 걸어줌

- 해당 퍼블리셔는 데이터를 1회 다운로드 받아 viewModel로 전달할 용도이므로 최초 1회 호출 후 재사용하지 않음
따라서 퍼블리셔 변수에 전달한 뒤 cancellable인 coinSubscription을 cancel 해줌