private DistributionPackage toDistributionPackage()

in src/main/java/org/apache/sling/distribution/journal/bookkeeper/PackageHandler.java [71:85]

• 15 lines of code
• 2 McCabe index (conditional complexity)

    private DistributionPackage toDistributionPackage(PackageMessage pkgMsg)
            throws DistributionException {
        LOG.debug("Importing paths {}",pkgMsg.getPaths());
        final byte[] data;
        try (InputStream inputStream = stream(pkgMsg)) {
            data = toByteArray(inputStream);
        } catch (IOException e) {
            throw new DistributionException("Failed to download package from binary store", e);
        }
        DistributionPackageInfo distributionPackageInfo = new DistributionPackageInfo(pkgMsg.getPkgType());
        distributionPackageInfo.put(PROPERTY_REQUEST_PATHS, pkgMsg.getPaths().toArray());
        distributionPackageInfo.put(PROPERTY_REQUEST_DEEP_PATHS, pkgMsg.getDeepPaths().toArray());
        distributionPackageInfo.put(PROPERTY_REQUEST_TYPE, pkgMsg.getReqType());
        return new JournalDistributionPackage(pkgMsg.getPkgId(), pkgMsg.getPkgType(), data, distributionPackageInfo);
    }