xtremflow/lib/features/iptv/providers/xtream_provider.dart

import 'package:flutter_riverpod/flutter_riverpod.dart';
import '../../../core/models/playlist_config.dart';
import '../services/xtream_service.dart';

/// Family provider for Xtream service - one instance per playlist
final xtreamServiceProvider = Provider.family<XtreamService, PlaylistConfig>((ref, playlist) {
  final service = XtreamService();
  service.setPlaylist(playlist);
  ref.onDispose(() => service.dispose());
  return service;
});

/// Singleton Xtream service provider (legacy, for activeXtreamServiceProvider)
final _singletonXtreamServiceProvider = Provider<XtreamService>((ref) {
  final service = XtreamService();
  ref.onDispose(() => service.dispose());
  return service;
});

/// Current selected playlist provider
final selectedPlaylistProvider = StateProvider<PlaylistConfig?>((ref) => null);

/// Provider that watches for playlist changes and updates Xtream service
final activeXtreamServiceProvider = Provider<XtreamService>((ref) {
  final service = ref.watch(_singletonXtreamServiceProvider);
  final playlist = ref.watch(selectedPlaylistProvider);
  
  if (playlist != null) {
    service.setPlaylist(playlist);
  }
  
  return service;
});

/// Provider for live TV channels grouped by category
final liveChannelsProvider = FutureProvider.autoDispose((ref) async {
  final service = ref.watch(activeXtreamServiceProvider);
  return await service.getLiveChannels();
});

/// Provider for live TV channels by playlist (family provider)
final liveChannelsByPlaylistProvider = FutureProvider.family.autoDispose((ref, PlaylistConfig playlist) async {
  final service = ref.watch(xtreamServiceProvider(playlist));
  return await service.getLiveChannels();
});

/// Provider for VOD items (movies) grouped by category
final vodItemsProvider = FutureProvider.autoDispose((ref) async {
  final service = ref.watch(activeXtreamServiceProvider);
  return await service.getVodItems();
});

/// Provider for series grouped by category
final seriesProvider = FutureProvider.autoDispose((ref) async {
  final service = ref.watch(activeXtreamServiceProvider);
  return await service.getSeries();
});

/// Provider for EPG of a specific stream
final epgProvider = FutureProvider.family.autoDispose((ref, String streamId) async {
  final service = ref.watch(activeXtreamServiceProvider);
  return await service.getShortEpg(streamId);
});

/// EPG request key for family provider (combines playlist and streamId)
class EpgRequestKey {
  final PlaylistConfig playlist;
  final String streamId;
  
  const EpgRequestKey({required this.playlist, required this.streamId});
  
  @override
  bool operator ==(Object other) =>
      identical(this, other) ||
      other is EpgRequestKey &&
          runtimeType == other.runtimeType &&
          playlist == other.playlist &&
          streamId == other.streamId;

  @override
  int get hashCode => playlist.hashCode ^ streamId.hashCode;
}

/// Provider for EPG with playlist context
final epgByPlaylistProvider = FutureProvider.family.autoDispose((ref, EpgRequestKey key) async {
  final service = ref.watch(xtreamServiceProvider(key.playlist));
  return await service.getShortEpg(key.streamId);
});