VitalApp/lib/architecture/network_connectivity.dart

import 'dart:async';

import 'package:connectivity_plus/connectivity_plus.dart';
import 'package:vnote_device_plugin/events/event_type.dart';
import 'package:vitalapp/architecture/utils/prompt_box.dart';
import 'package:fis_common/logger/logger.dart';

/// 网络连接检测器 - 全局实例
final netChecker = _init();

NetworkConnectivityChecker _init() {
  final instance = NetworkConnectivityChecker._();

  bool isConnecting = true;

  instance.onlineChangedEvent.addListener((sender, e) {
    if (e) {
      if (!isConnecting) {
        PromptBox.toast("网络已连接");
      }
    } else {
      PromptBox.error("网络已断开");
    }
    isConnecting = e;
  });

  return instance;
}

/// 网络连接检查器
class NetworkConnectivityChecker {
  NetworkConnectivityChecker._();

  final Connectivity _api = Connectivity();
  StreamSubscription<ConnectivityResult>? _subscription;
  ConnectivityResult _status = ConnectivityResult.none;

  /// 在线状态变更事件
  final FEventHandler<bool> onlineChangedEvent = FEventHandler<bool>();

  /// 连接状态
  ConnectivityResult get status => _status;

  /// 是否在线
  bool get isOnline => status != ConnectivityResult.none;

  void run() {
    if (_subscription != null) {
      return;
    }
    _subscription = _api.onConnectivityChanged.listen((event) {
      logger.i(
          "NetworkConnectivityChecker - Current net connection type: ${event.name}.");
      final originIsOnline = isOnline;
      _status = event;
      if (originIsOnline != isOnline) {
        onlineChangedEvent.emit(this, isOnline);
      }
      logger.i("NetworkConnectivityChecker - IsOnline: $isOnline.");
    });
  }

  void stop() {
    _subscription?.cancel();
    _subscription = null;
  }
}