TaskState doesn't change when the upload completer FirebaseStorage Flutter

[mohsenGhalem]

Hello I'm getting the same error but when the upload complete the TaskState doesn't changeto TaskState.success

The error I get :

unable to change internal state to: INTERNAL_STATE_CANCELED, INTERNAL_STATE_CANCELING isUser: true from state:INTERNAL_STATE_SUCCESS

the upload function :

Future<Either<Failure, UploadTask>> uploadAssessmentVideo({
    required File video,
    required String patientId,
    required AssessmentResult assessmentResult,
  }) async {
    try {
      if (await networkInfo.isConnected) {
        debugPrint('Uploading video');
        final storage = FirebaseStorage.instance;
        final fileName =
            '${assessmentResult.id}_${patientId}_${assessmentResult.createdAt.toIso8601String()}.mp4';
        final ref = storage.ref().child('assessments/$fileName');

        final UploadTask uploadTask = ref.putFile(
          video,
          SettableMetadata(contentType: 'video/mp4', customMetadata: {
            'patientId': patientId,
            'date': assessmentResult.createdAt.toIso8601String(),
          }),
        );

        return Right(uploadTask);
      } else {
        throw NoInternetException('no-internet');
      }
    } catch (e) {
      debugPrint('Error: $e');
      return Left(Failure(e.toString()));
    }
  }

The controller i use to control the UI state :

uploadAssessmentVideo({
    required File video,
    required String patientId,
    required AssessmentResult assessmentResult,
  }) async {
    change(TaskState.running, status: RxStatus.success());
    final result = await assessmentsRepository.uploadAssessmentVideo(
      video: video,
      patientId: patientId,
      assessmentResult: assessmentResult,
    );

    result.fold(
      (l) {
        Get.snackbar(
          'Error',
          l.message,
          snackPosition: SnackPosition.BOTTOM,
          backgroundColor: Colors.red,
          colorText: Colors.white,
        );
      },
      (r) {
        r.snapshotEvents.listen(
          (event) {
            if (state == TaskState.running) {
              debugPrint('Uploading: $percentage%');
              percentage.value =
                  (event.bytesTransferred * 100 ~/ event.totalBytes).toInt();
            } else if (state == TaskState.success) {
              debugPrint('Upload success');
              _updateAssessmentReuslt(event, assessmentResult, patientId)
                  .then((value) {
                change(TaskState.success);
              });
            } else if (state == TaskState.error) {
              debugPrint('Upload failed');
              change(TaskState.error);
            }
            update();
          },
        );

        r.then(
          (value) async {},
        );
      },
    );
  }

[minhdanh]

Hello @mohsenGhalem, could you get this resolved? I'm seeing this too.

[mohsenGhalem]

Hello @minhdanh , I was able to solve this issue by checking the percentage of the upload

 uploadAssessmentVideo({
    required File video,
    required String patientId,
    required AssessmentResult assessmentResult,
  }) async {
    bool isUpdated = false;
    change(TaskState.running, status: RxStatus.success());
    final result = await assessmentsRepository.uploadAssessmentVideo(
      video: video,
      patientId: patientId,
      assessmentResult: assessmentResult,
    );

    result.fold(
      (l) {
        Get.snackbar(
          'error'.tr,
          l.message.tr,
          snackPosition: SnackPosition.BOTTOM,
          backgroundColor: Colors.red,
          colorText: Colors.white,
        );
      },
      (r) {
        r.snapshotEvents.listen(
          (event) {
            if (state == TaskState.running) {
              debugPrint('Uploading: $percentage%');
              percentage.value =
                  (event.bytesTransferred * 100 ~/ event.totalBytes).toInt();
              
              if (percentage.value == 100 && !isUpdated) {
                isUpdated = true;
                _updateAssessmentReuslt(
                  event,
                  assessmentResult,
                  patientId,
                ).then((value) {
                  change(TaskState.success);
                });
              }
            } else if (state == TaskState.success) {
              debugPrint('Upload success');

              ///FIXME: Waiting an answer from firebase team
              // _updateAssessmentReuslt(event, assessmentResult, patientId)
              //     .then((value) {
              //   change(TaskState.success);
              // });
            } else if (state == TaskState.error) {
              debugPrint('Upload failed');
              change(TaskState.error);
            }
            update();
          },
        );

        r.then(
          (value) async {},
        );
      },
    );
  }