Compare commits
5 Commits
88308b46f5
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
da033cf12c | ||
|
|
08ad702f9d | ||
|
|
85a19fdd71 | ||
|
|
ba24c767a0 | ||
|
|
bf44a7b7eb |
@@ -53,6 +53,8 @@ final class GamesViewModel {
|
|||||||
@ObservationIgnored
|
@ObservationIgnored
|
||||||
private var refreshTask: Task<Void, Never>?
|
private var refreshTask: Task<Void, Never>?
|
||||||
@ObservationIgnored
|
@ObservationIgnored
|
||||||
|
private var lastLoadDateString: String?
|
||||||
|
@ObservationIgnored
|
||||||
private var authenticatedVideoFeedCache: [String: AuthenticatedVideoFeedCacheEntry] = [:]
|
private var authenticatedVideoFeedCache: [String: AuthenticatedVideoFeedCacheEntry] = [:]
|
||||||
@ObservationIgnored
|
@ObservationIgnored
|
||||||
private var videoShuffleBagsByModel: [String: [String: [URL]]] = [:]
|
private var videoShuffleBagsByModel: [String: [String: [URL]]] = [:]
|
||||||
@@ -105,12 +107,21 @@ final class GamesViewModel {
|
|||||||
func startAutoRefresh() {
|
func startAutoRefresh() {
|
||||||
stopAutoRefresh()
|
stopAutoRefresh()
|
||||||
refreshTask = Task { [weak self] in
|
refreshTask = Task { [weak self] in
|
||||||
|
var ticksSinceFullLoad = 0
|
||||||
while !Task.isCancelled {
|
while !Task.isCancelled {
|
||||||
try? await Task.sleep(for: .seconds(60))
|
try? await Task.sleep(for: .seconds(60))
|
||||||
guard !Task.isCancelled else { break }
|
guard !Task.isCancelled else { break }
|
||||||
guard let self else { break }
|
guard let self else { break }
|
||||||
// Refresh if there are live games or active streams
|
ticksSinceFullLoad += 1
|
||||||
if !self.liveGames.isEmpty || !self.activeStreams.isEmpty {
|
|
||||||
|
// Full schedule reload every 10 minutes (or immediately on day change)
|
||||||
|
let today = Self.dateFormatter.string(from: Date())
|
||||||
|
let dayChanged = self.lastLoadDateString != nil && self.lastLoadDateString != today
|
||||||
|
if dayChanged || ticksSinceFullLoad >= 10 {
|
||||||
|
ticksSinceFullLoad = 0
|
||||||
|
await self.loadGames()
|
||||||
|
} else if !self.liveGames.isEmpty || !self.activeStreams.isEmpty {
|
||||||
|
// Fast score refresh every 60s when games are live
|
||||||
await self.refreshScores()
|
await self.refreshScores()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -122,6 +133,14 @@ final class GamesViewModel {
|
|||||||
refreshTask = nil
|
refreshTask = nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func refreshIfDayChanged() async {
|
||||||
|
let today = Self.dateFormatter.string(from: Date())
|
||||||
|
if lastLoadDateString != today {
|
||||||
|
logGamesViewModel("Day changed (\(lastLoadDateString ?? "nil") → \(today)), reloading games")
|
||||||
|
await loadGames()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
private func refreshScores() async {
|
private func refreshScores() async {
|
||||||
let statsGames = await fetchStatsGames()
|
let statsGames = await fetchStatsGames()
|
||||||
guard !statsGames.isEmpty else { return }
|
guard !statsGames.isEmpty else { return }
|
||||||
@@ -227,6 +246,7 @@ final class GamesViewModel {
|
|||||||
errorMessage = "No games found"
|
errorMessage = "No games found"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
lastLoadDateString = todayDateString
|
||||||
isLoading = false
|
isLoading = false
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -260,7 +260,11 @@ struct DashboardView: View {
|
|||||||
mediaId: selection.broadcast.mediaId,
|
mediaId: selection.broadcast.mediaId,
|
||||||
streamURLString: selection.broadcast.streamURL
|
streamURLString: selection.broadcast.streamURL
|
||||||
)
|
)
|
||||||
guard let url = await viewModel.resolveStreamURL(for: stream) else { return nil }
|
guard let url = await viewModel.resolveStreamURL(
|
||||||
|
for: stream,
|
||||||
|
resolutionOverride: viewModel.defaultResolution,
|
||||||
|
preserveServerResolutionWhenBest: false
|
||||||
|
) else { return nil }
|
||||||
return SingleStreamPlaybackSource(url: url)
|
return SingleStreamPlaybackSource(url: url)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -619,22 +623,24 @@ struct WerkoutNSFWSheet: View {
|
|||||||
sheetBackground
|
sheetBackground
|
||||||
.ignoresSafeArea()
|
.ignoresSafeArea()
|
||||||
|
|
||||||
ViewThatFits {
|
ScrollView(.vertical, showsIndicators: false) {
|
||||||
HStack(alignment: .top, spacing: 32) {
|
ViewThatFits(in: .horizontal) {
|
||||||
overviewColumn
|
HStack(alignment: .top, spacing: 32) {
|
||||||
.frame(maxWidth: .infinity, alignment: .leading)
|
overviewColumn
|
||||||
|
.frame(maxWidth: .infinity, alignment: .leading)
|
||||||
|
|
||||||
actionColumn
|
actionColumn
|
||||||
.frame(width: 360, alignment: .leading)
|
.frame(width: 360, alignment: .leading)
|
||||||
}
|
}
|
||||||
|
|
||||||
VStack(alignment: .leading, spacing: 24) {
|
VStack(alignment: .leading, spacing: 24) {
|
||||||
overviewColumn
|
overviewColumn
|
||||||
actionColumn
|
actionColumn
|
||||||
.frame(maxWidth: .infinity, alignment: .leading)
|
.frame(maxWidth: .infinity, alignment: .leading)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
.padding(38)
|
.padding(usesStackedLayout ? 24 : 38)
|
||||||
.background(
|
.background(
|
||||||
RoundedRectangle(cornerRadius: 34, style: .continuous)
|
RoundedRectangle(cornerRadius: 34, style: .continuous)
|
||||||
.fill(.black.opacity(0.46))
|
.fill(.black.opacity(0.46))
|
||||||
|
|||||||
@@ -69,6 +69,7 @@ struct GameCenterView: View {
|
|||||||
VideoPlayer(player: player)
|
VideoPlayer(player: player)
|
||||||
.ignoresSafeArea()
|
.ignoresSafeArea()
|
||||||
.onAppear { player.play() }
|
.onAppear { player.play() }
|
||||||
|
.onDisappear { player.pause() }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -352,10 +352,11 @@ private struct MultiStreamTile: View {
|
|||||||
@State private var player: AVPlayer?
|
@State private var player: AVPlayer?
|
||||||
@State private var hasError = false
|
@State private var hasError = false
|
||||||
@State private var startupPlaybackTask: Task<Void, Never>?
|
@State private var startupPlaybackTask: Task<Void, Never>?
|
||||||
@State private var qualityUpgradeTask: Task<Void, Never>?
|
@State private var werkoutMonitorTask: Task<Void, Never>?
|
||||||
@State private var clipTimeLimitObserver: Any?
|
@State private var clipTimeLimitObserver: Any?
|
||||||
@State private var isAdvancingClip = false
|
@State private var isAdvancingClip = false
|
||||||
@StateObject private var playbackDiagnostics = MultiStreamPlaybackDiagnostics()
|
@StateObject private var playbackDiagnostics = MultiStreamPlaybackDiagnostics()
|
||||||
|
@State private var audioDiagnostics: AudioDiagnostics?
|
||||||
|
|
||||||
private static let maxClipDuration: Double = 15.0
|
private static let maxClipDuration: Double = 15.0
|
||||||
private static var audioSessionConfigured = false
|
private static var audioSessionConfigured = false
|
||||||
@@ -445,10 +446,16 @@ private struct MultiStreamTile: View {
|
|||||||
logMultiView("tile disappeared id=\(stream.id) label=\(stream.label)")
|
logMultiView("tile disappeared id=\(stream.id) label=\(stream.label)")
|
||||||
startupPlaybackTask?.cancel()
|
startupPlaybackTask?.cancel()
|
||||||
startupPlaybackTask = nil
|
startupPlaybackTask = nil
|
||||||
qualityUpgradeTask?.cancel()
|
werkoutMonitorTask?.cancel()
|
||||||
qualityUpgradeTask = nil
|
werkoutMonitorTask = nil
|
||||||
if let player { removeClipTimeLimit(from: player) }
|
if let player {
|
||||||
|
removeClipTimeLimit(from: player)
|
||||||
|
player.pause()
|
||||||
|
}
|
||||||
|
player = nil
|
||||||
playbackDiagnostics.clear(streamID: stream.id, reason: "tile disappeared")
|
playbackDiagnostics.clear(streamID: stream.id, reason: "tile disappeared")
|
||||||
|
audioDiagnostics?.detach()
|
||||||
|
audioDiagnostics = nil
|
||||||
}
|
}
|
||||||
#if os(tvOS)
|
#if os(tvOS)
|
||||||
.focusEffectDisabled()
|
.focusEffectDisabled()
|
||||||
@@ -529,11 +536,8 @@ private struct MultiStreamTile: View {
|
|||||||
.clipShape(Capsule())
|
.clipShape(Capsule())
|
||||||
}
|
}
|
||||||
|
|
||||||
private var multiViewStartupResolution: String { "504p" }
|
private var multiViewStartupResolution: String {
|
||||||
|
viewModel.defaultResolution
|
||||||
private var multiViewUpgradeTargetResolution: String? {
|
|
||||||
let desiredResolution = viewModel.defaultResolution
|
|
||||||
return desiredResolution == multiViewStartupResolution ? nil : desiredResolution
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private func startStream() async {
|
private func startStream() async {
|
||||||
@@ -549,18 +553,18 @@ private struct MultiStreamTile: View {
|
|||||||
onPlaybackEnded: playbackEndedHandler(for: player)
|
onPlaybackEnded: playbackEndedHandler(for: player)
|
||||||
)
|
)
|
||||||
scheduleStartupPlaybackRecovery(for: player)
|
scheduleStartupPlaybackRecovery(for: player)
|
||||||
scheduleQualityUpgrade(for: player)
|
|
||||||
installClipTimeLimit(on: player)
|
installClipTimeLimit(on: player)
|
||||||
|
attachAudioDiagnostics(to: player)
|
||||||
logMultiView("startStream reused inline player id=\(stream.id) muted=\(player.isMuted)")
|
logMultiView("startStream reused inline player id=\(stream.id) muted=\(player.isMuted)")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if !Self.audioSessionConfigured {
|
if !Self.audioSessionConfigured {
|
||||||
do {
|
do {
|
||||||
try AVAudioSession.sharedInstance().setCategory(.playback)
|
try AVAudioSession.sharedInstance().setCategory(.playback, mode: .default)
|
||||||
try AVAudioSession.sharedInstance().setActive(true)
|
try AVAudioSession.sharedInstance().setActive(true)
|
||||||
Self.audioSessionConfigured = true
|
Self.audioSessionConfigured = true
|
||||||
logMultiView("startStream audio session configured id=\(stream.id)")
|
logMultiView("startStream audio session configured id=\(stream.id) mode=default")
|
||||||
} catch {
|
} catch {
|
||||||
logMultiView("startStream audio session failed id=\(stream.id) error=\(error.localizedDescription)")
|
logMultiView("startStream audio session failed id=\(stream.id) error=\(error.localizedDescription)")
|
||||||
}
|
}
|
||||||
@@ -576,8 +580,8 @@ private struct MultiStreamTile: View {
|
|||||||
onPlaybackEnded: playbackEndedHandler(for: existingPlayer)
|
onPlaybackEnded: playbackEndedHandler(for: existingPlayer)
|
||||||
)
|
)
|
||||||
scheduleStartupPlaybackRecovery(for: existingPlayer)
|
scheduleStartupPlaybackRecovery(for: existingPlayer)
|
||||||
scheduleQualityUpgrade(for: existingPlayer)
|
|
||||||
installClipTimeLimit(on: existingPlayer)
|
installClipTimeLimit(on: existingPlayer)
|
||||||
|
attachAudioDiagnostics(to: existingPlayer)
|
||||||
logMultiView("startStream reused shared player id=\(stream.id) muted=\(existingPlayer.isMuted)")
|
logMultiView("startStream reused shared player id=\(stream.id) muted=\(existingPlayer.isMuted)")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@@ -604,15 +608,16 @@ private struct MultiStreamTile: View {
|
|||||||
avPlayer.currentItem?.preferredForwardBufferDuration = 2
|
avPlayer.currentItem?.preferredForwardBufferDuration = 2
|
||||||
|
|
||||||
self.player = avPlayer
|
self.player = avPlayer
|
||||||
|
// Set mute state BEFORE playback to prevent audio spikes
|
||||||
|
viewModel.attachPlayer(avPlayer, to: stream.id)
|
||||||
playbackDiagnostics.attach(
|
playbackDiagnostics.attach(
|
||||||
to: avPlayer,
|
to: avPlayer,
|
||||||
streamID: stream.id,
|
streamID: stream.id,
|
||||||
label: stream.label,
|
label: stream.label,
|
||||||
onPlaybackEnded: playbackEndedHandler(for: avPlayer)
|
onPlaybackEnded: playbackEndedHandler(for: avPlayer)
|
||||||
)
|
)
|
||||||
viewModel.attachPlayer(avPlayer, to: stream.id)
|
|
||||||
scheduleStartupPlaybackRecovery(for: avPlayer)
|
scheduleStartupPlaybackRecovery(for: avPlayer)
|
||||||
scheduleQualityUpgrade(for: avPlayer)
|
attachAudioDiagnostics(to: avPlayer)
|
||||||
logMultiView("startStream attached player id=\(stream.id) muted=\(avPlayer.isMuted) startupResolution=\(multiViewStartupResolution) fastStart=true calling playImmediately(atRate: 1.0)")
|
logMultiView("startStream attached player id=\(stream.id) muted=\(avPlayer.isMuted) startupResolution=\(multiViewStartupResolution) fastStart=true calling playImmediately(atRate: 1.0)")
|
||||||
avPlayer.playImmediately(atRate: 1.0)
|
avPlayer.playImmediately(atRate: 1.0)
|
||||||
installClipTimeLimit(on: avPlayer)
|
installClipTimeLimit(on: avPlayer)
|
||||||
@@ -625,19 +630,35 @@ private struct MultiStreamTile: View {
|
|||||||
)
|
)
|
||||||
|
|
||||||
let item = makePlayerItem(url: url, headers: headers)
|
let item = makePlayerItem(url: url, headers: headers)
|
||||||
return AVPlayer(playerItem: item)
|
let player = AVPlayer(playerItem: item)
|
||||||
|
player.appliesMediaSelectionCriteriaAutomatically = false
|
||||||
|
logMultiView("startStream configured AVPlayer id=\(stream.id) appliesMediaSelectionCriteriaAutomatically=false")
|
||||||
|
return player
|
||||||
}
|
}
|
||||||
|
|
||||||
private func makePlayerItem(url: URL, headers: [String: String]) -> AVPlayerItem {
|
private func makePlayerItem(url: URL, headers: [String: String]) -> AVPlayerItem {
|
||||||
|
let item: AVPlayerItem
|
||||||
if headers.isEmpty {
|
if headers.isEmpty {
|
||||||
return AVPlayerItem(url: url)
|
item = AVPlayerItem(url: url)
|
||||||
|
} else {
|
||||||
|
let assetOptions: [String: Any] = [
|
||||||
|
"AVURLAssetHTTPHeaderFieldsKey": headers,
|
||||||
|
]
|
||||||
|
let asset = AVURLAsset(url: url, options: assetOptions)
|
||||||
|
item = AVPlayerItem(asset: asset)
|
||||||
}
|
}
|
||||||
|
item.allowedAudioSpatializationFormats = []
|
||||||
|
logMultiView("startStream configured player item id=\(stream.id) allowedAudioSpatializationFormats=[]")
|
||||||
|
pinAudioSelection(on: item)
|
||||||
|
return item
|
||||||
|
}
|
||||||
|
|
||||||
let assetOptions: [String: Any] = [
|
/// Pin the HLS audio rendition so ABR can't swap channel layouts mid-stream.
|
||||||
"AVURLAssetHTTPHeaderFieldsKey": headers,
|
private func pinAudioSelection(on item: AVPlayerItem) {
|
||||||
]
|
let streamID = stream.id
|
||||||
let asset = AVURLAsset(url: url, options: assetOptions)
|
Task { @MainActor in
|
||||||
return AVPlayerItem(asset: asset)
|
await enforcePinnedMultiStreamAudioSelection(on: item, streamID: streamID)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private func scheduleStartupPlaybackRecovery(for player: AVPlayer) {
|
private func scheduleStartupPlaybackRecovery(for player: AVPlayer) {
|
||||||
@@ -678,92 +699,18 @@ private struct MultiStreamTile: View {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private func scheduleQualityUpgrade(for player: AVPlayer) {
|
|
||||||
qualityUpgradeTask?.cancel()
|
|
||||||
|
|
||||||
guard stream.overrideURL == nil else {
|
|
||||||
logMultiView("qualityUpgrade skip id=\(stream.id) reason=override-url")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
guard let targetResolution = multiViewUpgradeTargetResolution else {
|
|
||||||
logMultiView("qualityUpgrade skip id=\(stream.id) reason=target-already-\(multiViewStartupResolution)")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
let streamID = stream.id
|
|
||||||
let label = stream.label
|
|
||||||
qualityUpgradeTask = Task { @MainActor in
|
|
||||||
let checkDelays: [Double] = [2.0, 4.0, 7.0]
|
|
||||||
|
|
||||||
for delay in checkDelays {
|
|
||||||
try? await Task.sleep(for: .seconds(delay))
|
|
||||||
guard !Task.isCancelled else { return }
|
|
||||||
guard let currentPlayer = self.player, currentPlayer === player else {
|
|
||||||
logMultiView("qualityUpgrade abort id=\(streamID) label=\(label) reason=player-changed")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
let itemStatus = multiViewItemStatusDescription(player.currentItem?.status ?? .unknown)
|
|
||||||
let likelyToKeepUp = player.currentItem?.isPlaybackLikelyToKeepUp ?? false
|
|
||||||
let bufferEmpty = player.currentItem?.isPlaybackBufferEmpty ?? false
|
|
||||||
let currentResolution = currentStreamResolution(for: player) ?? "unknown"
|
|
||||||
let stable = (itemStatus == "readyToPlay" || likelyToKeepUp) && !bufferEmpty
|
|
||||||
|
|
||||||
logMultiView(
|
|
||||||
"qualityUpgrade check id=\(streamID) delay=\(delay)s currentResolution=\(currentResolution) targetResolution=\(targetResolution) stable=\(stable) rate=\(player.rate)"
|
|
||||||
)
|
|
||||||
|
|
||||||
guard stable else { continue }
|
|
||||||
|
|
||||||
if currentResolution == targetResolution {
|
|
||||||
logMultiView("qualityUpgrade skip id=\(streamID) reason=already-\(targetResolution)")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
guard let upgradedURL = await viewModel.resolveStreamURL(
|
|
||||||
for: stream,
|
|
||||||
resolutionOverride: targetResolution,
|
|
||||||
preserveServerResolutionWhenBest: false
|
|
||||||
) else {
|
|
||||||
logMultiView("qualityUpgrade failed id=\(streamID) targetResolution=\(targetResolution) reason=resolve-nil")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
if let currentURL = currentStreamURL(for: player), currentURL == upgradedURL {
|
|
||||||
logMultiView("qualityUpgrade skip id=\(streamID) reason=same-url targetResolution=\(targetResolution)")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
logMultiView("qualityUpgrade begin id=\(streamID) targetResolution=\(targetResolution) url=\(upgradedURL.absoluteString)")
|
|
||||||
let upgradedItem = AVPlayerItem(url: upgradedURL)
|
|
||||||
upgradedItem.preferredForwardBufferDuration = 4
|
|
||||||
player.replaceCurrentItem(with: upgradedItem)
|
|
||||||
player.automaticallyWaitsToMinimizeStalling = false
|
|
||||||
playbackDiagnostics.attach(to: player, streamID: streamID, label: label)
|
|
||||||
viewModel.attachPlayer(player, to: streamID)
|
|
||||||
scheduleStartupPlaybackRecovery(for: player)
|
|
||||||
logMultiView("qualityUpgrade replay id=\(streamID) targetResolution=\(targetResolution)")
|
|
||||||
player.playImmediately(atRate: 1.0)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
logMultiView("qualityUpgrade timeout id=\(streamID) targetResolution=\(targetResolution)")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private func currentStreamURL(for player: AVPlayer) -> URL? {
|
private func currentStreamURL(for player: AVPlayer) -> URL? {
|
||||||
(player.currentItem?.asset as? AVURLAsset)?.url
|
(player.currentItem?.asset as? AVURLAsset)?.url
|
||||||
}
|
}
|
||||||
|
|
||||||
private func currentStreamResolution(for player: AVPlayer) -> String? {
|
private func attachAudioDiagnostics(to player: AVPlayer) {
|
||||||
guard let url = currentStreamURL(for: player) else { return nil }
|
if audioDiagnostics == nil {
|
||||||
return URLComponents(url: url, resolvingAgainstBaseURL: false)?
|
audioDiagnostics = AudioDiagnostics(tag: "multi:\(stream.label)")
|
||||||
.queryItems?
|
}
|
||||||
.first(where: { $0.name == "resolution" })?
|
audioDiagnostics?.attach(to: player)
|
||||||
.value
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
private func installClipTimeLimit(on player: AVPlayer) {
|
private func installClipTimeLimit(on player: AVPlayer) {
|
||||||
removeClipTimeLimit(from: player)
|
removeClipTimeLimit(from: player)
|
||||||
guard stream.id == SpecialPlaybackChannelConfig.werkoutNSFWStreamID else { return }
|
guard stream.id == SpecialPlaybackChannelConfig.werkoutNSFWStreamID else { return }
|
||||||
@@ -851,9 +798,11 @@ private struct MultiStreamTile: View {
|
|||||||
installClipTimeLimit(on: player)
|
installClipTimeLimit(on: player)
|
||||||
|
|
||||||
// Monitor for failure and auto-skip to next clip
|
// Monitor for failure and auto-skip to next clip
|
||||||
Task { @MainActor in
|
werkoutMonitorTask?.cancel()
|
||||||
|
werkoutMonitorTask = Task { @MainActor in
|
||||||
for checkDelay in [1.0, 3.0] {
|
for checkDelay in [1.0, 3.0] {
|
||||||
try? await Task.sleep(for: .seconds(checkDelay))
|
try? await Task.sleep(for: .seconds(checkDelay))
|
||||||
|
guard !Task.isCancelled else { return }
|
||||||
let postItemStatus = player.currentItem?.status
|
let postItemStatus = player.currentItem?.status
|
||||||
let error = player.currentItem?.error?.localizedDescription ?? "nil"
|
let error = player.currentItem?.error?.localizedDescription ?? "nil"
|
||||||
logMultiView(
|
logMultiView(
|
||||||
@@ -869,6 +818,45 @@ private struct MultiStreamTile: View {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@MainActor
|
||||||
|
private func enforcePinnedMultiStreamAudioSelection(on item: AVPlayerItem, streamID: String) async {
|
||||||
|
let asset = item.asset
|
||||||
|
guard let group = try? await asset.loadMediaSelectionGroup(for: .audible),
|
||||||
|
let option = preferredMultiStreamAudioOption(in: group) else { return }
|
||||||
|
let current = item.currentMediaSelection.selectedMediaOption(in: group)
|
||||||
|
if current != option {
|
||||||
|
item.select(option, in: group)
|
||||||
|
}
|
||||||
|
logMultiView(
|
||||||
|
"pinAudioSelection id=\(streamID) selected=\(option.displayName) current=\(current?.displayName ?? "nil") options=\(group.options.count)"
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
private func preferredMultiStreamAudioOption(in group: AVMediaSelectionGroup) -> AVMediaSelectionOption? {
|
||||||
|
let defaultOption = group.defaultOption
|
||||||
|
return group.options.max { lhs, rhs in
|
||||||
|
multiStreamAudioPreferenceScore(for: lhs, defaultOption: defaultOption) < multiStreamAudioPreferenceScore(for: rhs, defaultOption: defaultOption)
|
||||||
|
} ?? defaultOption ?? group.options.first
|
||||||
|
}
|
||||||
|
|
||||||
|
private func multiStreamAudioPreferenceScore(for option: AVMediaSelectionOption, defaultOption: AVMediaSelectionOption?) -> Int {
|
||||||
|
let name = option.displayName.lowercased()
|
||||||
|
var score = 0
|
||||||
|
|
||||||
|
if option == defaultOption { score += 40 }
|
||||||
|
if name.contains("stereo") || name.contains("2.0") || name.contains("main") { score += 30 }
|
||||||
|
if name.contains("english") || name.contains("eng") { score += 20 }
|
||||||
|
if name.contains("surround") || name.contains("5.1") || name.contains("atmos") { score -= 30 }
|
||||||
|
if name.contains("spanish") || name.contains("sap") || name.contains("descriptive") || name.contains("alternate") {
|
||||||
|
score -= 25
|
||||||
|
}
|
||||||
|
if option.hasMediaCharacteristic(.describesVideoForAccessibility) {
|
||||||
|
score -= 40
|
||||||
|
}
|
||||||
|
|
||||||
|
return score
|
||||||
|
}
|
||||||
|
|
||||||
private struct MultiStreamPlayerLayerView: UIViewRepresentable {
|
private struct MultiStreamPlayerLayerView: UIViewRepresentable {
|
||||||
let player: AVPlayer
|
let player: AVPlayer
|
||||||
let streamID: String
|
let streamID: String
|
||||||
@@ -1483,3 +1471,245 @@ private func nextMultiViewFocusID(
|
|||||||
.streamID
|
.streamID
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
// MARK: - AudioDiagnostics
|
||||||
|
//
|
||||||
|
// Audio-specific diagnostic logging. Attach one `AudioDiagnostics` per AVPlayer
|
||||||
|
// you want to track. Emits a `[AUDIO]`-prefixed 1 Hz heartbeat with rate,
|
||||||
|
// mute, time, bitrate, and route info — plus immediate logs on route changes,
|
||||||
|
// interruptions, access-log events, and media-selection changes.
|
||||||
|
//
|
||||||
|
// Grep Xcode console with `[AUDIO]` to isolate these lines.
|
||||||
|
|
||||||
|
@MainActor
|
||||||
|
final class AudioDiagnostics {
|
||||||
|
private let tag: String
|
||||||
|
private weak var player: AVPlayer?
|
||||||
|
private var heartbeatTask: Task<Void, Never>?
|
||||||
|
private var observations: [NSKeyValueObservation] = []
|
||||||
|
private var tokens: [NSObjectProtocol] = []
|
||||||
|
|
||||||
|
private static var processWideInstalled = false
|
||||||
|
|
||||||
|
init(tag: String) {
|
||||||
|
self.tag = tag
|
||||||
|
AudioDiagnostics.installProcessWideObservers()
|
||||||
|
}
|
||||||
|
|
||||||
|
deinit {
|
||||||
|
heartbeatTask?.cancel()
|
||||||
|
}
|
||||||
|
|
||||||
|
func attach(to player: AVPlayer) {
|
||||||
|
detach()
|
||||||
|
self.player = player
|
||||||
|
log("attach rate=\(player.rate) isMuted=\(player.isMuted) volume=\(player.volume)")
|
||||||
|
|
||||||
|
observations.append(
|
||||||
|
player.observe(\.rate, options: [.new]) { [weak self] p, _ in
|
||||||
|
Task { @MainActor in self?.log("rate-change rate=\(p.rate) tc=\(p.timeControlStatus.rawValue)") }
|
||||||
|
}
|
||||||
|
)
|
||||||
|
observations.append(
|
||||||
|
player.observe(\.isMuted, options: [.new]) { [weak self] p, _ in
|
||||||
|
Task { @MainActor in self?.log("isMuted-change value=\(p.isMuted)") }
|
||||||
|
}
|
||||||
|
)
|
||||||
|
observations.append(
|
||||||
|
player.observe(\.volume, options: [.new]) { [weak self] p, _ in
|
||||||
|
Task { @MainActor in self?.log("volume-change value=\(p.volume)") }
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
|
if let item = player.currentItem {
|
||||||
|
attachItemObservers(item)
|
||||||
|
}
|
||||||
|
observations.append(
|
||||||
|
player.observe(\.currentItem, options: [.new]) { [weak self] p, _ in
|
||||||
|
Task { @MainActor in
|
||||||
|
guard let self else { return }
|
||||||
|
self.log("currentItem-change newItem=\(p.currentItem != nil)")
|
||||||
|
if let item = p.currentItem {
|
||||||
|
self.attachItemObservers(item)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
|
startHeartbeat()
|
||||||
|
}
|
||||||
|
|
||||||
|
func detach() {
|
||||||
|
heartbeatTask?.cancel()
|
||||||
|
heartbeatTask = nil
|
||||||
|
observations.removeAll()
|
||||||
|
for t in tokens {
|
||||||
|
NotificationCenter.default.removeObserver(t)
|
||||||
|
}
|
||||||
|
tokens.removeAll()
|
||||||
|
player = nil
|
||||||
|
}
|
||||||
|
|
||||||
|
private func attachItemObservers(_ item: AVPlayerItem) {
|
||||||
|
tokens.append(
|
||||||
|
NotificationCenter.default.addObserver(
|
||||||
|
forName: .AVPlayerItemNewAccessLogEntry,
|
||||||
|
object: item,
|
||||||
|
queue: .main
|
||||||
|
) { [weak self, weak item] _ in
|
||||||
|
guard let self, let event = item?.accessLog()?.events.last else { return }
|
||||||
|
Task { @MainActor in
|
||||||
|
self.log(
|
||||||
|
"accessLog indicated=\(Int(event.indicatedBitrate)) observed=\(Int(event.observedBitrate)) switches=\(event.numberOfMediaRequests) stalls=\(event.numberOfStalls) avgVideo=\(Int(event.averageVideoBitrate)) avgAudio=\(Int(event.averageAudioBitrate))"
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
|
tokens.append(
|
||||||
|
NotificationCenter.default.addObserver(
|
||||||
|
forName: .AVPlayerItemNewErrorLogEntry,
|
||||||
|
object: item,
|
||||||
|
queue: .main
|
||||||
|
) { [weak self, weak item] _ in
|
||||||
|
guard let self, let event = item?.errorLog()?.events.last else { return }
|
||||||
|
Task { @MainActor in
|
||||||
|
self.log("errorLog domain=\(event.errorDomain) statusCode=\(event.errorStatusCode) comment=\(event.errorComment ?? "nil")")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
|
tokens.append(
|
||||||
|
NotificationCenter.default.addObserver(
|
||||||
|
forName: AVPlayerItem.mediaSelectionDidChangeNotification,
|
||||||
|
object: item,
|
||||||
|
queue: .main
|
||||||
|
) { [weak self, weak item] _ in
|
||||||
|
guard let self, let item else { return }
|
||||||
|
Task { @MainActor in
|
||||||
|
await enforcePinnedMultiStreamAudioSelection(on: item, streamID: self.tag)
|
||||||
|
let asset = item.asset
|
||||||
|
guard let group = try? await asset.loadMediaSelectionGroup(for: .audible),
|
||||||
|
let selected = item.currentMediaSelection.selectedMediaOption(in: group) else {
|
||||||
|
self.log("mediaSelection-change selected=nil")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
let codec = (selected.mediaSubTypes as [NSNumber]).map { audioDiagFourCC($0.uint32Value) }.joined(separator: ",")
|
||||||
|
self.log("mediaSelection-change audio=\"\(selected.displayName)\" codec=\(codec)")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
private func startHeartbeat() {
|
||||||
|
heartbeatTask?.cancel()
|
||||||
|
heartbeatTask = Task { @MainActor [weak self] in
|
||||||
|
while !Task.isCancelled {
|
||||||
|
self?.emitHeartbeat()
|
||||||
|
try? await Task.sleep(for: .seconds(1))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private func emitHeartbeat() {
|
||||||
|
guard let player, let item = player.currentItem else { return }
|
||||||
|
let currentTime = CMTimeGetSeconds(player.currentTime())
|
||||||
|
let event = item.accessLog()?.events.last
|
||||||
|
let indicated = event.map { Int($0.indicatedBitrate) } ?? 0
|
||||||
|
let observed = event.map { Int($0.observedBitrate) } ?? 0
|
||||||
|
log(
|
||||||
|
"hb t=\(String(format: "%.1f", currentTime))s rate=\(player.rate) tc=\(player.timeControlStatus.rawValue) muted=\(player.isMuted) vol=\(String(format: "%.2f", player.volume)) indicated=\(indicated) observed=\(observed) ltku=\(item.isPlaybackLikelyToKeepUp) route=\(AudioDiagnostics.currentRouteDescription())"
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
private func log(_ message: String) {
|
||||||
|
let ts = AudioDiagnostics.timestamp()
|
||||||
|
print("[AUDIO \(tag) \(ts)] \(message)")
|
||||||
|
}
|
||||||
|
|
||||||
|
// MARK: Process-wide
|
||||||
|
|
||||||
|
private static func installProcessWideObservers() {
|
||||||
|
guard !processWideInstalled else { return }
|
||||||
|
processWideInstalled = true
|
||||||
|
|
||||||
|
let session = AVAudioSession.sharedInstance()
|
||||||
|
print("[AUDIO SYSTEM \(timestamp())] initial category=\(session.category.rawValue) mode=\(session.mode.rawValue) sampleRate=\(session.sampleRate) route=\(currentRouteDescription())")
|
||||||
|
|
||||||
|
NotificationCenter.default.addObserver(
|
||||||
|
forName: AVAudioSession.routeChangeNotification,
|
||||||
|
object: nil,
|
||||||
|
queue: .main
|
||||||
|
) { notification in
|
||||||
|
let reasonValue = notification.userInfo?[AVAudioSessionRouteChangeReasonKey] as? UInt ?? 0
|
||||||
|
let reason = AVAudioSession.RouteChangeReason(rawValue: reasonValue).map(audioDiagReasonDescription) ?? "unknown(\(reasonValue))"
|
||||||
|
let prev = (notification.userInfo?[AVAudioSessionRouteChangePreviousRouteKey] as? AVAudioSessionRouteDescription).map(routeDescription) ?? "nil"
|
||||||
|
print("[AUDIO SYSTEM \(timestamp())] routeChange reason=\(reason) previous=\(prev) current=\(currentRouteDescription())")
|
||||||
|
}
|
||||||
|
|
||||||
|
NotificationCenter.default.addObserver(
|
||||||
|
forName: AVAudioSession.interruptionNotification,
|
||||||
|
object: nil,
|
||||||
|
queue: .main
|
||||||
|
) { notification in
|
||||||
|
let typeValue = notification.userInfo?[AVAudioSessionInterruptionTypeKey] as? UInt ?? 0
|
||||||
|
let type = AVAudioSession.InterruptionType(rawValue: typeValue).map(audioDiagInterruptionDescription) ?? "unknown(\(typeValue))"
|
||||||
|
print("[AUDIO SYSTEM \(timestamp())] interruption type=\(type)")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
nonisolated static func currentRouteDescription() -> String {
|
||||||
|
routeDescription(AVAudioSession.sharedInstance().currentRoute)
|
||||||
|
}
|
||||||
|
|
||||||
|
nonisolated static func routeDescription(_ route: AVAudioSessionRouteDescription) -> String {
|
||||||
|
let outs = route.outputs.map { "\($0.portType.rawValue):\($0.portName)" }.joined(separator: ",")
|
||||||
|
return outs.isEmpty ? "none" : outs
|
||||||
|
}
|
||||||
|
|
||||||
|
nonisolated static func timestamp() -> String {
|
||||||
|
audioDiagTSFormatter.string(from: Date())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private let audioDiagTSFormatter: DateFormatter = {
|
||||||
|
let f = DateFormatter()
|
||||||
|
f.dateFormat = "HH:mm:ss.SSS"
|
||||||
|
return f
|
||||||
|
}()
|
||||||
|
|
||||||
|
private func audioDiagFourCC(_ raw: UInt32) -> String {
|
||||||
|
let bytes: [UInt8] = [
|
||||||
|
UInt8((raw >> 24) & 0xFF),
|
||||||
|
UInt8((raw >> 16) & 0xFF),
|
||||||
|
UInt8((raw >> 8) & 0xFF),
|
||||||
|
UInt8(raw & 0xFF),
|
||||||
|
]
|
||||||
|
let chars = bytes.map { b -> Character in
|
||||||
|
let scalar = UnicodeScalar(b)
|
||||||
|
return (0x20...0x7E).contains(b) ? Character(scalar) : "?"
|
||||||
|
}
|
||||||
|
return String(chars)
|
||||||
|
}
|
||||||
|
|
||||||
|
private func audioDiagReasonDescription(_ reason: AVAudioSession.RouteChangeReason) -> String {
|
||||||
|
switch reason {
|
||||||
|
case .unknown: "unknown"
|
||||||
|
case .newDeviceAvailable: "newDeviceAvailable"
|
||||||
|
case .oldDeviceUnavailable: "oldDeviceUnavailable"
|
||||||
|
case .categoryChange: "categoryChange"
|
||||||
|
case .override: "override"
|
||||||
|
case .wakeFromSleep: "wakeFromSleep"
|
||||||
|
case .noSuitableRouteForCategory: "noSuitableRouteForCategory"
|
||||||
|
case .routeConfigurationChange: "routeConfigurationChange"
|
||||||
|
@unknown default: "unknown-future"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private func audioDiagInterruptionDescription(_ type: AVAudioSession.InterruptionType) -> String {
|
||||||
|
switch type {
|
||||||
|
case .began: "began"
|
||||||
|
case .ended: "ended"
|
||||||
|
@unknown default: "unknown-future"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -57,22 +57,70 @@ private func singleStreamTimeControlDescription(_ status: AVPlayer.TimeControlSt
|
|||||||
}
|
}
|
||||||
|
|
||||||
private func makeSingleStreamPlayerItem(from source: SingleStreamPlaybackSource) -> AVPlayerItem {
|
private func makeSingleStreamPlayerItem(from source: SingleStreamPlaybackSource) -> AVPlayerItem {
|
||||||
|
let item: AVPlayerItem
|
||||||
if source.httpHeaders.isEmpty {
|
if source.httpHeaders.isEmpty {
|
||||||
let item = AVPlayerItem(url: source.url)
|
item = AVPlayerItem(url: source.url)
|
||||||
item.preferredForwardBufferDuration = 2
|
} else {
|
||||||
return item
|
let assetOptions: [String: Any] = [
|
||||||
|
"AVURLAssetHTTPHeaderFieldsKey": source.httpHeaders,
|
||||||
|
]
|
||||||
|
let asset = AVURLAsset(url: source.url, options: assetOptions)
|
||||||
|
item = AVPlayerItem(asset: asset)
|
||||||
|
logSingleStream(
|
||||||
|
"Configured authenticated AVURLAsset headerKeys=\(singleStreamHeaderKeysDescription(source.httpHeaders))"
|
||||||
|
)
|
||||||
|
}
|
||||||
|
item.preferredForwardBufferDuration = 8
|
||||||
|
item.allowedAudioSpatializationFormats = []
|
||||||
|
logSingleStream("Configured player item preferredForwardBufferDuration=8 allowedAudioSpatializationFormats=[]")
|
||||||
|
pinSingleStreamAudioSelection(on: item)
|
||||||
|
return item
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Pin the HLS audio rendition so ABR can't swap channel layouts mid-stream.
|
||||||
|
private func pinSingleStreamAudioSelection(on item: AVPlayerItem) {
|
||||||
|
Task { @MainActor in
|
||||||
|
await enforcePinnedSingleStreamAudioSelection(on: item)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@MainActor
|
||||||
|
private func enforcePinnedSingleStreamAudioSelection(on item: AVPlayerItem) async {
|
||||||
|
let asset = item.asset
|
||||||
|
guard let group = try? await asset.loadMediaSelectionGroup(for: .audible),
|
||||||
|
let option = preferredSingleStreamAudioOption(in: group) else { return }
|
||||||
|
let current = item.currentMediaSelection.selectedMediaOption(in: group)
|
||||||
|
if current != option {
|
||||||
|
item.select(option, in: group)
|
||||||
|
}
|
||||||
|
logSingleStream(
|
||||||
|
"pinAudioSelection selected=\(option.displayName) current=\(current?.displayName ?? "nil") options=\(group.options.count)"
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
private func preferredSingleStreamAudioOption(in group: AVMediaSelectionGroup) -> AVMediaSelectionOption? {
|
||||||
|
let defaultOption = group.defaultOption
|
||||||
|
return group.options.max { lhs, rhs in
|
||||||
|
audioPreferenceScore(for: lhs, defaultOption: defaultOption) < audioPreferenceScore(for: rhs, defaultOption: defaultOption)
|
||||||
|
} ?? defaultOption ?? group.options.first
|
||||||
|
}
|
||||||
|
|
||||||
|
private func audioPreferenceScore(for option: AVMediaSelectionOption, defaultOption: AVMediaSelectionOption?) -> Int {
|
||||||
|
let name = option.displayName.lowercased()
|
||||||
|
var score = 0
|
||||||
|
|
||||||
|
if option == defaultOption { score += 40 }
|
||||||
|
if name.contains("stereo") || name.contains("2.0") || name.contains("main") { score += 30 }
|
||||||
|
if name.contains("english") || name.contains("eng") { score += 20 }
|
||||||
|
if name.contains("surround") || name.contains("5.1") || name.contains("atmos") { score -= 30 }
|
||||||
|
if name.contains("spanish") || name.contains("sap") || name.contains("descriptive") || name.contains("alternate") {
|
||||||
|
score -= 25
|
||||||
|
}
|
||||||
|
if option.hasMediaCharacteristic(.describesVideoForAccessibility) {
|
||||||
|
score -= 40
|
||||||
}
|
}
|
||||||
|
|
||||||
let assetOptions: [String: Any] = [
|
return score
|
||||||
"AVURLAssetHTTPHeaderFieldsKey": source.httpHeaders,
|
|
||||||
]
|
|
||||||
let asset = AVURLAsset(url: source.url, options: assetOptions)
|
|
||||||
let item = AVPlayerItem(asset: asset)
|
|
||||||
item.preferredForwardBufferDuration = 2
|
|
||||||
logSingleStream(
|
|
||||||
"Configured authenticated AVURLAsset headerKeys=\(singleStreamHeaderKeysDescription(source.httpHeaders))"
|
|
||||||
)
|
|
||||||
return item
|
|
||||||
}
|
}
|
||||||
|
|
||||||
struct SingleStreamPlaybackScreen: View {
|
struct SingleStreamPlaybackScreen: View {
|
||||||
@@ -544,24 +592,32 @@ struct SingleStreamPlayerView: UIViewControllerRepresentable {
|
|||||||
)
|
)
|
||||||
|
|
||||||
do {
|
do {
|
||||||
try AVAudioSession.sharedInstance().setCategory(.playback, mode: .moviePlayback)
|
try AVAudioSession.sharedInstance().setCategory(.playback, mode: .default)
|
||||||
try AVAudioSession.sharedInstance().setActive(true)
|
try AVAudioSession.sharedInstance().setActive(true)
|
||||||
logSingleStream("AVAudioSession configured for playback")
|
logSingleStream("AVAudioSession configured for playback mode=default")
|
||||||
} catch {
|
} catch {
|
||||||
logSingleStream("AVAudioSession configuration failed error=\(error.localizedDescription)")
|
logSingleStream("AVAudioSession configuration failed error=\(error.localizedDescription)")
|
||||||
}
|
}
|
||||||
|
|
||||||
let playerItem = makeSingleStreamPlayerItem(from: source)
|
let playerItem = makeSingleStreamPlayerItem(from: source)
|
||||||
let player = AVPlayer(playerItem: playerItem)
|
let player = AVPlayer(playerItem: playerItem)
|
||||||
player.automaticallyWaitsToMinimizeStalling = false
|
player.appliesMediaSelectionCriteriaAutomatically = false
|
||||||
|
player.automaticallyWaitsToMinimizeStalling = true
|
||||||
player.isMuted = source.forceMuteAudio
|
player.isMuted = source.forceMuteAudio
|
||||||
logSingleStream("Configured player for fast start preferredForwardBufferDuration=2 automaticallyWaitsToMinimizeStalling=false")
|
logSingleStream(
|
||||||
|
"Configured player for quality ramp preferredForwardBufferDuration=8 automaticallyWaitsToMinimizeStalling=true appliesMediaSelectionCriteriaAutomatically=false"
|
||||||
|
)
|
||||||
context.coordinator.attachDebugObservers(to: player, url: url, resolveNextSource: resolveNextSource)
|
context.coordinator.attachDebugObservers(to: player, url: url, resolveNextSource: resolveNextSource)
|
||||||
controller.player = player
|
controller.player = player
|
||||||
|
if context.coordinator.audioDiagnostics == nil {
|
||||||
|
context.coordinator.audioDiagnostics = AudioDiagnostics(tag: "single")
|
||||||
|
}
|
||||||
|
context.coordinator.audioDiagnostics?.attach(to: player)
|
||||||
logSingleStream("AVPlayer assigned to controller; calling playImmediately(atRate: 1.0)")
|
logSingleStream("AVPlayer assigned to controller; calling playImmediately(atRate: 1.0)")
|
||||||
player.playImmediately(atRate: 1.0)
|
player.playImmediately(atRate: 1.0)
|
||||||
context.coordinator.installClipTimeLimit(on: player, resolveNextSource: resolveNextSource)
|
context.coordinator.installClipTimeLimit(on: player, resolveNextSource: resolveNextSource)
|
||||||
context.coordinator.scheduleStartupRecovery(for: player)
|
context.coordinator.scheduleStartupRecovery(for: player)
|
||||||
|
context.coordinator.scheduleQualityMonitor(for: player)
|
||||||
}
|
}
|
||||||
|
|
||||||
return controller
|
return controller
|
||||||
@@ -583,11 +639,15 @@ struct SingleStreamPlayerView: UIViewControllerRepresentable {
|
|||||||
|
|
||||||
static func dismantleUIViewController(_ uiViewController: AVPlayerViewController, coordinator: Coordinator) {
|
static func dismantleUIViewController(_ uiViewController: AVPlayerViewController, coordinator: Coordinator) {
|
||||||
logSingleStream("dismantleUIViewController start isPiPActive=\(coordinator.isPiPActive)")
|
logSingleStream("dismantleUIViewController start isPiPActive=\(coordinator.isPiPActive)")
|
||||||
|
coordinator.clearDebugObservers()
|
||||||
if coordinator.isPiPActive {
|
if coordinator.isPiPActive {
|
||||||
logSingleStream("dismantleUIViewController skipped — PiP is active")
|
logSingleStream("dismantleUIViewController — PiP active, observers cleared but keeping player")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
coordinator.clearDebugObservers()
|
Task { @MainActor in
|
||||||
|
coordinator.audioDiagnostics?.detach()
|
||||||
|
coordinator.audioDiagnostics = nil
|
||||||
|
}
|
||||||
uiViewController.player?.pause()
|
uiViewController.player?.pause()
|
||||||
uiViewController.player = nil
|
uiViewController.player = nil
|
||||||
logSingleStream("dismantleUIViewController complete")
|
logSingleStream("dismantleUIViewController complete")
|
||||||
@@ -597,7 +657,9 @@ struct SingleStreamPlayerView: UIViewControllerRepresentable {
|
|||||||
private var playerObservations: [NSKeyValueObservation] = []
|
private var playerObservations: [NSKeyValueObservation] = []
|
||||||
private var notificationTokens: [NSObjectProtocol] = []
|
private var notificationTokens: [NSObjectProtocol] = []
|
||||||
private var startupRecoveryTask: Task<Void, Never>?
|
private var startupRecoveryTask: Task<Void, Never>?
|
||||||
|
private var qualityMonitorTask: Task<Void, Never>?
|
||||||
private var clipTimeLimitObserver: Any?
|
private var clipTimeLimitObserver: Any?
|
||||||
|
var audioDiagnostics: AudioDiagnostics?
|
||||||
private static let maxClipDuration: Double = 15.0
|
private static let maxClipDuration: Double = 15.0
|
||||||
var onTogglePitchInfo: (() -> Void)?
|
var onTogglePitchInfo: (() -> Void)?
|
||||||
var onToggleGameCenter: (() -> Void)?
|
var onToggleGameCenter: (() -> Void)?
|
||||||
@@ -789,6 +851,19 @@ struct SingleStreamPlayerView: UIViewControllerRepresentable {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
|
notificationTokens.append(
|
||||||
|
NotificationCenter.default.addObserver(
|
||||||
|
forName: AVPlayerItem.mediaSelectionDidChangeNotification,
|
||||||
|
object: item,
|
||||||
|
queue: .main
|
||||||
|
) { _ in
|
||||||
|
logSingleStream("Notification mediaSelectionDidChange")
|
||||||
|
Task { @MainActor in
|
||||||
|
await enforcePinnedSingleStreamAudioSelection(on: item)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
func scheduleStartupRecovery(for player: AVPlayer) {
|
func scheduleStartupRecovery(for player: AVPlayer) {
|
||||||
@@ -863,9 +938,38 @@ struct SingleStreamPlayerView: UIViewControllerRepresentable {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func scheduleQualityMonitor(for player: AVPlayer) {
|
||||||
|
qualityMonitorTask?.cancel()
|
||||||
|
qualityMonitorTask = Task { @MainActor [weak player] in
|
||||||
|
// Check at 5s, 15s, and 30s whether AVPlayer has ramped to a reasonable bitrate
|
||||||
|
for delay in [5.0, 15.0, 30.0] {
|
||||||
|
try? await Task.sleep(for: .seconds(delay))
|
||||||
|
guard !Task.isCancelled, let player else { return }
|
||||||
|
|
||||||
|
let indicatedBitrate = player.currentItem?.accessLog()?.events.last?.indicatedBitrate ?? 0
|
||||||
|
let observedBitrate = player.currentItem?.accessLog()?.events.last?.observedBitrate ?? 0
|
||||||
|
let likelyToKeepUp = player.currentItem?.isPlaybackLikelyToKeepUp ?? false
|
||||||
|
|
||||||
|
logSingleStream(
|
||||||
|
"qualityMonitor check delay=\(delay)s indicatedBitrate=\(Int(indicatedBitrate)) observedBitrate=\(Int(observedBitrate)) likelyToKeepUp=\(likelyToKeepUp) rate=\(player.rate)"
|
||||||
|
)
|
||||||
|
|
||||||
|
// If observed bandwidth supports higher quality but indicated is low, nudge AVPlayer
|
||||||
|
if likelyToKeepUp && indicatedBitrate > 0 && observedBitrate > indicatedBitrate * 2 {
|
||||||
|
logSingleStream(
|
||||||
|
"qualityMonitor nudge delay=\(delay)s — observed bandwidth \(Int(observedBitrate)) >> indicated \(Int(indicatedBitrate)), setting preferredPeakBitRate=0 to uncap"
|
||||||
|
)
|
||||||
|
player.currentItem?.preferredPeakBitRate = 0
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func clearDebugObservers() {
|
func clearDebugObservers() {
|
||||||
startupRecoveryTask?.cancel()
|
startupRecoveryTask?.cancel()
|
||||||
startupRecoveryTask = nil
|
startupRecoveryTask = nil
|
||||||
|
qualityMonitorTask?.cancel()
|
||||||
|
qualityMonitorTask = nil
|
||||||
playerObservations.removeAll()
|
playerObservations.removeAll()
|
||||||
for token in notificationTokens {
|
for token in notificationTokens {
|
||||||
NotificationCenter.default.removeObserver(token)
|
NotificationCenter.default.removeObserver(token)
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ import SwiftUI
|
|||||||
@main
|
@main
|
||||||
struct mlbTVOSApp: App {
|
struct mlbTVOSApp: App {
|
||||||
@State private var viewModel = GamesViewModel()
|
@State private var viewModel = GamesViewModel()
|
||||||
|
@Environment(\.scenePhase) private var scenePhase
|
||||||
|
|
||||||
init() {
|
init() {
|
||||||
configureAudioSession()
|
configureAudioSession()
|
||||||
@@ -13,6 +14,11 @@ struct mlbTVOSApp: App {
|
|||||||
WindowGroup {
|
WindowGroup {
|
||||||
ContentView()
|
ContentView()
|
||||||
.environment(viewModel)
|
.environment(viewModel)
|
||||||
|
.onChange(of: scenePhase) { _, newPhase in
|
||||||
|
if newPhase == .active {
|
||||||
|
Task { await viewModel.refreshIfDayChanged() }
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -24,5 +30,23 @@ struct mlbTVOSApp: App {
|
|||||||
} catch {
|
} catch {
|
||||||
print("Failed to set audio session: \(error)")
|
print("Failed to set audio session: \(error)")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
NotificationCenter.default.addObserver(
|
||||||
|
forName: AVAudioSession.interruptionNotification,
|
||||||
|
object: AVAudioSession.sharedInstance(),
|
||||||
|
queue: .main
|
||||||
|
) { notification in
|
||||||
|
guard let info = notification.userInfo,
|
||||||
|
let typeValue = info[AVAudioSessionInterruptionTypeKey] as? UInt,
|
||||||
|
let type = AVAudioSession.InterruptionType(rawValue: typeValue) else { return }
|
||||||
|
|
||||||
|
if type == .ended {
|
||||||
|
let options = (info[AVAudioSessionInterruptionOptionKey] as? UInt)
|
||||||
|
.flatMap(AVAudioSession.InterruptionOptions.init) ?? []
|
||||||
|
if options.contains(.shouldResume) {
|
||||||
|
try? AVAudioSession.sharedInstance().setActive(true)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user