public class org.apache.nifi.registry.service.RegistryService extends java.lang.Object { private static final org.slf4j.Logger LOGGER; private final org.apache.nifi.registry.service.MetadataService metadataService; private final org.apache.nifi.registry.flow.FlowPersistenceProvider flowPersistenceProvider; private final org.apache.nifi.registry.extension.BundlePersistenceProvider bundlePersistenceProvider; private final org.apache.nifi.registry.serialization.FlowContentSerializer flowContentSerializer; private final javax.validation.Validator validator; private final org.apache.nifi.registry.service.alias.RegistryUrlAliasService registryUrlAliasService; public void (org.apache.nifi.registry.service.MetadataService, org.apache.nifi.registry.flow.FlowPersistenceProvider, org.apache.nifi.registry.extension.BundlePersistenceProvider, org.apache.nifi.registry.serialization.FlowContentSerializer, javax.validation.Validator, org.apache.nifi.registry.service.alias.RegistryUrlAliasService) { org.apache.nifi.registry.flow.FlowPersistenceProvider v; org.apache.nifi.registry.serialization.FlowContentSerializer v; javax.validation.Validator v; org.apache.nifi.registry.extension.BundlePersistenceProvider v; org.apache.nifi.registry.service.MetadataService v; org.apache.nifi.registry.service.alias.RegistryUrlAliasService v; java.lang.Object v, v, v, v, v, v; org.apache.nifi.registry.service.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: org.apache.nifi.registry.service.MetadataService; v := @parameter: org.apache.nifi.registry.flow.FlowPersistenceProvider; v := @parameter: org.apache.nifi.registry.extension.BundlePersistenceProvider; v := @parameter: org.apache.nifi.registry.serialization.FlowContentSerializer; v := @parameter: javax.validation.Validator; v := @parameter: org.apache.nifi.registry.service.alias.RegistryUrlAliasService; specialinvoke v.()>(); v = staticinvoke (v); v. = v; v = staticinvoke (v); v. = v; v = staticinvoke (v); v. = v; v = staticinvoke (v); v. = v; v = staticinvoke (v); v. = v; v = staticinvoke (v); v. = 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.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; 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.bucket.Bucket createBucket(org.apache.nifi.registry.bucket.Bucket) { java.lang.IllegalStateException v; org.apache.nifi.registry.bucket.Bucket v, v; long v; org.apache.nifi.registry.service.MetadataService v, v; int v; java.lang.Boolean v, v, v, v; java.lang.String v; java.lang.IllegalArgumentException v; java.util.List v; org.apache.nifi.registry.db.entity.BucketEntity v, v; org.apache.nifi.registry.service.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: org.apache.nifi.registry.bucket.Bucket; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket cannot be null"); throw v; label: v = staticinvoke (); virtualinvoke v.(v); v = virtualinvoke v.(); if v != null goto label; v = staticinvoke (0); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v != null goto label; v = staticinvoke (0); virtualinvoke v.(v); label: specialinvoke v.(v, "Cannot create Bucket"); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v <= 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("A bucket with the same name already exists"); throw v; label: v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (v); return v; } public org.apache.nifi.registry.bucket.Bucket getBucket(java.lang.String) { org.apache.nifi.registry.bucket.Bucket v; org.slf4j.Logger v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.service.MetadataService v; org.apache.nifi.registry.db.entity.BucketEntity v; org.apache.nifi.registry.exception.ResourceNotFoundException v; java.lang.String v; org.apache.nifi.registry.service.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: java.lang.String; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifier cannot be null"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified bucket id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket ID does not exist in this registry."); throw v; label: v = staticinvoke (v); return v; } public void verifyBucketExists(java.lang.String) { org.apache.nifi.registry.db.entity.BucketEntity v; org.slf4j.Logger v; org.apache.nifi.registry.exception.ResourceNotFoundException v; java.lang.String v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.service.RegistryService v; org.apache.nifi.registry.service.MetadataService v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: java.lang.String; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifier cannot be null"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified bucket id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket ID does not exist in this registry."); throw v; label: return; } public org.apache.nifi.registry.bucket.Bucket getBucketByName(java.lang.String) { org.apache.nifi.registry.bucket.Bucket v; org.slf4j.Logger v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.service.MetadataService v; java.util.List v; org.apache.nifi.registry.exception.ResourceNotFoundException v; java.lang.Object v; java.lang.String v; org.apache.nifi.registry.service.RegistryService v; boolean v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: java.lang.String; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket name cannot be null"); throw v; label: v = v.; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("The specified bucket name [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket name does not exist in this registry."); throw v; label: v = interfaceinvoke v.(0); v = staticinvoke (v); return v; } public java.util.List getBuckets() { 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.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } public java.util.List getBuckets(java.util.Set) { java.util.Set 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.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: java.util.Set; v = v.; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } public org.apache.nifi.registry.bucket.Bucket updateBucket(org.apache.nifi.registry.bucket.Bucket) { java.lang.IllegalStateException v; org.apache.nifi.registry.service.MetadataService v, v, v; boolean v, v, v, v, v, v, v; java.util.List v; org.apache.nifi.registry.db.entity.BucketEntity v, v; org.apache.nifi.registry.bucket.Bucket v, v; org.apache.nifi.registry.exception.ResourceNotFoundException v; java.lang.Boolean v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v; java.util.Iterator v; java.lang.IllegalArgumentException v, v, v; java.lang.Object v; org.apache.nifi.registry.service.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: org.apache.nifi.registry.bucket.Bucket; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket cannot be null"); throw v; label: v = virtualinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifier cannot be null"); throw v; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket name cannot be blank"); throw v; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("The specified bucket id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket ID does not exist in this registry."); throw v; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = new java.lang.IllegalStateException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("A bucket with the same name already exists - \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = interfaceinvoke v.(v); v = staticinvoke (v); return v; } public org.apache.nifi.registry.bucket.Bucket deleteBucket(java.lang.String) { org.apache.nifi.registry.service.MetadataService v, v, v, v; boolean v, v; java.util.List v, v; org.apache.nifi.registry.db.entity.BucketEntity v; org.apache.nifi.registry.bucket.Bucket v; org.apache.nifi.registry.extension.BundlePersistenceProvider v; org.apache.nifi.registry.exception.ResourceNotFoundException v; java.lang.String v, v, v, v, v, v, v; org.slf4j.Logger v; java.util.Iterator v, v; org.apache.nifi.registry.flow.FlowPersistenceProvider v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.provider.extension.StandardBundleCoordinate$Builder v, v, v, v; org.apache.nifi.registry.provider.extension.StandardBundleCoordinate v; java.lang.Object v, v; org.apache.nifi.registry.service.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: java.lang.String; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifier cannot be null"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified bucket id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket ID does not exist in this registry."); throw v; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke 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); goto label; label: v = v.; interfaceinvoke v.(v); v = staticinvoke (v); return v; } public java.util.List getBucketItems(java.lang.String) { org.slf4j.Logger v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.service.MetadataService v, v; java.util.ArrayList v; java.util.function.Consumer v; java.util.List v; org.apache.nifi.registry.db.entity.BucketEntity v; java.util.stream.Stream v; org.apache.nifi.registry.exception.ResourceNotFoundException v; java.lang.String v, v; org.apache.nifi.registry.service.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: java.lang.String; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifier cannot be null"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified bucket id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket ID does not exist in this registry."); throw v; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v, v); interfaceinvoke v.(v); return v; } public java.util.List getBucketItems(java.util.Set) { java.util.Set v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.service.MetadataService v; java.util.ArrayList v; java.util.function.Consumer v; java.util.List v; java.util.stream.Stream v; org.apache.nifi.registry.service.RegistryService v; boolean v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: java.util.Set; if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifiers cannot be null or empty"); throw v; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v, v); interfaceinvoke v.(v); return v; } private void addBucketItem(java.util.List, org.apache.nifi.registry.db.entity.BucketItemEntity) { org.slf4j.Logger v; org.apache.nifi.registry.extension.bundle.Bundle v; org.apache.nifi.registry.flow.VersionedFlow v; java.util.List v; org.apache.nifi.registry.db.entity.BucketItemEntity v; java.lang.Class v; java.lang.String v, v; org.apache.nifi.registry.service.RegistryService v; boolean v, v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: java.util.List; v := @parameter: org.apache.nifi.registry.db.entity.BucketItemEntity; v = v instanceof org.apache.nifi.registry.db.entity.FlowEntity; if v == 0 goto label; v = staticinvoke (null, v); interfaceinvoke v.(v); goto label; label: v = v instanceof org.apache.nifi.registry.db.entity.BundleEntity; if v == 0 goto label; v = staticinvoke (null, v); interfaceinvoke v.(v); goto label; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown type of BucketItemEntity: \u0001"); interfaceinvoke v.(v); label: return; } public org.apache.nifi.registry.flow.VersionedFlow createFlow(java.lang.String, org.apache.nifi.registry.flow.VersionedFlow) { java.lang.IllegalStateException v; long v; org.apache.nifi.registry.service.MetadataService v, v, v; org.apache.nifi.registry.db.entity.FlowEntity v, v; org.apache.nifi.registry.exception.ResourceNotFoundException v; int v; java.lang.String v, v, v, v, v, v, v; boolean v, v; org.slf4j.Logger v; java.lang.IllegalArgumentException v, v, v; org.apache.nifi.registry.flow.VersionedFlow v, v; java.util.List v; org.apache.nifi.registry.db.entity.BucketEntity v; org.apache.nifi.registry.service.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.registry.flow.VersionedFlow; 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)>("Versioned flow cannot be null"); throw v; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Bucket identifiers must match"); throw v; label: v = virtualinvoke v.(); if v != null goto label; virtualinvoke v.(v); label: v = staticinvoke (); virtualinvoke v.(v); virtualinvoke v.(v); specialinvoke v.(v, "Cannot create versioned flow"); v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified bucket id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket ID does not exist in this registry."); throw v; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); if v == null goto label; v = interfaceinvoke v.(); if v <= 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("A versioned flow with the same name already exists in the selected bucket"); throw v; label: v = staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = interfaceinvoke v.(v); v = staticinvoke (v, v); return v; } public org.apache.nifi.registry.flow.VersionedFlow getFlow(java.lang.String, java.lang.String) { java.lang.IllegalStateException v; org.apache.nifi.registry.service.MetadataService v, v; org.apache.nifi.registry.db.entity.FlowEntity v; org.apache.nifi.registry.exception.ResourceNotFoundException v, v; java.lang.String v, v, v, v; boolean v, v, v; org.slf4j.Logger v, v; java.lang.IllegalArgumentException v, v; org.apache.nifi.registry.flow.VersionedFlow v; org.apache.nifi.registry.db.entity.BucketEntity v; org.apache.nifi.registry.service.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; 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 identifier 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)>("Versioned flow identifier cannot be null or blank"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified bucket id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket ID does not exist in this registry."); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified flow id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified flow ID does not exist in this bucket."); throw v; label: 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 flow is not located in the given bucket"); throw v; label: v = staticinvoke (v, v); return v; } public org.apache.nifi.registry.flow.VersionedFlow getFlow(java.lang.String) { org.slf4j.Logger v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.flow.VersionedFlow v; org.apache.nifi.registry.service.MetadataService v, v; org.apache.nifi.registry.db.entity.FlowEntity v; org.apache.nifi.registry.db.entity.BucketEntity v; org.apache.nifi.registry.exception.ResourceNotFoundException v; java.lang.String v, v; org.apache.nifi.registry.service.RegistryService v; boolean v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: java.lang.String; v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Versioned flow identifier cannot be null or blank"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified flow id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified flow ID does not exist."); throw v; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = staticinvoke (v, v); return v; } public void verifyFlowExists(java.lang.String) { org.slf4j.Logger v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.service.MetadataService v; org.apache.nifi.registry.db.entity.FlowEntity v; org.apache.nifi.registry.exception.ResourceNotFoundException v; java.lang.String v; org.apache.nifi.registry.service.RegistryService v; boolean v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: java.lang.String; v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Versioned flow identifier cannot be null or blank"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified flow id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified flow ID does not exist."); throw v; label: return; } public java.util.List getFlows(java.lang.String) { java.util.function.Function v; org.apache.nifi.registry.service.MetadataService v, v; org.apache.nifi.registry.exception.ResourceNotFoundException v; java.lang.String v, v; java.util.stream.Collector v; boolean v; org.slf4j.Logger v; java.lang.IllegalArgumentException 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.service.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; 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"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified bucket id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket ID does not exist in this registry."); throw v; label: v = v.; v = virtualinvoke 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.flow.VersionedFlow updateFlow(org.apache.nifi.registry.flow.VersionedFlow) { java.lang.IllegalStateException v, v; org.apache.nifi.registry.service.MetadataService v, v, v, v; org.apache.nifi.registry.db.entity.FlowEntity v, v; boolean v, v, v, v, v, v, v, v; java.util.List v; org.apache.nifi.registry.db.entity.BucketEntity v; org.apache.nifi.registry.exception.ResourceNotFoundException v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v; java.util.Iterator v; java.lang.IllegalArgumentException v, v, v, v; org.apache.nifi.registry.flow.VersionedFlow v, v; java.lang.Object v; org.apache.nifi.registry.service.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: org.apache.nifi.registry.flow.VersionedFlow; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Versioned flow cannot be null"); throw v; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Versioned flow identifier cannot be null or blank"); throw v; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Versioned flow bucket identifier cannot be null or blank"); throw v; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Versioned flow name cannot be blank"); throw v; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("The specified bucket id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket ID does not exist in this registry."); throw v; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("The specified flow id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified flow ID does not exist in this bucket."); throw v; label: 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 flow is not located in the given bucket"); throw v; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke 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)>("A versioned flow with the same name already exists in the selected bucket"); throw v; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = interfaceinvoke v.(v); v = staticinvoke (v, v); return v; } public org.apache.nifi.registry.flow.VersionedFlow deleteFlow(java.lang.String, java.lang.String) { java.lang.IllegalStateException v; org.apache.nifi.registry.service.MetadataService v, v, v; org.apache.nifi.registry.db.entity.FlowEntity v; org.apache.nifi.registry.exception.ResourceNotFoundException v, v; java.lang.String v, v, v, v, v, v; boolean v, v, v; org.slf4j.Logger v, v; org.apache.nifi.registry.flow.FlowPersistenceProvider v; java.lang.IllegalArgumentException v, v; org.apache.nifi.registry.flow.VersionedFlow v; org.apache.nifi.registry.db.entity.BucketEntity v; org.apache.nifi.registry.service.RegistryService v; v := @this: org.apache.nifi.registry.service.RegistryService; 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 identifier 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)>("Flow identifier cannot be null or blank"); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified bucket id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket ID does not exist in this registry."); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified flow id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified flow ID does not exist in this bucket."); throw v; label: 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 flow is not located in the given bucket"); throw v; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(v); v = staticinvoke (v, v); return v; } public org.apache.nifi.registry.flow.VersionedFlowSnapshot createFlowSnapshot(org.apache.nifi.registry.flow.VersionedFlowSnapshot) { byte[] v; org.apache.nifi.registry.service.MetadataService v, v, v, v, v, v; org.apache.nifi.registry.db.entity.FlowEntity v, v; org.apache.nifi.registry.flow.VersionedFlowSnapshotMetadata v, v, v; org.apache.nifi.registry.provider.flow.StandardFlowSnapshotContext$Builder v; org.apache.nifi.registry.db.entity.FlowSnapshotEntity v; org.apache.nifi.registry.db.entity.BucketEntity v; java.util.stream.Stream v; org.apache.nifi.flow.VersionedProcessGroup v, v; java.io.ByteArrayOutputStream v; long v; java.util.TreeSet v; org.apache.nifi.registry.exception.ResourceNotFoundException v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.registry.serialization.FlowContentSerializer v; org.apache.nifi.registry.flow.VersionedFlowSnapshot v; org.apache.nifi.registry.service.RegistryService v; java.lang.IllegalStateException v, v, v, v; boolean v; java.util.List v; org.apache.nifi.registry.service.alias.RegistryUrlAliasService v, v; org.apache.nifi.registry.bucket.Bucket v; org.apache.nifi.registry.serialization.FlowContent v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v; org.apache.nifi.registry.provider.flow.StandardFlowSnapshotContext v; org.apache.nifi.registry.flow.FlowPersistenceProvider v; java.lang.IllegalArgumentException v, v; org.apache.nifi.registry.flow.VersionedFlow v, v; java.util.function.Consumer v; java.lang.Object v; v := @this: org.apache.nifi.registry.service.RegistryService; v := @parameter: org.apache.nifi.registry.flow.VersionedFlowSnapshot; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Versioned flow snapshot cannot be null"); throw v; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (); virtualinvoke v.(v); label: virtualinvoke v.(null); virtualinvoke v.(null); specialinvoke v.(v, "Cannot create versioned flow snapshot"); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("The specified bucket id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified bucket ID does not exist in this registry."); throw v; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("The specified flow id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified flow ID does not exist in this bucket."); throw v; label: 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 flow is not located in the given bucket"); throw v; label: v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Version must be greater than zero, or use -1 to indicate latest version"); throw v; label: v = new java.util.TreeSet; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = interfaceinvoke v.(); v = staticinvoke (v, v); interfaceinvoke v.(v); label: v = interfaceinvoke v.(); if v <= 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = (int) -1; if v != v goto label; v = virtualinvoke v.(); v = v + 1; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v > v goto label; v = new java.lang.IllegalStateException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("A Versioned flow snapshot with the same version already exists: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + 1; if v <= v goto label; v = new java.lang.IllegalStateException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Version must be a one-up number, last version was \u and version for this snapshot was \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v = (int) -1; if v != v goto label; virtualinvoke v.(1); goto label; label: v = virtualinvoke v.