Переименованы поля
This commit is contained in:
@@ -22,6 +22,6 @@ public class CtfService {
|
|||||||
|
|
||||||
private boolean mergeAdjacentPackets;
|
private boolean mergeAdjacentPackets;
|
||||||
|
|
||||||
private boolean inflateWebSockets;
|
private boolean parseWebSockets;
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -52,7 +52,7 @@ public class Packet {
|
|||||||
|
|
||||||
private boolean ungzipped;
|
private boolean ungzipped;
|
||||||
|
|
||||||
private boolean webSocketInflated;
|
private boolean webSocketParsed;
|
||||||
|
|
||||||
private byte[] content;
|
private byte[] content;
|
||||||
|
|
||||||
|
|||||||
@@ -36,8 +36,8 @@ public class StreamOptimizer {
|
|||||||
unpackGzip();
|
unpackGzip();
|
||||||
}
|
}
|
||||||
|
|
||||||
if (service.isInflateWebSockets()) {
|
if (service.isParseWebSockets()) {
|
||||||
inflateWebSocket();
|
parseWebSockets();
|
||||||
}
|
}
|
||||||
|
|
||||||
if (service.isUrldecodeHttpRequests()) {
|
if (service.isUrldecodeHttpRequests()) {
|
||||||
@@ -89,7 +89,7 @@ public class StreamOptimizer {
|
|||||||
final List<Packet> cut = packets.subList(start, end);
|
final List<Packet> cut = packets.subList(start, end);
|
||||||
final long timestamp = cut.get(0).getTimestamp();
|
final long timestamp = cut.get(0).getTimestamp();
|
||||||
final boolean ungzipped = cut.stream().anyMatch(Packet::isUngzipped);
|
final boolean ungzipped = cut.stream().anyMatch(Packet::isUngzipped);
|
||||||
final boolean webSocketInflated = cut.stream().anyMatch(Packet::isWebSocketInflated);
|
final boolean webSocketParsed = cut.stream().anyMatch(Packet::isWebSocketParsed);
|
||||||
boolean incoming = cut.get(0).isIncoming();
|
boolean incoming = cut.get(0).isIncoming();
|
||||||
//noinspection OptionalGetWithoutIsPresent
|
//noinspection OptionalGetWithoutIsPresent
|
||||||
final byte[] content = cut.stream()
|
final byte[] content = cut.stream()
|
||||||
@@ -102,7 +102,7 @@ public class StreamOptimizer {
|
|||||||
.incoming(incoming)
|
.incoming(incoming)
|
||||||
.timestamp(timestamp)
|
.timestamp(timestamp)
|
||||||
.ungzipped(ungzipped)
|
.ungzipped(ungzipped)
|
||||||
.webSocketInflated(webSocketInflated)
|
.webSocketParsed(webSocketParsed)
|
||||||
.content(content)
|
.content(content)
|
||||||
.build());
|
.build());
|
||||||
}
|
}
|
||||||
@@ -223,7 +223,7 @@ public class StreamOptimizer {
|
|||||||
.incoming(false)
|
.incoming(false)
|
||||||
.timestamp(cut.get(0).getTimestamp())
|
.timestamp(cut.get(0).getTimestamp())
|
||||||
.ungzipped(true)
|
.ungzipped(true)
|
||||||
.webSocketInflated(false)
|
.webSocketParsed(false)
|
||||||
.content(newContent)
|
.content(newContent)
|
||||||
.build();
|
.build();
|
||||||
} catch (ZipException e) {
|
} catch (ZipException e) {
|
||||||
@@ -235,7 +235,7 @@ public class StreamOptimizer {
|
|||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
private void inflateWebSocket() {
|
private void parseWebSockets() {
|
||||||
if (!packets.get(0).getContentString().contains("HTTP/")) {
|
if (!packets.get(0).getContentString().contains("HTTP/")) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -133,7 +133,7 @@ public class WebSocketsParser {
|
|||||||
.timestamp(lastPacket.getTimestamp())
|
.timestamp(lastPacket.getTimestamp())
|
||||||
.ttl(lastPacket.getTtl())
|
.ttl(lastPacket.getTtl())
|
||||||
.ungzipped(lastPacket.isUngzipped())
|
.ungzipped(lastPacket.isUngzipped())
|
||||||
.webSocketInflated(true)
|
.webSocketParsed(true)
|
||||||
.build()
|
.build()
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user