Merge branch 'main' into set-viewport-fit-cover

flow-client/src/main/java/com/vaadin/client/communication/MessageHandler.java

@@ -295,10 +295,10 @@ protected void handleJSON(final ValueMap valueMap) {
         }
 
         /**
-         * Should only prepare resync after the if (locked ||
+         * Should only prepare resync after the (locked ||
          * !isNextExpectedMessage(serverId)) {...} since
          * stateTree.repareForResync() will remove the nodes, and if locked is
-         * true, it will return without handling the message, thus won't adding
+         * true, it will return without handling the message, thus won't add
          * nodes back.
          *
          * This is related to https://github.com/vaadin/flow/issues/8699 It

flow-client/src/main/java/com/vaadin/client/communication/MessageSender.java

@@ -15,7 +15,11 @@
  */
 package com.vaadin.client.communication;
 
+import java.util.ArrayList;
+import java.util.List;
+
 import com.google.gwt.core.client.GWT;
+import com.google.gwt.user.client.Timer;
 
 import com.vaadin.client.ConnectionIndicator;
 import com.vaadin.client.Console;
@@ -67,6 +71,10 @@ public enum ResynchronizationState {
 
     private JsonObject pushPendingMessage;
 
+    private List<JsonObject> messageQueue = new ArrayList<>();
+
+    private Timer resendMessageTimer;
+
     /**
      * Creates a new instance connected to the given registry.
      *
@@ -119,7 +127,10 @@ private void doSendInvocationsToServer() {
             JsonObject payload = pushPendingMessage;
             pushPendingMessage = null;
             registry.getRequestResponseTracker().startRequest();
-            send(payload);
+            sendPayload(payload);
+            return;
+        } else if (hasQueuedMessages() && resendMessageTimer == null) {
+            sendPayload(messageQueue.get(0));
             return;
         }
 
@@ -146,6 +157,8 @@ private void doSendInvocationsToServer() {
         if (resynchronizationState == ResynchronizationState.SEND_TO_SERVER) {
             resynchronizationState = ResynchronizationState.WAITING_FOR_RESPONSE;
             Console.warn("Resynchronizing from server");
+            messageQueue.clear();
+            resetTimer();
             extraJson.put(ApplicationConstants.RESYNCHRONIZE_ID, true);
         }
         if (showLoadingIndicator) {
@@ -166,7 +179,6 @@ protected void send(final JsonArray reqInvocations,
             final JsonObject extraJson) {
         registry.getRequestResponseTracker().startRequest();
         send(preparePayload(reqInvocations, extraJson));
-
     }
 
     private JsonObject preparePayload(final JsonArray reqInvocations,
@@ -177,10 +189,6 @@ private JsonObject preparePayload(final JsonArray reqInvocations,
             payload.put(ApplicationConstants.CSRF_TOKEN, csrfToken);
         }
         payload.put(ApplicationConstants.RPC_INVOCATIONS, reqInvocations);
-        payload.put(ApplicationConstants.SERVER_SYNC_ID,
-                registry.getMessageHandler().getLastSeenServerSyncId());
-        payload.put(ApplicationConstants.CLIENT_TO_SERVER_ID,
-                clientToServerMessageId++);
         if (extraJson != null) {
             for (String key : extraJson.keys()) {
                 JsonValue value = extraJson.get(key);
@@ -192,12 +200,44 @@ private JsonObject preparePayload(final JsonArray reqInvocations,
 
     /**
      * Sends an asynchronous or synchronous UIDL request to the server using the
-     * given URI.
+     * given URI. Adds message to message queue and postpones sending if queue
+     * not empty.
      *
      * @param payload
      *            The contents of the request to send
      */
     public void send(final JsonObject payload) {
+        if (hasQueuedMessages()) {
+            messageQueue.add(payload);
+            return;
+        }
+        messageQueue.add(payload);
+        sendPayload(payload);
+    }
+
+    /**
+     * Sends an asynchronous or synchronous UIDL request to the server using the
+     * given URI.
+     *
+     * @param payload
+     *            The contents of the request to send
+     */
+    private void sendPayload(final JsonObject payload) {
+        payload.put(ApplicationConstants.SERVER_SYNC_ID,
+                registry.getMessageHandler().getLastSeenServerSyncId());
+        // clientID should only be set and updated if payload doesn't contain
+        // clientID. If one exists we are probably trying to resend.
+        if (!payload.hasKey(ApplicationConstants.CLIENT_TO_SERVER_ID)) {
+            payload.put(ApplicationConstants.CLIENT_TO_SERVER_ID,
+                    clientToServerMessageId++);
+        }
+
+        if (!registry.getRequestResponseTracker().hasActiveRequest()) {
+            // Direct calls to send from outside probably have not started
+            // request.
+            registry.getRequestResponseTracker().startRequest();
+        }
+
         if (push != null && push.isBidirectional()) {
             // When using bidirectional transport, the payload is not resent
             // to the server during reconnection attempts.
@@ -211,6 +251,31 @@ public void send(final JsonObject payload) {
         } else {
             Console.debug("send XHR");
             registry.getXhrConnection().send(payload);
+
+            resetTimer();
+            // resend last payload if response hasn't come in.
+            resendMessageTimer = new Timer() {
+                @Override
+                public void run() {
+                    resendMessageTimer
+                            .schedule(registry.getApplicationConfiguration()
+                                    .getMaxMessageSuspendTimeout() + 500);
+                    if (!registry.getRequestResponseTracker()
+                            .hasActiveRequest()) {
+                        registry.getRequestResponseTracker().startRequest();
+                    }
+                    registry.getXhrConnection().send(payload);
+                }
+            };
+            resendMessageTimer.schedule(registry.getApplicationConfiguration()
+                    .getMaxMessageSuspendTimeout() + 500);
+        }
+    }
+
+    private void resetTimer() {
+        if (resendMessageTimer != null) {
+            resendMessageTimer.cancel();
+            resendMessageTimer = null;
         }
     }
 
@@ -289,6 +354,8 @@ public String getCommunicationMethodName() {
      */
     public void resynchronize() {
         if (requestResynchronize()) {
+            messageQueue.clear();
+            resetTimer();
             sendInvocationsToServer();
         }
     }
@@ -311,12 +378,24 @@ public void setClientToServerMessageId(int nextExpectedId, boolean force) {
                             ApplicationConstants.CLIENT_TO_SERVER_ID) < nextExpectedId) {
                 pushPendingMessage = null;
             }
+            if (hasQueuedMessages()) {
+                // If queued message is the expected one. remove from queue
+                // and send next message if any.
+                if (messageQueue.get(0)
+                        .getNumber(ApplicationConstants.CLIENT_TO_SERVER_ID)
+                        + 1 == nextExpectedId) {
+                    resetTimer();
+                    messageQueue.remove(0);
+                }
+            }
             return;
         }
         if (force) {
             Console.debug(
                     "Forced update of clientId to " + clientToServerMessageId);
             clientToServerMessageId = nextExpectedId;
+            messageQueue.clear();
+            resetTimer();
             return;
         }
 
@@ -372,4 +451,8 @@ void clearResynchronizationState() {
     ResynchronizationState getResynchronizationState() {
         return resynchronizationState;
     }
+
+    public boolean hasQueuedMessages() {
+        return !messageQueue.isEmpty();
+    }
 }

flow-client/src/main/java/com/vaadin/client/communication/RequestResponseTracker.java

@@ -112,7 +112,8 @@ public void endRequest() {
         if ((registry.getUILifecycle().isRunning()
                 && registry.getServerRpcQueue().isFlushPending())
                 || registry.getMessageSender()
-                        .getResynchronizationState() == ResynchronizationState.SEND_TO_SERVER) {
+                        .getResynchronizationState() == ResynchronizationState.SEND_TO_SERVER
+                || registry.getMessageSender().hasQueuedMessages()) {
             // Send the pending RPCs immediately.
             // This might be an unnecessary optimization as ServerRpcQueue has a
             // finally scheduled command which trigger the send if we do not do

flow-client/src/test/frontend/FlowTests.ts

@@ -748,7 +748,7 @@ function stubServerRemoteFunction(
         handlers.leaveNavigation();
       }
     }
-    req.respond(200, { 'content-type': 'application/json' }, 'for(;;);[{}]');
+    req.respond(200, {'content-type': 'application/json'}, 'for(;;);[{"syncId":' + (payload["syncId"] + 1) + ',"clientId":' + (payload["clientId"] + 1) + '}]');
   });
 }
 

