public class org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider extends org.apache.nifi.registry.security.authorization.AbstractConfigurableAccessPolicyProvider { private static final org.slf4j.Logger logger; private static final java.lang.String AUTHORIZATIONS_XSD; private static final java.lang.String JAXB_AUTHORIZATIONS_PATH; private static final javax.xml.bind.JAXBContext JAXB_AUTHORIZATIONS_CONTEXT; private static final javax.xml.stream.XMLOutputFactory XML_OUTPUT_FACTORY; private static final java.lang.String POLICY_ELEMENT; private static final java.lang.String POLICY_USER_ELEMENT; private static final java.lang.String POLICY_GROUP_ELEMENT; private static final java.lang.String IDENTIFIER_ATTR; private static final java.lang.String RESOURCE_ATTR; private static final java.lang.String ACTIONS_ATTR; static final java.lang.String READ_CODE; static final java.lang.String WRITE_CODE; static final java.lang.String DELETE_CODE; static final java.lang.String PROP_AUTHORIZATIONS_FILE; private org.apache.nifi.registry.security.identity.IdentityMapper identityMapper; private javax.xml.validation.Schema authorizationsSchema; private java.io.File authorizationsFile; private java.lang.String initialAdminIdentity; private java.util.Set nifiIdentities; private java.lang.String nifiGroupName; private final java.util.concurrent.atomic.AtomicReference authorizationsHolder; public void () { java.util.concurrent.atomic.AtomicReference v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; specialinvoke v.()>(); v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v. = v; return; } private static javax.xml.bind.JAXBContext initializeJaxbContext(java.lang.String) { java.lang.Throwable v; java.lang.Class v; java.lang.ClassLoader v; java.lang.RuntimeException v; java.lang.String v; javax.xml.bind.JAXBContext v; v := @parameter: java.lang.String; label: v = class "Lorg/apache/nifi/registry/security/authorization/file/FileAuthorizer;"; v = virtualinvoke v.(); v = staticinvoke (v, v); label: return v; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("Unable to create JAXBContext."); throw v; catch javax.xml.bind.JAXBException from label to label with label; } public void doInitialize(org.apache.nifi.registry.security.authorization.AccessPolicyProviderInitializationContext) throws org.apache.nifi.registry.security.exception.SecurityProviderCreationException { javax.xml.validation.SchemaFactory v; java.net.URL v; org.apache.nifi.registry.security.exception.SecurityProviderCreationException v; org.apache.nifi.registry.security.authorization.AccessPolicyProviderInitializationContext v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.lang.Exception v; javax.xml.validation.Schema v; java.lang.Class v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.AccessPolicyProviderInitializationContext; label: v = staticinvoke ("http://www.w.org/2001/XMLSchema"); v = class "Lorg/apache/nifi/registry/security/authorization/file/FileAuthorizer;"; v = virtualinvoke v.("/authorizations.xsd"); v = virtualinvoke v.(v); v. = v; label: goto label; label: v := @caughtexception; v = new org.apache.nifi.registry.security.exception.SecurityProviderCreationException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: return; catch java.lang.Exception from label to label with label; } public void doOnConfigured(org.apache.nifi.registry.security.authorization.AuthorizerConfigurationContext) throws org.apache.nifi.registry.security.exception.SecurityProviderCreationException { java.lang.Throwable v; java.lang.Object[] v, v; java.util.Date v; org.apache.nifi.registry.security.identity.IdentityMapper v, v, v; java.lang.String v, v, v, v, v, v, v; boolean v, v; org.slf4j.Logger v, v; org.apache.nifi.registry.security.exception.SecurityProviderCreationException v, v; java.util.Set v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.io.File v, v, v; org.apache.nifi.registry.security.authorization.AuthorizerConfigurationContext v; org.apache.nifi.registry.util.PropertyValue v; org.apache.nifi.registry.security.authorization.file.generated.Authorizations v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.AuthorizerConfigurationContext; label: v = interfaceinvoke v.("Authorizations File"); v = interfaceinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = new org.apache.nifi.registry.security.exception.SecurityProviderCreationException; specialinvoke v.(java.lang.String)>("The authorizations file must be specified."); throw v; label: v = new java.io.File; v = interfaceinvoke v.(); specialinvoke v.(java.lang.String)>(v); v. = v; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = ; v = newarray (java.lang.Object)[1]; v = v.; v = virtualinvoke v.(); v[0] = v; interfaceinvoke v.("Creating new authorizations file at {}", v); v = new org.apache.nifi.registry.security.authorization.file.generated.Authorizations; specialinvoke v.()>(); specialinvoke v.(v); label: v = v.; v = staticinvoke (v, v); v. = v; v = v.; v = staticinvoke (v, v); v. = v; v = v.; v = staticinvoke (v, v); v. = v; specialinvoke v.(); v = ; v = newarray (java.lang.Object)[1]; v = new java.util.Date; specialinvoke v.()>(); v = virtualinvoke v.(); v[0] = v; v = staticinvoke ("Authorizations file loaded at %s", v); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = new org.apache.nifi.registry.security.exception.SecurityProviderCreationException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: return; catch javax.xml.bind.JAXBException from label to label with label; catch org.xml.sax.SAXException from label to label with label; } public java.util.Set getAccessPolicies() throws org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException { java.util.Set v; java.lang.Object v; java.util.concurrent.atomic.AtomicReference v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } public synchronized org.apache.nifi.registry.security.authorization.AccessPolicy addAccessPolicy(org.apache.nifi.registry.security.authorization.AccessPolicy) throws org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException { org.apache.nifi.registry.security.authorization.AccessPolicy v; java.lang.IllegalArgumentException v; java.util.concurrent.atomic.AtomicReference v, v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.util.List v; java.util.Map v; org.apache.nifi.registry.security.authorization.file.generated.Policies v; org.apache.nifi.registry.security.authorization.file.generated.Policy v; java.lang.Object v, v, v; java.lang.String v; org.apache.nifi.registry.security.authorization.file.generated.Authorizations v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.AccessPolicy; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("AccessPolicy cannot be null"); throw v; label: v = specialinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); specialinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); return v; } public org.apache.nifi.registry.security.authorization.AccessPolicy getAccessPolicy(java.lang.String) throws org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException { java.util.Map v; java.lang.Object v, v; java.lang.String v; java.util.concurrent.atomic.AtomicReference v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: java.lang.String; if v != null goto label; return null; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); return v; } public org.apache.nifi.registry.security.authorization.AccessPolicy getAccessPolicy(java.lang.String, org.apache.nifi.registry.security.authorization.RequestAction) throws org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException { java.lang.Object v; org.apache.nifi.registry.security.authorization.AccessPolicy v; org.apache.nifi.registry.security.authorization.RequestAction v; java.lang.String v; java.util.concurrent.atomic.AtomicReference v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.registry.security.authorization.RequestAction; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); return v; } public synchronized org.apache.nifi.registry.security.authorization.AccessPolicy updateAccessPolicy(org.apache.nifi.registry.security.authorization.AccessPolicy) throws org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException { org.apache.nifi.registry.security.authorization.AccessPolicy v; java.util.concurrent.atomic.AtomicReference v, v; java.util.Map v; org.apache.nifi.registry.security.authorization.file.generated.Policies v; java.lang.String v, v, v; boolean v, v; java.util.Iterator v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.util.List v; org.apache.nifi.registry.security.authorization.file.generated.Policy v; java.lang.Object v, v, v, v; org.apache.nifi.registry.security.authorization.file.generated.Authorizations v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.AccessPolicy; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("AccessPolicy cannot be null"); throw v; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = null; v = virtualinvoke v.(); v = virtualinvoke v.(); 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 = v; label: if v != null goto label; return null; label: specialinvoke v.(v, v); specialinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); return v; } public synchronized org.apache.nifi.registry.security.authorization.AccessPolicy deleteAccessPolicy(org.apache.nifi.registry.security.authorization.AccessPolicy) throws org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException { org.apache.nifi.registry.security.authorization.AccessPolicy v, v; java.lang.String v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.AccessPolicy; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("AccessPolicy cannot be null"); throw v; label: v = virtualinvoke v.(); v = specialinvoke v.(v); return v; } private synchronized org.apache.nifi.registry.security.authorization.AccessPolicy deleteAccessPolicy(java.lang.String) throws org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException { java.util.Iterator v; java.lang.IllegalArgumentException v; java.util.concurrent.atomic.AtomicReference v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.util.List v; java.util.Map v; org.apache.nifi.registry.security.authorization.file.generated.Policies v; java.lang.Object v, v, v; java.lang.String v, v; boolean v, v; org.apache.nifi.registry.security.authorization.file.generated.Authorizations v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: java.lang.String; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Access policy identifier cannot be null"); throw v; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; return null; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke 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; interfaceinvoke v.(); label: specialinvoke v.(v); return v; } org.apache.nifi.registry.security.authorization.file.AuthorizationsHolder getAuthorizationsHolder() { java.lang.Object v; java.util.concurrent.atomic.AtomicReference v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v = v.; v = virtualinvoke v.(); return v; } public void setIdentityMapper(org.apache.nifi.registry.security.identity.IdentityMapper) { org.apache.nifi.registry.security.identity.IdentityMapper v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.identity.IdentityMapper; v. = v; return; } public synchronized void inheritFingerprint(java.lang.String) throws org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException { java.util.function.Consumer v; java.util.List v; java.lang.String v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: java.lang.String; v = specialinvoke v.(v); v = staticinvoke (v); interfaceinvoke v.(v); return; } public void checkInheritability(java.lang.String) throws org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException, org.apache.nifi.registry.security.authorization.exception.UninheritableAuthorizationsException { java.lang.Throwable v; java.util.Set v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; org.apache.nifi.registry.security.authorization.exception.UninheritableAuthorizationsException v, v; java.lang.String v, v; boolean v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: java.lang.String; label: specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = new org.apache.nifi.registry.security.authorization.exception.UninheritableAuthorizationsException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to parse the proposed fingerprint: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = new org.apache.nifi.registry.security.authorization.exception.UninheritableAuthorizationsException; specialinvoke v.(java.lang.String)>("Proposed fingerprint is not inheritable because the current access policies is not empty."); throw v; label: return; catch org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException from label to label with label; } public java.lang.String getFingerprint() throws org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException { java.lang.Throwable v; java.util.Iterator v; java.io.StringWriter v; java.util.Set v; java.util.function.Function v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.util.ArrayList v; javax.xml.stream.XMLOutputFactory v; javax.xml.stream.XMLStreamException v; java.lang.Object v; javax.xml.stream.XMLStreamWriter v; java.lang.String v; java.util.Comparator v; org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException v; boolean v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v = new java.util.ArrayList; v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = staticinvoke (); v = staticinvoke (v); staticinvoke (v, v); v = new java.io.StringWriter; specialinvoke v.()>(); label: v = ; v = virtualinvoke v.(v); interfaceinvoke v.(); interfaceinvoke v.("accessPolicies"); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v, v); goto label; label: interfaceinvoke v.(); interfaceinvoke v.(); interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = new org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Unable to generate fingerprint", v); throw v; label: v := @caughtexception; throw v; label: v = virtualinvoke v.(); return v; catch javax.xml.stream.XMLStreamException from label to label with label; catch java.lang.Throwable from label to label with label; } private java.util.List parsePolicies(java.lang.String) { java.lang.Throwable v, v; byte[] v; org.apache.nifi.registry.security.authorization.AccessPolicy v; java.util.ArrayList v; java.io.ByteArrayInputStream v; java.nio.charset.Charset v; org.w3c.dom.Document v; org.w3c.dom.Node v; int v, v; java.lang.String v; org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException v; org.apache.nifi.xml.processing.parsers.StandardDocumentProvider v; org.w3c.dom.NodeList v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; org.w3c.dom.Element v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: java.lang.String; v = new java.util.ArrayList; specialinvoke v.()>(); v = ; v = virtualinvoke v.(v); label: v = new java.io.ByteArrayInputStream; specialinvoke v.(byte[])>(v); label: v = new org.apache.nifi.xml.processing.parsers.StandardDocumentProvider; specialinvoke v.()>(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.("policy"); v = 0; label: v = interfaceinvoke v.(); if v >= v goto label; v = interfaceinvoke v.(v); v = specialinvoke v.(v); interfaceinvoke v.(v); v = v + 1; goto label; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = new org.apache.nifi.registry.security.authorization.exception.AuthorizationAccessException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Unable to parse fingerprint", v); throw v; label: return v; catch java.lang.Throwable from label to label with label; catch org.apache.nifi.xml.processing.ProcessingException from label to label with label; catch java.io.IOException from label to label with label; } private org.apache.nifi.registry.security.authorization.AccessPolicy parsePolicy(org.w3c.dom.Element) { java.lang.IllegalStateException v; boolean v, v, v; org.apache.nifi.registry.security.authorization.AccessPolicy v; org.apache.nifi.registry.security.authorization.RequestAction v, v, v, v, v, v; org.w3c.dom.Node v, v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v; org.apache.nifi.registry.security.authorization.AccessPolicy$Builder v, v, v; org.w3c.dom.NodeList v, v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; org.w3c.dom.Element v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.w3c.dom.Element; v = new org.apache.nifi.registry.security.authorization.AccessPolicy$Builder; specialinvoke v.()>(); v = interfaceinvoke v.("identifier"); v = virtualinvoke v.(v); v = interfaceinvoke v.("resource"); v = virtualinvoke v.(v); v = interfaceinvoke v.("actions"); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; virtualinvoke v.(v); goto label; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; virtualinvoke v.(v); goto label; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; virtualinvoke v.(v); goto label; label: v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown Policy Action: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.("policyUser"); v = 0; label: v = interfaceinvoke v.(); if v >= v goto label; v = interfaceinvoke v.(v); v = interfaceinvoke v.("identifier"); virtualinvoke v.(v); v = v + 1; goto label; label: v = interfaceinvoke v.("policyGroup"); v = 0; label: v = interfaceinvoke v.(); if v >= v goto label; v = interfaceinvoke v.(v); v = interfaceinvoke v.("identifier"); virtualinvoke v.(v); v = v + 1; goto label; label: v = virtualinvoke v.(); return v; } private void writePolicy(javax.xml.stream.XMLStreamWriter, org.apache.nifi.registry.security.authorization.AccessPolicy) throws javax.xml.stream.XMLStreamException { org.apache.nifi.registry.security.authorization.AccessPolicy v; org.apache.nifi.registry.security.authorization.RequestAction v; java.util.ArrayList v, v; javax.xml.stream.XMLStreamWriter v; java.lang.String v, v, v; boolean v, v; java.util.Iterator v, v; java.util.Set v, v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.lang.Object v, v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: javax.xml.stream.XMLStreamWriter; v := @parameter: org.apache.nifi.registry.security.authorization.AccessPolicy; v = new java.util.ArrayList; v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); staticinvoke (v); v = new java.util.ArrayList; v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); staticinvoke (v); interfaceinvoke v.("policy"); v = virtualinvoke v.(); interfaceinvoke v.("identifier", v); v = virtualinvoke v.(); interfaceinvoke v.("resource", v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("actions", v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.("policyUser"); interfaceinvoke v.("identifier", v); interfaceinvoke v.(); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.("policyGroup"); interfaceinvoke v.("identifier", v); interfaceinvoke v.(); goto label; label: interfaceinvoke v.(); return; } private synchronized void load() throws javax.xml.bind.JAXBException, org.xml.sax.SAXException { java.util.concurrent.atomic.AtomicReference v; org.apache.nifi.registry.security.authorization.file.AuthorizationsHolder v; org.apache.nifi.registry.security.authorization.file.generated.Policies v, v; java.lang.String v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v; java.util.Set v, v, v, v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; org.apache.nifi.registry.security.authorization.file.generated.Authorizations v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v = specialinvoke v.(); v = virtualinvoke v.(); if v != null goto label; v = new org.apache.nifi.registry.security.authorization.file.generated.Policies; specialinvoke v.()>(); virtualinvoke v.(v); label: v = new org.apache.nifi.registry.security.authorization.file.AuthorizationsHolder; specialinvoke v.(org.apache.nifi.registry.security.authorization.file.generated.Authorizations)>(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; if v == null goto label; v = v.; v = staticinvoke (v); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; if v == 0 goto label; if v == 0 goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Populating authorizations for Initial Admin: \'\u0001\'"); interfaceinvoke v.(v); specialinvoke v.(v); label: if v == 0 goto label; v = ; v = v.; v = staticinvoke (v, ";"); interfaceinvoke v.("Populating authorizations for NiFi identities: [{}]", v); specialinvoke v.(v); label: v = v.; v = staticinvoke (v); if v != 0 goto label; v = ; v = v.; interfaceinvoke v.("Populating authorizations for NiFi identity group: [{}]", v); specialinvoke v.(v); label: specialinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(v); label: return; } private void saveAuthorizations(org.apache.nifi.registry.security.authorization.file.generated.Authorizations) throws javax.xml.bind.JAXBException { javax.xml.bind.Marshaller v; java.lang.Boolean v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.io.File v; javax.xml.bind.JAXBContext v; javax.xml.validation.Schema v; org.apache.nifi.registry.security.authorization.file.generated.Authorizations v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.file.generated.Authorizations; v = ; v = virtualinvoke v.(); v = v.; interfaceinvoke v.(v); v = staticinvoke (1); interfaceinvoke v.("jaxb.formatted.output", v); v = v.; interfaceinvoke v.(v, v); return; } private org.apache.nifi.registry.security.authorization.file.generated.Authorizations unmarshallAuthorizations() throws javax.xml.bind.JAXBException { javax.xml.bind.Unmarshaller v; javax.xml.bind.JAXBElement v; javax.xml.transform.stream.StreamSource v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.io.File v; javax.xml.validation.Schema v; java.lang.Object v; javax.xml.bind.JAXBContext v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v = ; v = virtualinvoke v.(); v = v.; interfaceinvoke v.(v); v = new javax.xml.transform.stream.StreamSource; v = v.; specialinvoke v.(java.io.File)>(v); v = interfaceinvoke v.(v, class "Lorg/apache/nifi/registry/security/authorization/file/generated/Authorizations;"); v = virtualinvoke v.(); return v; } private void populateInitialAdmin(org.apache.nifi.registry.security.authorization.file.generated.Authorizations) { org.apache.nifi.registry.security.authorization.Resource v; org.apache.nifi.registry.security.authorization.RequestAction v; java.lang.String v, v, v, v, v, v; boolean v; java.util.Iterator v; org.apache.nifi.registry.security.exception.SecurityProviderCreationException v; java.util.Set v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; org.apache.nifi.registry.security.authorization.User v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.lang.Object v; org.apache.nifi.registry.security.authorization.file.generated.Authorizations v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.file.generated.Authorizations; v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.nifi.registry.security.exception.SecurityProviderCreationException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to locate initial admin \u to seed policies"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(v, v, v, v); goto label; label: return; } private void populateNiFiIdentities(org.apache.nifi.registry.security.authorization.file.generated.Authorizations) { org.apache.nifi.registry.security.authorization.Resource v; org.apache.nifi.registry.security.authorization.RequestAction v; java.lang.String v, v, v, v; boolean v, v; java.util.Iterator v, v; org.apache.nifi.registry.security.exception.SecurityProviderCreationException v; java.util.Set v, v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; org.apache.nifi.registry.security.authorization.User v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.lang.Object v, v; org.apache.nifi.registry.security.authorization.file.generated.Authorizations v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.file.generated.Authorizations; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.nifi.registry.security.exception.SecurityProviderCreationException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to locate NiFi identities\'\u0001\' to seed policies."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(v, v, v, v); goto label; label: return; } private void populateNiFiGroup(org.apache.nifi.registry.security.authorization.file.generated.Authorizations) { org.apache.nifi.registry.security.authorization.Resource v; java.util.Iterator v; java.util.Set v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; org.apache.nifi.registry.security.authorization.RequestAction v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; org.apache.nifi.registry.security.authorization.Group v; java.lang.Object v; java.lang.String v, v, v, v; boolean v; org.apache.nifi.registry.security.authorization.file.generated.Authorizations v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.file.generated.Authorizations; v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(v, v, v, v); goto label; label: return; } private void addGroupToAccessPolicy(org.apache.nifi.registry.security.authorization.file.generated.Authorizations, java.lang.String, java.lang.String, java.lang.String) { org.apache.nifi.registry.security.authorization.AccessPolicy v; org.apache.nifi.registry.security.authorization.RequestAction v; org.apache.nifi.registry.security.authorization.file.generated.Policies v, v; java.lang.String v, v, v, v; boolean v; org.apache.nifi.registry.security.authorization.AccessPolicy$Builder v, v, v, v, v; java.util.function.Predicate v, v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.util.List v, v, v; org.apache.nifi.registry.security.authorization.file.generated.Policy$Group v; java.util.stream.Stream v, v, v; org.apache.nifi.registry.security.authorization.file.generated.Policy v; java.util.Optional v; java.lang.Object v; org.apache.nifi.registry.security.authorization.file.generated.Authorizations v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.file.generated.Authorizations; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = new org.apache.nifi.registry.security.authorization.file.generated.Policy$Group; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = new org.apache.nifi.registry.security.authorization.AccessPolicy$Builder; specialinvoke v.()>(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001\u0001"); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = specialinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v); interfaceinvoke v.(v); label: return; } private void addUserToAccessPolicy(org.apache.nifi.registry.security.authorization.file.generated.Authorizations, java.lang.String, java.lang.String, java.lang.String) { org.apache.nifi.registry.security.authorization.AccessPolicy v; org.apache.nifi.registry.security.authorization.RequestAction v; org.apache.nifi.registry.security.authorization.file.generated.Policy$User v; org.apache.nifi.registry.security.authorization.file.generated.Policies v, v; java.lang.String v, v, v, v, v, v; boolean v, v, v; org.apache.nifi.registry.security.authorization.AccessPolicy$Builder v, v, v, v, v; java.util.Iterator v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.util.List v, v, v; org.apache.nifi.registry.security.authorization.file.generated.Policy v, v; java.lang.Object v; org.apache.nifi.registry.security.authorization.file.generated.Authorizations v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.file.generated.Authorizations; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = null; v = virtualinvoke v.(); v = virtualinvoke 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; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v; label: if v != null goto label; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001\u0001"); v = new org.apache.nifi.registry.security.authorization.AccessPolicy$Builder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = specialinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = new org.apache.nifi.registry.security.authorization.file.generated.Policy$User; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); label: return; } private org.apache.nifi.registry.security.authorization.file.generated.Policy createJAXBPolicy(org.apache.nifi.registry.security.authorization.AccessPolicy) { org.apache.nifi.registry.security.authorization.file.generated.Policy v; org.apache.nifi.registry.security.authorization.AccessPolicy v; org.apache.nifi.registry.security.authorization.RequestAction v; java.lang.String v, v, v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.AccessPolicy; v = new org.apache.nifi.registry.security.authorization.file.generated.Policy; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = specialinvoke v.(v); virtualinvoke v.(v); specialinvoke v.(v, v); return v; } private java.lang.String getActionCode(org.apache.nifi.registry.security.authorization.RequestAction) { java.lang.IllegalStateException v; int[] v; int v, v; org.apache.nifi.registry.security.authorization.RequestAction v; java.lang.String v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.RequestAction; v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; default: goto label; }; label: return "R"; label: return "W"; label: return "D"; label: v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown action: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; } private org.apache.nifi.registry.security.authorization.RequestAction getAction(java.lang.String) { java.lang.IllegalStateException v; org.apache.nifi.registry.security.authorization.RequestAction v, v, v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; byte v; int v; java.lang.String v, v; boolean v, v, v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: java.lang.String; v = -1; v = virtualinvoke v.(); lookupswitch(v) { case 68: goto label; case 82: goto label; case 87: goto label; default: goto label; }; label: v = virtualinvoke v.("R"); if v == 0 goto label; v = 0; goto label; label: v = virtualinvoke v.("W"); if v == 0 goto label; v = 1; goto label; label: v = virtualinvoke v.("D"); if v == 0 goto label; v = 2; label: tableswitch(v) { case 0: goto label; case 1: goto label; case 2: goto label; default: goto label; }; label: v = ; return v; label: v = ; return v; label: v = ; return v; label: v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unknown action: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; } private void transferUsersAndGroups(org.apache.nifi.registry.security.authorization.AccessPolicy, org.apache.nifi.registry.security.authorization.file.generated.Policy) { org.apache.nifi.registry.security.authorization.AccessPolicy v; org.apache.nifi.registry.security.authorization.file.generated.Policy$User v; boolean v, v; java.util.Iterator v, v; java.util.Set v, v; org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider v; java.util.List v, v, v, v; org.apache.nifi.registry.security.authorization.file.generated.Policy$Group v; org.apache.nifi.registry.security.authorization.file.generated.Policy v; java.lang.Object v, v; v := @this: org.apache.nifi.registry.security.authorization.file.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.registry.security.authorization.AccessPolicy; v := @parameter: org.apache.nifi.registry.security.authorization.file.generated.Policy; v = virtualinvoke v.(); interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new org.apache.nifi.registry.security.authorization.file.generated.Policy$User; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.