Read devices status from Firebase realtime database

lib/features/devices/bloc/ceiling_bloc/ceiling_sensor_bloc.dart

@@ -1,3 +1,4 @@
+import 'package:firebase_database/firebase_database.dart';
 import 'package:flutter_bloc/flutter_bloc.dart';
 import 'package:syncrow_app/features/devices/bloc/ceiling_bloc/ceiling_sensor_event.dart';
 import 'package:syncrow_app/features/devices/bloc/ceiling_bloc/ceiling_sensor_state.dart';
@@ -15,6 +16,7 @@ class CeilingSensorBloc extends Bloc<CeilingSensorEvent, CeilingSensorState> {
   CeilingSensorBloc({required this.deviceId}) : super(InitialState()) {
     on<InitialEvent>(_fetchCeilingSensorStatus);
     on<ChangeValueEvent>(_changeValue);
+    on<CeilingSensorUpdated>(_onCeilingSensorUpdated);
   }
 
   void _fetchCeilingSensorStatus(InitialEvent event, Emitter<CeilingSensorState> emit) async {
@@ -27,12 +29,36 @@ class CeilingSensorBloc extends Bloc<CeilingSensorEvent, CeilingSensorState> {
       }
       deviceStatus = CeilingSensorModel.fromJson(statusModelList);
       emit(UpdateState(ceilingSensorModel: deviceStatus));
+      _listenToChanges();
     } catch (e) {
       emit(FailedState(error: e.toString()));
       return;
     }
   }
 
+  _listenToChanges() {
+    try {
+      DatabaseReference ref = FirebaseDatabase.instance.ref('device-status/$deviceId');
+      Stream<DatabaseEvent> stream = ref.onValue;
+
+      stream.listen((DatabaseEvent event) {
+        Map<dynamic, dynamic> usersMap = event.snapshot.value as Map<dynamic, dynamic>;
+        List<StatusModel> statusList = [];
+
+        usersMap['status'].forEach((element) {
+          statusList.add(StatusModel(code: element['code'], value: element['value']));
+        });
+
+        deviceStatus = CeilingSensorModel.fromJson(statusList);
+        add(CeilingSensorUpdated());
+      });
+    } catch (_) {}
+  }
+
+  _onCeilingSensorUpdated(CeilingSensorUpdated event, Emitter<CeilingSensorState> emit) {
+    emit(UpdateState(ceilingSensorModel: deviceStatus));
+  }
+
   void _changeValue(ChangeValueEvent event, Emitter<CeilingSensorState> emit) async {
     emit(LoadingNewSate(ceilingSensorModel: deviceStatus));
     try {

lib/features/devices/bloc/ceiling_bloc/ceiling_sensor_event.dart

@@ -11,6 +11,8 @@ class LoadingEvent extends CeilingSensorEvent {}
 
 class InitialEvent extends CeilingSensorEvent {}
 
+class CeilingSensorUpdated extends CeilingSensorEvent {}
+
 class ChangeValueEvent extends CeilingSensorEvent {
   final int value;
   final String code;