feat(jellyfin): add local server discovery

close #1188
2026-05-31 10:51:08 +02:00
parent 656d512858
commit e3db54940d
41 changed files with 698 additions and 26 deletions
@@ -0,0 +1,86 @@
+import 'dart:async';
+import 'dart:convert';
+import 'dart:io';
+
+import '../utils/app_logger.dart';
+import 'jellyfin_endpoint_discovery.dart';
+
+class DiscoveredJellyfinServer {
+  final String address;
+  final String id;
+  final String name;
+
+  DiscoveredJellyfinServer({required this.address, required this.id, required this.name});
+}
+
+class JellyfinLanDiscoveryService {
+  static const int discoveryPort = 7359;
+  static const String discoveryMessage = 'who is JellyfinServer?';
+
+  Future<List<DiscoveredJellyfinServer>> discover({
+    Duration timeout = const Duration(seconds: 2),
+    InternetAddress? broadcastAddress,
+  }) async {
+    RawDatagramSocket? socket;
+    StreamSubscription<RawSocketEvent>? subscription;
+    final discovered = <String, DiscoveredJellyfinServer>{};
+    try {
+      socket = await RawDatagramSocket.bind(InternetAddress.anyIPv4, 0);
+      socket.broadcastEnabled = true;
+      subscription = socket.listen((event) {
+        if (event != RawSocketEvent.read) return;
+        Datagram? datagram;
+        while ((datagram = socket?.receive()) != null) {
+          final server = parseDiscoveryResponse(datagram!.data);
+          if (server == null) continue;
+          discovered.putIfAbsent(server.id, () => server);
+        }
+      });
+
+      final data = utf8.encode(discoveryMessage);
+      final target = broadcastAddress ?? InternetAddress('255.255.255.255');
+      socket.send(data, target, discoveryPort);
+      await Future<void>.delayed(const Duration(milliseconds: 350));
+      socket.send(data, target, discoveryPort);
+      await Future<void>.delayed(timeout);
+    } catch (e, st) {
+      appLogger.w('Jellyfin LAN discovery failed', error: e, stackTrace: st);
+    } finally {
+      await subscription?.cancel();
+      socket?.close();
+    }
+
+    final servers = discovered.values.toList()
+      ..sort((a, b) {
+        final name = a.name.toLowerCase().compareTo(b.name.toLowerCase());
+        if (name != 0) return name;
+        return a.address.compareTo(b.address);
+      });
+    return List.unmodifiable(servers);
+  }
+
+  static DiscoveredJellyfinServer? parseDiscoveryResponse(List<int> data) {
+    try {
+      final decoded = jsonDecode(utf8.decode(data));
+      if (decoded is! Map<String, dynamic>) return null;
+
+      final address = _stringValue(decoded, 'Address') ?? _stringValue(decoded, 'address');
+      final id = _stringValue(decoded, 'Id') ?? _stringValue(decoded, 'id');
+      final name = _stringValue(decoded, 'Name') ?? _stringValue(decoded, 'name');
+      if (address == null || id == null || name == null) return null;
+
+      final normalized = JellyfinEndpointDiscovery.normalizeBaseUrl(address);
+      if (normalized.isEmpty || id.trim().isEmpty || name.trim().isEmpty) return null;
+      return DiscoveredJellyfinServer(address: normalized, id: id.trim(), name: name.trim());
+    } catch (_) {
+      return null;
+    }
+  }
+
+  static String? _stringValue(Map<String, dynamic> json, String key) {
+    final value = json[key];
+    if (value is! String) return null;
+    final trimmed = value.trim();
+    return trimmed.isEmpty ? null : trimmed;
+  }
+}