import 'package:flutter_bloc/flutter_bloc.dart';
import 'package:equatable/equatable.dart';
import 'package:flux/features/customers/data/customer_repository.dart';
import 'package:flux/features/customers/models/customer_model.dart';
import 'package:get_it/get_it.dart';

part 'customer_events.dart';
part 'customer_state.dart';

class CustomerBloc extends Bloc<CustomerEvent, CustomerState> {
  final CustomerRepository _repository = GetIt.I<CustomerRepository>();

  CustomerBloc() : super(const CustomerState()) {
    on<LoadCustomersRequested>(_onLoadCustomers);
    on<CreateCustomerRequested>(_onCreateCustomer);
    on<SearchCustomersRequested>(_onSearchCustomers);
    on<UpdateCustomerRequested>(_onUpdateCustomer);
  }

  Future<void> _onLoadCustomers(
    LoadCustomersRequested event,
    Emitter<CustomerState> emit,
  ) async {
    emit(state.copyWith(status: CustomerStatus.loading));
    try {
      final customers = await _repository.getCustomers(event.companyId);
      emit(
        state.copyWith(status: CustomerStatus.success, customers: customers),
      );
    } catch (e) {
      emit(
        state.copyWith(
          status: CustomerStatus.failure,
          errorMessage: e.toString(),
        ),
      );
    }
  }

  Future<void> _onCreateCustomer(
    CreateCustomerRequested event,
    Emitter<CustomerState> emit,
  ) async {
    emit(state.copyWith(status: CustomerStatus.loading));
    try {
      final newCustomer = await _repository.createCustomer(event.customer);

      // Aggiorniamo la lista locale aggiungendo il nuovo cliente in cima
      final updatedList = List<CustomerModel>.from(state.customers)
        ..insert(0, newCustomer);

      emit(
        state.copyWith(
          status: CustomerStatus.success,
          customers: updatedList,
          lastCreatedCustomer:
              newCustomer, // Lo passiamo per le Dialog "al volo"
        ),
      );
    } catch (e) {
      emit(
        state.copyWith(
          status: CustomerStatus.failure,
          errorMessage: e.toString(),
        ),
      );
    }
  }

  Future<void> _onUpdateCustomer(
    UpdateCustomerRequested event,
    Emitter<CustomerState> emit,
  ) async {
    emit(state.copyWith(status: CustomerStatus.loading));
    try {
      // Qui dovresti aggiungere un metodo updateCustomer nel Repository
      // Simile al create ma usando .update().eq('id', customer.id)
      final updatedCustomer = await _repository.updateCustomer(event.customer);

      final updatedList = List<CustomerModel>.from(state.customers);
      final index = updatedList.indexWhere((c) => c.id == updatedCustomer.id);

      if (index != -1) {
        updatedList[index] = updatedCustomer;
      }

      emit(
        state.copyWith(
          status: CustomerStatus.success,
          customers: updatedList,
          lastCreatedCustomer: updatedCustomer,
        ),
      );
    } catch (e) {
      emit(
        state.copyWith(
          status: CustomerStatus.failure,
          errorMessage: e.toString(),
        ),
      );
    }
  }

  Future<void> _onSearchCustomers(
    SearchCustomersRequested event,
    Emitter<CustomerState> emit,
  ) async {
    // Non mettiamo loading per evitare flickering durante la digitazione
    try {
      final results = await _repository.searchCustomers(
        event.companyId,
        event.query,
      );
      emit(state.copyWith(status: CustomerStatus.success, customers: results));
    } catch (_) {}
  }
}