w

lib/features/tasks/blocs/task_list_cubit.dart

@@ -0,0 +1,92 @@
+import 'dart:async';
+
+import 'package:equatable/equatable.dart';
+import 'package:flutter_bloc/flutter_bloc.dart';
+import 'package:flux/features/tasks/data/task_repository.dart';
+import 'package:flux/features/tasks/models/task_model.dart';
+import 'package:flux/features/tasks/models/task_status.dart';
+import 'package:get_it/get_it.dart';
+import 'package:supabase_flutter/supabase_flutter.dart';
+
+part 'task_list_state.dart';
+
+class TaskListCubit extends Cubit<TaskListState> {
+  final SupabaseClient _supabase = GetIt.I.get<SupabaseClient>();
+  RealtimeChannel? _taskChannel;
+  final TaskRepository _repository = GetIt.I.get<TaskRepository>();
+
+  TaskListCubit() : super(TaskListState(status: TaskListStatus.initial));
+
+  // --- AVVIA L'ASCOLTO IN TEMPO REALE ---
+  void startListening({required String companyId, String? storeId}) {
+    emit(state.copyWith(status: TaskListStatus.loading));
+
+    // Facciamo subito il caricamento manuale, chiedendo SOLO quelli attivi
+    _loadTasks(companyId: companyId, storeId: storeId);
+
+    _taskChannel?.unsubscribe();
+
+    _taskChannel = _supabase
+        .channel('public:tasks_company_$companyId')
+        .onPostgresChanges(
+          event: PostgresChangeEvent.all,
+          schema: 'public',
+          table: 'tasks',
+          filter: PostgresChangeFilter(
+            type: PostgresChangeFilterType.eq,
+            column: 'company_id',
+            value: companyId,
+          ),
+          callback: (payload) {
+            // Ricarica la lista applicando sempre i filtri di stato
+            _loadTasks(companyId: companyId, storeId: storeId);
+          },
+        );
+
+    _taskChannel?.subscribe();
+  }
+
+  // --- HELPER DI CARICAMENTO ---
+  Future<void> _loadTasks({required String companyId, String? storeId}) async {
+    try {
+      final tasks = await _repository.getTasks(
+        companyId: companyId,
+        storeId: storeId,
+        // CHICCA: Passiamo solo gli stati attivi!
+        statuses: [TaskStatus.open, TaskStatus.inProgress],
+      );
+
+      emit(
+        state.copyWith(
+          status: TaskListStatus.success,
+          tasks: tasks,
+          errorMessage: null,
+        ),
+      );
+    } catch (e) {
+      emit(
+        state.copyWith(
+          status: TaskListStatus.failure,
+          errorMessage: e.toString(),
+        ),
+      );
+    }
+  }
+
+  // --- OPERAZIONI MANUALI ---
+  // (Le lasciamo gestire al repository o le metti qui se preferisci,
+  // tanto il risultato lo vedrai magicamente aggiornato dallo stream sopra!)
+
+  /*
+  Future<void> markAsCompleted(String taskId) async { ... }
+  Future<void> deleteTask(String taskId) async { ... }
+  */
+
+  // --- PULIZIA FONDAMENTALE ---
+  @override
+  Future<void> close() {
+    // Chiudiamo il rubinetto quando usciamo dalla pagina per non intasarci la memoria!
+    _taskChannel?.unsubscribe();
+    return super.close();
+  }
+}