Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merged branch 'jetty-11.0.x' into 'jetty-12.0.x'. 

Signed-off-by: Simone Bordet <simone.bordet@gmail.com>
This commit is contained in:
Simone Bordet 2024-01-08 10:19:20 +01:00
parent 356f400d2e 5d7dc7182d
commit 581f9ae9f4
No known key found for this signature in database
GPG Key ID: 1677D141BCF3584D
5 changed files with 37 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
jetty-core/jetty-http/src/main/java/org/eclipse/jetty/http/MetaData.java
View File

@ -238,26 +238,35 @@ public class MetaData implements Iterable<HttpField>
{
private final String _protocol;
public ConnectRequest(HttpScheme scheme, HostPortHttpField authority, String path, HttpFields headers, String protocol)
public ConnectRequest(HttpScheme scheme, HostPortHttpField authority, String pathQuery, HttpFields headers, String protocol)
{
this(NanoTime.now(), scheme == null ? null : scheme.asString(), authority, path, headers, protocol);
this(scheme == null ? null : scheme.asString(), authority, pathQuery, headers, protocol);
}
public ConnectRequest(long beginNanoTime, HttpScheme scheme, HostPortHttpField authority, String path, HttpFields headers, String protocol)
public ConnectRequest(long beginNanoTime, HttpScheme scheme, HostPortHttpField authority, String pathQuery, HttpFields headers, String protocol)
{
this(beginNanoTime, scheme == null ? null : scheme.asString(), authority, path, headers, protocol);
this(beginNanoTime, scheme == null ? null : scheme.asString(), authority, pathQuery, headers, protocol);
}
public ConnectRequest(String scheme, HostPortHttpField authority, String path, HttpFields headers, String protocol)
public ConnectRequest(String scheme, HostPortHttpField authority, String pathQuery, HttpFields headers, String protocol)
{
this(NanoTime.now(), scheme, authority, path, headers, protocol);
this(NanoTime.now(), scheme, authority, pathQuery, headers, protocol);
}
public ConnectRequest(long beginNanoTime, String scheme, HostPortHttpField authority, String path, HttpFields headers, String protocol)
public ConnectRequest(long beginNanoTime, String scheme, HostPortHttpField authority, String pathQuery, HttpFields headers, String protocol)
{
super(beginNanoTime, HttpMethod.CONNECT.asString(),
HttpURI.build().scheme(scheme).host(authority == null ? null : authority.getHost()).port(authority == null ? -1 : authority.getPort()).pathQuery(path),
HttpVersion.HTTP_2, headers, -1, null);
super(beginNanoTime,
HttpMethod.CONNECT.asString(),
HttpURI.build()
.scheme(scheme)
.host(authority == null ? null : authority.getHost())
.port(authority == null ? -1 : authority.getPort())
.pathQuery(pathQuery),
HttpVersion.HTTP_2,
headers,
-1,
null
);
_protocol = protocol;
}

4
jetty-core/jetty-http2/jetty-http2-client-transport/src/main/java/org/eclipse/jetty/http2/client/transport/internal/HttpSenderOverHTTP2.java
View File

@ -34,6 +34,7 @@ import org.eclipse.jetty.http2.frames.HeadersFrame;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.util.Promise;
import org.eclipse.jetty.util.URIUtil;
public class HttpSenderOverHTTP2 extends HttpSender
{
@ -64,7 +65,8 @@ public class HttpSenderOverHTTP2 extends HttpSender
else
{
HostPortHttpField authority = new HostPortHttpField(request.getHost(), request.getPort());
metaData = new MetaData.ConnectRequest(request.getScheme(), authority, request.getPath(), request.getHeaders(), upgradeProtocol);
String pathQuery = URIUtil.addPathQuery(request.getPath(), request.getQuery());
metaData = new MetaData.ConnectRequest(request.getScheme(), authority, pathQuery, request.getHeaders(), upgradeProtocol);
}
}
else

4
jetty-core/jetty-http3/jetty-http3-client-transport/src/main/java/org/eclipse/jetty/http3/client/transport/internal/HttpSenderOverHTTP3.java
View File

@ -34,6 +34,7 @@ import org.eclipse.jetty.http3.frames.DataFrame;
import org.eclipse.jetty.http3.frames.HeadersFrame;
import org.eclipse.jetty.util.BufferUtil;
import org.eclipse.jetty.util.Callback;
import org.eclipse.jetty.util.URIUtil;
public class HttpSenderOverHTTP3 extends HttpSender
{
@ -64,7 +65,8 @@ public class HttpSenderOverHTTP3 extends HttpSender
else
{
HostPortHttpField authority = new HostPortHttpField(request.getHost(), request.getPort());
metaData = new MetaData.ConnectRequest(request.getScheme(), authority, request.getPath(), request.getHeaders(), upgradeProtocol);
String pathQuery = URIUtil.addPathQuery(request.getPath(), request.getQuery());
metaData = new MetaData.ConnectRequest(request.getScheme(), authority, pathQuery, request.getHeaders(), upgradeProtocol);
}
}
else

7
jetty-ee10/jetty-ee10-websocket/jetty-ee10-websocket-jetty-tests/src/test/java/org/eclipse/jetty/ee10/websocket/tests/WebSocketOverHTTP2Test.java
View File

@ -179,7 +179,7 @@ public class WebSocketOverHTTP2Test
startClient(protocolFn);
EventSocket wsEndPoint = new EventSocket();
URI uri = URI.create("ws://localhost:" + connector.getLocalPort() + "/ws/echo");
URI uri = URI.create("ws://localhost:" + connector.getLocalPort() + "/ws/echo/query?param=value");
Session session = wsClient.connect(wsEndPoint, uri).get(5, TimeUnit.SECONDS);
String text = "websocket";
@ -391,6 +391,11 @@ public class WebSocketOverHTTP2Test
protected void configure(JettyWebSocketServletFactory factory)
{
factory.addMapping("/ws/echo", (request, response) -> new EchoSocket());
factory.addMapping("/ws/echo/query", (request, response) ->
{
assertNotNull(request.getQueryString());
return new EchoSocket();
});
factory.addMapping("/ws/null", (request, response) ->
{
response.sendError(HttpStatus.SERVICE_UNAVAILABLE_503, "null");

7
jetty-ee9/jetty-ee9-websocket/jetty-ee9-websocket-jetty-tests/src/test/java/org/eclipse/jetty/ee9/websocket/tests/WebSocketOverHTTP2Test.java
View File

@ -162,7 +162,7 @@ public class WebSocketOverHTTP2Test
startClient(protocolFn);
EventSocket wsEndPoint = new EventSocket();
URI uri = URI.create("ws://localhost:" + connector.getLocalPort() + "/ws/echo");
URI uri = URI.create("ws://localhost:" + connector.getLocalPort() + "/ws/echo/query?param=value");
Session session = wsClient.connect(wsEndPoint, uri).get(5, TimeUnit.SECONDS);
String text = "websocket";
@ -382,6 +382,11 @@ public class WebSocketOverHTTP2Test
protected void configure(JettyWebSocketServletFactory factory)
{
factory.addMapping("/ws/echo", (request, response) -> new EchoSocket());
factory.addMapping("/ws/echo/query", (request, response) ->
{
assertNotNull(request.getQueryString());
return new EchoSocket();
});
factory.addMapping("/ws/null", (request, response) ->
{
response.sendError(HttpStatus.SERVICE_UNAVAILABLE_503, "null");