مراقبة حالة الاتصال بالإنترنت باستخدام Flutter وDart

import 'dart:async';
import 'dart:io';
import 'package:connectivity_plus/connectivity_plus.dart';
import 'package:flutter/cupertino.dart';
import 'package:hayyak/core/injection/injector.dart';
import '../routing_manager/routing_manager.dart';

class ConnectionStatusListener {
  static final ConnectionStatusListener _singleton = ConnectionStatusListener._internal();

  ConnectionStatusListener._internal();

  bool hasShownNoInternet = false;
  final Connectivity _connectivity = Connectivity();
  static ConnectionStatusListener getInstance() => _singleton;

  bool hasConnection = false;
  StreamController<bool> connectionChangeController = StreamController<bool>.broadcast();
  Stream<bool> get connectionChange => connectionChangeController.stream;

  void _connectionChange(List<ConnectivityResult> result) {
    checkConnection(result);
  }

  Future<bool> checkConnection(List<ConnectivityResult> result) async {
    bool previousConnection = hasConnection;

    if (result.contains(ConnectivityResult.wifi) || result.contains(ConnectivityResult.mobile)) {
      try {
        final result = await InternetAddress.lookup('google.com');
        if (result.isNotEmpty && result[0].rawAddress.isNotEmpty) {
          hasConnection = true;
        } else {
          hasConnection = false;
        }
      } on SocketException catch (_) {
        hasConnection = false;
      }
    } else {
      hasConnection = false;
    }

    if (previousConnection != hasConnection) {
      connectionChangeController.add(hasConnection);
    }
    return hasConnection;
  }

  Future<void> initialize() async {
    _connectivity.onConnectivityChanged.listen(_connectionChange);

    List<ConnectivityResult> result = await _connectivity.checkConnectivity();
    _connectionChange(result);
  }

  void dispose() {
    connectionChangeController.close();
  }
}

final GlobalKey<NavigatorState> navigatorKey = GlobalKey<NavigatorState>();

initNoInternetListener() async {
  var connectionStatus = injector<ConnectionStatusListener>();
  await connectionStatus.initialize();

  updateConnectivity(connectionStatus.hasConnection, connectionStatus);

  connectionStatus.connectionChange.listen((hasConnection) {
    updateConnectivity(hasConnection, connectionStatus);
  });
}

updateConnectivity(bool hasConnection, ConnectionStatusListener connectionStatus) {
  WidgetsBinding.instance.addPostFrameCallback((_) {
    if (!hasConnection && !connectionStatus.hasShownNoInternet) {
      connectionStatus.hasShownNoInternet = true;
      navigatorKey.currentState?.pushNamed(RouteManager.internet);
    } else if (hasConnection && connectionStatus.hasShownNoInternet) {
      connectionStatus.hasShownNoInternet = false;
      if (navigatorKey.currentState?.canPop() ?? false) {
        navigatorKey.currentState?.pop();
      }
    }
  });
}

إنشاء Stream لحالة الاتصال بالإنترنت في تطبيقات Flutter

final injector = GetIt.instance;

class Injector {
  static void init() async {
    injector.registerFactory(() => ConnectionStatusListener.getInstance());
    initNoInternetListener();
  }
}

كيفية تحسين تجربة المستخدم في Flutter عند انقطاع الاتصال بالشبكة