public class org.apache.nifi.registry.service.AuthorizationService extends java.lang.Object { private static final org.slf4j.Logger LOGGER; public static final java.lang.String MSG_NON_MANAGED_AUTHORIZER; public static final java.lang.String MSG_NON_CONFIGURABLE_POLICIES; public static final java.lang.String MSG_NON_CONFIGURABLE_USERS; private org.apache.nifi.registry.security.authorization.AuthorizableLookup authorizableLookup; private org.apache.nifi.registry.security.authorization.Authorizer authorizer; private org.apache.nifi.registry.service.RegistryService registryService; private org.apache.nifi.registry.security.authorization.UserGroupProvider userGroupProvider; private org.apache.nifi.registry.security.authorization.AccessPolicyProvider accessPolicyProvider; public void (org.apache.nifi.registry.security.authorization.AuthorizableLookup, org.apache.nifi.registry.security.authorization.Authorizer, org.apache.nifi.registry.service.RegistryService) { org.apache.nifi.registry.security.authorization.Authorizer v, v; org.apache.nifi.registry.security.authorization.AccessPolicyProvider v, v, v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.service.RegistryService v; org.apache.nifi.registry.security.authorization.AuthorizableLookup v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.security.authorization.AuthorizableLookup; v := @parameter: org.apache.nifi.registry.security.authorization.Authorizer; v := @parameter: org.apache.nifi.registry.service.RegistryService; specialinvoke v.()>(); v. = v; v. = v; v. = v; v = v.; v = staticinvoke (v); if v == 0 goto label; v = interfaceinvoke v.(); v. = v; goto label; label: v = staticinvoke (); v. = v; label: v = v.; v = interfaceinvoke v.(); v. = v; return; } public org.apache.nifi.registry.security.authorization.AuthorizableLookup getAuthorizableLookup() { org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.AuthorizableLookup v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; return v; } public void authorize(org.apache.nifi.registry.security.authorization.resource.Authorizable, org.apache.nifi.registry.security.authorization.RequestAction) throws org.apache.nifi.registry.security.authorization.exception.AccessDeniedException { org.apache.nifi.registry.security.authorization.Authorizer v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.RequestAction v; org.apache.nifi.registry.security.authorization.user.NiFiUser v; org.apache.nifi.registry.security.authorization.resource.Authorizable v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.security.authorization.resource.Authorizable; v := @parameter: org.apache.nifi.registry.security.authorization.RequestAction; v = v.; v = staticinvoke (); interfaceinvoke v.(v, v, v); return; } public boolean isManagedAuthorizer() { org.apache.nifi.registry.security.authorization.Authorizer v; org.apache.nifi.registry.service.AuthorizationService v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; v = staticinvoke (v); return v; } public boolean isConfigurableUserGroupProvider() { org.apache.nifi.registry.security.authorization.Authorizer v; org.apache.nifi.registry.service.AuthorizationService v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; v = staticinvoke (v); return v; } public boolean isConfigurableAccessPolicyProvider() { org.apache.nifi.registry.security.authorization.Authorizer v; org.apache.nifi.registry.service.AuthorizationService v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; v = staticinvoke (v); return v; } public void verifyAuthorizerIsManaged() { org.apache.nifi.registry.service.AuthorizationService v; java.lang.IllegalStateException v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("This NiFi Registry is not configured to internally manage users, groups, or policies. Please contact your system administrator."); throw v; label: return; } public void verifyAuthorizerSupportsConfigurablePolicies() { org.apache.nifi.registry.service.AuthorizationService v; java.lang.IllegalStateException v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(); v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("This NiFi Registry is not configured to allow configurable policies. Please contact your system administrator."); throw v; label: return; } public void verifyAuthorizerSupportsConfigurableUserGroups() { org.apache.nifi.registry.service.AuthorizationService v; java.lang.IllegalStateException v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("This NiFi Registry is not configured to allow configurable users and groups. Please contact your system administrator."); throw v; label: return; } public org.apache.nifi.registry.authorization.CurrentUser getCurrentUser() { org.apache.nifi.registry.authorization.ResourcePermissions v; org.apache.nifi.registry.authorization.CurrentUser v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.user.NiFiUser v; java.lang.String v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = staticinvoke (); v = new org.apache.nifi.registry.authorization.CurrentUser; specialinvoke v.()>(); v = interfaceinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); virtualinvoke v.(v); v = specialinvoke v.(); virtualinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.Permissions getPermissionsForResource(org.apache.nifi.registry.security.authorization.resource.Authorizable) { org.apache.nifi.registry.security.authorization.Authorizer v, v, v; org.apache.nifi.registry.authorization.Permissions v; org.apache.nifi.registry.security.authorization.RequestAction v, v, v; org.apache.nifi.registry.security.authorization.user.NiFiUser v; org.apache.nifi.registry.security.authorization.resource.Authorizable v; org.apache.nifi.registry.service.AuthorizationService v; boolean v, v, v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.security.authorization.resource.Authorizable; v = staticinvoke (); v = new org.apache.nifi.registry.authorization.Permissions; specialinvoke v.()>(); v = v.; v = ; v = interfaceinvoke v.(v, v, v); virtualinvoke v.(v); v = v.; v = ; v = interfaceinvoke v.(v, v, v); virtualinvoke v.(v); v = v.; v = ; v = interfaceinvoke v.(v, v, v); virtualinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.Permissions getPermissionsForResource(org.apache.nifi.registry.security.authorization.resource.Authorizable, org.apache.nifi.registry.authorization.Permissions) { org.apache.nifi.registry.security.authorization.Authorizer v, v, v; org.apache.nifi.registry.authorization.Permissions v, v, v; org.apache.nifi.registry.security.authorization.RequestAction v, v, v; org.apache.nifi.registry.security.authorization.user.NiFiUser v; org.apache.nifi.registry.security.authorization.resource.Authorizable v; boolean v, v, v, v, v, v; org.apache.nifi.registry.service.AuthorizationService v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.security.authorization.resource.Authorizable; v := @parameter: org.apache.nifi.registry.authorization.Permissions; if v != null goto label; v = virtualinvoke v.(v); return v; label: v = new org.apache.nifi.registry.authorization.Permissions; specialinvoke v.(org.apache.nifi.registry.authorization.Permissions)>(v); v = staticinvoke (); v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = ; v = interfaceinvoke v.(v, v, v); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = ; v = interfaceinvoke v.(v, v, v); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = ; v = interfaceinvoke v.(v, v, v); virtualinvoke v.(v); label: return v; } private org.apache.nifi.registry.authorization.ResourcePermissions getTopLevelPermissions() { org.apache.nifi.registry.authorization.Permissions v, v, v, v; org.apache.nifi.registry.security.authorization.resource.Authorizable v, v, v, v; org.apache.nifi.registry.authorization.ResourcePermissions v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.AuthorizableLookup v, v, v, v; v := @this: org.apache.nifi.registry.service.AuthorizationService; staticinvoke (); v = new org.apache.nifi.registry.authorization.ResourcePermissions; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.User createUser(org.apache.nifi.registry.authorization.User) { org.apache.nifi.registry.security.authorization.ConfigurableUserGroupProvider v; org.apache.nifi.registry.authorization.User v, v; org.apache.nifi.registry.security.authorization.User v, v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.authorization.User; specialinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("User identity must be specified when creating a new user."); throw v; label: v = specialinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = specialinvoke v.(v); return v; } public java.util.List getUsers() { java.util.Set v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; java.util.function.Function v; java.util.stream.Stream v, v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.Object v; java.util.stream.Collector v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.User getUser(java.lang.String) { org.slf4j.Logger v; org.apache.nifi.registry.authorization.User v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; org.apache.nifi.registry.security.authorization.User v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified user id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified user ID does not exist in this registry."); throw v; label: v = specialinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.User getUserByIdentity(java.lang.String) { org.slf4j.Logger v; org.apache.nifi.registry.authorization.User v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; org.apache.nifi.registry.security.authorization.User v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified user identity [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified user ID does not exist in this registry."); throw v; label: v = specialinvoke v.(v); return v; } public void verifyUserExists(java.lang.String) { org.slf4j.Logger v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; org.apache.nifi.registry.security.authorization.User v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified user id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified user ID does not exist in this registry."); throw v; label: return; } public org.apache.nifi.registry.authorization.User updateUser(org.apache.nifi.registry.authorization.User) { org.slf4j.Logger v; org.apache.nifi.registry.security.authorization.ConfigurableUserGroupProvider v; org.apache.nifi.registry.authorization.User v, v; org.apache.nifi.registry.security.authorization.User v, v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.authorization.User; specialinvoke v.(); v = specialinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v != null goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("The specified user id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified user ID does not exist in this registry."); throw v; label: v = specialinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.User deleteUser(java.lang.String) { org.slf4j.Logger v; org.apache.nifi.registry.security.authorization.ConfigurableUserGroupProvider v; org.apache.nifi.registry.authorization.User v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; org.apache.nifi.registry.security.authorization.User v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; specialinvoke v.(); v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified user id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified user ID does not exist in this registry."); throw v; label: v = specialinvoke v.(); interfaceinvoke v.(v); v = specialinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.UserGroup createUserGroup(org.apache.nifi.registry.authorization.UserGroup) { org.apache.nifi.registry.security.authorization.ConfigurableUserGroupProvider v; org.apache.nifi.registry.authorization.UserGroup v, v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.security.authorization.Group v, v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.authorization.UserGroup; specialinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("User group identity must be specified when creating a new group."); throw v; label: v = specialinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = specialinvoke v.(v); return v; } public java.util.List getUserGroups() { java.util.Set v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; java.util.function.Function v; java.util.stream.Stream v, v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.Object v; java.util.stream.Collector v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.UserGroup getUserGroup(java.lang.String) { org.apache.nifi.registry.security.authorization.Group v; org.slf4j.Logger v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.authorization.UserGroup v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified user group id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified user group ID does not exist in this registry."); throw v; label: v = specialinvoke v.(v); return v; } public void verifyUserGroupExists(java.lang.String) { org.apache.nifi.registry.security.authorization.Group v; org.slf4j.Logger v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified user group id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified user group ID does not exist in this registry."); throw v; label: return; } public org.apache.nifi.registry.authorization.UserGroup updateUserGroup(org.apache.nifi.registry.authorization.UserGroup) { org.slf4j.Logger v; org.apache.nifi.registry.security.authorization.ConfigurableUserGroupProvider v; org.apache.nifi.registry.authorization.UserGroup v, v; org.apache.nifi.registry.security.authorization.Group v, v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.authorization.UserGroup; specialinvoke v.(); v = specialinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v != null goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("The specified user group id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified user group ID does not exist in this registry."); throw v; label: v = specialinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.UserGroup deleteUserGroup(java.lang.String) { org.slf4j.Logger v; org.apache.nifi.registry.security.authorization.ConfigurableUserGroupProvider v; org.apache.nifi.registry.authorization.UserGroup v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; org.apache.nifi.registry.security.authorization.Group v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; specialinvoke v.(); v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified user group id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified user group ID does not exist in this registry."); throw v; label: v = specialinvoke v.(); interfaceinvoke v.(v); v = specialinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.AccessPolicy createAccessPolicy(org.apache.nifi.registry.authorization.AccessPolicy) { org.apache.nifi.registry.security.authorization.AccessPolicy v, v; java.lang.IllegalArgumentException v; org.apache.nifi.registry.security.authorization.ConfigurableAccessPolicyProvider v; org.apache.nifi.registry.authorization.AccessPolicy v, v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v, v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.authorization.AccessPolicy; specialinvoke v.(); v = virtualinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Resource must be specified when creating a new access policy."); throw v; label: v = virtualinvoke v.(); staticinvoke (v); v = specialinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = specialinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.AccessPolicy getAccessPolicy(java.lang.String) { org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; org.slf4j.Logger v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.authorization.AccessPolicy v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.AccessPolicy v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified access policy id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified policy does not exist in this registry."); throw v; label: v = specialinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.AccessPolicy getAccessPolicy(java.lang.String, org.apache.nifi.registry.security.authorization.RequestAction) { org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; org.apache.nifi.registry.security.authorization.AccessPolicy v; org.apache.nifi.registry.security.authorization.RequestAction v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.authorization.AccessPolicy v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v, v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.registry.security.authorization.RequestAction; v = v.; v = interfaceinvoke v.(v, v); if v != null goto label; v = new org.apache.nifi.registry.exception.ResourceNotFoundException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("No policy found for action=\'\u0001\', resource=\'\u0001\'"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = specialinvoke v.(v); return v; } public java.util.List getAccessPolicies() { org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; java.util.Set v; java.util.function.Function v; java.util.stream.Stream v, v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.Object v; java.util.stream.Collector v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } public java.util.List getAccessPolicySummaries() { org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; java.util.Set v; java.util.function.Function v; java.util.stream.Stream v, v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.Object v; java.util.stream.Collector v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } private java.util.List getAccessPolicySummariesForUser(java.lang.String) { org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; java.util.function.Predicate v; java.util.Set v; java.util.function.Function v; java.util.stream.Stream v, v, v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.Object v; java.lang.String v; java.util.stream.Collector v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } private java.util.List getAccessPolicySummariesForUserGroup(java.lang.String) { org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; java.util.function.Predicate v; java.util.Set v; java.util.function.Function v; java.util.stream.Stream v, v, v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.Object v; java.lang.String v; java.util.stream.Collector v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } public void verifyAccessPolicyExists(java.lang.String) { org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; org.slf4j.Logger v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.AccessPolicy v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified access policy id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified policy does not exist in this registry."); throw v; label: return; } public org.apache.nifi.registry.authorization.AccessPolicy updateAccessPolicy(org.apache.nifi.registry.authorization.AccessPolicy) { org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; org.apache.nifi.registry.security.authorization.AccessPolicy v, v, v; org.apache.nifi.registry.security.authorization.RequestAction v; org.apache.nifi.registry.exception.ResourceNotFoundException v, v; org.apache.nifi.registry.authorization.AccessPolicy v, v; java.lang.String v, v, v, v, v; org.slf4j.Logger v, v; org.apache.nifi.registry.security.authorization.ConfigurableAccessPolicyProvider v; org.apache.nifi.registry.service.AuthorizationService v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.authorization.AccessPolicy; specialinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("The specified access policy id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified policy does not exist in this registry."); throw v; label: v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = specialinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v != null goto label; v = ; v = virtualinvoke v.(); interfaceinvoke v.("The specified access policy id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified policy does not exist in this registry."); throw v; label: v = specialinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.AccessPolicy deleteAccessPolicy(java.lang.String) { org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; org.slf4j.Logger v; org.apache.nifi.registry.security.authorization.AccessPolicy v; org.apache.nifi.registry.security.authorization.ConfigurableAccessPolicyProvider v; org.apache.nifi.registry.exception.ResourceNotFoundException v; org.apache.nifi.registry.authorization.AccessPolicy v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; specialinvoke v.(); v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = ; interfaceinvoke v.("The specified access policy id [{}] does not exist.", v); v = new org.apache.nifi.registry.exception.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified policy does not exist in this registry."); throw v; label: v = specialinvoke v.(); interfaceinvoke v.(v); v = specialinvoke v.(v); return v; } public java.util.List getResources() { java.util.List v; java.util.stream.Stream v, v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.Object v; java.util.stream.Collector v; java.util.function.Function v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = specialinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } public java.util.List getAuthorizedResources(org.apache.nifi.registry.security.authorization.RequestAction) { org.apache.nifi.registry.service.AuthorizationService v; java.util.List v; org.apache.nifi.registry.security.authorization.RequestAction v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.security.authorization.RequestAction; v = virtualinvoke v.(v, null); return v; } public java.util.List getAuthorizedResources(org.apache.nifi.registry.security.authorization.RequestAction, org.apache.nifi.registry.security.authorization.resource.ResourceType) { org.apache.nifi.registry.security.authorization.resource.ResourceType v; java.util.function.Predicate v; org.apache.nifi.registry.security.authorization.RequestAction v; java.util.function.Function v; java.util.List v; java.util.stream.Stream v, v, v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.Object v; java.util.stream.Collector v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.security.authorization.RequestAction; v := @parameter: org.apache.nifi.registry.security.authorization.resource.ResourceType; v = specialinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } private org.apache.nifi.registry.security.authorization.ConfigurableUserGroupProvider configurableUserGroupProvider() { org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; return v; } private org.apache.nifi.registry.security.authorization.ConfigurableAccessPolicyProvider configurableAccessPolicyProvider() { org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; return v; } private void verifyUserGroupProviderIsConfigurable() { java.lang.IllegalStateException v; org.apache.nifi.registry.service.AuthorizationService v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; v = v instanceof org.apache.nifi.registry.security.authorization.ConfigurableUserGroupProvider; if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("This NiFi Registry is not configured to allow configurable users and groups. Please contact your system administrator."); throw v; label: return; } private void verifyAccessPolicyProviderIsConfigurable() { java.lang.IllegalStateException v; org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; org.apache.nifi.registry.service.AuthorizationService v; boolean v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = v.; v = v instanceof org.apache.nifi.registry.security.authorization.ConfigurableAccessPolicyProvider; if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("This NiFi Registry is not configured to allow configurable policies. Please contact your system administrator."); throw v; label: return; } private org.apache.nifi.registry.authorization.ResourcePermissions getTopLevelPermissions(java.lang.String) { org.apache.nifi.registry.security.authorization.Resource v, v, v, v; org.apache.nifi.registry.authorization.Permissions v, v, v, v; org.apache.nifi.registry.authorization.ResourcePermissions v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v = new org.apache.nifi.registry.authorization.ResourcePermissions; specialinvoke v.()>(); v = staticinvoke (); v = specialinvoke v.(v, v); virtualinvoke v.(v); v = staticinvoke (); v = specialinvoke v.(v, v); virtualinvoke v.(v); v = staticinvoke (); v = specialinvoke v.(v, v); virtualinvoke v.(v); v = staticinvoke (); v = specialinvoke v.(v, v); virtualinvoke v.(v); return v; } private org.apache.nifi.registry.authorization.Permissions getPermissionsForResource(java.lang.String, org.apache.nifi.registry.security.authorization.Resource) { org.apache.nifi.registry.security.authorization.Resource v; org.apache.nifi.registry.authorization.Permissions v; org.apache.nifi.registry.security.authorization.RequestAction v, v, v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v; boolean v, v, v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.registry.security.authorization.Resource; v = new org.apache.nifi.registry.authorization.Permissions; specialinvoke v.()>(); v = ; v = specialinvoke v.(v, v, v); virtualinvoke v.(v); v = ; v = specialinvoke v.(v, v, v); virtualinvoke v.(v); v = ; v = specialinvoke v.(v, v, v); virtualinvoke v.(v); return v; } private boolean checkTenantBelongsToPolicy(java.lang.String, org.apache.nifi.registry.security.authorization.Resource, org.apache.nifi.registry.security.authorization.RequestAction) { org.apache.nifi.registry.security.authorization.Resource v; org.apache.nifi.registry.security.authorization.AccessPolicyProvider v; java.util.Set v, v; org.apache.nifi.registry.security.authorization.AccessPolicy v; org.apache.nifi.registry.security.authorization.RequestAction v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.String v, v; boolean v, v, v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.registry.security.authorization.Resource; v := @parameter: org.apache.nifi.registry.security.authorization.RequestAction; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v, v); if v != null goto label; return 0; label: v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } private java.util.List getAuthorizableResources() { org.apache.nifi.registry.service.AuthorizationService v; java.util.List v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v = specialinvoke v.(null); return v; } private java.util.List getAuthorizableResources(org.apache.nifi.registry.security.authorization.resource.ResourceType) { org.apache.nifi.registry.security.authorization.Resource v, v, v, v, v, v, v; java.util.ArrayList v; java.lang.String v, v; boolean v, v, v, v, v, v, v; java.util.Iterator v; org.apache.nifi.registry.security.authorization.resource.ResourceType v, v, v, v, v, v, v; java.util.List v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.Object v; org.apache.nifi.registry.service.RegistryService v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.security.authorization.resource.ResourceType; v = new java.util.ArrayList; specialinvoke v.()>(); if v == null goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; label: v = staticinvoke (); interfaceinvoke v.(v); label: if v == null goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; label: v = staticinvoke (); interfaceinvoke v.(v); label: if v == null goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; label: v = staticinvoke (); interfaceinvoke v.(v); label: if v == null goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; label: v = staticinvoke (); interfaceinvoke v.(v); label: if v == null goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; label: v = staticinvoke (); interfaceinvoke v.(v); label: if v == null goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; label: v = staticinvoke (); interfaceinvoke v.(v); v = 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 = staticinvoke (v, v); interfaceinvoke v.(v); goto label; label: return v; } public org.apache.nifi.registry.authorization.User userToDTO(org.apache.nifi.registry.security.authorization.User) { org.apache.nifi.registry.security.authorization.Authorizer v; org.apache.nifi.registry.authorization.User v; java.util.function.Function v; java.lang.Boolean v; java.lang.String v, v, v, v; java.util.stream.Collector v; boolean v; java.util.function.Predicate v; java.util.Set v; org.apache.nifi.registry.security.authorization.UserGroupProvider v; org.apache.nifi.registry.security.authorization.User v; java.util.List v; java.util.stream.Stream v, v, v; org.apache.nifi.registry.authorization.ResourcePermissions v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.Object v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.security.authorization.User; if v != null goto label; return null; label: v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = specialinvoke v.(v); v = new org.apache.nifi.registry.authorization.User; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = v.; v = staticinvoke (v, v); v = staticinvoke (v); virtualinvoke v.(v); v = virtualinvoke v.(); v = specialinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); return v; } public org.apache.nifi.registry.authorization.UserGroup userGroupToDTO(org.apache.nifi.registry.security.authorization.Group) { org.apache.nifi.registry.security.authorization.Authorizer v; java.util.function.Function v; org.apache.nifi.registry.security.authorization.Group v; java.lang.Boolean v; java.lang.String v, v, v, v; java.util.stream.Collector v; boolean v; java.util.function.Predicate v; java.util.Set v, v; org.apache.nifi.registry.authorization.UserGroup v; java.util.List v; java.util.stream.Stream v, v, v; org.apache.nifi.registry.authorization.ResourcePermissions v; org.apache.nifi.registry.service.AuthorizationService v; java.lang.Object v; v := @this: org.apache.nifi.registry.service.AuthorizationService; v := @parameter: org.apache.nifi.registry.security.authorization.Group; if v != null goto label; return null; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); goto label; label: v = null; label: v = virtualinvoke v.(); v = specialinvoke v.(v); v = new org.apache.nifi.registry.authorization.UserGroup; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = v.; v = staticinvoke (v, v); v = staticinvoke (v); virtualinvoke v.(v); v = virtualinvoke v.(); v = specialinvoke v.(v); virtualinvoke v.