* See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle.caching.internal.tasks;

public interface DataTargetFactory {
    DataTarget createDataTarget(String name);

        return directoryProvider.getRoot(level).resolve(name);
    }

    @Override
    public DataTargetFactory createTargetFactory(final String root, Level level) throws IOException {
        final Path rootDir = Files.createTempDirectory(directoryProvider.getRoot(level), root);
        return new DataTargetFactory() {
            @Override
            public DataTarget createDataTarget(String name) {

    }

    @Override
    public DataTarget createTarget(String name, Level level) {
        return new Target(name);
    }

    @Override
    public DataTargetFactory createTargetFactory(final String root, Level level) {
        return new DataTargetFactory() {
            @Override
            public DataTarget createDataTarget(String name) {
                return new Target(root + "/" + name);
            }
        };

import java.io.IOException;

public interface DataAccessor {
    DataSource createSource(String name, byte[] bytes, Level level) throws IOException;
    DataTarget createTarget(String name, Level level);
    DataTargetFactory createTargetFactory(String root, Level level) throws IOException;

import java.io.IOException;
import java.util.List;

interface Packer {
    void pack(List<DataSource> inputs, DataTarget output) throws IOException;
    void unpack(DataSource input, DataTargetFactory targetFactory) throws IOException;

                return new SnappyFramedOutputStream(super.openOutput());
            }
        });
    }

    @Override
    public void unpack(DataSource input, DataTargetFactory targetFactory) throws IOException {
        delegate.unpack(new DelegatingDataSource(input) {
            @Override
            public InputStream openInput() throws IOException {

                return new SnappyFramedOutputStream(super.openOutput());
            }
        });
    }

    @Override
    public void unpack(DataSource input, DataTargetFactory targetFactory) throws IOException {
        delegate.unpack(new DelegatingDataSource(input) {
            @Override
            public InputStream openInput() throws IOException {

            PackerUtils.packEntry(input, tarOutput, buffer);
            tarOutput.closeArchiveEntry();
        }
        tarOutput.close();
    }

    @Override
    public void unpack(DataSource input, DataTargetFactory targetFactory) throws IOException {
        TarArchiveInputStream tarInput = new TarArchiveInputStream(input.openInput());
        while (true) {
            TarArchiveEntry entry = tarInput.getNextEntry();

        } finally {
            inputStream.close();
        }
    }

    public static void unpackEntry(String name, InputStream inputStream, byte[] buffer, DataTargetFactory targetFactory) throws IOException {
        DataTarget target = targetFactory.createDataTarget(name);
        OutputStream outputStream = target.openOutput();
        try {

                return new GZIPOutputStream(super.openOutput());
            }
        });
    }

    @Override
    public void unpack(DataSource input, DataTargetFactory targetFactory) throws IOException {
        delegate.unpack(new DelegatingDataSource(input) {
            @Override
            public InputStream openInput() throws IOException {