ModuleViewManager.swift

import Foundation
import Observation
import os

/// Менеджер UI-представления модуля. Реализует механизм обновления экрана:
///
/// - пересчитывает описание экрана (`view.body`), попутно записывая,
///   какие свойства вью-модели вью прочитала;
/// - при изменении любого из них ставит наблюдатель на фазу `beforeWaiting`
///   главного RunLoop — несколько изменений за один цикл схлопываются
///   в одну перерисовку;
/// - при каждом пересчёте записывает зависимости заново.
///
/// В монорепозитории это `AnyModuleViewManager` с `withPerceptionTracking`
/// (Perception — бэкпорт Observation на старые iOS). Здесь — нативный
/// `withObservationTracking`, механика та же.
///
/// Известные границы (в проде так же): изменение состояния с фонового
/// потока не будит спящий главный RunLoop — перерисовка случится
/// со следующим его пробуждением; изменение состояния прямо во время
/// пересчёта откладывает следующий пересчёт до следующего пробуждения.
@MainActor
public final class ModuleViewManager<View: ModuleView> {

    public let view: View

    private let viewBodyUpdateAction: @MainActor (View.Body) -> Void

    private nonisolated let isUpdatingViewBody = OSAllocatedUnfairLock(initialState: false)

    public init(
        view: View,
        onViewBodyUpdate: @escaping @MainActor (View.Body) -> Void
    ) {
        self.view = view

        viewBodyUpdateAction = onViewBodyUpdate
    }

    public func updateViewBodyWithObservation() {
        withObservationTracking(updateViewBody) { [weak self] in
            self?.updateViewBodyWithChanges()
        }
    }

    private nonisolated func updateViewBodyWithChanges() {
        let isAlreadyScheduled = isUpdatingViewBody.withLock { isUpdating in
            defer { isUpdating = true }

            return isUpdating
        }

        guard !isAlreadyScheduled else {
            return
        }

        let viewRunLoopObserver = CFRunLoopObserverCreateWithHandler(
            kCFAllocatorDefault,
            CFRunLoopActivity.beforeWaiting.rawValue,
            false,
            0
        ) { [weak self] observer, _ in
            CFRunLoopRemoveObserver(
                CFRunLoopGetMain(),
                observer,
                .commonModes
            )

            // Наблюдаем исключительно за циклом выполнения главного потока
            MainActor.assumeIsolated {
                self?.updateViewBodyWithObservation()
            }
        }

        CFRunLoopAddObserver(
            CFRunLoopGetMain(),
            viewRunLoopObserver,
            .commonModes
        )
    }

    private func updateViewBody() {
        // Флаг снимается до пересчёта: изменение состояния во время
        // пересчёта должно запланировать следующий цикл, а не потеряться.
        // В монорепозитории этот случай решает очередь отложенных действий.
        isUpdatingViewBody.withLock { isUpdating in
            isUpdating = false
        }

        viewBodyUpdateAction(view.body)
    }
}