//
// Swiftfin is subject to the terms of the Mozilla Public
// License, v2.0. If a copy of the MPL was not distributed with this
// file, you can obtain one at https://mozilla.org/MPL/2.0/.
//
// Copyright (c) 2025 Jellyfin & Jellyfin Contributors
//

import Combine
import Foundation

class PokeIntervalTimer: ObservableObject, Publisher {

    typealias Output = Void
    typealias Failure = Never

    private let defaultInterval: TimeInterval
    private var delaySubject: PassthroughSubject<Void, Never> = .init()
    private var delayedWorkItem: DispatchWorkItem?

    init(defaultInterval: TimeInterval = 5) {
        self.defaultInterval = defaultInterval
    }

    func receive<S>(subscriber: S) where S: Subscriber, S.Failure == Never, S.Input == Void {
        delaySubject.receive(subscriber: subscriber)
    }

    func poke(interval: TimeInterval? = nil) {

        let interval = interval ?? defaultInterval

        delayedWorkItem?.cancel()

        let newPollItem = DispatchWorkItem {
            self.delaySubject.send(())
        }

        delayedWorkItem = newPollItem

        DispatchQueue.main.asyncAfter(deadline: .now() + interval, execute: newPollItem)
    }

    func stop() {
        delayedWorkItem?.cancel()
    }
}