Trying to fix issue where client doesn't appear after dealer has reconnected

Author: devgianlu

core/src/main/java/xyz/gianlu/librespot/connectstate/DeviceStateHandler.java

@@ -150,6 +150,11 @@ public void onMessage(@NotNull String uri, @NotNull Map<String, String> headers,
         }
     }
 
+    @Override
+    public void onConnectionRestarted() {
+        // Do nothing (already handled by StateWrapper)
+    }
+
     @NotNull
     @Override
     public RequestResult onRequest(@NotNull String mid, int pid, @NotNull String sender, @NotNull JsonObject command) {

core/src/main/java/xyz/gianlu/librespot/dealer/DealerClient.java

@@ -196,13 +196,21 @@ private void connectionInvalided() {
 
             try {
                 connect();
+                notifyConnectionRestarted();
             } catch (IOException | MercuryClient.MercuryException ex) {
                 LOGGER.error("Failed reconnecting, retrying...", ex);
                 connectionInvalided();
             }
         }, 10, TimeUnit.SECONDS);
     }
 
+    private void notifyConnectionRestarted() {
+        synchronized (msgListeners) {
+            for (MessageListener listener : msgListeners.keySet())
+                listener.onConnectionRestarted();
+        }
+    }
+
     public enum RequestResult {
         UNKNOWN_SEND_COMMAND_RESULT, SUCCESS,
         DEVICE_NOT_FOUND, CONTEXT_PLAYER_ERROR,
@@ -217,6 +225,8 @@ public interface RequestListener {
 
     public interface MessageListener {
         void onMessage(@NotNull String uri, @NotNull Map<String, String> headers, @NotNull String[] payloads) throws IOException;
+
+        void onConnectionRestarted();
     }
 
     private static class Looper implements Runnable, Closeable {

core/src/main/java/xyz/gianlu/librespot/player/StateWrapper.java

@@ -654,6 +654,11 @@ else if (op.getKind() == Playlist4ApiProto.Op.Kind.REM)
         }
     }
 
+    @Override
+    public void onConnectionRestarted() {
+        updated();
+    }
+
     private synchronized void performCollectionUpdate(@NotNull List<String> uris, boolean inCollection) {
         for (String uri : uris)
             tracksKeeper.updateMetadataFor(uri, "collection.in_collection", String.valueOf(inCollection));