Skip to content

Commit 2addf93

Browse files
committed
remove server-side WebSocket implementation from the core and add it to the client.
1 parent 910d0fb commit 2addf93

24 files changed

Lines changed: 6 additions & 2475 deletions

httpcore5-websocket/pom.xml

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -60,11 +60,6 @@
6060
<artifactId>junit-platform-launcher</artifactId>
6161
<scope>test</scope>
6262
</dependency>
63-
<dependency>
64-
<groupId>org.hamcrest</groupId>
65-
<artifactId>hamcrest</artifactId>
66-
<scope>test</scope>
67-
</dependency>
6863
</dependencies>
6964

7065
</project>

httpcore5-websocket/src/main/java/org/apache/hc/core5/websocket/PerMessageDeflateExtension.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828

2929
import java.io.ByteArrayOutputStream;
3030
import java.nio.ByteBuffer;
31+
import java.util.LinkedHashMap;
3132
import java.util.Map;
3233
import java.util.zip.Deflater;
3334
import java.util.zip.Inflater;
@@ -147,7 +148,7 @@ public ByteBuffer encode(final WebSocketFrameType type, final boolean fin, final
147148

148149
@Override
149150
public WebSocketExtensionData getResponseData() {
150-
final Map<String, String> params = new java.util.LinkedHashMap<>();
151+
final Map<String, String> params = new LinkedHashMap<>();
151152
if (serverNoContextTakeover) {
152153
params.put("server_no_context_takeover", null);
153154
}

httpcore5-websocket/src/main/java/org/apache/hc/core5/websocket/WebSocketFrameReader.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
import java.nio.ByteBuffer;
3232
import java.util.Collections;
3333
import java.util.List;
34+
import java.util.function.Predicate;
3435

3536
import org.apache.hc.core5.util.Args;
3637

@@ -131,7 +132,7 @@ WebSocketFrame readFrame() throws IOException {
131132
return new WebSocketFrame(fin, false, false, false, type, data);
132133
}
133134

134-
private WebSocketExtension selectExtension(final java.util.function.Predicate<WebSocketExtension> predicate) {
135+
private WebSocketExtension selectExtension(final Predicate<WebSocketExtension> predicate) {
135136
WebSocketExtension selected = null;
136137
for (final WebSocketExtension extension : extensions) {
137138
if (predicate.test(extension)) {

httpcore5-websocket/src/main/java/org/apache/hc/core5/websocket/WebSocketHandshake.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import java.nio.charset.StandardCharsets;
3030
import java.security.MessageDigest;
3131
import java.util.ArrayList;
32+
import java.util.Base64;
3233
import java.util.List;
3334

3435
import org.apache.hc.core5.http.Header;
@@ -74,7 +75,7 @@ public static String createAcceptKey(final String key) throws WebSocketException
7475
final MessageDigest sha1 = MessageDigest.getInstance("SHA-1");
7576
final String acceptSource = key.trim() + WebSocketConstants.WEBSOCKET_GUID;
7677
final byte[] digest = sha1.digest(acceptSource.getBytes(StandardCharsets.ISO_8859_1));
77-
return java.util.Base64.getEncoder().encodeToString(digest);
78+
return Base64.getEncoder().encodeToString(digest);
7879
} catch (final Exception ex) {
7980
throw new WebSocketException("Unable to compute Sec-WebSocket-Accept", ex);
8081
}

httpcore5-websocket/src/main/java/org/apache/hc/core5/websocket/server/WebSocketContextKeys.java

Lines changed: 0 additions & 35 deletions
This file was deleted.

httpcore5-websocket/src/main/java/org/apache/hc/core5/websocket/server/WebSocketH2Server.java

Lines changed: 0 additions & 99 deletions
This file was deleted.

0 commit comments

Comments
 (0)