1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package org.apache.commons.compress.archivers.zip;
18
19 import static org.junit.jupiter.api.Assertions.assertEquals;
20 import static org.junit.jupiter.api.Assertions.assertTrue;
21
22 import java.io.ByteArrayInputStream;
23 import java.io.File;
24 import java.io.IOException;
25 import java.io.InputStream;
26 import java.util.concurrent.ExecutionException;
27 import java.util.zip.ZipEntry;
28
29 import org.apache.commons.compress.AbstractTempDirTest;
30 import org.apache.commons.compress.parallel.InputStreamSupplier;
31 import org.apache.commons.compress.utils.IOUtils;
32 import org.junit.jupiter.api.Test;
33
34 public class ScatterSampleTest extends AbstractTempDirTest {
35
36 private void checkFile(final File result) throws IOException {
37 try (ZipFile zipFile = ZipFile.builder().setFile(result).get()) {
38 final ZipArchiveEntry archiveEntry1 = zipFile.getEntries().nextElement();
39 assertEquals("test1.xml", archiveEntry1.getName());
40 try (InputStream inputStream = zipFile.getInputStream(archiveEntry1)) {
41 final byte[] b = new byte[6];
42 final int i = IOUtils.readFully(inputStream, b);
43 assertEquals(5, i);
44 assertEquals('H', b[0]);
45 assertEquals('o', b[4]);
46 }
47 }
48 assertTrue(result.delete());
49 }
50
51 private void createFile(final File result) throws IOException, ExecutionException, InterruptedException {
52 final ScatterSample scatterSample = new ScatterSample(this);
53 final ZipArchiveEntry archiveEntry = new ZipArchiveEntry("test1.xml");
54 archiveEntry.setMethod(ZipEntry.DEFLATED);
55 final InputStreamSupplier supp = () -> new ByteArrayInputStream("Hello".getBytes());
56
57 scatterSample.addEntry(archiveEntry, supp);
58 try (ZipArchiveOutputStream zipArchiveOutputStream = new ZipArchiveOutputStream(result)) {
59 scatterSample.writeTo(zipArchiveOutputStream);
60 }
61 }
62
63 @Test
64 public void testSample() throws Exception {
65 final File result = createTempFile("testSample", "fe");
66 createFile(result);
67 checkFile(result);
68 }
69 }