flux/lib/core/blocs/session/session_bloc.dart

import 'package:flutter_bloc/flutter_bloc.dart';
import 'package:equatable/equatable.dart';
import 'package:flux/core/enums/enums.dart';
import 'package:flux/features/company/models/company_model.dart';
import 'package:flux/features/master_data/store/data/store_repository.dart';
import 'package:flux/features/master_data/store/models/store_model.dart';
import 'package:get_it/get_it.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'dart:async';
import 'package:supabase_flutter/supabase_flutter.dart';

part 'session_events.dart';
part 'session_state.dart';

class SessionBloc extends Bloc<SessionEvent, SessionState> {
  final SupabaseClient _supabase = GetIt.I.get<SupabaseClient>();
  final StoreRepository _storeRepository = GetIt.I.get<StoreRepository>();
  StreamSubscription<AuthState>? _authSubscription;

  SessionBloc() : super(const SessionState(status: SessionStatus.unknown)) {
    on<AppStarted>((event, emit) {
      // 1. Controlla la sessione attuale al boot
      final session = _supabase.auth.currentSession;
      if (session != null) {
        add(UserChanged(session.user.id));
      } else {
        add(UserChanged(null));
      }

      // 2. Ascolta i cambiamenti futuri (login, logout, token scaduto)
      _authSubscription = _supabase.auth.onAuthStateChange.listen((data) {
        final userId = data.session?.user.id;
        add(UserChanged(userId));
      });
    });

    on<UserChanged>((event, emit) async {
      if (event.userId == null) {
        emit(SessionState(status: SessionStatus.unauthenticated));
        return;
      }
      // 1. Controlla se l'utente ha una Company
      final companyJson = await _supabase
          .from('company')
          .select()
          .eq('user_id', event.userId!)
          .maybeSingle();

      if (companyJson == null) {
        emit(
          SessionState(
            status: SessionStatus.authenticatedNoCompany,
            userId: event.userId,
          ),
        );
        return;
      }
      CompanyModel company = CompanyModel.fromJson(companyJson);

      // 2. Controlla i negozi
      final stores = await _storeRepository.fetchAllCompanyStores(company.id);

      if (stores.isEmpty) {
        emit(
          SessionState(
            status: SessionStatus.authenticatedNoStore,
            userId: event.userId,
            company: company,
          ),
        );
        return;
      }

      // 3. Tutto ok, gestiamo le SharedPreferences per il negozio
      final prefs = GetIt.I.get<SharedPreferences>();
      String? lastStoreId = prefs.getString(PrefKeys.lastStore.value);

      // Se non c'è nelle SharedPreferences, prendi il primo della lista
      if (lastStoreId == null || !stores.any((s) => s.id == lastStoreId)) {
        lastStoreId = stores.first.id;
        await prefs.setString('last_store_id', lastStoreId!);
      }
      final selectedStore = stores.firstWhere((s) => s.id == lastStoreId);
      emit(
        SessionState(
          status: SessionStatus.ready,
          userId: event.userId,
          company: company,
          selectedStore: selectedStore,
          availableStores: stores,
        ),
      );
    });
  }

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