downgrade javaparser version and add unit test for this regression (#63)

Signed-off-by: Olivier Lamy <[email protected]>

Author: olamy

pom.xml

@@ -49,6 +49,7 @@
     <maven.compiler.source>11</maven.compiler.source>
     <maven.compiler.target>11</maven.compiler.target>
     <maven.version>3.8.7</maven.version>
+    <javaparser.version>3.25.2</javaparser.version>
   </properties>
 
   <developers>
@@ -79,7 +80,7 @@
     <dependency>
       <groupId>com.github.javaparser</groupId>
       <artifactId>javaparser-core</artifactId>
-      <version>3.25.3</version>
+      <version>${javaparser.version}</version>
     </dependency>
     <dependency>
       <groupId>org.apache.maven</groupId>

src/test/java/org/eclipse/jetty/toolchain/modifysources/ModifyEE9ToEE8Test.java

@@ -124,6 +124,9 @@ public void testChangeToEE8()
             assertThat(sourceModified, containsString("private JavaxWebSocketMessageMetadata textMetadata;"));
             assertThat(sourceModified, containsString("private JavaxWebSocketMessageMetadata textMetadata;"));
 
+            assertThat(sourceModified, containsString("int permits = _passes == null ? 0 : _passes.availablePermits();"));
+            assertThat(sourceModified, containsString("_passes = new Semaphore((value - _throttledRequests + permits), true);"));
+
             assertThat(sourceModified,
                     containsString("JavaxWebSocketMessageMetadata actualTextMetadata = JavaxWebSocketMessageMetadata.copyOf(textMetadata);"));
             assertThat(sourceModified,

src/test/resources/project-modify/src/main/java/org/eclipse/jetty/ee9/websocket/jakarta/common/JakartaWebSocketFrameHandler.java

@@ -22,6 +22,7 @@
 import java.util.Map;
 import java.util.Optional;
 import java.util.Set;
+import java.util.concurrent.Semaphore;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.stream.Collectors;
 
@@ -118,6 +119,13 @@ public JakartaWebSocketFrameHandler(JakartaWebSocketContainer container,
         this.endpointConfig = endpointConfig;
     }
 
+    public void setThrottledRequests(int value)
+    {
+        int permits = _passes == null ? 0 : _passes.availablePermits();
+        _passes = new Semaphore((value - _throttledRequests + permits), true);
+        _throttledRequests = value;
+    }
+
     public Object getEndpoint()
     {
         return endpointInstance;