{
* {@inheritDoc}
* @see org.jboss.shrinkwrap.tar.impl.importer.TarImporterBase#getActualClass()
*/
<<<<<<< HEAD:extension-tar/impl/src/main/java/org/jboss/shrinkwrap/tar/impl/importer/TarImporterBase.java
private I importFrom(final S stream) throws ArchiveImportException
Validate.notNull(stream, "Stream must be specified");
try
{
TarEntry entry;
while ((entry = stream.getNextEntry()) != null)
{
// Get the name
String entryName = entry.getName();
final Archive archive = this.getArchive();
// Handle directories separately
if (entry.isDirectory())
{
archive.addDirectory(entryName);
continue;
}
ByteArrayOutputStream output = new ByteArrayOutputStream(8192);
byte[] content = new byte[4096];
int readBytes;
while ((readBytes = stream.read(content, 0, content.length)) != -1)
{
output.write(content, 0, readBytes);
}
archive.add(new ByteArrayAsset(output.toByteArray()), entryName);
}
}
catch (final RuntimeException re)
{
throw new ArchiveImportException("Could not import stream", re);
}
catch (IOException e)
{
throw new ArchiveImportException("Could not import stream", e);
}
return this.covarientReturn();
}
/**
* {@inheritDoc}
* @see org.jboss.shrinkwrap.api.importer.StreamImporter#importFrom(java.lang.Object)
*/
@Override
public I importFrom(final File file) throws ArchiveImportException
{
Validate.notNull(file, "File must be specified");
if (!file.exists())
{
throw new IllegalArgumentException("Specified file for import does not exist: " + file);
}
if (file.isDirectory())
{
throw new IllegalArgumentException("Specified file for import is a directory: " + file);
}
final S archive;
try
{
archive = this.getInputStreamForFile(file);
}
catch (final IOException e)
{
throw new ArchiveImportException("Could not read archive file " + file, e);
}
return this.importFrom(archive);
}
//-------------------------------------------------------------------------------------||
// Internal Helper Methods ------------------------------------------------------------||
//-------------------------------------------------------------------------------------||
/**
* Obtains an implementation-specific stream to the specified {@link File}
* @param file To open a stream to, must be specified
* @return
* @throws IOException If there was a problem getting an instream to the file
*/
private S getInputStreamForFile(File file) throws IOException
{
assert file != null : "File must be specified";
return this.getInputStreamForRawStream(new FileInputStream(file));
}
=======
@Override
Class getActualClass()
{
return TarGzImporter.class;
}
>>>>>>> 531727916e57b466581d2327684bc5556a9246da:extension-tar/src/main/java/org/jboss/shrinkwrap/tar/impl/importer/TarGzImporterImpl.java
} |