diff --git a/src/main/java/ru/serega6531/packmate/service/StreamOptimizer.java b/src/main/java/ru/serega6531/packmate/service/StreamOptimizer.java index c805d04..3374555 100644 --- a/src/main/java/ru/serega6531/packmate/service/StreamOptimizer.java +++ b/src/main/java/ru/serega6531/packmate/service/StreamOptimizer.java @@ -60,7 +60,7 @@ public class StreamOptimizer { if (packetsInRow > 1) { compress(start, i); - i++; // продвигаем указатель на следующий после склеенного блок TODO проверить работу этого + i = start + 1; // продвигаем указатель на следующий после склеенного блок } start = i; packetsInRow = 1; diff --git a/src/test/java/ru/serega6531/packmate/StreamOptimizerTest.java b/src/test/java/ru/serega6531/packmate/StreamOptimizerTest.java index 6fa53a3..4f83ae3 100644 --- a/src/test/java/ru/serega6531/packmate/StreamOptimizerTest.java +++ b/src/test/java/ru/serega6531/packmate/StreamOptimizerTest.java @@ -13,7 +13,12 @@ import static org.junit.jupiter.api.Assertions.*; class StreamOptimizerTest { @Test - public void testUrldecodeRequests() { + void testUnpackGzip() { + //TODO + } + + @Test + void testUrldecodeRequests() { CtfService service = new CtfService(); service.setUrldecodeHttpRequests(true); @@ -27,7 +32,7 @@ class StreamOptimizerTest { } @Test - public void testMergeAdjacentPackets() { + void testMergeAdjacentPackets() { CtfService service = new CtfService(); service.setMergeAdjacentPackets(true); @@ -49,7 +54,9 @@ class StreamOptimizerTest { new StreamOptimizer(service, list).optimizeStream(); assertEquals(4, list.size()); - //TODO + assertEquals(2, list.get(1).getContent().length); + assertEquals(1, list.get(2).getContent().length); + assertEquals(2, list.get(3).getContent().length); } private Packet createPacket(int content, boolean incoming) {