* 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);

        }
    }

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

        final Path rootDir = Files.createTempDirectory(directoryProvider.getRoot(level), root);
        return new DataTargetFactory() {
            @Override
            public DataTarget createDataTarget(String name) {
                return new Target(rootDir.resolve(name));
            }
        };
    }

    protected abstract InputStream openInput(Path path) throws IOException;

    }

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

    private static class Source implements DataSource {
        private final String name;