// // ContentAllViewModel.swift // SodaLive // // Created by klaus on 11/14/25. // import Foundation import Combine final class ContentAllViewModel: ObservableObject { enum Sort: String { case NEWEST, POPULARITY } private let repository = ContentRepository() private var subscription = Set() @Published var errorMessage = "" @Published var isShowPopup = false @Published var isLoading = false @Published var themeList = [String]() @Published var contentList = [AudioContentMainItem]() @Published var sort = Sort.NEWEST { didSet { page = 1 isLast = false contentList.removeAll() fetchData() } } @Published var selectedTheme = I18n.Category.all { didSet { page = 1 isLast = false contentList.removeAll() fetchData() } } var page = 1 var isLast = false private let pageSize = 20 var isFree: Bool = false var isPointAvailableOnly: Bool = false func fetchData() { if !isLast && !isLoading { isLoading = true repository.getAllAudioContents(page: page, size: pageSize, isFree: isFree, isPointAvailableOnly: isPointAvailableOnly, sortType: sort, theme: selectedTheme == I18n.Category.all ? nil : selectedTheme) .sink { result in switch result { case .finished: DEBUG_LOG("finish") case .failure(let error): ERROR_LOG(error.localizedDescription) } } receiveValue: { [unowned self] response in self.isLoading = false let responseData = response.data do { let jsonDecoder = JSONDecoder() let decoded = try jsonDecoder.decode(ApiResponse<[AudioContentMainItem]>.self, from: responseData) self.isLoading = false if let data = decoded.data, decoded.success { if page == 1 { contentList.removeAll() } if !data.isEmpty { page += 1 self.contentList.append(contentsOf: data) } else { isLast = true } } else { if let message = decoded.message { self.errorMessage = message } else { self.errorMessage = I18n.Common.commonError } self.isShowPopup = true } } catch { self.errorMessage = I18n.Common.commonError self.isShowPopup = true self.isLoading = false } } .store(in: &subscription) } } func getThemeList() { repository.getAudioContentActiveThemeList(isFree: isFree, isPointAvailableOnly: isPointAvailableOnly) .sink { result in switch result { case .finished: DEBUG_LOG("finish") case .failure(let error): ERROR_LOG(error.localizedDescription) } } receiveValue: { [unowned self] response in self.isLoading = false let responseData = response.data do { let jsonDecoder = JSONDecoder() let decoded = try jsonDecoder.decode(ApiResponse<[String]>.self, from: responseData) self.isLoading = false if let data = decoded.data, decoded.success { self.themeList = [I18n.Category.all] + data } else { if let message = decoded.message { self.errorMessage = message } else { self.errorMessage = I18n.Common.commonError } self.isShowPopup = true } } catch { self.errorMessage = I18n.Common.commonError self.isShowPopup = true self.isLoading = false } } .store(in: &subscription) } func selectTheme(theme: String) { if selectedTheme != theme { selectedTheme = theme } } }