70 lines
2.0 KiB
Dart
70 lines
2.0 KiB
Dart
import 'dart:async';
|
|
import 'package:flutter/material.dart';
|
|
import '../utils/watch_state_notifier.dart';
|
|
|
|
/// Mixin for screens that need to react to watch state changes.
|
|
///
|
|
/// Provides automatic subscription management and filtering based on
|
|
/// which items the screen cares about.
|
|
///
|
|
/// Example usage:
|
|
/// ```dart
|
|
/// class _MyScreenState extends State<MyScreen> with WatchStateAware {
|
|
/// List<PlexMetadata> _items = [];
|
|
///
|
|
/// @override
|
|
/// Set<String>? get watchedRatingKeys =>
|
|
/// _items.map((e) => e.ratingKey).toSet();
|
|
///
|
|
/// @override
|
|
/// void onWatchStateChanged(WatchStateEvent event) {
|
|
/// // Refresh affected item
|
|
/// _refreshItem(event.ratingKey);
|
|
/// }
|
|
/// }
|
|
/// ```
|
|
mixin WatchStateAware<T extends StatefulWidget> on State<T> {
|
|
StreamSubscription<WatchStateEvent>? _watchStateSubscription;
|
|
|
|
/// Override to specify which ratingKeys this screen cares about.
|
|
///
|
|
/// Return null to receive ALL events (not recommended for performance).
|
|
/// Return an empty set to receive no events.
|
|
///
|
|
/// The set should include:
|
|
/// - Direct items displayed (e.g., episode ratingKeys in a season view)
|
|
/// - Parent items that affect display (e.g., show ratingKey for on-deck)
|
|
Set<String>? get watchedRatingKeys;
|
|
|
|
/// Called when a relevant watch state change occurs.
|
|
///
|
|
/// Only called if [watchedRatingKeys] is null or contains an affected key.
|
|
void onWatchStateChanged(WatchStateEvent event);
|
|
|
|
@override
|
|
void initState() {
|
|
super.initState();
|
|
_subscribeToWatchState();
|
|
}
|
|
|
|
void _subscribeToWatchState() {
|
|
_watchStateSubscription = WatchStateNotifier().stream.listen((event) {
|
|
if (!mounted) return;
|
|
|
|
final keys = watchedRatingKeys;
|
|
// If keys is null, receive all events
|
|
// Otherwise, filter to events that affect our keys
|
|
if (keys == null || event.affectsAnyOf(keys)) {
|
|
onWatchStateChanged(event);
|
|
}
|
|
});
|
|
}
|
|
|
|
@override
|
|
void dispose() {
|
|
_watchStateSubscription?.cancel();
|
|
_watchStateSubscription = null;
|
|
super.dispose();
|
|
}
|
|
}
|