import org.apache.commons.io.IOUtils;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

public class PackerUtils {
    public static void packEntry(DataSource entry, OutputStream outputStream, byte[] buffer) throws IOException {
        InputStream inputStream = entry.openInput();
        try {
            IOUtils.copyLarge(inputStream, outputStream, buffer);

            TarHeader header = TarHeader.createHeader(input.getName(), input.getLength(), 0, false, 0644);
            TarEntry entry = new TarEntry(header);
            tarOutput.putNextEntry(entry);
            PackerUtils.packEntry(input, tarOutput, buffer);
        }
        tarOutput.close();
    }

    @Override
    public void unpack(DataSource input, DataTargetFactory targetFactory) throws IOException {

        for (DataSource input : inputs) {
            ZipEntry entry = new ZipEntry(input.getName());
            entry.setSize(input.getLength());
            zipOutput.putNextEntry(entry);
            PackerUtils.packEntry(input, zipOutput, buffer);
            zipOutput.closeEntry();
        }
        zipOutput.close();
    }

    @Override
    public void unpack(DataSource input, DataTargetFactory targetFactory) throws IOException {

            TarArchiveEntry entry = new TarArchiveEntry(input.getName());
            entry.setSize(input.getLength());
            tarOutput.putArchiveEntry(entry);
            PackerUtils.packEntry(input, tarOutput, buffer);
            tarOutput.closeArchiveEntry();
        }
        tarOutput.close();
    }

    @Override