flow-server/src/main/java/com/vaadin/flow/server/communication/IndexHtmlRequestHandler.java

@@ -287,7 +287,7 @@ private void catchErrorsInDevMode(Document indexDocument) {
                 + //
                 "};" + //
                 "window.addEventListener('unhandledrejection', e => {" + //
-                "    window.Vaadin.ConsoleErrors.push([e.reason]);" + //
+                "    window.Vaadin.ConsoleErrors.push(e.reason);" + //
                 "});" //
         );
     }

flow-server/src/main/java/com/vaadin/flow/server/communication/ServerRpcHandler.java

@@ -113,7 +113,7 @@ public RpcRequest(String jsonString, boolean isSyncIdCheckEnabled) {
                 this.csrfToken = csrfToken;
             }
 
-            if (isSyncIdCheckEnabled) {
+            if (isSyncIdCheckEnabled && !isUnloadBeaconRequest()) {
                 syncId = (int) json
                         .getNumber(ApplicationConstants.SERVER_SYNC_ID);
             } else {
@@ -131,7 +131,10 @@ public RpcRequest(String jsonString, boolean isSyncIdCheckEnabled) {
                 clientToServerMessageId = (int) json
                         .getNumber(ApplicationConstants.CLIENT_TO_SERVER_ID);
             } else {
-                getLogger().warn("Server message without client id received");
+                if (!isUnloadBeaconRequest()) {
+                    getLogger()
+                            .warn("Server message without client id received");
+                }
                 clientToServerMessageId = -1;
             }
             invocations = json.getArray(ApplicationConstants.RPC_INVOCATIONS);

flow-server/src/main/resources/com/vaadin/flow/server/frontend/dependencies/default/package.json

@@ -9,7 +9,7 @@
   },
   "devDependencies": {
     "async": "3.2.6",
-    "glob": "11.0.0",
+    "glob": "11.0.1",
     "typescript": "5.7.3",
     "workbox-core": "7.3.0",
     "workbox-precaching": "7.3.0",

flow-server/src/main/resources/com/vaadin/flow/server/frontend/dependencies/react19/package.json

@@ -6,7 +6,7 @@
     "react-dom": "19.0.0"
   },
   "devDependencies": {
-    "@types/react": "19.0.2",
-    "@types/react-dom": "19.0.2"
+    "@types/react": "19.0.6",
+    "@types/react-dom": "19.0.3"
   }
 }

