public class WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource extends org.apache.nifi.web.api.ApplicationResource
{
private static final org.slf4j.Logger logger;
private static final java.lang.String VERIFICATION_REQUEST_TYPE;
private org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager;
private org.apache.nifi.web.NiFiServiceFacade serviceFacade;
private org.apache.nifi.authorization.Authorizer authorizer;
private javax.servlet.ServletContext servletContext;
public void <init>()
{
java.util.concurrent.TimeUnit v;
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
long v;
org.apache.nifi.web.api.concurrent.AsyncRequestManager v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
specialinvoke v.<org.apache.nifi.web.api.ApplicationResource: void <init>()>();
v = new org.apache.nifi.web.api.concurrent.AsyncRequestManager;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MINUTES>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(1L);
specialinvoke v.<org.apache.nifi.web.api.concurrent.AsyncRequestManager: void <init>(int,long,java.lang.String)>(100, v, "Verify Controller Service Config Thread");
v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager> = v;
return;
}
public java.util.Set populateRemainingControllerServiceEntitiesContent(java.util.Set)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
java.util.Iterator v;
java.util.Set v;
java.lang.Object v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: java.util.Set;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.api.entity.ControllerServiceEntity populateRemainingControllerServiceEntityContent(org.apache.nifi.web.api.entity.ControllerServiceEntity)>(v);
goto label;
label:
return v;
}
public org.apache.nifi.web.api.entity.ControllerServiceEntity populateRemainingControllerServiceEntityContent(org.apache.nifi.web.api.entity.ControllerServiceEntity)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.web.api.dto.ControllerServiceDTO v, v;
org.apache.nifi.web.api.entity.ControllerServiceEntity v;
java.lang.String[] v;
java.lang.String v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: org.apache.nifi.web.api.entity.ControllerServiceEntity;
v = newarray (java.lang.String)[2];
v[0] = "controller-services";
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: java.lang.String getId()>();
v[1] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: java.lang.String generateResourceUri(java.lang.String[])>(v);
virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: void setUri(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: org.apache.nifi.web.api.dto.ControllerServiceDTO getComponent()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: org.apache.nifi.web.api.dto.ControllerServiceDTO getComponent()>();
virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.api.dto.ControllerServiceDTO populateRemainingControllerServiceContent(org.apache.nifi.web.api.dto.ControllerServiceDTO)>(v);
label:
return v;
}
public org.apache.nifi.web.api.dto.ControllerServiceDTO populateRemainingControllerServiceContent(org.apache.nifi.web.api.dto.ControllerServiceDTO)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.web.api.dto.BundleDTO v;
org.apache.nifi.web.UiExtensionType v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
boolean v, v, v;
java.util.Iterator v;
org.apache.nifi.web.api.dto.ControllerServiceDTO v;
java.util.List v;
java.lang.Object v, v;
javax.servlet.ServletContext v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: org.apache.nifi.web.api.dto.ControllerServiceDTO;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerServiceDTO: org.apache.nifi.web.api.dto.BundleDTO getBundle()>();
v = v.<org.apache.nifi.web.api.ControllerServiceResource: javax.servlet.ServletContext servletContext>;
v = interfaceinvoke v.<javax.servlet.ServletContext: java.lang.Object getAttribute(java.lang.String)>("nifi-ui-extensions");
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerServiceDTO: java.lang.String getType()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getGroup()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getArtifact()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getVersion()>();
v = virtualinvoke v.<org.apache.nifi.ui.extension.UiExtensionMapping: boolean hasUiExtension(java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerServiceDTO: java.lang.String getType()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getGroup()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getArtifact()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getVersion()>();
v = virtualinvoke v.<org.apache.nifi.ui.extension.UiExtensionMapping: java.util.List getUiExtension(java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.nifi.web.UiExtensionType: org.apache.nifi.web.UiExtensionType ControllerServiceConfiguration>;
v = virtualinvoke v.<org.apache.nifi.ui.extension.UiExtension: org.apache.nifi.web.UiExtensionType getExtensionType()>();
v = virtualinvoke v.<org.apache.nifi.web.UiExtensionType: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.ui.extension.UiExtension: java.lang.String getContextPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/configure");
virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerServiceDTO: void setCustomUiUrl(java.lang.String)>(v);
goto label;
label:
return v;
}
public javax.ws.rs.core.Response getControllerService(java.lang.String, boolean)
{
org.apache.nifi.web.NiFiServiceFacade v, v;
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.web.api.entity.ControllerServiceEntity v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.ws.rs.core.Response v, v;
javax.ws.rs.core.Response$ResponseBuilder v;
java.lang.String v;
boolean v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String)>("GET");
return v;
label:
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_getControllerService_0__446: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: org.apache.nifi.web.api.entity.ControllerServiceEntity getControllerService(java.lang.String,boolean)>(v, 1);
if v == 0 goto label;
virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: void stripNonUiRelevantFields(org.apache.nifi.web.api.entity.ControllerServiceEntity)>(v);
label:
virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.api.entity.ControllerServiceEntity populateRemainingControllerServiceEntityContent(org.apache.nifi.web.api.entity.ControllerServiceEntity)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
}
public javax.ws.rs.core.Response getPropertyDescriptor(java.lang.String, java.lang.String, boolean)
{
org.apache.nifi.web.NiFiServiceFacade v, v;
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.web.api.entity.PropertyDescriptorEntity v;
java.lang.IllegalArgumentException v;
org.apache.nifi.authorization.AuthorizeAccess v;
org.apache.nifi.web.api.dto.PropertyDescriptorDTO v;
javax.ws.rs.core.Response v, v;
javax.ws.rs.core.Response$ResponseBuilder v;
java.lang.String v, v;
boolean v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("The property name must be specified.");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String)>("GET");
return v;
label:
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_getPropertyDescriptor_1__447: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: org.apache.nifi.web.api.dto.PropertyDescriptorDTO getControllerServicePropertyDescriptor(java.lang.String,java.lang.String,boolean)>(v, v, v);
v = new org.apache.nifi.web.api.entity.PropertyDescriptorEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.PropertyDescriptorEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.PropertyDescriptorEntity: void setPropertyDescriptor(org.apache.nifi.web.api.dto.PropertyDescriptorDTO)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
}
public javax.ws.rs.core.Response getState(java.lang.String)
{
org.apache.nifi.web.NiFiServiceFacade v, v;
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.ws.rs.core.Response v, v;
javax.ws.rs.core.Response$ResponseBuilder v;
org.apache.nifi.web.api.dto.ComponentStateDTO v;
org.apache.nifi.web.api.entity.ComponentStateEntity v;
java.lang.String v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String)>("GET");
return v;
label:
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_getState_2__448: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: org.apache.nifi.web.api.dto.ComponentStateDTO getControllerServiceState(java.lang.String)>(v);
v = new org.apache.nifi.web.api.entity.ComponentStateEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.ComponentStateEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.ComponentStateEntity: void setComponentState(org.apache.nifi.web.api.dto.ComponentStateDTO)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
}
public javax.ws.rs.core.Response clearState(javax.servlet.http.HttpServletRequest, java.lang.String)
{
org.apache.nifi.web.NiFiServiceFacade v;
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.web.api.entity.ControllerServiceEntity v;
java.lang.Runnable v;
java.util.function.Function v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.servlet.http.HttpServletRequest v;
javax.ws.rs.core.Response v, v;
java.lang.String v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String)>("POST");
return v;
label:
v = new org.apache.nifi.web.api.entity.ControllerServiceEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: void setId(java.lang.String)>(v);
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_clearState_3__449: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_clearState_4__450: java.lang.Runnable bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_clearState_5__451: java.util.function.Function bootstrap$(org.apache.nifi.web.api.ControllerServiceResource)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.Function)>(v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response getControllerServiceReferences(java.lang.String)
{
org.apache.nifi.web.api.entity.ControllerServiceReferencingComponentsEntity v;
org.apache.nifi.web.NiFiServiceFacade v, v;
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.ws.rs.core.Response v, v;
javax.ws.rs.core.Response$ResponseBuilder v;
java.lang.String v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String)>("GET");
return v;
label:
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_getControllerServiceReferences_6__452: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: org.apache.nifi.web.api.entity.ControllerServiceReferencingComponentsEntity getControllerServiceReferencingComponents(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
}
public javax.ws.rs.core.Response updateControllerServiceReferences(javax.servlet.http.HttpServletRequest, java.lang.String, org.apache.nifi.web.api.entity.UpdateControllerServiceReferenceRequestEntity)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
java.util.function.BiFunction v;
java.lang.Runnable v;
org.apache.nifi.authorization.AuthorizeAccess v;
java.util.Map v, v;
java.util.stream.Collector v;
boolean v, v, v, v;
java.util.Collection v;
java.util.Set v;
java.util.stream.Stream v;
javax.ws.rs.core.Response v, v;
org.apache.nifi.controller.ScheduledState v;
org.apache.nifi.controller.service.ControllerServiceState v, v, v;
java.util.function.Function v, v;
java.util.HashSet v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.web.api.entity.UpdateControllerServiceReferenceRequestEntity v;
java.lang.Boolean v;
java.lang.String v, v, v, v;
org.apache.nifi.web.NiFiServiceFacade v;
java.lang.IllegalArgumentException v, v, v, v, v, v;
java.lang.Object v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.entity.UpdateControllerServiceReferenceRequestEntity;
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.UpdateControllerServiceReferenceRequestEntity: java.lang.String getId()>();
if v != null goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("The controller service identifier must be specified.");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.UpdateControllerServiceReferenceRequestEntity: java.util.Map getReferencingComponentRevisions()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("The controller service referencing components revisions must be specified.");
throw v;
label:
v = null;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.UpdateControllerServiceReferenceRequestEntity: java.lang.String getState()>();
v = staticinvoke <org.apache.nifi.controller.service.ControllerServiceState: org.apache.nifi.controller.service.ControllerServiceState valueOf(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
v = null;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.UpdateControllerServiceReferenceRequestEntity: java.lang.String getState()>();
v = staticinvoke <org.apache.nifi.controller.ScheduledState: org.apache.nifi.controller.ScheduledState valueOf(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
if v != null goto label;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Must specify the updated state. To update referencing Processors and Reporting Tasks the state should be RUNNING or STOPPED. To update the referencing Controller Services the state should be ENABLED or DISABLED.");
throw v;
label:
if v == null goto label;
v = <org.apache.nifi.controller.service.ControllerServiceState: org.apache.nifi.controller.service.ControllerServiceState ENABLING>;
v = virtualinvoke v.<org.apache.nifi.controller.service.ControllerServiceState: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.nifi.controller.service.ControllerServiceState: org.apache.nifi.controller.service.ControllerServiceState DISABLING>;
v = virtualinvoke v.<org.apache.nifi.controller.service.ControllerServiceState: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Cannot set the referencing services to ENABLING or DISABLING");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String,java.lang.Object)>("PUT", v);
return v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isDisconnectedFromCluster()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.UpdateControllerServiceReferenceRequestEntity: java.lang.Boolean isDisconnectedNodeAcknowledged()>();
virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: void verifyDisconnectedNodeModification(java.lang.Boolean)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.UpdateControllerServiceReferenceRequestEntity: java.util.Map getReferencingComponentRevisions()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$getKey__453: java.util.function.Function bootstrap$()>();
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_updateControllerServiceReferences_7__454: java.util.function.Function bootstrap$()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toMap(java.util.function.Function,java.util.function.Function)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = new java.util.HashSet;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_updateControllerServiceReferences_9__455: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.util.Map,java.lang.String)>(v, v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_updateControllerServiceReferences_10__456: java.lang.Runnable bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,org.apache.nifi.web.api.entity.UpdateControllerServiceReferenceRequestEntity,org.apache.nifi.controller.ScheduledState,org.apache.nifi.controller.service.ControllerServiceState)>(v, v, v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_updateControllerServiceReferences_12__457: java.util.function.BiFunction bootstrap$(org.apache.nifi.web.api.ControllerServiceResource)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,java.util.Set,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.BiFunction)>(v, v, v, v, v, v);
return v;
catch java.lang.IllegalArgumentException from label to label with label;
catch java.lang.IllegalArgumentException from label to label with label;
}
public javax.ws.rs.core.Response updateControllerService(javax.servlet.http.HttpServletRequest, java.lang.String, org.apache.nifi.web.api.entity.ControllerServiceEntity)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
java.lang.Object[] v;
org.apache.nifi.web.Revision v;
java.util.function.BiFunction v;
org.apache.nifi.web.api.entity.ControllerServiceEntity v;
org.apache.nifi.web.api.dto.RevisionDTO v;
java.lang.Runnable v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.servlet.http.HttpServletRequest v;
java.lang.Boolean v;
java.lang.String v, v, v, v;
boolean v, v, v;
org.apache.nifi.web.NiFiServiceFacade v;
org.apache.nifi.web.api.dto.ControllerServiceDTO v, v;
java.lang.IllegalArgumentException v, v, v;
javax.ws.rs.core.Response v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.entity.ControllerServiceEntity;
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: org.apache.nifi.web.api.dto.ControllerServiceDTO getComponent()>();
if v != null goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Controller service details must be specified.");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: org.apache.nifi.web.api.dto.RevisionDTO getRevision()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Revision must be specified.");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: org.apache.nifi.web.api.dto.ControllerServiceDTO getComponent()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerServiceDTO: java.lang.String getId()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerServiceDTO: java.lang.String getId()>();
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("The controller service id (%s) in the request body does not equal the controller service id of the requested resource (%s).", v);
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String,java.lang.Object)>("PUT", v);
return v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isDisconnectedFromCluster()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: java.lang.Boolean isDisconnectedNodeAcknowledged()>();
virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: void verifyDisconnectedNodeModification(java.lang.Boolean)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.Revision getRevision(org.apache.nifi.web.api.entity.ComponentEntity,java.lang.String)>(v, v);
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_updateControllerService_13__458: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String,org.apache.nifi.web.api.dto.ControllerServiceDTO)>(v, v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_updateControllerService_14__459: java.lang.Runnable bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,org.apache.nifi.web.api.dto.ControllerServiceDTO)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_updateControllerService_15__460: java.util.function.BiFunction bootstrap$(org.apache.nifi.web.api.ControllerServiceResource)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.web.Revision,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.BiFunction)>(v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response removeControllerService(javax.servlet.http.HttpServletRequest, org.apache.nifi.web.api.request.LongParameter, org.apache.nifi.web.api.request.ClientIdParameter, java.lang.Boolean, java.lang.String)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.web.Revision v;
java.util.function.BiFunction v;
org.apache.nifi.web.api.entity.ControllerServiceEntity v;
java.lang.Runnable v;
org.apache.nifi.web.api.request.ClientIdParameter v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.servlet.http.HttpServletRequest v;
java.lang.Long v;
java.lang.Boolean v;
java.lang.String v, v;
boolean v, v;
org.apache.nifi.web.NiFiServiceFacade v;
org.apache.nifi.web.api.request.LongParameter v;
javax.ws.rs.core.Response v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: org.apache.nifi.web.api.request.LongParameter;
v := @parameter: org.apache.nifi.web.api.request.ClientIdParameter;
v := @parameter: java.lang.Boolean;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String)>("DELETE");
return v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isDisconnectedFromCluster()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: void verifyDisconnectedNodeModification(java.lang.Boolean)>(v);
label:
v = new org.apache.nifi.web.api.entity.ControllerServiceEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceEntity: void setId(java.lang.String)>(v);
v = new org.apache.nifi.web.Revision;
if v != null goto label;
v = null;
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.request.LongParameter: java.lang.Long getLong()>();
label:
v = virtualinvoke v.<org.apache.nifi.web.api.request.ClientIdParameter: java.lang.String getClientId()>();
specialinvoke v.<org.apache.nifi.web.Revision: void <init>(java.lang.Long,java.lang.String,java.lang.String)>(v, v, v);
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_removeControllerService_16__461: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_removeControllerService_17__462: java.lang.Runnable bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_removeControllerService_18__463: java.util.function.BiFunction bootstrap$(org.apache.nifi.web.api.ControllerServiceResource)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.web.Revision,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.BiFunction)>(v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response updateRunStatus(javax.servlet.http.HttpServletRequest, java.lang.String, org.apache.nifi.web.api.entity.ControllerServiceRunStatusEntity)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.web.Revision v;
java.util.function.BiFunction v;
org.apache.nifi.web.api.entity.ControllerServiceRunStatusEntity v;
org.apache.nifi.web.api.dto.RevisionDTO v, v;
java.lang.Runnable v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.servlet.http.HttpServletRequest v;
java.lang.Boolean v;
java.lang.String v;
boolean v, v;
org.apache.nifi.web.NiFiServiceFacade v;
java.lang.IllegalArgumentException v, v;
javax.ws.rs.core.Response v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.entity.ControllerServiceRunStatusEntity;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Controller service run status must be specified.");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceRunStatusEntity: org.apache.nifi.web.api.dto.RevisionDTO getRevision()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Revision must be specified.");
throw v;
label:
virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceRunStatusEntity: void validateState()>();
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String,java.lang.Object)>("PUT", v);
return v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isDisconnectedFromCluster()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceRunStatusEntity: java.lang.Boolean isDisconnectedNodeAcknowledged()>();
virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: void verifyDisconnectedNodeModification(java.lang.Boolean)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerServiceRunStatusEntity: org.apache.nifi.web.api.dto.RevisionDTO getRevision()>();
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.Revision getRevision(org.apache.nifi.web.api.dto.RevisionDTO,java.lang.String)>(v, v);
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_updateRunStatus_19__464: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_updateRunStatus_20__465: java.lang.Runnable bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String,org.apache.nifi.web.api.entity.ControllerServiceRunStatusEntity)>(v, v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_updateRunStatus_21__466: java.util.function.BiFunction bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.web.Revision,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.BiFunction)>(v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response analyzeConfiguration(java.lang.String, org.apache.nifi.web.api.entity.ConfigurationAnalysisEntity)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
java.lang.Runnable v;
java.util.function.Function v;
org.apache.nifi.authorization.AuthorizeAccess v;
java.util.Map v;
java.lang.String v, v, v;
boolean v, v;
org.apache.nifi.web.NiFiServiceFacade v;
org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO v, v;
java.lang.IllegalArgumentException v, v, v, v;
javax.ws.rs.core.Response v, v;
org.apache.nifi.web.api.entity.ConfigurationAnalysisEntity v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.entity.ConfigurationAnalysisEntity;
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ConfigurationAnalysisEntity: org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO getConfigurationAnalysis()>();
if v != null goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Controller Service\'s configuration must be specified");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ConfigurationAnalysisEntity: org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO getConfigurationAnalysis()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO: java.lang.String getComponentId()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Controller Service\'s identifier must be specified in the request");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO: java.lang.String getComponentId()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Controller Service\'s identifier in the request must match the identifier provided in the URL");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO: java.util.Map getProperties()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Controller Service\'s properties must be specified in the request");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String,java.lang.Object)>("POST", v);
return v;
label:
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_analyzeConfiguration_22__467: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_analyzeConfiguration_23__468: java.lang.Runnable bootstrap$()>();
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_analyzeConfiguration_24__469: java.util.function.Function bootstrap$(org.apache.nifi.web.api.ControllerServiceResource)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.Function)>(v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response submitConfigVerificationRequest(java.lang.String, org.apache.nifi.web.api.entity.VerifyConfigRequestEntity)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.web.api.dto.VerifyConfigRequestDTO v;
java.lang.Runnable v;
java.util.function.Function v;
org.apache.nifi.authorization.AuthorizeAccess v;
org.apache.nifi.authorization.user.NiFiUser v;
java.util.Map v;
java.lang.String v, v, v;
org.apache.nifi.web.api.entity.VerifyConfigRequestEntity v;
boolean v, v;
org.apache.nifi.web.NiFiServiceFacade v;
java.lang.IllegalArgumentException v, v, v, v;
javax.ws.rs.core.Response v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.entity.VerifyConfigRequestEntity;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Controller Service\'s configuration must be specified");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.VerifyConfigRequestEntity: org.apache.nifi.web.api.dto.VerifyConfigRequestDTO getRequest()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.util.Map getProperties()>();
if v != null goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Controller Service properties must be specified");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.lang.String getComponentId()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Controller Service\'s identifier must be specified in the request");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.lang.String getComponentId()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Controller Service\'s identifier in the request must match the identifier provided in the URL");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String,java.lang.Object)>("POST", v);
return v;
label:
v = staticinvoke <org.apache.nifi.authorization.user.NiFiUserUtils: org.apache.nifi.authorization.user.NiFiUser getNiFiUser()>();
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_submitConfigVerificationRequest_25__470: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_submitConfigVerificationRequest_26__471: java.lang.Runnable bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_submitConfigVerificationRequest_27__472: java.util.function.Function bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,org.apache.nifi.authorization.user.NiFiUser)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.Function)>(v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response getVerificationRequest(java.lang.String, java.lang.String)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
javax.ws.rs.core.Response v, v;
org.apache.nifi.authorization.user.NiFiUser v;
javax.ws.rs.core.Response$ResponseBuilder v;
java.lang.String v, v;
org.apache.nifi.web.api.entity.VerifyConfigRequestEntity v;
org.apache.nifi.web.api.concurrent.RequestManager v;
org.apache.nifi.web.api.concurrent.AsynchronousWebRequest v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String)>("GET");
return v;
label:
v = staticinvoke <org.apache.nifi.authorization.user.NiFiUserUtils: org.apache.nifi.authorization.user.NiFiUser getNiFiUser()>();
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager>;
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.RequestManager: org.apache.nifi.web.api.concurrent.AsynchronousWebRequest getRequest(java.lang.String,java.lang.String,org.apache.nifi.authorization.user.NiFiUser)>("verification-request", v, v);
v = specialinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.api.entity.VerifyConfigRequestEntity createVerifyControllerServiceConfigRequestEntity(org.apache.nifi.web.api.concurrent.AsynchronousWebRequest,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
}
public javax.ws.rs.core.Response deleteVerificationRequest(java.lang.String, java.lang.String)
{
java.lang.IllegalStateException v;
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
javax.servlet.http.HttpServletRequest v, v, v, v;
org.apache.nifi.authorization.user.NiFiUser v;
org.apache.nifi.web.ResourceNotFoundException v;
java.lang.String v, v, v;
org.apache.nifi.web.api.entity.VerifyConfigRequestEntity v;
boolean v, v, v, v, v, v;
javax.ws.rs.core.Response v, v, v, v;
javax.ws.rs.core.Response$ResponseBuilder v, v, v;
org.apache.nifi.web.api.concurrent.RequestManager v, v;
org.apache.nifi.web.api.concurrent.AsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response replicate(java.lang.String)>("DELETE");
return v;
label:
v = staticinvoke <org.apache.nifi.authorization.user.NiFiUserUtils: org.apache.nifi.authorization.user.NiFiUser getNiFiUser()>();
v = v.<org.apache.nifi.web.api.ControllerServiceResource: javax.servlet.http.HttpServletRequest httpServletRequest>;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isTwoPhaseRequest(javax.servlet.http.HttpServletRequest)>(v);
v = v.<org.apache.nifi.web.api.ControllerServiceResource: javax.servlet.http.HttpServletRequest httpServletRequest>;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isExecutionPhase(javax.servlet.http.HttpServletRequest)>(v);
if v == 0 goto label;
if v == 0 goto label;
label:
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager>;
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.RequestManager: org.apache.nifi.web.api.concurrent.AsynchronousWebRequest removeRequest(java.lang.String,java.lang.String,org.apache.nifi.authorization.user.NiFiUser)>("verification-request", v, v);
if v != null goto label;
v = new org.apache.nifi.web.ResourceNotFoundException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Could not find request of type verification-request with ID \u0001");
specialinvoke v.<org.apache.nifi.web.ResourceNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: boolean isComplete()>();
if v != 0 goto label;
interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: void cancel()>();
label:
v = specialinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.api.entity.VerifyConfigRequestEntity createVerifyControllerServiceConfigRequestEntity(org.apache.nifi.web.api.concurrent.AsynchronousWebRequest,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
label:
v = v.<org.apache.nifi.web.api.ControllerServiceResource: javax.servlet.http.HttpServletRequest httpServletRequest>;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isValidationPhase(javax.servlet.http.HttpServletRequest)>(v);
if v == 0 goto label;
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager>;
interfaceinvoke v.<org.apache.nifi.web.api.concurrent.RequestManager: org.apache.nifi.web.api.concurrent.AsynchronousWebRequest getRequest(java.lang.String,java.lang.String,org.apache.nifi.authorization.user.NiFiUser)>("verification-request", v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response$ResponseBuilder generateContinueResponse()>();
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
label:
v = v.<org.apache.nifi.web.api.ControllerServiceResource: javax.servlet.http.HttpServletRequest httpServletRequest>;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: boolean isCancellationPhase(javax.servlet.http.HttpServletRequest)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse()>();
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("This request does not appear to be part of the two phase commit.");
throw v;
}
public javax.ws.rs.core.Response performAsyncConfigVerification(org.apache.nifi.web.api.entity.VerifyConfigRequestEntity, org.apache.nifi.authorization.user.NiFiUser)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.web.api.concurrent.StandardUpdateStep v;
org.apache.nifi.web.api.dto.VerifyConfigRequestDTO v;
org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
java.util.function.Consumer v;
java.util.List v;
javax.ws.rs.core.Response v;
org.apache.nifi.authorization.user.NiFiUser v;
javax.ws.rs.core.Response$ResponseBuilder v;
java.lang.String v, v;
org.apache.nifi.web.api.entity.VerifyConfigRequestEntity v, v;
org.apache.nifi.web.api.concurrent.RequestManager v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: org.apache.nifi.web.api.entity.VerifyConfigRequestEntity;
v := @parameter: org.apache.nifi.authorization.user.NiFiUser;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: java.lang.String generateUuid()>();
v = virtualinvoke v.<org.apache.nifi.web.api.entity.VerifyConfigRequestEntity: org.apache.nifi.web.api.dto.VerifyConfigRequestDTO getRequest()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.lang.String getComponentId()>();
v = new org.apache.nifi.web.api.concurrent.StandardUpdateStep;
specialinvoke v.<org.apache.nifi.web.api.concurrent.StandardUpdateStep: void <init>(java.lang.String)>("Verify Controller Service Configuration");
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
v = new org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
specialinvoke v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: void <init>(java.lang.String,java.lang.Object,java.lang.String,org.apache.nifi.authorization.user.NiFiUser,java.util.List)>(v, v, v, v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource$lambda_performAsyncConfigVerification_28__473: java.util.function.Consumer bootstrap$(org.apache.nifi.web.api.ControllerServiceResource,org.apache.nifi.web.api.dto.VerifyConfigRequestDTO,java.lang.String)>(v, v, v);
v = v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager>;
interfaceinvoke v.<org.apache.nifi.web.api.concurrent.RequestManager: void submitRequest(java.lang.String,java.lang.String,org.apache.nifi.web.api.concurrent.AsynchronousWebRequest,java.util.function.Consumer)>("verification-request", v, v, v);
v = specialinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.api.entity.VerifyConfigRequestEntity createVerifyControllerServiceConfigRequestEntity(org.apache.nifi.web.api.concurrent.AsynchronousWebRequest,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
}
private org.apache.nifi.web.api.entity.VerifyConfigRequestEntity createVerifyControllerServiceConfigRequestEntity(org.apache.nifi.web.api.concurrent.AsynchronousWebRequest, java.lang.String)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
java.util.Date v;
org.apache.nifi.web.api.dto.VerifyConfigRequestDTO v, v;
java.lang.String[] v;
java.util.Map v;
int v;
java.lang.String v, v, v, v, v, v;
org.apache.nifi.web.api.entity.VerifyConfigRequestEntity v;
boolean v;
java.lang.Object v, v;
org.apache.nifi.web.api.concurrent.AsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: org.apache.nifi.web.api.concurrent.AsynchronousWebRequest;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: java.lang.Object getRequest()>();
v = virtualinvoke v.<org.apache.nifi.web.api.entity.VerifyConfigRequestEntity: org.apache.nifi.web.api.dto.VerifyConfigRequestDTO getRequest()>();
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: java.lang.Object getResults()>();
v = new org.apache.nifi.web.api.dto.VerifyConfigRequestDTO;
specialinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.lang.String getComponentId()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setComponentId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.util.Map getProperties()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setProperties(java.util.Map)>(v);
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setResults(java.util.List)>(v);
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: boolean isComplete()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setComplete(boolean)>(v);
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: java.lang.String getFailureReason()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setFailureReason(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: java.util.Date getLastUpdated()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setLastUpdated(java.util.Date)>(v);
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: int getPercentComplete()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setPercentCompleted(int)>(v);
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setRequestId(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: java.lang.String getState()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setState(java.lang.String)>(v);
v = newarray (java.lang.String)[5];
v[0] = "controller-services";
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.lang.String getComponentId()>();
v[1] = v;
v[2] = "config";
v[3] = "verification-requests";
v[4] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.ControllerServiceResource: java.lang.String generateResourceUri(java.lang.String[])>(v);
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setUri(java.lang.String)>(v);
v = new org.apache.nifi.web.api.entity.VerifyConfigRequestEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.VerifyConfigRequestEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.VerifyConfigRequestEntity: void setRequest(org.apache.nifi.web.api.dto.VerifyConfigRequestDTO)>(v);
return v;
}
private org.apache.nifi.web.api.dto.ControllerServiceDTO createDTOWithDesiredRunStatus(java.lang.String, java.lang.String)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.web.api.dto.ControllerServiceDTO v;
java.lang.String v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new org.apache.nifi.web.api.dto.ControllerServiceDTO;
specialinvoke v.<org.apache.nifi.web.api.dto.ControllerServiceDTO: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerServiceDTO: void setId(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerServiceDTO: void setState(java.lang.String)>(v);
return v;
}
public void setServiceFacade(org.apache.nifi.web.NiFiServiceFacade)
{
org.apache.nifi.web.NiFiServiceFacade v;
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: org.apache.nifi.web.NiFiServiceFacade;
v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade> = v;
return;
}
public void setAuthorizer(org.apache.nifi.authorization.Authorizer)
{
WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource v;
org.apache.nifi.authorization.Authorizer v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ControllerServiceResource;
v := @parameter: org.apache.nifi.authorization.Authorizer;
v.<org.apache.nifi.web.api.ControllerServiceResource: org.apache.nifi.authorization.Authorizer authorizer> = v;
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/nifi/web/api/ControllerServiceResource;");
<org.apache.nifi.web.api.ControllerServiceResource: org.slf4j.Logger logger> = v;
return;
}
}