public class org.apache.nifi.authorization.FileAccessPolicyProvider extends java.lang.Object implements org.apache.nifi.authorization.ConfigurableAccessPolicyProvider { 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 java.lang.String USERS_XSD; private static final java.lang.String JAXB_USERS_PATH; private static final javax.xml.bind.JAXBContext JAXB_AUTHORIZATIONS_CONTEXT; private static final javax.xml.bind.JAXBContext JAXB_USERS_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 PROP_NODE_IDENTITY_PREFIX; static final java.lang.String PROP_NODE_GROUP_NAME; static final java.lang.String PROP_USER_GROUP_PROVIDER; static final java.lang.String PROP_AUTHORIZATIONS_FILE; static final java.lang.String PROP_INITIAL_ADMIN_IDENTITY; static final java.util.regex.Pattern NODE_IDENTITY_PATTERN; private javax.xml.validation.Schema usersSchema; private javax.xml.validation.Schema authorizationsSchema; private org.apache.nifi.util.NiFiProperties properties; private java.io.File authorizationsFile; private java.io.File restoreAuthorizationsFile; private java.lang.String rootGroupId; private java.lang.String initialAdminIdentity; private java.lang.String legacyAuthorizedUsersFile; private java.util.Set nodeIdentities; private java.lang.String nodeGroupIdentifier; private java.util.List ports; private java.util.List identityMappings; private java.util.List groupMappings; private org.apache.nifi.authorization.UserGroupProvider userGroupProvider; private org.apache.nifi.authorization.UserGroupProviderLookup userGroupProviderLookup; private final java.util.concurrent.atomic.AtomicReference authorizationsHolder; public void () { org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.concurrent.atomic.AtomicReference v; java.util.ArrayList v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v. = 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/authorization/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 initialize(org.apache.nifi.authorization.AccessPolicyProviderInitializationContext) throws org.apache.nifi.authorization.exception.AuthorizerCreationException { org.apache.nifi.authorization.FileAccessPolicyProvider v; javax.xml.validation.SchemaFactory v; org.apache.nifi.authorization.AccessPolicyProviderInitializationContext v; java.net.URL v, v; java.lang.Exception v; javax.xml.validation.Schema v, v; java.lang.Class v, v; org.apache.nifi.authorization.exception.AuthorizerCreationException v; org.apache.nifi.authorization.UserGroupProviderLookup v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.authorization.AccessPolicyProviderInitializationContext; v = interfaceinvoke v.(); v. = v; label: v = staticinvoke ("http://www.w.org/2001/XMLSchema"); v = class "Lorg/apache/nifi/authorization/FileAuthorizer;"; v = virtualinvoke v.("/authorizations.xsd"); v = virtualinvoke v.(v); v. = v; v = class "Lorg/apache/nifi/authorization/FileAuthorizer;"; v = virtualinvoke v.("/legacy-users.xsd"); v = virtualinvoke v.(v); v. = v; label: goto label; label: v := @caughtexception; v = new org.apache.nifi.authorization.exception.AuthorizerCreationException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: return; catch java.lang.Exception from label to label with label; } public void onConfigured(org.apache.nifi.authorization.AuthorizerConfigurationContext) throws org.apache.nifi.authorization.exception.AuthorizerCreationException { org.apache.nifi.authorization.UserGroupProvider v, v, v; java.util.regex.Matcher v; java.util.Map v; org.apache.nifi.authorization.file.generated.Authorizations v; java.util.Set v, v, v; java.lang.Exception v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.io.File v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.util.NiFiProperties v, v, v; java.util.Date v; org.apache.nifi.components.PropertyValue v, v, v, v, v; org.apache.nifi.authorization.exception.AuthorizerCreationException v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.authorization.FileAccessPolicyProvider v; org.apache.nifi.authorization.AuthorizerConfigurationContext v; java.util.List v, v, v, v, v, v; java.util.regex.Pattern v; org.apache.nifi.authorization.UserGroupProviderLookup v; java.util.HashSet v; org.slf4j.Logger v, v, v, v, v, v, v; java.util.Iterator v, v; java.lang.Object v, v, v, v, v, v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.authorization.AuthorizerConfigurationContext; label: v = interfaceinvoke v.("User Group Provider"); v = interfaceinvoke v.(); if v != 0 goto label; v = new org.apache.nifi.authorization.exception.AuthorizerCreationException; specialinvoke v.(java.lang.String)>("The user group provider must be specified."); throw v; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v. = v; v = v.; if v != null goto label; v = new org.apache.nifi.authorization.exception.AuthorizerCreationException; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to locate user group provider with identifier \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.("Authorizations File"); v = interfaceinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = new org.apache.nifi.authorization.exception.AuthorizerCreationException; 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.authorization.file.generated.Authorizations; specialinvoke v.()>(); specialinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v == null goto label; staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = new org.apache.nifi.authorization.exception.AuthorizerCreationException; v = newarray (java.lang.Object)[2]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = staticinvoke ("Authorizations file directory \'%s\' is the same as restore directory \'%s\' ", v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new java.io.File; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.io.File,java.lang.String)>(v, v); v. = v; label: v = v.; v = v.; v = ; staticinvoke (v, v, v); label: goto label; label: v := @caughtexception; v = new org.apache.nifi.authorization.exception.AuthorizerCreationException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = v.; v = staticinvoke (v); v = staticinvoke (v); v. = v; v = v.; v = staticinvoke (v); v = staticinvoke (v); v. = v; v = interfaceinvoke v.("Initial Admin Identity"); v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = staticinvoke (v, v); goto label; label: v = null; label: v. = v; v = interfaceinvoke v.("Legacy Authorized Users File"); v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); goto label; label: v = null; label: v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = interfaceinvoke v.(); v = v.; v = staticinvoke (v, v); v = v.; interfaceinvoke v.(v); v = ; v = newarray (java.lang.Object)[2]; v[0] = v; v = interfaceinvoke v.(); v[1] = v; interfaceinvoke v.("Added mapped node {} (raw node identity {})", v); goto label; label: v = interfaceinvoke v.("Node Group"); if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); goto label; label: v = null; label: v = v; v. = null; if v == null goto label; v = staticinvoke (v); if v != 0 goto label; v = ; interfaceinvoke v.("Trying to load node group \'{}\' from the underlying userGroupProvider", v); v = v.; v = interfaceinvoke 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. = v; label: v = v.; if v != null goto label; v = new org.apache.nifi.authorization.exception.AuthorizerCreationException; v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke ("Authorizations node group \'%s\' could not be found", v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; interfaceinvoke v.("Empty node group name provided"); label: specialinvoke v.(); v = v.; if v == null goto label; v = v.; v = v.; v = ; staticinvoke (v, v, 0, 0, v); label: 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.authorization.exception.AuthorizerCreationException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: return; catch java.io.IOException from label to label with label; catch java.lang.IllegalStateException from label to label with label; catch java.io.IOException from label to label with label; catch org.apache.nifi.authorization.exception.AuthorizerCreationException from label to label with label; catch javax.xml.bind.JAXBException from label to label with label; catch java.lang.IllegalStateException from label to label with label; catch org.xml.sax.SAXException from label to label with label; } public org.apache.nifi.authorization.UserGroupProvider getUserGroupProvider() { org.apache.nifi.authorization.UserGroupProvider v; org.apache.nifi.authorization.FileAccessPolicyProvider v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v = v.; return v; } public java.util.Set getAccessPolicies() throws org.apache.nifi.authorization.exception.AuthorizationAccessException { org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.Set v; java.lang.Object v; java.util.concurrent.atomic.AtomicReference v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } public synchronized org.apache.nifi.authorization.AccessPolicy addAccessPolicy(org.apache.nifi.authorization.AccessPolicy) throws org.apache.nifi.authorization.exception.AuthorizationAccessException { org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.concurrent.atomic.AtomicReference v; java.util.List v; org.apache.nifi.authorization.AccessPolicy v; java.util.Map v; java.lang.Object v, v; java.lang.String v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.authorization.AccessPolicy; v = staticinvoke (v); specialinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); return v; } private synchronized void addAccessPolicies(java.util.List) throws org.apache.nifi.authorization.exception.AuthorizationAccessException { org.apache.nifi.authorization.file.generated.Authorizations v; org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.Iterator v; java.lang.IllegalArgumentException v; java.util.concurrent.atomic.AtomicReference v; org.apache.nifi.authorization.file.generated.Policies v; java.util.List v, v; java.lang.Object v, v; org.apache.nifi.authorization.file.generated.Policy v; boolean v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: java.util.List; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("AccessPolicies cannot be null"); throw v; label: v = v.; v = virtualinvoke v.(); 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 = specialinvoke v.(v); interfaceinvoke v.(v); goto label; label: specialinvoke v.(v); return; } public synchronized void purgePolicies(boolean) { org.apache.nifi.authorization.file.generated.Authorizations v; org.apache.nifi.authorization.file.generated.Policies v; java.util.List v; org.apache.nifi.authorization.FileAccessPolicyProvider v; java.lang.Object v; java.util.concurrent.atomic.AtomicReference v; boolean v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: boolean; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(); if v == 0 goto label; specialinvoke v.(v); label: return; } public void backupPolicies() throws javax.xml.bind.JAXBException { org.apache.nifi.authorization.file.generated.Authorizations v; org.apache.nifi.authorization.FileAccessPolicyProvider v; org.slf4j.Logger v; java.util.Date v; java.text.SimpleDateFormat v; java.util.concurrent.atomic.AtomicReference v; java.io.File v, v, v, v; java.lang.Object v; java.lang.String v, v, v, v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = new java.text.SimpleDateFormat; specialinvoke v.(java.lang.String)>("yyyy-MM-dd-HH-mm-ss"); v = new java.util.Date; specialinvoke v.()>(); v = virtualinvoke v.(v); v = new java.io.File; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u.\u0001"); specialinvoke v.(java.io.File,java.lang.String)>(v, v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("Writing backup of Policies to {}", v); specialinvoke v.(v, v); return; } public org.apache.nifi.authorization.AccessPolicy getAccessPolicy(java.lang.String) throws org.apache.nifi.authorization.exception.AuthorizationAccessException { org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.Map v; java.lang.Object v, v; java.lang.String v; java.util.concurrent.atomic.AtomicReference v; v := @this: org.apache.nifi.authorization.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.authorization.AccessPolicy getAccessPolicy(java.lang.String, org.apache.nifi.authorization.RequestAction) throws org.apache.nifi.authorization.exception.AuthorizationAccessException { org.apache.nifi.authorization.FileAccessPolicyProvider v; org.apache.nifi.authorization.AccessPolicy v; org.apache.nifi.authorization.RequestAction v; java.lang.Object v; java.lang.String v; java.util.concurrent.atomic.AtomicReference v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.authorization.RequestAction; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); return v; } public synchronized org.apache.nifi.authorization.AccessPolicy updateAccessPolicy(org.apache.nifi.authorization.AccessPolicy) throws org.apache.nifi.authorization.exception.AuthorizationAccessException { java.util.concurrent.atomic.AtomicReference v, v; java.util.Map v; org.apache.nifi.authorization.file.generated.Policy v; java.lang.String v, v, v; boolean v, v; org.apache.nifi.authorization.file.generated.Authorizations v; org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.Iterator v; java.lang.IllegalArgumentException v; org.apache.nifi.authorization.file.generated.Policies v; java.util.List v; org.apache.nifi.authorization.AccessPolicy v; java.lang.Object v, v, v, v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.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.authorization.AccessPolicy deleteAccessPolicy(org.apache.nifi.authorization.AccessPolicy) throws org.apache.nifi.authorization.exception.AuthorizationAccessException { org.apache.nifi.authorization.file.generated.Authorizations v; org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.Iterator v; java.lang.IllegalArgumentException v; java.util.concurrent.atomic.AtomicReference v; org.apache.nifi.authorization.file.generated.Policies v; java.util.List v; org.apache.nifi.authorization.AccessPolicy v; java.lang.Object v, v; java.lang.String v, v; boolean v, v, v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.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 = 0; 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; interfaceinvoke v.(); v = 1; label: if v != 0 goto label; return null; label: specialinvoke v.(v); return v; } org.apache.nifi.authorization.AuthorizationsHolder getAuthorizationsHolder() { java.lang.Object v; org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.concurrent.atomic.AtomicReference v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v = v.; v = virtualinvoke v.(); return v; } public void setNiFiProperties(org.apache.nifi.util.NiFiProperties) { org.apache.nifi.authorization.FileAccessPolicyProvider v; org.apache.nifi.util.NiFiProperties v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.util.NiFiProperties; v. = v; return; } public synchronized void inheritFingerprint(java.lang.String) throws org.apache.nifi.authorization.exception.AuthorizationAccessException { java.util.List v; org.apache.nifi.authorization.FileAccessPolicyProvider v; java.lang.String v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: java.lang.String; v = specialinvoke v.(v); specialinvoke v.(v); return; } private synchronized void inheritAccessPolicies(java.util.List) { java.util.List v; org.apache.nifi.authorization.FileAccessPolicyProvider v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: java.util.List; specialinvoke v.(v); return; } public synchronized void forciblyInheritFingerprint(java.lang.String) throws org.apache.nifi.authorization.exception.AuthorizationAccessException { java.lang.Throwable v; org.apache.nifi.authorization.FileAccessPolicyProvider v; org.slf4j.Logger v, v; java.util.List v; org.apache.nifi.authorization.exception.AuthorizationAccessException v; java.lang.String v; boolean v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: java.lang.String; v = specialinvoke v.(v); v = specialinvoke v.(v); if v == 0 goto label; v = ; interfaceinvoke v.("Inheriting cluster\'s Access Policies"); specialinvoke v.(v); goto label; label: v = ; interfaceinvoke v.("Cannot directly inherit cluster\'s Access Policies. Will create backup of existing policies and replace with proposed policies"); label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = new org.apache.nifi.authorization.exception.AuthorizationAccessException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Failed to backup existing policies so will not inherit any policies", v); throw v; label: virtualinvoke v.(0); specialinvoke v.(v); label: return; catch javax.xml.bind.JAXBException from label to label with label; } public void checkInheritability(java.lang.String) throws org.apache.nifi.authorization.exception.AuthorizationAccessException, org.apache.nifi.authorization.exception.UninheritableAuthorizationsException { java.lang.Throwable v; org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.List v; org.apache.nifi.authorization.exception.UninheritableAuthorizationsException v, v; java.lang.String v, v; boolean v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: java.lang.String; label: v = specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = new org.apache.nifi.authorization.exception.UninheritableAuthorizationsException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to parse the proposed fingerprint: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = specialinvoke v.(v); if v != 0 goto label; v = new org.apache.nifi.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.authorization.exception.AuthorizationAccessException from label to label with label; } private boolean isInheritable(java.util.List) { java.util.List v; org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.Set v; boolean v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: java.util.List; v = virtualinvoke v.(); v = interfaceinvoke v.(); return v; } public java.lang.String getFingerprint() throws org.apache.nifi.authorization.exception.AuthorizationAccessException { java.lang.Throwable v; org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.Iterator v; java.io.StringWriter v; java.util.Set v; java.util.function.Function v; java.util.ArrayList v; javax.xml.stream.XMLOutputFactory v; javax.xml.stream.XMLStreamException v; org.apache.nifi.authorization.exception.AuthorizationAccessException v; java.lang.Object v; javax.xml.stream.XMLStreamWriter v; java.lang.String v; java.util.Comparator v; boolean v; v := @this: org.apache.nifi.authorization.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.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; 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.xml.processing.parsers.StandardDocumentProvider v; org.apache.nifi.authorization.FileAccessPolicyProvider v; org.w3c.dom.NodeList v; org.w3c.dom.Element v; org.apache.nifi.authorization.AccessPolicy v; org.apache.nifi.authorization.exception.AuthorizationAccessException v; v := @this: org.apache.nifi.authorization.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 = virtualinvoke 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.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.authorization.AccessPolicy parsePolicy(org.w3c.dom.Element) { java.lang.IllegalStateException v; org.w3c.dom.Node v, v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; org.apache.nifi.authorization.AccessPolicy$Builder v, v, v; boolean v, v; org.apache.nifi.authorization.FileAccessPolicyProvider v; org.w3c.dom.NodeList v, v; org.apache.nifi.authorization.RequestAction v, v, v, v; org.w3c.dom.Element v; org.apache.nifi.authorization.AccessPolicy v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: org.w3c.dom.Element; v = new org.apache.nifi.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 = 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.authorization.AccessPolicy) throws javax.xml.stream.XMLStreamException { java.util.ArrayList v, v; javax.xml.stream.XMLStreamWriter v; java.lang.String v, v, v; boolean v, v; org.apache.nifi.authorization.FileAccessPolicyProvider v; java.util.Iterator v, v; org.apache.nifi.authorization.RequestAction v; java.util.Set v, v; org.apache.nifi.authorization.AccessPolicy v; java.lang.Object v, v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: javax.xml.stream.XMLStreamWriter; v := @parameter: org.apache.nifi.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, java.io.IOException, java.lang.IllegalStateException, org.xml.sax.SAXException { java.util.concurrent.atomic.AtomicReference v; java.lang.String v, v, v, v, v, v, v, v; org.apache.nifi.authorization.exception.AuthorizerCreationException v; boolean v, v, v, v, v, v, v; org.apache.nifi.authorization.file.generated.Authorizations v; org.apache.nifi.authorization.FileAccessPolicyProvider v; org.slf4j.Logger v, v; java.util.Set v; org.apache.nifi.authorization.file.generated.Policies v, v; org.apache.nifi.authorization.AuthorizationsHolder v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v = specialinvoke v.(); v = virtualinvoke v.(); if v != null goto label; v = new org.apache.nifi.authorization.file.generated.Policies; specialinvoke v.()>(); virtualinvoke v.(v); label: v = new org.apache.nifi.authorization.AuthorizationsHolder; specialinvoke v.(org.apache.nifi.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 = staticinvoke (v); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; if v == 0 goto label; specialinvoke v.(); if v == 0 goto label; if v == 0 goto label; v = new org.apache.nifi.authorization.exception.AuthorizerCreationException; specialinvoke v.(java.lang.String)>("Cannot provide an Initial Admin Identity and a Legacy Authorized Users File"); throw v; 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); goto label; label: if v == 0 goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Converting \u to new authorizations model"); interfaceinvoke v.(v); specialinvoke v.(v); label: specialinvoke v.(v); specialinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(v); label: return; } private void saveAuthorizations(org.apache.nifi.authorization.file.generated.Authorizations) throws javax.xml.bind.JAXBException { org.apache.nifi.authorization.file.generated.Authorizations v; org.apache.nifi.authorization.FileAccessPolicyProvider v; java.io.File v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.authorization.file.generated.Authorizations; v = v.; specialinvoke v.(v, v); return; } private void saveAuthorizations(org.apache.nifi.authorization.file.generated.Authorizations, java.io.File) throws javax.xml.bind.JAXBException { org.apache.nifi.authorization.file.generated.Authorizations v; org.apache.nifi.authorization.FileAccessPolicyProvider v; javax.xml.bind.Marshaller v; java.lang.Boolean v; java.io.File v; javax.xml.bind.JAXBContext v; javax.xml.validation.Schema v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v := @parameter: org.apache.nifi.authorization.file.generated.Authorizations; v := @parameter: java.io.File; v = ; v = virtualinvoke v.(); v = v.; interfaceinvoke v.(v); v = staticinvoke (1); interfaceinvoke v.("jaxb.formatted.output", v); interfaceinvoke v.(v, v); return; } private org.apache.nifi.authorization.file.generated.Authorizations unmarshallAuthorizations() throws javax.xml.bind.JAXBException { java.lang.Throwable v; javax.xml.bind.Unmarshaller v; org.apache.nifi.authorization.FileAccessPolicyProvider v; org.slf4j.Logger v; javax.xml.bind.JAXBElement v; javax.xml.transform.stream.StreamSource v; org.apache.nifi.xml.processing.stream.StandardXMLStreamReaderProvider v; javax.xml.bind.JAXBException v; java.io.File v; javax.xml.validation.Schema v; javax.xml.stream.XMLStreamReader v; java.lang.Object v; javax.xml.bind.JAXBContext v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; label: v = new org.apache.nifi.xml.processing.stream.StandardXMLStreamReaderProvider; specialinvoke v.()>(); v = new javax.xml.transform.stream.StreamSource; v = v.; specialinvoke v.(java.io.File)>(v); v = interfaceinvoke v.(v); v = ; v = virtualinvoke v.(); v = v.; interfaceinvoke v.(v); v = interfaceinvoke v.(v, class "Lorg/apache/nifi/authorization/file/generated/Authorizations;"); v = virtualinvoke v.(); label: return v; label: v := @caughtexception; v = ; interfaceinvoke v.("Encountered an error reading authorizations file: ", v); v = new javax.xml.bind.JAXBException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Error reading authorizations file", v); throw v; catch org.apache.nifi.xml.processing.ProcessingException from label to label with label; } private void parseFlow() throws org.xml.sax.SAXException { org.apache.nifi.authorization.FileAccessPolicyProvider v; java.io.File v, v; java.util.ArrayList v; java.util.List v, v; org.apache.nifi.util.NiFiProperties v, v; org.apache.nifi.util.FlowParser v; java.lang.String v; org.apache.nifi.util.FlowInfo v; boolean v; v := @this: org.apache.nifi.authorization.FileAccessPolicyProvider; v = new org.apache.nifi.util.FlowParser; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v; goto label; label: v = v.; v = virtualinvoke v.