tasks

lib/features/tasks/data/task_repository.dart

@@ -1,3 +1,5 @@
+import 'dart:async';
+
 import 'package:flux/core/enums_and_consts/consts.dart';
 import 'package:flux/features/tasks/models/task_status.dart';
 import 'package:supabase_flutter/supabase_flutter.dart';
@@ -10,6 +12,42 @@ class TaskRepository {
   TaskRepository({SupabaseClient? supabase})
     : _supabase = supabase ?? Supabase.instance.client;
 
+  // --- LOGICA REAL-TIME (Il Campanello) ---
+  Stream<void> watchCompanyTasks(String companyId) {
+    // Usiamo un broadcast nel caso più bloc volessero ascoltarlo in futuro
+    final controller = StreamController<void>.broadcast();
+
+    final channel = _supabase.channel('public:tasks_company_$companyId');
+
+    channel
+        .onPostgresChanges(
+          event: PostgresChangeEvent.all,
+          schema: 'public',
+          table: Tables.tasks,
+          filter: PostgresChangeFilter(
+            type: PostgresChangeFilterType.eq,
+            column: 'company_id',
+            value: companyId,
+          ),
+          callback: (payload) {
+            if (!controller.isClosed) {
+              controller.add(
+                null,
+              ); // Suoniamo il campanello! Nessun dato, solo il "ding"
+            }
+          },
+        )
+        .subscribe();
+
+    // Quando il Cubit smette di ascoltare, puliamo il canale Supabase in automatico
+    controller.onCancel = () {
+      channel.unsubscribe();
+      controller.close();
+    };
+
+    return controller.stream;
+  }
+
   // --- RECUPERO DEI TASK FILTRATI ---
   Future<List<TaskModel>> getTasks({
     required String companyId,