Add connectivity service and documentation

Introduced Connectivity service in both Dart and Python SDKs, enabling connectivity status checks and change notifications. Registered connectivity_plus plugin for macOS and Windows clients, updated dependencies, and added example usage and documentation for the new service.

Author: FeodorFitsner

client/macos/Flutter/GeneratedPluginRegistrant.swift

@@ -7,6 +7,7 @@ import Foundation
 
 import audioplayers_darwin
 import battery_plus
+import connectivity_plus
 import device_info_plus
 import file_picker
 import geolocator_apple
@@ -29,6 +30,7 @@ import window_to_front
 func RegisterGeneratedPlugins(registry: FlutterPluginRegistry) {
   AudioplayersDarwinPlugin.register(with: registry.registrar(forPlugin: "AudioplayersDarwinPlugin"))
   BatteryPlusMacosPlugin.register(with: registry.registrar(forPlugin: "BatteryPlusMacosPlugin"))
+  ConnectivityPlusPlugin.register(with: registry.registrar(forPlugin: "ConnectivityPlusPlugin"))
   DeviceInfoPlusMacosPlugin.register(with: registry.registrar(forPlugin: "DeviceInfoPlusMacosPlugin"))
   FilePickerPlugin.register(with: registry.registrar(forPlugin: "FilePickerPlugin"))
   GeolocatorPlugin.register(with: registry.registrar(forPlugin: "GeolocatorPlugin"))

client/pubspec.lock

@@ -145,6 +145,22 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.19.1"
+  connectivity_plus:
+    dependency: transitive
+    description:
+      name: connectivity_plus
+      sha256: b5e72753cf63becce2c61fd04dfe0f1c430cc5278b53a1342dc5ad839eab29ec
+      url: "https://pub.dev"
+    source: hosted
+    version: "6.1.5"
+  connectivity_plus_platform_interface:
+    dependency: transitive
+    description:
+      name: connectivity_plus_platform_interface
+      sha256: "42657c1715d48b167930d5f34d00222ac100475f73d10162ddf43e714932f204"
+      url: "https://pub.dev"
+    source: hosted
+    version: "2.0.1"
   cross_file:
     dependency: transitive
     description:
@@ -798,6 +814,14 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "1.0.0"
+  nm:
+    dependency: transitive
+    description:
+      name: nm
+      sha256: "2c9aae4127bdc8993206464fcc063611e0e36e72018696cd9631023a31b24254"
+      url: "https://pub.dev"
+    source: hosted
+    version: "0.5.0"
   package_info_plus:
     dependency: "direct main"
     description:

client/windows/flutter/generated_plugin_registrant.cc

@@ -8,6 +8,7 @@
 
 #include <audioplayers_windows/audioplayers_windows_plugin.h>
 #include <battery_plus/battery_plus_windows_plugin.h>
+#include <connectivity_plus/connectivity_plus_windows_plugin.h>
 #include <geolocator_windows/geolocator_windows.h>
 #include <media_kit_libs_windows_video/media_kit_libs_windows_video_plugin_c_api.h>
 #include <media_kit_video/media_kit_video_plugin_c_api.h>
@@ -26,6 +27,8 @@ void RegisterPlugins(flutter::PluginRegistry* registry) {
       registry->GetRegistrarForPlugin("AudioplayersWindowsPlugin"));
   BatteryPlusWindowsPluginRegisterWithRegistrar(
       registry->GetRegistrarForPlugin("BatteryPlusWindowsPlugin"));
+  ConnectivityPlusWindowsPluginRegisterWithRegistrar(
+      registry->GetRegistrarForPlugin("ConnectivityPlusWindowsPlugin"));
   GeolocatorWindowsRegisterWithRegistrar(
       registry->GetRegistrarForPlugin("GeolocatorWindows"));
   MediaKitLibsWindowsVideoPluginCApiRegisterWithRegistrar(

client/windows/flutter/generated_plugins.cmake

@@ -5,6 +5,7 @@
 list(APPEND FLUTTER_PLUGIN_LIST
   audioplayers_windows
   battery_plus
+  connectivity_plus
   geolocator_windows
   media_kit_libs_windows_video
   media_kit_video

packages/flet/lib/src/flet_core_extension.dart

@@ -109,6 +109,7 @@ import 'models/control.dart';
 import 'services/browser_context_menu.dart';
 import 'services/battery.dart';
 import 'services/clipboard.dart';
+import 'services/connectivity.dart';
 import 'services/file_picker.dart';
 import 'services/haptic_feedback.dart';
 import 'services/semantics_service.dart';
@@ -382,6 +383,8 @@ class FletCoreExtension extends FletExtension {
         return BatteryService(control: control);
       case "Clipboard":
         return ClipboardService(control: control);
+      case "Connectivity":
+        return ConnectivityService(control: control);
       case "FilePicker":
         return FilePickerService(control: control);
       case "HapticFeedback":

packages/flet/lib/src/services/connectivity.dart

@@ -0,0 +1,63 @@
+import 'dart:async';
+
+import 'package:connectivity_plus/connectivity_plus.dart';
+import 'package:flutter/foundation.dart';
+
+import '../flet_service.dart';
+import '../utils/numbers.dart';
+
+class ConnectivityService extends FletService {
+  final Connectivity _connectivity = Connectivity();
+  StreamSubscription<List<ConnectivityResult>>? _subscription;
+
+  ConnectivityService({required super.control});
+
+  @override
+  void init() {
+    super.init();
+    debugPrint("ConnectivityService(${control.id}).init");
+    control.addInvokeMethodListener(_invokeMethod);
+    _updateListeners();
+  }
+
+  @override
+  void update() {
+    _updateListeners();
+  }
+
+  Future<dynamic> _invokeMethod(String name, dynamic args) async {
+    switch (name) {
+      case "check_connectivity":
+        final results = await _connectivity.checkConnectivity();
+        return results.map((r) => r.name).toList();
+      default:
+        throw Exception("Unknown Connectivity method: $name");
+    }
+  }
+
+  void _updateListeners() {
+    final listenChange = control.getBool("on_connectivity_change") == true;
+    if (listenChange && _subscription == null) {
+      _subscription = _connectivity.onConnectivityChanged.listen(
+          (List<ConnectivityResult> result) {
+        control.triggerEvent("connectivity_change",
+            {"connectivity": result.map((r) => r.name).toList()});
+      }, onError: (error) {
+        debugPrint(
+            "ConnectivityService: error listening to connectivity: $error");
+      });
+    } else if (!listenChange && _subscription != null) {
+      _subscription?.cancel();
+      _subscription = null;
+    }
+  }
+
+  @override
+  void dispose() {
+    debugPrint("ConnectivityService(${control.id}).dispose()");
+    control.removeInvokeMethodListener(_invokeMethod);
+    _subscription?.cancel();
+    _subscription = null;
+    super.dispose();
+  }
+}

packages/flet/pubspec.yaml

@@ -23,6 +23,7 @@ dependencies:
     sdk: flutter
   battery_plus: ^6.2.2
   collection: ^1.19.0
+  connectivity_plus: ^6.1.2
   device_info_plus: ^12.1.0
   equatable: ^2.0.3
   file_picker: ^10.3.3

sdk/python/examples/controls/connectivity/basic.py

@@ -0,0 +1,35 @@
+import flet as ft
+
+
+async def main(page: ft.Page):
+    connectivity = ft.Connectivity()
+
+    status = ft.Text()
+    changes = ft.Text()
+
+    async def refresh(_=None):
+        results = await connectivity.check_connectivity()
+        status.value = "Current connectivity: " + ", ".join(r.value for r in results)
+
+    async def on_change(e: ft.ConnectivityChangeEvent):
+        changes.value = "Connectivity changed: " + ", ".join(
+            r.value for r in e.connectivity
+        )
+        await refresh()
+
+    connectivity.on_connectivity_change = on_change
+
+    await refresh()
+
+    page.add(
+        ft.Column(
+            [
+                status,
+                ft.Button("Refresh connectivity", on_click=refresh),
+                changes,
+            ],
+        )
+    )
+
+
+ft.run(main)

sdk/python/packages/flet/docs/controls/connectivity.md

@@ -0,0 +1,14 @@
+---
+class_name: flet.Connectivity
+examples: ../../examples/controls/connectivity
+---
+
+{{ class_summary(class_name) }}
+
+## Examples
+
+```python
+--8<-- "{{ examples }}/basic.py"
+```
+
+{{ class_members(class_name) }}

sdk/python/packages/flet/docs/types/connectivitychangeevent.md

@@ -0,0 +1 @@
+{{ class_all_options("flet.ConnectivityChangeEvent", separate_signature=False) }}