startHeartBeat method

Future<void> startHeartBeat()

Implementation

Future<void> startHeartBeat() async {
  if (_stateDataObs.isJoinClassSuccess) {
    if (_config.classId.toString().isEmpty) {
      TCICLog.error(
        'classId is empty, please check the classId',
        actionModule: ActionModule.tcicController.name,
        actionName: ActionName.startHeartBeat.name,
      );
      return;
    }
    final stateReport = json.encode({
      "RtcInfos": {"userId": _config.userId},
      "Role": getRole().name,
      "Time": DateTime.now().toIso8601String(),
      "Seq": heartBeatSeq,
    });
    TCICLog.info(
      "$stateReport, heartBeatInterval: $heartBeatInterval ms",
      actionModule: ActionModule.tcicController.name,
      actionName: ActionName.startHeartBeat.name,
    );
    // 如果 networkService.sendHeartBeat 3 秒内没有返回，则直接 return
    try {
      final data = await networkService
          .sendHeartBeat(
            HeartbeatBody(classId: _config.classId, stateReport: stateReport),
          )
          .timeout(
            const Duration(seconds: 3),
            onTimeout: () {
              TCICLog.error(
                'sendHeartBeat 超时（3秒未返回）',
                actionModule: ActionModule.tcicController.name,
                actionName: ActionName.startHeartBeat.name,
              );
              return null;
            },
          );
      if (data == null) {
        return;
      } else {
        if (data.errorCode == 0) {
          heartBeatSeq++;
          if (data.interval != 0) {
            final currentInterval = (data.interval);
            if (currentInterval != heartBeatInterval) {
              heartBeatInterval = currentInterval;
              TCICLog.info(
                'heartBeatInterval changed: $heartBeatInterval',
                actionModule: ActionModule.tcicController.name,
                actionName: ActionName.startHeartBeat.name,
              );
            }
          }
        } else {
          if (_handleHeartBeatResult(data)) {
            return;
          }
        }
      }
    } catch (e) {
      TCICLog.error(
        'sendHeartBeat 异常: $e',
        actionModule: ActionModule.tcicController.name,
        actionName: ActionName.startHeartBeat.name,
      );
      return;
    }

    cancelHeartBeatTimer();
    _heartBeatTimer = Timer.periodic(
      Duration(milliseconds: heartBeatInterval),
      (timer) {
        startHeartBeat();
      },
    );
  }
}