Commit b7569651 authored by Riegel's avatar Riegel
Browse files

Refactor: Rename CityGmlZipInputStream

parent caf28d22
Showing with 16 additions and 16 deletions
+16 -16
...@@ -39,7 +39,7 @@ import javax.xml.validation.SchemaFactory; ...@@ -39,7 +39,7 @@ import javax.xml.validation.SchemaFactory;
import javax.xml.validation.Validator; import javax.xml.validation.Validator;
import de.hft.stuttgart.citydoctor2.zip.CityGmlZipEntry; import de.hft.stuttgart.citydoctor2.zip.CityGmlZipEntry;
import de.hft.stuttgart.citydoctor2.zip.CityGmlZipInputStream; import de.hft.stuttgart.citydoctor2.zip.CityGmlZipEntryFile;
import org.apache.logging.log4j.Level; import org.apache.logging.log4j.Level;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
...@@ -199,8 +199,8 @@ public class CityGmlParser { ...@@ -199,8 +199,8 @@ public class CityGmlParser {
CityGMLContext context = getContext(); CityGMLContext context = getContext();
if (config.getValidate()) { if (config.getValidate()) {
try (CityGmlZipInputStream cgis = new CityGmlZipInputStream(entry)){ try (CityGmlZipEntryFile entryFile = new CityGmlZipEntryFile(entry)){
List<String> messages = validateStream(cgis.getInputStream(),context); List<String> messages = validateStream(entryFile.getInputStream(),context);
if (!messages.isEmpty()) { if (!messages.isEmpty()) {
throw new InvalidGmlFileException("Invalid GML File. First error: \n" + messages.get(0)); throw new InvalidGmlFileException("Invalid GML File. First error: \n" + messages.get(0));
} }
...@@ -220,8 +220,8 @@ public class CityGmlParser { ...@@ -220,8 +220,8 @@ public class CityGmlParser {
public static CityDoctorModel decompressAndParseCityGmlEntry(CityGmlZipEntry entry, ParserConfiguration config, ProgressListener l, CityGMLContext context) public static CityDoctorModel decompressAndParseCityGmlEntry(CityGmlZipEntry entry, ParserConfiguration config, ProgressListener l, CityGMLContext context)
throws CityGmlParseException { throws CityGmlParseException {
try (CityGmlZipInputStream cgis = new CityGmlZipInputStream(entry)){ try (CityGmlZipEntryFile entryFile = new CityGmlZipEntryFile(entry)){
BufferedInputStream bis = new BufferedInputStream(cgis.getInputStream()); BufferedInputStream bis = new BufferedInputStream(entryFile.getInputStream());
readEpsgCodeFromInputStream(bis,config); readEpsgCodeFromInputStream(bis,config);
CityGMLInputFactory in = context.createCityGMLInputFactory() CityGMLInputFactory in = context.createCityGMLInputFactory()
.withChunking(ChunkOptions.chunkByProperties(chunkProperties).skipCityModel(false)); .withChunking(ChunkOptions.chunkByProperties(chunkProperties).skipCityModel(false));
...@@ -294,8 +294,8 @@ public class CityGmlParser { ...@@ -294,8 +294,8 @@ public class CityGmlParser {
public static void streamCityGml(CityGmlZipEntry entry, ParserConfiguration config, CityGmlConsumer cityObjectConsumer, public static void streamCityGml(CityGmlZipEntry entry, ParserConfiguration config, CityGmlConsumer cityObjectConsumer,
String outputFile) throws CityGmlParseException, IOException { String outputFile) throws CityGmlParseException, IOException {
try (CityGmlZipInputStream cgis = new CityGmlZipInputStream(entry)) { try (CityGmlZipEntryFile entryFile = new CityGmlZipEntryFile(entry)) {
parseEpsgCodeFromStream(cgis.getInputStream(), config); parseEpsgCodeFromStream(entryFile.getInputStream(), config);
startReadingCityGmlZipEntry(entry, config, null,cityObjectConsumer, outputFile); startReadingCityGmlZipEntry(entry, config, null,cityObjectConsumer, outputFile);
} catch (ParserConfigurationException | SAXException | IOException e) { } catch (ParserConfigurationException | SAXException | IOException e) {
throw new CityGmlParseException("Failed to read CityGML stream", e); throw new CityGmlParseException("Failed to read CityGML stream", e);
...@@ -360,8 +360,8 @@ public class CityGmlParser { ...@@ -360,8 +360,8 @@ public class CityGmlParser {
private static void startReadingCityGmlZipEntry(CityGmlZipEntry entry, ParserConfiguration config, ProgressListener l, private static void startReadingCityGmlZipEntry(CityGmlZipEntry entry, ParserConfiguration config, ProgressListener l,
CityGmlConsumer cityObjectConsumer, String outputFile) { CityGmlConsumer cityObjectConsumer, String outputFile) {
try (CityGmlZipInputStream cgis = new CityGmlZipInputStream(entry); try (CityGmlZipEntryFile entryFile = new CityGmlZipEntryFile(entry);
ObservedInputStream ois = new ObservedInputStream(cgis.getInputStream(), entry.getFileSize())){ ObservedInputStream ois = new ObservedInputStream(entryFile.getInputStream(), entry.getFileSize())){
if (l != null) { if (l != null) {
ois.addListener(l::updateProgress); ois.addListener(l::updateProgress);
} }
......
...@@ -71,8 +71,8 @@ public class CityGmlZipEntry implements Serializable { ...@@ -71,8 +71,8 @@ public class CityGmlZipEntry implements Serializable {
if (fileSize != -1L) { if (fileSize != -1L) {
return memoryLimit > fileSize; return memoryLimit > fileSize;
} }
try (CityGmlZipInputStream cgis = new CityGmlZipInputStream(this)){ try (CityGmlZipEntryFile entryFile = new CityGmlZipEntryFile(this)){
long filesize = cgis.getFileSize(); long filesize = entryFile.getFileSize();
if (filesize != -1){ if (filesize != -1){
this.fileSize = filesize; this.fileSize = filesize;
return memoryLimit > fileSize; return memoryLimit > fileSize;
......
...@@ -6,14 +6,14 @@ import java.io.InputStream; ...@@ -6,14 +6,14 @@ import java.io.InputStream;
import java.util.zip.ZipEntry; import java.util.zip.ZipEntry;
import java.util.zip.ZipFile; import java.util.zip.ZipFile;
public class CityGmlZipInputStream implements AutoCloseable { public class CityGmlZipEntryFile implements AutoCloseable {
private final ZipFile zip; private final ZipFile zip;
private final ZipEntry zipEntry; private final ZipEntry zipEntry;
private boolean closed = false; private boolean closed = false;
private static final long MB = 1024 * 1024L; private static final long MB = 1024 * 1024L;
public CityGmlZipInputStream(CityGmlZipEntry entry) throws IOException { public CityGmlZipEntryFile(CityGmlZipEntry entry) throws IOException {
CityGmlZipArchive archive = entry.getArchive(); CityGmlZipArchive archive = entry.getArchive();
zip = new ZipFile(archive.getArchivePath().toFile()); zip = new ZipFile(archive.getArchivePath().toFile());
zipEntry = zip.getEntry(entry.getFileName()); zipEntry = zip.getEntry(entry.getFileName());
......
...@@ -49,7 +49,7 @@ import javax.xml.transform.sax.SAXResult; ...@@ -49,7 +49,7 @@ import javax.xml.transform.sax.SAXResult;
import javax.xml.transform.stream.StreamSource; import javax.xml.transform.stream.StreamSource;
import de.hft.stuttgart.citydoctor2.zip.CityGmlZipEntry; import de.hft.stuttgart.citydoctor2.zip.CityGmlZipEntry;
import de.hft.stuttgart.citydoctor2.zip.CityGmlZipInputStream; import de.hft.stuttgart.citydoctor2.zip.CityGmlZipEntryFile;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
...@@ -754,8 +754,8 @@ public class Checker { ...@@ -754,8 +754,8 @@ public class Checker {
PdfStreamReporter pdfReporter = getPdfReporter(config, pdfBos, fileName); PdfStreamReporter pdfReporter = getPdfReporter(config, pdfBos, fileName);
// execute schematron first // execute schematron first
try (CityGmlZipInputStream cgis = new CityGmlZipInputStream(entry)) { try (CityGmlZipEntryFile entryFile = new CityGmlZipEntryFile(entry)) {
SvrlContentHandler handler = executeSchematronValidationIfAvailable(config, cgis.getInputStream()); SvrlContentHandler handler = executeSchematronValidationIfAvailable(config, entryFile.getInputStream());
CityGmlConsumer con = new StreamCityGmlConsumer(c, xmlReporter, pdfReporter, handler, config, null); CityGmlConsumer con = new StreamCityGmlConsumer(c, xmlReporter, pdfReporter, handler, config, null);
// parse and validate // parse and validate
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment