fix(bugs): update message when in progress

This commit is contained in:
anhtunz
2025-02-11 11:51:58 +07:00
parent bcf205f171
commit a98e84880b
2 changed files with 69 additions and 47 deletions

View File

@@ -4,6 +4,7 @@ import 'dart:developer';
import 'package:sfm_app/feature/devices/device_model.dart';
import 'package:sfm_app/product/base/bloc/base_bloc.dart';
import 'package:sfm_app/product/constant/app/app_constants.dart';
import 'package:sfm_app/product/services/api_services.dart';
import 'package:sfm_app/product/utils/date_time_utils.dart';
@@ -28,6 +29,10 @@ class DeviceLogsBloc extends BlocBase {
StreamSink<List<SensorLogs>> get sinkSensors => sensors.sink;
Stream<List<SensorLogs>> get streamSensors => sensors.stream;
final message = StreamController<String>.broadcast();
StreamSink<String> get sinkmessage => message.sink;
Stream<String> get streammessage => message.stream;
@override
void dispose() {}
@@ -49,11 +54,10 @@ class DeviceLogsBloc extends BlocBase {
DateTime fromDate,
List<SensorLogs> sensors,
) async {
log("SensorLength: ${sensors.length}");
sinkmessage.add(ApplicationConstants.LOADING);
String fromDateString =
DateTimeUtils.instance.formatDateTimeToString(fromDate);
String now = DateTimeUtils.instance.formatDateTimeToString(DateTime.now());
// List<SensorLogs> sensors = [];
Map<String, dynamic> params = {
'thing_id': thingID,
'from': fromDateString,
@@ -74,8 +78,9 @@ class DeviceLogsBloc extends BlocBase {
for (var sensor in devicesListLog.sensors!) {
sensors.add(sensor);
}
} else {
sinkmessage.add(ApplicationConstants.NO_DATA);
}
sinkSensors.add(sensors);
}
}