import 'dart:async';
import 'package:flutter_bloc/flutter_bloc.dart';
import 'package:travel_mate/data/models/trip.dart';
import 'trip_event.dart';
import 'trip_state.dart';
import '../../repositories/trip_repository.dart';


class TripBloc extends Bloc<TripEvent, TripState> {
  final TripRepository _repository;
  StreamSubscription? _tripsSubscription;
  String? _currentUserId;

  TripBloc(this._repository) : super(TripInitial()) {
    on<LoadTripsByUserId>(_onLoadTripsByUserId);
    on<TripCreateRequested>(_onTripCreateRequested);
    on<TripUpdateRequested>(_onTripUpdateRequested);
    on<TripDeleteRequested>(_onTripDeleteRequested);
    on<_TripsUpdated>(_onTripsUpdated);
  }

  Future<void> _onLoadTripsByUserId(
    LoadTripsByUserId event,
    Emitter<TripState> emit,
  ) async {
    print('🔍 Chargement des trips pour userId: ${event.userId}');
    
    // MODIFIÉ : Toujours émettre Loading pour forcer le rechargement
    emit(TripLoading());
    
    _currentUserId = event.userId;
    await _tripsSubscription?.cancel();

    _tripsSubscription = _repository.getTripsByUserId(event.userId).listen(
      (trips) {
        print('📦 Stream reçu: ${trips.length} trips');
        add(_TripsUpdated(trips));
      },
      onError: (error) {
        print('❌ Erreur stream: $error');
        emit(TripError(error.toString()));
      },
    );
  }

  void _onTripsUpdated(
    _TripsUpdated event,
    Emitter<TripState> emit,
  ) {
    print('✅ Émission de TripLoaded avec ${event.trips.length} trips');
    emit(TripLoaded(event.trips));
  }

  Future<void> _onTripCreateRequested(
    TripCreateRequested event,
    Emitter<TripState> emit,
  ) async {
    try {
      print('📝 Création du voyage: ${event.trip.title}');
      emit(TripLoading());
      
      final tripId = await _repository.createTrip(event.trip);
      print('✅ Voyage créé avec ID: $tripId');
      
      // Émettre TripCreated pour que create_trip_content puisse créer le groupe
      emit(TripCreated(tripId: tripId));
      
      // AJOUTÉ : Attendre un peu puis recharger manuellement
      await Future.delayed(const Duration(milliseconds: 800));
      if (_currentUserId != null) {
        print('🔄 Rechargement forcé après création');
        add(LoadTripsByUserId(userId: _currentUserId!));
      }
      
    } catch (e) {
      print('❌ Erreur création: $e');
      emit(TripError('Erreur lors de la création: $e'));
    }
  }

  Future<void> _onTripUpdateRequested(
    TripUpdateRequested event,
    Emitter<TripState> emit,
  ) async {
    try {
      print('📝 Mise à jour du voyage: ${event.trip.title}');
      
      await _repository.updateTrip(event.trip.id!, event.trip);
      print('✅ Voyage mis à jour');
      
      emit(const TripOperationSuccess('Voyage mis à jour avec succès'));
      
      // AJOUTÉ : Recharger après mise à jour
      await Future.delayed(const Duration(milliseconds: 500));
      if (_currentUserId != null) {
        print('🔄 Rechargement forcé après mise à jour');
        add(LoadTripsByUserId(userId: _currentUserId!));
      }
      
    } catch (e) {
      print('❌ Erreur mise à jour: $e');
      emit(TripError('Erreur lors de la mise à jour: $e'));
    }
  }

  Future<void> _onTripDeleteRequested(
    TripDeleteRequested event,
    Emitter<TripState> emit,
  ) async {
    try {
      print('🗑️ Suppression du voyage: ${event.tripId}');
      
      await _repository.deleteTrip(event.tripId);
      print('✅ Voyage supprimé');
      
      emit(const TripOperationSuccess('Voyage supprimé avec succès'));
      
      // AJOUTÉ : Recharger après suppression
      await Future.delayed(const Duration(milliseconds: 500));
      if (_currentUserId != null) {
        print('🔄 Rechargement forcé après suppression');
        add(LoadTripsByUserId(userId: _currentUserId!));
      }
      
    } catch (e) {
      print('❌ Erreur suppression: $e');
      emit(TripError('Erreur lors de la suppression: $e'));
    }
  }

  @override
  Future<void> close() {
    _tripsSubscription?.cancel();
    return super.close();
  }
}

class _TripsUpdated extends TripEvent {
  final List<Trip> trips;

  const _TripsUpdated(this.trips);

  @override
  List<Object?> get props => [trips];
}