package org.reflections.vfs;
import org.reflections.ReflectionsException;
import org.reflections.util.Utils;
import java.io.IOException;
import java.net.URL;
import java.util.Iterator;
import java.util.jar.JarInputStream;
import java.util.zip.ZipEntry;
public class JarInputDir implements Vfs.Dir {
private final URL url;
JarInputStream jarInputStream;
long cursor = 0;
long nextCursor = 0;
public JarInputDir(URL url) {
this.url = url;
}
public String getPath() {
return url.getPath();
}
public Iterable<Vfs.File> getFiles() {
return () -> new Iterator<Vfs.File>() {
{
try { jarInputStream = new JarInputStream(url.openConnection().getInputStream()); }
catch (Exception e) { throw new ReflectionsException("Could not open url connection", e); }
}
Vfs.File entry = null;
@Override
public boolean hasNext() {
return entry != null || (entry = computeNext()) != null;
}
@Override
public Vfs.File next() {
Vfs.File next = entry;
entry = null;
return next;
}
private Vfs.File computeNext() {
while (true) {
try {
ZipEntry entry = jarInputStream.getNextJarEntry();
if (entry == null) {
return null;
}
long size = entry.getSize();
if (size < 0) size = 0xffffffffl + size;
nextCursor += size;
if (!entry.isDirectory()) {
return new JarInputFile(entry, JarInputDir.this, cursor, nextCursor);
}
} catch (IOException e) {
throw new ReflectionsException("could not get next zip entry", e);
}
}
}
};
}
public void close() {
Utils.close(jarInputStream);
}
}