//
//  TalkViewModel.swift
//  SodaLive
//
//  Created by klaus on 8/29/25.
//

import Foundation
import Combine
import Moya

final class TalkViewModel: ObservableObject {
    // MARK: - Published State
    @Published private(set) var talkRooms = [TalkRoom]()
    
    @Published var isLoading: Bool = false
    @Published var errorMessage: String = ""
    @Published var isShowPopup = false
    @Published var isLoadingMore: Bool = false
    
    // MARK: - Private
    private let repository = TalkRepository()
    private var subscription = Set<AnyCancellable>()
    
    private var page: Int = 0
    private var isLastPage: Bool = false
    private var isLoadingPage: Bool = false
    
    // MARK: - API
    func getTalkRooms() {
        // 초기 로드: 페이지 리셋 후 0페이지 요청
        page = 0
        isLastPage = false
        talkRooms.removeAll()
        fetch(page: page, isInitial: true)
    }
    
    func loadNextPage() {
        guard !isLastPage, !isLoadingPage else { return }
        page += 1
        fetch(page: page, isInitial: false)
    }
    
    private func fetch(page: Int, isInitial: Bool) {
        if isInitial {
            isLoading = true
        } else {
            isLoadingMore = true
        }
        isLoadingPage = true
        
        repository.getTalkRooms(page: page)
            .sink { [weak self] completion in
                guard let self = self else { return }
                DispatchQueue.main.async {
                    self.isLoading = false
                    self.isLoadingMore = false
                    self.isLoadingPage = false
                }
                
                if case let .failure(error) = completion {
                    ERROR_LOG(error.localizedDescription)
                    DispatchQueue.main.async {
                        self.errorMessage = "다시 시도해 주세요.\n계속 같은 문제가 발생할 경우 고객센터로 문의 주시기 바랍니다."
                        self.isShowPopup = true
                    }
                } else {
                    DEBUG_LOG("fetch page=\(page) finished")
                }
            } receiveValue: { [weak self] response in
                guard let self = self else { return }
                let responseData = response.data
                
                do {
                    let jsonDecoder = JSONDecoder()
                    let decoded = try jsonDecoder.decode(ApiResponse<[TalkRoom]>.self, from: responseData)
                    
                    if let data = decoded.data, decoded.success {
                        if data.isEmpty {
                            // 빈 데이터면 마지막 페이지로 인식
                            self.isLastPage = true
                            return
                        }
                        if isInitial || self.talkRooms.isEmpty && page == 0 {
                            self.talkRooms = data
                        } else {
                            self.talkRooms.append(contentsOf: data)
                        }
                    } else {
                        if let message = decoded.message {
                            self.errorMessage = message
                        } else {
                            self.errorMessage = "다시 시도해 주세요.\n계속 같은 문제가 발생할 경우 고객센터로 문의 주시기 바랍니다."
                        }
                        self.isShowPopup = true
                    }
                } catch {
                    self.errorMessage = "다시 시도해 주세요.\n계속 같은 문제가 발생할 경우 고객센터로 문의 주시기 바랍니다."
                    self.isShowPopup = true
                }
            }
            .store(in: &subscription)
    }
}