🐛: fixed socket issues

lib/app.dart

@@ -59,7 +59,7 @@ class App extends HookWidget {
                   ],
                 ),
                 SizedBox(height: 18),
-                ...snapshot.requireData.map((e) => Text(e.address.address)),
+                Text("Neighbour Devices: " + snapshot.requireData.length.toString()),
               ],
             );
           },

lib/logic/network/client.dart

@@ -2,24 +2,36 @@ import 'dart:io';
 
 import 'package:clipboard_sync/logic/clipboard/clipboard.dart';
 import 'package:clipboard_sync/logic/models/messages.dart';
+import 'package:rxdart/rxdart.dart';
 
-handleClient(Socket socket) async {
-  bool pause = false;
+const KEEP_ALIVE_INTERVAL = Duration(seconds: 1);
 
-  clipboard.listen((value) {
-    if (!pause) {
+handleClient(BehaviorSubject<List<Socket>> sockets, Socket socket) async {
+  String socketValue = "";
+  final sub = clipboard.listen((value) {
+    if (socketValue != value.value) {
       final clipboardValue = encodeClipboardValue(value);
+      print("sending $clipboardValue");
       socket.write(clipboardValue);
     }
   });
 
   socket.listen((event) {
-    pause = true;
+    if (String.fromCharCodes(event).trim() == "alive") return;
+
     final clipboardValue = decodeClipboardValue(event);
     if (clipboard.value.value != clipboardValue.value &&
         clipboardValue.timestamp.compareTo(clipboardValue.timestamp) >= 0) {
+      print("receiving ${String.fromCharCodes(event).trim()}");
+      socketValue = clipboardValue.value;
       clipboard.value = clipboardValue;
     }
-    pause = false;
   });
+
+  while (sockets.value.contains(socket)) {
+    await Future.delayed(KEEP_ALIVE_INTERVAL);
+    socket.write("alive");
+  }
+
+  sub.cancel();
 }

lib/logic/network/network.dart

@@ -11,7 +11,7 @@ const SERVER_PORT = 10542;
 const SEARCH_PORT = 38899;
 const SEARCH_SOURCE_PORT = 40000;
 const SEARCH_INTERVAL = const Duration(seconds: 1);
-const BROADCAST_ADDRESS = "255.255.255.255";
+const BROADCAST_ADDRESS = "192.168.255.255";
 
 BehaviorSubject<List<Socket>> initializeNetwork() {
   final socketStream = BehaviorSubject<List<Socket>>.seeded([]);
@@ -29,7 +29,7 @@ _initializeNetwork(BehaviorSubject<List<Socket>> socketStream) async {
     list.add(socket);
     socketStream.value = list;
     _removeSocketOnClose(socket, socketStream);
-    handleClient(socket);
+    handleClient(socketStream, socket);
   });
 
   _handleServerSearchers(deviceInfo, serverSocket);
@@ -105,7 +105,7 @@ _handleServerConnections(RawDatagramSocket udpSocket, BehaviorSubject<List<Socke
         _removeSocketOnClose(socket, socketStream);
         list.add(socket);
         socketStream.value = list;
-        handleClient(socket);
+        handleClient(socketStream, socket);
       } catch (e) {
         print(e);
       }