public class org.apache.nifi.registry.service.extension.StandardExtensionService extends java.lang.Object implements org.apache.nifi.registry.service.extension.ExtensionService { private static final org.slf4j.Logger LOGGER; static final java.lang.String SNAPSHOT_VERSION_SUFFIX; private final org.apache.nifi.registry.serialization.Serializer extensionSerializer; private final org.apache.nifi.registry.service.extension.docs.ExtensionDocWriter extensionDocWriter; private final org.apache.nifi.registry.service.MetadataService metadataService; private final java.util.Map extractors; private final org.apache.nifi.registry.extension.BundlePersistenceProvider bundlePersistenceProvider; private final javax.validation.Validator validator; private final java.io.File extensionsWorkingDir; public void (org.apache.nifi.registry.serialization.Serializer, org.apache.nifi.registry.service.extension.docs.ExtensionDocWriter, org.apache.nifi.registry.service.MetadataService, java.util.Map, org.apache.nifi.registry.extension.BundlePersistenceProvider, javax.validation.Validator, org.apache.nifi.registry.properties.NiFiRegistryProperties) { javax.validation.Validator v, v; org.apache.nifi.registry.extension.BundlePersistenceProvider v, v; org.apache.nifi.registry.serialization.Serializer v, v; java.io.File v, v; org.apache.nifi.registry.service.MetadataService v, v; java.util.Map v, v; org.apache.nifi.registry.properties.NiFiRegistryProperties v; org.apache.nifi.registry.service.extension.docs.ExtensionDocWriter v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: org.apache.nifi.registry.serialization.Serializer; v := @parameter: org.apache.nifi.registry.service.extension.docs.ExtensionDocWriter; v := @parameter: org.apache.nifi.registry.service.MetadataService; v := @parameter: java.util.Map; v := @parameter: org.apache.nifi.registry.extension.BundlePersistenceProvider; v := @parameter: javax.validation.Validator; v := @parameter: org.apache.nifi.registry.properties.NiFiRegistryProperties; specialinvoke v.()>(); v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v = virtualinvoke v.(); v. = v; v = v.; staticinvoke (v); v = v.; staticinvoke (v); v = v.; staticinvoke (v); v = v.; staticinvoke (v); v = v.; staticinvoke (v); v = v.; staticinvoke (v); return; } private void validate(java.lang.Object, java.lang.String) { java.lang.Class[] v; java.util.Set v; javax.validation.Validator v; javax.validation.ConstraintViolationException v; int v; java.lang.Object v; java.lang.String v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.lang.Object; v := @parameter: java.lang.String; v = v.; v = newarray (java.lang.Class)[0]; v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(); if v <= 0 goto label; v = new javax.validation.ConstraintViolationException; specialinvoke v.(java.lang.String,java.util.Set)>(v, v); throw v; label: return; } public org.apache.nifi.registry.extension.bundle.BundleVersion createBundleVersion(java.lang.String, org.apache.nifi.registry.extension.bundle.BundleType, java.io.InputStream, java.lang.String) throws java.io.IOException { byte[] v; org.apache.nifi.registry.service.MetadataService v, v, v, v, v; org.apache.nifi.registry.extension.bundle.BundleVersionMetadata v; java.util.Map v, v; org.apache.nifi.registry.bundle.model.BundleDetails v; java.util.Set v, v; java.lang.Exception v, v; org.apache.nifi.registry.db.entity.BucketEntity v; java.lang.Throwable v, v, v, v; java.lang.Object[] v, v, v, v, v, v, v; long v, v; org.apache.nifi.registry.db.entity.BundleEntity v, v; org.apache.nifi.registry.extension.bundle.BundleType v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.io.FileOutputStream v; java.io.File v, v, v; java.security.DigestInputStream v; java.lang.IllegalStateException v, v, v; org.apache.nifi.registry.bundle.model.BundleIdentifier v; org.apache.nifi.registry.extension.bundle.Bundle v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.registry.db.entity.BundleVersionEntity v, v; java.util.UUID v, v; java.util.List v; org.apache.nifi.registry.extension.bundle.BundleVersion v; org.apache.nifi.registry.bucket.Bucket v; java.security.MessageDigest v; java.util.HashSet v; java.lang.Boolean v; org.apache.nifi.registry.service.extension.StandardExtensionService v; org.slf4j.Logger v, v, v, v, v, v, v, v; java.util.Iterator v; java.io.FileInputStream v; java.lang.IllegalArgumentException v, v, v, v; java.util.function.Consumer v, v, v; org.apache.nifi.registry.extension.bundle.BuildInfo v; java.lang.Object v, v; java.io.InputStream v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.registry.extension.bundle.BundleType; v := @parameter: java.io.InputStream; v := @parameter: java.lang.String; v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifier cannot be null or blank"); throw v; label: if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bundle type cannot be null"); throw v; label: if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Extension bundle input stream cannot be null"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("No metadata extractor is registered for bundle-type: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = specialinvoke v.(v); v = v.; staticinvoke (v); v = staticinvoke (); v = virtualinvoke v.(); v = new java.io.File; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, v); v = ; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; interfaceinvoke v.("Writing bundle contents to working directory at {}", v); label: v = staticinvoke (); v = new java.security.DigestInputStream; specialinvoke v.(java.io.InputStream,java.security.MessageDigest)>(v, v); label: v = new java.io.FileOutputStream; specialinvoke v.(java.io.File)>(v); label: staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; if v == 0 goto label; v = virtualinvoke v.(v); if v != 0 goto label; v = ; v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Client provided SHA-256 of \'{}\', but server calculated \'{}\'", v); v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("The SHA-256 of the received extension bundle does not match the SHA-256 provided by the client"); throw v; label: v = new java.io.FileInputStream; specialinvoke v.(java.io.File)>(v); label: v = v.; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.("SNAPSHOT"); if v != 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: v = v; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Extracted bundle details - \'{}:{}:{}\'", v); v = v.; v = interfaceinvoke v.(v, v, v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Found existing extension bundle with same group, artifact, and version, but different SHA-256 checksums"); throw v; label: v = staticinvoke (); v = specialinvoke v.(v, v, v, v, v); v = v.; v = interfaceinvoke v.(v, v, v, v); if v == null goto label; if v == 0 goto label; v = ; interfaceinvoke v.("Bundle overwriting allowed, deleting existing version..."); v = v.; interfaceinvoke v.(v); goto label; label: v = ; v = newarray (java.lang.Object)[2]; v[0] = v; v = virtualinvoke v.(); v[1] = v; interfaceinvoke v.("The specified version [{}] already exists for extension bundle [{}].", v); v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("The specified version already exists for the given extension bundle"); throw v; label: v = staticinvoke (); v = new org.apache.nifi.registry.extension.bundle.BundleVersionMetadata; specialinvoke v.()>(); v = staticinvoke (); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); v = staticinvoke (v); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); specialinvoke v.(v, "Cannot create extension bundle version"); v = staticinvoke (v); v = v.; interfaceinvoke v.(v); v = specialinvoke v.(v, v); v = staticinvoke (v); interfaceinvoke v.(v); v = specialinvoke v.(v, v); v = staticinvoke (v); interfaceinvoke v.(v); specialinvoke v.(v, v, v, v, v); v = v.; v = interfaceinvoke v.(v, v, v); v = new org.apache.nifi.registry.extension.bundle.BundleVersion; specialinvoke v.()>(); virtualinvoke v.(v); v = staticinvoke (v, v); virtualinvoke v.(v); v = staticinvoke (v); virtualinvoke v.(v); v = new java.util.HashSet; specialinvoke v.()>(); v = staticinvoke (v); interfaceinvoke v.(v); virtualinvoke v.(v); v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Created bundle - \'{}:{}:{}\'", v); label: v = virtualinvoke v.(); if v == 0 goto label; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; interfaceinvoke v.("Error removing temporary extension bundle file at {}", v); label: return v; label: v := @caughtexception; v = virtualinvoke v.(); if v == 0 goto label; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; interfaceinvoke v.("Error removing temporary extension bundle file at {}", v); label: throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; } private java.util.Set getDependencyEntities(org.apache.nifi.registry.db.entity.BundleVersionEntity, org.apache.nifi.registry.bundle.model.BundleDetails) { org.apache.nifi.registry.db.entity.BundleVersionDependencyEntity v; java.util.HashSet v; java.lang.String v, v, v, v, v; org.apache.nifi.registry.bundle.model.BundleDetails v; boolean v; org.apache.nifi.registry.service.extension.StandardExtensionService v; java.util.Iterator v; org.apache.nifi.registry.db.entity.BundleVersionEntity v; java.util.Set v, v; java.util.UUID v; org.apache.nifi.registry.extension.bundle.BundleVersionDependency v; java.lang.Object v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: org.apache.nifi.registry.db.entity.BundleVersionEntity; v := @parameter: org.apache.nifi.registry.bundle.model.BundleDetails; v = virtualinvoke v.(); if v != null goto label; v = staticinvoke (); return v; label: v = new java.util.HashSet; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new org.apache.nifi.registry.extension.bundle.BundleVersionDependency; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); specialinvoke v.(v, "Cannot create extension bundle version dependency"); v = staticinvoke (v); v = staticinvoke (); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); interfaceinvoke v.(v); goto label; label: return v; } private java.util.Set getExtensionEntities(org.apache.nifi.registry.db.entity.BundleVersionEntity, org.apache.nifi.registry.bundle.model.BundleDetails) { java.lang.Object[] v; java.util.HashSet v; java.util.Map v; java.lang.String v, v, v, v; org.apache.nifi.registry.bundle.model.BundleDetails v; boolean v, v; org.apache.nifi.registry.service.extension.StandardExtensionService v; org.apache.nifi.registry.db.entity.ExtensionEntity v; org.slf4j.Logger v; java.util.Iterator v; org.apache.nifi.registry.db.entity.BundleVersionEntity v; java.util.Set v, v, v, v, v; java.util.UUID v; org.apache.nifi.registry.serialization.Serializer v; java.util.function.Consumer v, v; java.lang.Object v, v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: org.apache.nifi.registry.db.entity.BundleVersionEntity; v := @parameter: org.apache.nifi.registry.bundle.model.BundleDetails; v = virtualinvoke v.(); if v != null goto label; v = staticinvoke (); return v; label: v = new java.util.HashSet; specialinvoke v.()>(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v, "Invalid extension due to one or more constraint violations"); v = v.; v = staticinvoke (v, v); v = staticinvoke (); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = staticinvoke (v); if v != 0 goto label; v = ; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; interfaceinvoke v.("Found additional details documentation for extension \'{}\'", v); virtualinvoke v.(v); label: interfaceinvoke v.(v); goto label; label: return v; } private org.apache.nifi.registry.db.entity.BundleEntity getOrCreateExtensionBundle(java.lang.String, java.lang.String, java.lang.String, org.apache.nifi.registry.extension.bundle.BundleType, long) { java.lang.IllegalStateException v; long v; org.apache.nifi.registry.extension.bundle.Bundle v; org.apache.nifi.registry.service.MetadataService v, v; org.apache.nifi.registry.db.entity.BundleEntity v, v; org.apache.nifi.registry.extension.bundle.BundleType v, v; java.lang.String v, v, v, v, v; org.apache.nifi.registry.service.extension.StandardExtensionService v; java.util.UUID v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.registry.extension.bundle.BundleType; v := @parameter: long; v = v.; v = interfaceinvoke v.(v, v, v); if v != null goto label; v = new org.apache.nifi.registry.extension.bundle.Bundle; specialinvoke v.()>(); v = staticinvoke (); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); specialinvoke v.(v, "Cannot create extension bundle"); v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == v goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("A bundle already exists with the same group id and artifact id, but a different bundle type"); throw v; label: return v; } private void persistBundleVersionContent(org.apache.nifi.registry.extension.bundle.BundleType, org.apache.nifi.registry.db.entity.BundleEntity, org.apache.nifi.registry.db.entity.BundleVersionEntity, java.io.File, boolean) throws java.io.IOException { java.io.BufferedInputStream v; java.util.Date v; org.apache.nifi.registry.provider.extension.StandardBundlePersistenceContext v; boolean v; org.apache.nifi.registry.db.entity.BundleVersionEntity v; java.lang.Throwable v, v; org.apache.nifi.registry.provider.extension.StandardBundleVersionCoordinate$Builder v, v, v, v, v, v; java.lang.Object[] v, v; org.apache.nifi.registry.extension.BundlePersistenceProvider v, v; long v, v; org.apache.nifi.registry.db.entity.BundleEntity v; org.apache.nifi.registry.extension.bundle.BundleType v; java.lang.String v, v, v, v, v, v, v; org.apache.nifi.registry.provider.extension.StandardBundlePersistenceContext$Builder v, v, v, v, v; org.apache.nifi.registry.extension.BundleVersionType v; org.apache.nifi.registry.service.extension.StandardExtensionService v; org.slf4j.Logger v, v; java.io.FileInputStream v; java.io.File v; org.apache.nifi.registry.provider.extension.StandardBundleVersionCoordinate v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: org.apache.nifi.registry.extension.bundle.BundleType; v := @parameter: org.apache.nifi.registry.db.entity.BundleEntity; v := @parameter: org.apache.nifi.registry.db.entity.BundleVersionEntity; v := @parameter: java.io.File; v := @parameter: boolean; v = new org.apache.nifi.registry.provider.extension.StandardBundleVersionCoordinate$Builder; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = specialinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.nifi.registry.provider.extension.StandardBundlePersistenceContext$Builder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new java.io.FileInputStream; specialinvoke v.(java.io.File)>(v); label: v = new java.io.BufferedInputStream; specialinvoke v.(java.io.InputStream)>(v); label: if v == 0 goto label; v = v.; interfaceinvoke v.(v, v); v = ; v = newarray (java.lang.Object)[1]; v = interfaceinvoke v.(); v[0] = v; interfaceinvoke v.("Bundle version updated in persistence provider - {}", v); goto label; label: v = v.; interfaceinvoke v.(v, v); v = ; v = newarray (java.lang.Object)[1]; v = interfaceinvoke v.(); v[0] = v; interfaceinvoke v.("Bundle version created in persistence provider - {}", v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private org.apache.nifi.registry.extension.BundleVersionType getProviderBundleType(org.apache.nifi.registry.extension.bundle.BundleType) { java.lang.IllegalArgumentException v; int[] v; org.apache.nifi.registry.extension.bundle.BundleType v; int v, v; java.lang.String v, v; org.apache.nifi.registry.extension.BundleVersionType v, v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: org.apache.nifi.registry.extension.bundle.BundleType; v = ; v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 1: goto label; case 2: goto label; default: goto label; }; label: v = ; return v; label: v = ; return v; label: v = new java.lang.IllegalArgumentException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown bundle type: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; } public java.util.List getBundles(java.util.Set, org.apache.nifi.registry.extension.bundle.BundleFilterParams) { org.apache.nifi.registry.extension.bundle.BundleFilterParams v, v; java.util.Set v; java.lang.IllegalArgumentException v; java.util.function.Function v; org.apache.nifi.registry.service.MetadataService v; java.util.List v; java.util.stream.Stream v, v; java.lang.Object v; java.util.stream.Collector v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.registry.extension.bundle.BundleFilterParams; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifiers cannot be null"); throw v; label: v = v.; if v != null goto label; v = staticinvoke (); goto label; label: v = v; label: v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } public java.util.List getBundlesByBucket(java.lang.String) { java.lang.IllegalArgumentException v; java.util.function.Function v; org.apache.nifi.registry.service.MetadataService v; java.util.List v; org.apache.nifi.registry.db.entity.BucketEntity v; java.util.stream.Stream v, v; java.lang.Object v; java.lang.String v; java.util.stream.Collector v; boolean v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.lang.String; v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifier cannot be null or blank"); throw v; label: v = specialinvoke v.(v); v = v.; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } public org.apache.nifi.registry.extension.bundle.Bundle getBundle(java.lang.String) { java.lang.IllegalArgumentException v; org.apache.nifi.registry.extension.bundle.Bundle v; org.apache.nifi.registry.db.entity.BucketEntity v; org.apache.nifi.registry.db.entity.BundleEntity v; java.lang.String v, v; boolean v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.lang.String; v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bundle identifier cannot be null or blank"); throw v; label: v = specialinvoke v.(v); v = virtualinvoke v.(); v = specialinvoke v.(v); v = staticinvoke (v, v); return v; } public org.apache.nifi.registry.extension.bundle.Bundle deleteBundle(org.apache.nifi.registry.extension.bundle.Bundle) { org.apache.nifi.registry.extension.BundlePersistenceProvider v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.extension.bundle.Bundle v; org.apache.nifi.registry.provider.extension.StandardBundleCoordinate$Builder v, v, v, v; org.apache.nifi.registry.service.MetadataService v; org.apache.nifi.registry.provider.extension.StandardBundleCoordinate v; java.lang.String v, v, v, v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: org.apache.nifi.registry.extension.bundle.Bundle; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Extension bundle cannot be null"); throw v; label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = new org.apache.nifi.registry.provider.extension.StandardBundleCoordinate$Builder; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = v.; interfaceinvoke v.(v); return v; } public java.util.SortedSet getBundleVersions(java.util.Set, org.apache.nifi.registry.extension.bundle.BundleVersionFilterParams) { java.util.Set v; java.lang.IllegalArgumentException v; java.util.function.Function v, v; java.util.TreeSet v; org.apache.nifi.registry.service.MetadataService v; java.util.function.Consumer v; java.util.List v; org.apache.nifi.registry.extension.bundle.BundleVersionFilterParams v, v; java.util.Comparator v, v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.registry.extension.bundle.BundleVersionFilterParams; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifiers cannot be null"); throw v; label: v = new java.util.TreeSet; v = staticinvoke (); v = staticinvoke (v); v = staticinvoke (); v = interfaceinvoke v.(v); specialinvoke v.(java.util.Comparator)>(v); v = v.; if v != null goto label; v = staticinvoke (); goto label; label: v = v; label: v = interfaceinvoke v.(v, v); if v == null goto label; v = staticinvoke (v); interfaceinvoke v.(v); label: return v; } public java.util.SortedSet getBundleVersions(java.lang.String) { java.util.SortedSet v; org.apache.nifi.registry.db.entity.BundleEntity v; java.lang.String v; java.lang.IllegalArgumentException v; boolean v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.lang.String; v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Extension bundle identifier cannot be null or blank"); throw v; label: v = specialinvoke v.(v); v = specialinvoke v.(v); return v; } private java.util.SortedSet getExtensionBundleVersionsSet(org.apache.nifi.registry.db.entity.BundleEntity) { java.util.TreeSet v; org.apache.nifi.registry.service.MetadataService v; java.util.function.Consumer v; java.util.List v; java.util.stream.Stream v; org.apache.nifi.registry.db.entity.BundleEntity v; java.lang.String v; java.util.Comparator v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: org.apache.nifi.registry.db.entity.BundleEntity; v = new java.util.TreeSet; v = staticinvoke (); specialinvoke v.(java.util.Comparator)>(v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); label: return v; } public org.apache.nifi.registry.extension.bundle.BundleVersion getBundleVersion(java.lang.String, java.lang.String, java.lang.String) { java.lang.IllegalStateException v; java.lang.Object[] v; org.apache.nifi.registry.service.MetadataService v; org.apache.nifi.registry.db.entity.BundleEntity v; org.apache.nifi.registry.exception.ResourceNotFoundException v; java.lang.String v, v, v, v, v; boolean v, v, v, v; org.apache.nifi.registry.service.extension.StandardExtensionService v; org.slf4j.Logger v; org.apache.nifi.registry.db.entity.BundleVersionEntity v; java.lang.IllegalArgumentException v, v, v; org.apache.nifi.registry.db.entity.BucketEntity v; org.apache.nifi.registry.extension.bundle.BundleVersion v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket id cannot be null or blank"); throw v; label: v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bundle id cannot be null or blank"); throw v; label: v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Version cannot be null or blank"); throw v; label: v = specialinvoke v.(v); v = specialinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("The requested bundle is not located in the given bucket"); throw v; label: v = v.; v = interfaceinvoke v.(v, v); if v != null goto label; v = ; v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("The specified version [{}] does not exist for extension bundle [{}].", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified extension bundle version does not exist."); throw v; label: v = specialinvoke v.(v, v, v); return v; } public org.apache.nifi.registry.extension.bundle.BundleVersion getBundleVersion(java.lang.String, java.lang.String, java.lang.String, java.lang.String) { java.lang.Object[] v, v; org.apache.nifi.registry.service.MetadataService v, v; org.apache.nifi.registry.db.entity.BundleEntity v; org.apache.nifi.registry.exception.ResourceNotFoundException v, v; java.lang.String v, v, v, v; boolean v, v, v, v; org.apache.nifi.registry.service.extension.StandardExtensionService v; org.slf4j.Logger v, v; org.apache.nifi.registry.db.entity.BundleVersionEntity v; java.lang.IllegalArgumentException v, v, v, v; org.apache.nifi.registry.db.entity.BucketEntity v; org.apache.nifi.registry.extension.bundle.BundleVersion v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket id cannot be null or blank"); throw v; label: v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Group id cannot be null or blank"); throw v; label: v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Artifact id cannot be null or blank"); throw v; label: v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Version cannot be null or blank"); throw v; label: v = specialinvoke v.(v); v = v.; v = interfaceinvoke v.(v, v, v); if v != null goto label; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("The specified extension bundle [{}-{}-{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified extension bundle does not exist in this bucket."); throw v; label: v = v.; v = interfaceinvoke v.(v, v, v, v); if v != null goto label; v = ; v = newarray (java.lang.Object)[4]; v[0] = v; v[1] = v; v[2] = v; v[3] = v; interfaceinvoke v.("The specified extension bundle version [{}-{}-{}-{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified extension bundle version does not exist in this bucket."); throw v; label: v = specialinvoke v.(v, v, v); return v; } private org.apache.nifi.registry.extension.bundle.BundleVersion getBundleVersion(org.apache.nifi.registry.db.entity.BucketEntity, org.apache.nifi.registry.db.entity.BundleEntity, org.apache.nifi.registry.db.entity.BundleVersionEntity) { org.apache.nifi.registry.bucket.Bucket v; org.apache.nifi.registry.extension.bundle.Bundle v; java.util.function.Function v; org.apache.nifi.registry.service.MetadataService v; org.apache.nifi.registry.extension.bundle.BundleVersionMetadata v; org.apache.nifi.registry.db.entity.BundleEntity v; java.lang.String v; java.util.stream.Collector v; org.apache.nifi.registry.service.extension.StandardExtensionService v; org.apache.nifi.registry.db.entity.BundleVersionEntity v; java.util.List v; org.apache.nifi.registry.db.entity.BucketEntity v; java.util.stream.Stream v, v; java.lang.Object v; org.apache.nifi.registry.extension.bundle.BundleVersion v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: org.apache.nifi.registry.db.entity.BucketEntity; v := @parameter: org.apache.nifi.registry.db.entity.BundleEntity; v := @parameter: org.apache.nifi.registry.db.entity.BundleVersionEntity; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = new org.apache.nifi.registry.extension.bundle.BundleVersion; specialinvoke v.()>(); v = staticinvoke (v); virtualinvoke v.(v); v = staticinvoke (v, v); virtualinvoke v.(v); v = staticinvoke (v); virtualinvoke v.(v); virtualinvoke v.(v); return v; } public void writeBundleVersionContent(org.apache.nifi.registry.extension.bundle.BundleVersion, java.io.OutputStream) { java.io.OutputStream v; org.apache.nifi.registry.extension.BundleVersionCoordinate v; org.apache.nifi.registry.extension.BundlePersistenceProvider v; org.apache.nifi.registry.extension.bundle.BundleVersion v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: org.apache.nifi.registry.extension.bundle.BundleVersion; v := @parameter: java.io.OutputStream; v = specialinvoke v.(v); v = v.; interfaceinvoke v.(v, v); return; } public org.apache.nifi.registry.extension.bundle.BundleVersion deleteBundleVersion(org.apache.nifi.registry.extension.bundle.BundleVersion) { org.apache.nifi.registry.extension.BundleVersionCoordinate v; org.apache.nifi.registry.extension.BundlePersistenceProvider v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.service.MetadataService v; org.apache.nifi.registry.extension.bundle.BundleVersionMetadata v; org.apache.nifi.registry.extension.bundle.BundleVersion v; java.lang.String v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: org.apache.nifi.registry.extension.bundle.BundleVersion; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Extension bundle version cannot be null"); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; interfaceinvoke v.(v); v = specialinvoke v.(v); v = v.; interfaceinvoke v.(v); return v; } public java.util.SortedSet getExtensionMetadata(java.util.Set, org.apache.nifi.extension.ExtensionFilterParams) { java.util.List v; java.util.SortedSet v; org.apache.nifi.extension.ExtensionFilterParams v; java.util.Set v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.service.MetadataService v; org.apache.nifi.registry.service.extension.StandardExtensionService v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.extension.ExtensionFilterParams; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifiers cannot be null"); throw v; label: v = v.; v = interfaceinvoke v.(v, v); v = specialinvoke v.(v); return v; } public java.util.SortedSet getExtensionMetadata(java.util.Set, org.apache.nifi.extension.manifest.ProvidedServiceAPI) { java.util.SortedSet v; org.apache.nifi.registry.service.MetadataService v; java.lang.String v, v, v, v; boolean v, v, v, v; org.apache.nifi.registry.service.extension.StandardExtensionService v; java.util.Set v; java.lang.IllegalArgumentException v, v; org.apache.nifi.extension.manifest.ProvidedServiceAPI v; java.util.List v; v := @this: org.apache.nifi.registry.service.extension.StandardExtensionService; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.extension.manifest.ProvidedServiceAPI; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifiers cannot be null"); throw v; label: if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.