flow-server/src/main/resources/com/vaadin/flow/server/frontend/dependencies/vite/package.json

@@ -15,7 +15,7 @@
     "@rollup/plugin-replace": "6.0.2",
     "@rollup/pluginutils": "5.1.4",
     "@babel/preset-react": "7.26.3",
-    "rollup-plugin-visualizer": "5.13.1",
+    "rollup-plugin-visualizer": "5.14.0",
     "rollup-plugin-brotli": "3.1.0",
     "vite-plugin-checker": "0.8.0",
     "workbox-build": "7.3.0",

flow-server/src/test/java/com/vaadin/flow/server/frontend/NodeUpdaterTest.java

@@ -239,7 +239,7 @@ public void updateDefaultDependencies_olderVersionsAreUpdated()
                 "7.0.0");
         nodeUpdater.updateDefaultDependencies(packageJson);
 
-        Assert.assertEquals("11.0.0", packageJson
+        Assert.assertEquals("11.0.1", packageJson
                 .getObject(NodeUpdater.DEV_DEPENDENCIES).getString("glob"));
     }
 

flow-tests/pom.xml

@@ -335,6 +335,7 @@
                 <module>test-react-adapter</module>
                 <module>test-react-adapter/pom-production.xml</module>
                 <module>test-legacy-frontend</module>
+                <module>test-client-queue</module>
             </modules>
         </profile>
         <profile>

flow-tests/test-client-queue/pom.xml

@@ -0,0 +1,63 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <artifactId>flow-tests</artifactId>
+        <groupId>com.vaadin</groupId>
+        <version>24.7-SNAPSHOT</version>
+    </parent>
+    <artifactId>flow-client-queue-test</artifactId>
+    <name>Test Flow client queue</name>
+
+    <packaging>war</packaging>
+    <properties>
+        <maven.deploy.skip>true</maven.deploy.skip>
+        <!-- Test checks client log so java.util.logging.Level import is needed -->
+        <enforcer.skip>true</enforcer.skip>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.vaadin</groupId>
+            <artifactId>flow-test-resources</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.vaadin</groupId>
+            <artifactId>vaadin-dev-server</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.vaadin</groupId>
+            <artifactId>flow-html-components-testbench</artifactId>
+            <version>${project.version}</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <!--  Run flow plugin to build frontend -->
+            <plugin>
+                <groupId>com.vaadin</groupId>
+                <artifactId>flow-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>prepare-frontend</goal>
+                        </goals>
+                    </execution>
+                </executions>
+<!--                <configuration>-->
+<!--                    <frontendHotdeploy>true</frontendHotdeploy>-->
+<!--                </configuration>-->
+            </plugin>
+            <!-- Run jetty before integration tests, and stop after -->
+            <plugin>
+                <groupId>org.eclipse.jetty.ee10</groupId>
+                <artifactId>jetty-ee10-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>