topchetoeu/j2s
1
0
Fork 0
Code Issues 6 Pull Requests Actions Packages Projects Releases 74 Wiki Activity

fix: messages larger than 64KB are now fragmented properly

Browse Source
This commit is contained in:
TopchetoEU 2023-11-04 11:41:31 +02:00
parent 4f82574b8c
commit f856cdf37e
Signed by: topchetoeu
GPG Key ID: 6531B8583E5F6ED4
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/me/topchetoeu/jscript/engine/debug/WebSocket.java
View File

@ -87,15 +87,18 @@ public class WebSocket implements AutoCloseable {
} }
private synchronized void write(int type, byte[] data) { private synchronized void write(int type, byte[] data) {
try { try {
for (int i = 0; i < (data.length >> 16); i++) { int i;
for (i = 0; i < data.length / 0xFFFF; i++) {
out().write(type); out().write(type);
writeLength(0xFFFF); writeLength(0xFFFF);
out().write(data, i << 16, 0xFFFF); out().write(data, i * 0xFFFF, 0xFFFF);
type = 0;
} }
out().write(type | 0x80); out().write(type | 0x80);
writeLength(data.length & 0xFFFF); writeLength(data.length % 0xFFFF);
out().write(data, data.length & 0xFFFF0000, data.length & 0xFFFF); out().write(data, i * 0xFFFF, data.length % 0xFFFF);
} }
catch (IOException e) { catch (IOException e) {
throw new UncheckedIOException(e); throw new UncheckedIOException(e);
@ -116,7 +119,7 @@ public class WebSocket implements AutoCloseable {
} }
public void send(Object data) { public void send(Object data) {
// TODO: Remove // TODO: Remove
System.out.println("SEND: " + data); // System.out.println("SEND: " + data);
if (closed) throw new IllegalStateException("Object is closed."); if (closed) throw new IllegalStateException("Object is closed.");
write(1, data.toString().getBytes()); write(1, data.toString().getBytes());
} }
@ -199,7 +202,7 @@ public class WebSocket implements AutoCloseable {
var raw = data.toByteArray(); var raw = data.toByteArray();
// TODO: Remove // TODO: Remove
System.out.println("RECEIVED: " + new String(raw)); // System.out.println("RECEIVED: " + new String(raw));
if (type == 1) return new WebSocketMessage(new String(raw)); if (type == 1) return new WebSocketMessage(new String(raw));