import Foundation
import Combine

final class MainHomeRecommendationViewModel: ObservableObject {
    private let repository = MainHomeRecommendationRepository()
    private let communityRepository = CreatorCommunityRepository()
    private var subscription = Set<AnyCancellable>()

    @Published var isLoading = false
    @Published var isShowPopup = false
    @Published var errorMessage = ""
    @Published var recommendations: HomeRecommendationResponse?
    @Published var isShowCommunityPostPurchaseDialog = false
    @Published var purchasingCommunityPostPrice = 0
    @Published private(set) var completedFollowKeys = Set<String>()
    @Published private(set) var followingKeys = Set<String>()
    private var purchasingCommunityPostId = 0

    func fetchRecommendations() {
        isLoading = true

        repository.getRecommendations()
            .sink { [weak self] result in
                guard let self else { return }

                switch result {
                case .finished:
                    DEBUG_LOG("finish")
                case .failure(let error):
                    ERROR_LOG(error.localizedDescription)
                    self.errorMessage = I18n.Common.commonError
                    self.isShowPopup = true
                    self.isLoading = false
                }
            } receiveValue: { [weak self] response in
                guard let self else { return }

                let responseData = response.data

                do {
                    let jsonDecoder = JSONDecoder()
                    let decoded = try jsonDecoder.decode(ApiResponse<HomeRecommendationResponse>.self, from: responseData)

                    if let data = decoded.data, decoded.success {
                        self.recommendations = data
                    } else {
                        self.errorMessage = decoded.message ?? I18n.Common.commonError
                        self.isShowPopup = true
                    }
                } catch {
                    self.errorMessage = I18n.Common.commonError
                    self.isShowPopup = true
                }

                self.isLoading = false
            }
            .store(in: &subscription)
    }

    func followAll(creatorIds: [Int], completionKey: String) {
        guard !creatorIds.isEmpty, !completionKey.isEmpty else { return }
        guard !completedFollowKeys.contains(completionKey), !followingKeys.contains(completionKey) else { return }

        followingKeys.insert(completionKey)

        repository.followRecommendedCreators(request: FollowRecommendedCreatorsRequest(creatorIds: creatorIds))
            .sink { [weak self] result in
                guard let self else { return }

                switch result {
                case .finished:
                    DEBUG_LOG("finish")
                case .failure(let error):
                    ERROR_LOG(error.localizedDescription)
                    self.errorMessage = I18n.Common.commonError
                    self.isShowPopup = true
                    self.followingKeys.remove(completionKey)
                }
            } receiveValue: { [weak self] response in
                guard let self else { return }

                let responseData = response.data

                do {
                    let jsonDecoder = JSONDecoder()
                    let decoded = try jsonDecoder.decode(ApiResponseWithoutData.self, from: responseData)

                    if decoded.success {
                        self.completedFollowKeys.insert(completionKey)
                    } else {
                        self.errorMessage = decoded.message ?? I18n.Common.commonError
                        self.isShowPopup = true
                    }
                } catch {
                    self.errorMessage = I18n.Common.commonError
                    self.isShowPopup = true
                }

                self.followingKeys.remove(completionKey)
            }
            .store(in: &subscription)
    }

    func isFollowAllCompleted(_ completionKey: String) -> Bool {
        completedFollowKeys.contains(completionKey)
    }

    func isFollowAllLoading(_ completionKey: String) -> Bool {
        followingKeys.contains(completionKey)
    }

    func likeCommunityPost(postId: Int) {
        guard postId > 0 else { return }

        communityRepository.communityPostLike(postId: postId)
            .sink { [weak self] result in
                guard let self else { return }

                switch result {
                case .finished:
                    DEBUG_LOG("finish")
                case .failure(let error):
                    ERROR_LOG(error.localizedDescription)
                    self.errorMessage = I18n.Common.commonError
                    self.isShowPopup = true
                }
            } receiveValue: { _ in }
            .store(in: &subscription)
    }

    func openCommunityPostPurchase(postId: Int, price: Int) {
        guard postId > 0, price > 0 else { return }

        purchasingCommunityPostId = postId
        purchasingCommunityPostPrice = price
        isShowCommunityPostPurchaseDialog = true
    }

    func purchaseCommunityPost() {
        let postId = purchasingCommunityPostId
        guard postId > 0, !isLoading else { return }

        isLoading = true

        communityRepository.purchaseCommunityPost(postId: postId)
            .sink { [weak self] result in
                guard let self else { return }

                switch result {
                case .finished:
                    DEBUG_LOG("finish")
                case .failure(let error):
                    ERROR_LOG(error.localizedDescription)
                    self.errorMessage = I18n.Common.commonError
                    self.isShowPopup = true
                    self.isLoading = false
                }
            } receiveValue: { [weak self] response in
                guard let self else { return }

                let responseData = response.data

                do {
                    let jsonDecoder = JSONDecoder()
                    let decoded = try jsonDecoder.decode(ApiResponse<GetCommunityPostListResponse>.self, from: responseData)

                    if decoded.success {
                        self.purchasingCommunityPostId = 0
                        self.purchasingCommunityPostPrice = 0
                        self.fetchRecommendations()
                    } else {
                        self.errorMessage = decoded.message ?? I18n.Common.commonError
                        self.isShowPopup = true
                        self.isLoading = false
                    }
                } catch {
                    self.errorMessage = I18n.Common.commonError
                    self.isShowPopup = true
                    self.isLoading = false
                }
            }
            .store(in: &subscription)
    }
}