public class WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor extends org.apache.nifi.audit.NiFiAuditor
{
private static final org.slf4j.Logger logger;
private static final java.lang.String COMMENTS;
private static final java.lang.String PENALTY_DURATION;
private static final java.lang.String YIELD_DURATION;
private static final java.lang.String CONCURRENTLY_SCHEDULABLE_TASKS;
private static final java.lang.String NAME;
private static final java.lang.String BULLETIN_LEVEL;
private static final java.lang.String ANNOTATION_DATA;
private static final java.lang.String AUTO_TERMINATED_RELATIONSHIPS;
private static final java.lang.String SCHEDULING_PERIOD;
private static final java.lang.String SCHEDULING_STRATEGY;
private static final java.lang.String EXECUTION_NODE;
private static final java.lang.String EXTENSION_VERSION;
private static final java.lang.String RETRY_COUNT;
private static final java.lang.String RETRIED_RELATIONSHIPS;
private static final java.lang.String BACKOFF_MECHANISM;
private static final java.lang.String MAX_BACKOFF_PERIOD;
public void <init>()
{
WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor v;
v := @this: WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor;
specialinvoke v.<org.apache.nifi.audit.NiFiAuditor: void <init>()>();
return;
}
public org.apache.nifi.controller.ProcessorNode createProcessorAdvice(org.aspectj.lang.ProceedingJoinPoint) throws java.lang.Throwable
{
org.slf4j.Logger v;
WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor v;
java.lang.Object v;
org.apache.nifi.action.Action v;
org.apache.nifi.action.Operation v;
org.aspectj.lang.ProceedingJoinPoint v;
v := @this: WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor;
v := @parameter: org.aspectj.lang.ProceedingJoinPoint;
v = interfaceinvoke v.<org.aspectj.lang.ProceedingJoinPoint: java.lang.Object proceed()>();
v = <org.apache.nifi.action.Operation: org.apache.nifi.action.Operation Add>;
v = virtualinvoke v.<org.apache.nifi.audit.ProcessorAuditor: org.apache.nifi.action.Action generateAuditRecord(org.apache.nifi.controller.ProcessorNode,org.apache.nifi.action.Operation)>(v, v);
if v == null goto label;
v = <org.apache.nifi.audit.ProcessorAuditor: org.slf4j.Logger logger>;
virtualinvoke v.<org.apache.nifi.audit.ProcessorAuditor: void saveAction(org.apache.nifi.action.Action,org.slf4j.Logger)>(v, v);
label:
return v;
}
public org.apache.nifi.controller.ProcessorNode updateProcessorAdvice(org.aspectj.lang.ProceedingJoinPoint, org.apache.nifi.web.api.dto.ProcessorDTO, org.apache.nifi.web.dao.ProcessorDAO) throws java.lang.Throwable
{
byte[] v, v;
org.apache.nifi.components.PropertyDescriptor v;
org.w3c.dom.Document v, v;
java.util.Map v, v;
org.apache.nifi.xml.processing.parsers.StandardDocumentProvider v;
java.util.Set v, v;
java.lang.Exception v;
org.apache.nifi.web.dao.ProcessorDAO v;
org.apache.nifi.controller.ScheduledState v, v, v, v, v, v, v;
java.util.ArrayList v;
org.apache.nifi.action.FlowChangeAction v, v;
org.apache.nifi.authorization.user.NiFiUser v;
java.util.function.BiConsumer v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.action.details.FlowChangeConfigureDetails v;
java.util.Date v, v;
WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor v;
java.io.ByteArrayInputStream v, v;
boolean v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.web.api.dto.ProcessorDTO v;
org.apache.nifi.controller.ProcessorNode v, v;
java.util.HashMap v, v, v;
org.apache.nifi.action.component.details.FlowChangeExtensionDetails v;
java.util.concurrent.atomic.AtomicReference v, v;
java.nio.charset.Charset v, v;
org.slf4j.Logger v, v;
org.w3c.dom.NodeList v, v;
java.util.Iterator v;
org.apache.nifi.action.Component v, v;
java.lang.Object v, v, v, v;
org.apache.nifi.action.Operation v, v, v, v, v, v;
org.aspectj.lang.ProceedingJoinPoint v;
v := @this: WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor;
v := @parameter: org.aspectj.lang.ProceedingJoinPoint;
v := @parameter: org.apache.nifi.web.api.dto.ProcessorDTO;
v := @parameter: org.apache.nifi.web.dao.ProcessorDAO;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorDTO: java.lang.String getId()>();
v = interfaceinvoke v.<org.apache.nifi.web.dao.ProcessorDAO: org.apache.nifi.controller.ProcessorNode getProcessor(java.lang.String)>(v);
v = specialinvoke v.<org.apache.nifi.audit.ProcessorAuditor: java.util.Map extractConfiguredPropertyValues(org.apache.nifi.controller.ProcessorNode,org.apache.nifi.web.api.dto.ProcessorDTO)>(v, v);
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: org.apache.nifi.controller.ScheduledState getScheduledState()>();
v = interfaceinvoke v.<org.aspectj.lang.ProceedingJoinPoint: java.lang.Object proceed()>();
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getIdentifier()>();
v = interfaceinvoke v.<org.apache.nifi.web.dao.ProcessorDAO: org.apache.nifi.controller.ProcessorNode getProcessor(java.lang.String)>(v);
v = staticinvoke <org.apache.nifi.authorization.user.NiFiUserUtils: org.apache.nifi.authorization.user.NiFiUser getNiFiUser()>();
if v == null goto label;
v = specialinvoke v.<org.apache.nifi.audit.ProcessorAuditor: java.util.Set getSensitiveDynamicPropertyNames(org.apache.nifi.web.api.dto.ProcessorDTO)>(v);
v = specialinvoke v.<org.apache.nifi.audit.ProcessorAuditor: java.util.Map extractConfiguredPropertyValues(org.apache.nifi.controller.ProcessorNode,org.apache.nifi.web.api.dto.ProcessorDTO)>(v, v);
v = new org.apache.nifi.action.component.details.FlowChangeExtensionDetails;
specialinvoke v.<org.apache.nifi.action.component.details.FlowChangeExtensionDetails: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getComponentType()>();
virtualinvoke v.<org.apache.nifi.action.component.details.FlowChangeExtensionDetails: void setType(java.lang.String)>(v);
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
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()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = null;
if v == null goto label;
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
label:
v = <org.apache.nifi.action.Operation: org.apache.nifi.action.Operation Configure>;
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: org.apache.nifi.components.PropertyDescriptor getPropertyDescriptor(java.lang.String)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: boolean isSensitive()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getName()>();
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getIdentifier()>();
v = <org.apache.nifi.audit.ProcessorAuditor: org.slf4j.Logger logger>;
virtualinvoke v.<org.apache.nifi.audit.ProcessorAuditor: void deletePreviousValues(java.lang.String,java.lang.String,org.slf4j.Logger)>(v, v, v);
if v == null goto label;
v = "********";
label:
if v == null goto label;
v = "********";
goto label;
label:
v = "Annotation Data";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
if v == null goto label;
if v == null goto label;
label:
v = new org.apache.nifi.xml.processing.parsers.StandardDocumentProvider;
specialinvoke v.<org.apache.nifi.xml.processing.parsers.StandardDocumentProvider: void <init>()>();
v = new java.io.ByteArrayInputStream;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
v = interfaceinvoke v.<org.apache.nifi.xml.processing.parsers.DocumentProvider: org.w3c.dom.Document parse(java.io.InputStream)>(v);
v = interfaceinvoke v.<org.w3c.dom.Document: org.w3c.dom.NodeList getChildNodes()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<org.w3c.dom.Document: java.lang.String getNodeName()>();
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");
specialinvoke v.<org.apache.nifi.audit.ProcessorAuditor: void getItemPaths(org.w3c.dom.NodeList,java.lang.String,java.util.Map)>(v, v, v);
v = new java.io.ByteArrayInputStream;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
v = interfaceinvoke v.<org.apache.nifi.xml.processing.parsers.DocumentProvider: org.w3c.dom.Document parse(java.io.InputStream)>(v);
v = interfaceinvoke v.<org.w3c.dom.Document: org.w3c.dom.NodeList getChildNodes()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<org.w3c.dom.Document: java.lang.String getNodeName()>();
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");
specialinvoke v.<org.apache.nifi.audit.ProcessorAuditor: void getItemPaths(org.w3c.dom.NodeList,java.lang.String,java.util.Map)>(v, v, v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = staticinvoke <WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor$lambda_updateProcessorAdvice_0__3: java.util.function.BiConsumer bootstrap$(java.util.Map,java.util.Map)>(v, v);
interfaceinvoke v.<java.util.Map: void forEach(java.util.function.BiConsumer)>(v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor$lambda_updateProcessorAdvice_1__4: java.util.function.BiConsumer bootstrap$(java.util.Map,java.util.Map)>(v, v);
interfaceinvoke v.<java.util.Map: void forEach(java.util.function.BiConsumer)>(v);
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>("");
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>("");
v = staticinvoke <WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor$lambda_updateProcessorAdvice_2__5: java.util.function.BiConsumer bootstrap$(java.util.concurrent.atomic.AtomicReference)>(v);
interfaceinvoke v.<java.util.Map: void forEach(java.util.function.BiConsumer)>(v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor$lambda_updateProcessorAdvice_3__6: java.util.function.BiConsumer bootstrap$(java.util.concurrent.atomic.AtomicReference)>(v);
interfaceinvoke v.<java.util.Map: void forEach(java.util.function.BiConsumer)>(v);
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
label:
goto label;
label:
v := @caughtexception;
label:
v = new org.apache.nifi.action.details.FlowChangeConfigureDetails;
specialinvoke v.<org.apache.nifi.action.details.FlowChangeConfigureDetails: void <init>()>();
virtualinvoke v.<org.apache.nifi.action.details.FlowChangeConfigureDetails: void setName(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.action.details.FlowChangeConfigureDetails: void setValue(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.action.details.FlowChangeConfigureDetails: void setPreviousValue(java.lang.String)>(v);
v = new org.apache.nifi.action.FlowChangeAction;
specialinvoke v.<org.apache.nifi.action.FlowChangeAction: void <init>()>();
v = interfaceinvoke v.<org.apache.nifi.authorization.user.NiFiUser: java.lang.String getIdentity()>();
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setUserIdentity(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setOperation(org.apache.nifi.action.Operation)>(v);
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setTimestamp(java.util.Date)>(v);
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getIdentifier()>();
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setSourceId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getName()>();
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setSourceName(java.lang.String)>(v);
v = <org.apache.nifi.action.Component: org.apache.nifi.action.Component Processor>;
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setSourceType(org.apache.nifi.action.Component)>(v);
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setComponentDetails(org.apache.nifi.action.component.details.ComponentDetails)>(v);
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setActionDetails(org.apache.nifi.action.details.ActionDetails)>(v);
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: org.apache.nifi.controller.ScheduledState getScheduledState()>();
if v == v goto label;
v = new org.apache.nifi.action.FlowChangeAction;
specialinvoke v.<org.apache.nifi.action.FlowChangeAction: void <init>()>();
v = interfaceinvoke v.<org.apache.nifi.authorization.user.NiFiUser: java.lang.String getIdentity()>();
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setUserIdentity(java.lang.String)>(v);
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setTimestamp(java.util.Date)>(v);
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getIdentifier()>();
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setSourceId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getName()>();
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setSourceName(java.lang.String)>(v);
v = <org.apache.nifi.action.Component: org.apache.nifi.action.Component Processor>;
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setSourceType(org.apache.nifi.action.Component)>(v);
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setComponentDetails(org.apache.nifi.action.component.details.ComponentDetails)>(v);
v = <org.apache.nifi.controller.ScheduledState: org.apache.nifi.controller.ScheduledState RUNNING>;
v = virtualinvoke v.<org.apache.nifi.controller.ScheduledState: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.apache.nifi.action.Operation: org.apache.nifi.action.Operation Start>;
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setOperation(org.apache.nifi.action.Operation)>(v);
goto label;
label:
v = <org.apache.nifi.controller.ScheduledState: org.apache.nifi.controller.ScheduledState DISABLED>;
v = virtualinvoke v.<org.apache.nifi.controller.ScheduledState: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.apache.nifi.action.Operation: org.apache.nifi.action.Operation Disable>;
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setOperation(org.apache.nifi.action.Operation)>(v);
goto label;
label:
v = <org.apache.nifi.controller.ScheduledState: org.apache.nifi.controller.ScheduledState RUNNING>;
v = virtualinvoke v.<org.apache.nifi.controller.ScheduledState: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.apache.nifi.action.Operation: org.apache.nifi.action.Operation Stop>;
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setOperation(org.apache.nifi.action.Operation)>(v);
goto label;
label:
v = <org.apache.nifi.controller.ScheduledState: org.apache.nifi.controller.ScheduledState DISABLED>;
v = virtualinvoke v.<org.apache.nifi.controller.ScheduledState: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.apache.nifi.action.Operation: org.apache.nifi.action.Operation Enable>;
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setOperation(org.apache.nifi.action.Operation)>(v);
goto label;
label:
v = <org.apache.nifi.controller.ScheduledState: org.apache.nifi.controller.ScheduledState STOPPED>;
v = virtualinvoke v.<org.apache.nifi.controller.ScheduledState: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.apache.nifi.action.Operation: org.apache.nifi.action.Operation RunOnce>;
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setOperation(org.apache.nifi.action.Operation)>(v);
label:
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
label:
v = interfaceinvoke v.<java.util.Collection: boolean isEmpty()>();
if v != 0 goto label;
v = <org.apache.nifi.audit.ProcessorAuditor: org.slf4j.Logger logger>;
virtualinvoke v.<org.apache.nifi.audit.ProcessorAuditor: void saveActions(java.util.Collection,org.slf4j.Logger)>(v, v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public void removeProcessorAdvice(org.aspectj.lang.ProceedingJoinPoint, java.lang.String, org.apache.nifi.web.dao.ProcessorDAO) throws java.lang.Throwable
{
org.apache.nifi.controller.ProcessorNode v;
org.slf4j.Logger v;
org.apache.nifi.web.dao.ProcessorDAO v;
WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor v;
java.lang.String v;
org.apache.nifi.action.Action v;
org.apache.nifi.action.Operation v;
org.aspectj.lang.ProceedingJoinPoint v;
v := @this: WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor;
v := @parameter: org.aspectj.lang.ProceedingJoinPoint;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.dao.ProcessorDAO;
v = interfaceinvoke v.<org.apache.nifi.web.dao.ProcessorDAO: org.apache.nifi.controller.ProcessorNode getProcessor(java.lang.String)>(v);
interfaceinvoke v.<org.aspectj.lang.ProceedingJoinPoint: java.lang.Object proceed()>();
v = <org.apache.nifi.action.Operation: org.apache.nifi.action.Operation Remove>;
v = virtualinvoke v.<org.apache.nifi.audit.ProcessorAuditor: org.apache.nifi.action.Action generateAuditRecord(org.apache.nifi.controller.ProcessorNode,org.apache.nifi.action.Operation)>(v, v);
if v == null goto label;
v = <org.apache.nifi.audit.ProcessorAuditor: org.slf4j.Logger logger>;
virtualinvoke v.<org.apache.nifi.audit.ProcessorAuditor: void saveAction(org.apache.nifi.action.Action,org.slf4j.Logger)>(v, v);
label:
return;
}
public org.apache.nifi.action.Action generateAuditRecord(org.apache.nifi.controller.ProcessorNode, org.apache.nifi.action.Operation)
{
org.apache.nifi.controller.ProcessorNode v;
WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor v;
org.apache.nifi.action.Action v;
org.apache.nifi.action.Operation v;
v := @this: WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor;
v := @parameter: org.apache.nifi.controller.ProcessorNode;
v := @parameter: org.apache.nifi.action.Operation;
v = virtualinvoke v.<org.apache.nifi.audit.ProcessorAuditor: org.apache.nifi.action.Action generateAuditRecord(org.apache.nifi.controller.ProcessorNode,org.apache.nifi.action.Operation,org.apache.nifi.action.details.ActionDetails)>(v, v, null);
return v;
}
public org.apache.nifi.action.Action generateAuditRecord(org.apache.nifi.controller.ProcessorNode, org.apache.nifi.action.Operation, org.apache.nifi.action.details.ActionDetails)
{
org.apache.nifi.controller.ProcessorNode v;
java.util.Date v;
org.apache.nifi.action.component.details.FlowChangeExtensionDetails v;
org.apache.nifi.action.FlowChangeAction v, v;
WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor v;
org.apache.nifi.action.details.ActionDetails v;
org.apache.nifi.authorization.user.NiFiUser v;
org.apache.nifi.action.Component v;
java.lang.String v, v, v, v;
org.apache.nifi.action.Operation v;
v := @this: WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor;
v := @parameter: org.apache.nifi.controller.ProcessorNode;
v := @parameter: org.apache.nifi.action.Operation;
v := @parameter: org.apache.nifi.action.details.ActionDetails;
v = null;
v = staticinvoke <org.apache.nifi.authorization.user.NiFiUserUtils: org.apache.nifi.authorization.user.NiFiUser getNiFiUser()>();
if v == null goto label;
v = new org.apache.nifi.action.component.details.FlowChangeExtensionDetails;
specialinvoke v.<org.apache.nifi.action.component.details.FlowChangeExtensionDetails: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getComponentType()>();
virtualinvoke v.<org.apache.nifi.action.component.details.FlowChangeExtensionDetails: void setType(java.lang.String)>(v);
v = new org.apache.nifi.action.FlowChangeAction;
specialinvoke v.<org.apache.nifi.action.FlowChangeAction: void <init>()>();
v = v;
v = interfaceinvoke v.<org.apache.nifi.authorization.user.NiFiUser: java.lang.String getIdentity()>();
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setUserIdentity(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setOperation(org.apache.nifi.action.Operation)>(v);
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setTimestamp(java.util.Date)>(v);
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getIdentifier()>();
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setSourceId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getName()>();
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setSourceName(java.lang.String)>(v);
v = <org.apache.nifi.action.Component: org.apache.nifi.action.Component Processor>;
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setSourceType(org.apache.nifi.action.Component)>(v);
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setComponentDetails(org.apache.nifi.action.component.details.ComponentDetails)>(v);
if v == null goto label;
virtualinvoke v.<org.apache.nifi.action.FlowChangeAction: void setActionDetails(org.apache.nifi.action.details.ActionDetails)>(v);
label:
return v;
}
private java.util.Set getSensitiveDynamicPropertyNames(org.apache.nifi.web.api.dto.ProcessorDTO)
{
WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor v;
org.apache.nifi.web.api.dto.ProcessorConfigDTO v;
org.apache.nifi.web.api.dto.ProcessorDTO v;
java.util.Set v, v, v;
v := @this: WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor;
v := @parameter: org.apache.nifi.web.api.dto.ProcessorDTO;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorDTO: org.apache.nifi.web.api.dto.ProcessorConfigDTO getConfig()>();
if v != null goto label;
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
return v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.util.Set getSensitiveDynamicPropertyNames()>();
if v != null goto label;
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.util.Set getSensitiveDynamicPropertyNames()>();
label:
return v;
}
private java.util.Map extractConfiguredPropertyValues(org.apache.nifi.controller.ProcessorNode, org.apache.nifi.web.api.dto.ProcessorDTO)
{
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.Map v, v, v;
java.util.Set v, v, v, v, v, v;
java.util.ArrayList v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.text.Collator v, v;
org.apache.nifi.scheduling.ExecutionNode v;
org.apache.nifi.bundle.BundleCoordinate v;
org.apache.nifi.web.api.dto.ProcessorConfigDTO v, v;
org.apache.nifi.web.api.dto.BundleDTO v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v;
WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor v;
java.util.Locale v, v;
org.apache.nifi.scheduling.SchedulingStrategy v;
boolean v, v;
org.apache.nifi.web.api.dto.ProcessorDTO v;
org.apache.nifi.controller.ProcessorNode v;
java.util.HashMap v;
int v, v, v;
org.apache.nifi.logging.LogLevel v;
java.util.Iterator v, v;
org.apache.nifi.controller.BackoffMechanism v;
java.lang.Object v, v, v;
v := @this: WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor;
v := @parameter: org.apache.nifi.controller.ProcessorNode;
v := @parameter: org.apache.nifi.web.api.dto.ProcessorDTO;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorDTO: java.lang.String getName()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getName()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Name", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorDTO: org.apache.nifi.web.api.dto.BundleDTO getBundle()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: org.apache.nifi.bundle.BundleCoordinate getBundleCoordinate()>();
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getComponentType()>();
v = virtualinvoke v.<org.apache.nifi.audit.ProcessorAuditor: java.lang.String formatExtensionVersion(java.lang.String,org.apache.nifi.bundle.BundleCoordinate)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Extension Version", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorDTO: org.apache.nifi.web.api.dto.ProcessorConfigDTO getConfig()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorDTO: org.apache.nifi.web.api.dto.ProcessorConfigDTO getConfig()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.Integer getConcurrentlySchedulableTaskCount()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: int getMaxConcurrentTasks()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Concurrent Tasks", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.String getPenaltyDuration()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getPenalizationPeriod()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Penalty Duration", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.String getYieldDuration()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getYieldPeriod()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Yield Duration", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.String getBulletinLevel()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: org.apache.nifi.logging.LogLevel getBulletinLevel()>();
v = virtualinvoke v.<org.apache.nifi.logging.LogLevel: java.lang.String name()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Bulletin Level", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.String getAnnotationData()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getAnnotationData()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Annotation Data", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.String getSchedulingPeriod()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getSchedulingPeriod()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Run Schedule", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.util.Set getAutoTerminatedRelationships()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.util.Set getAutoTerminatedRelationships()>();
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.Set: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
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()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship: java.lang.String getName()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <java.util.Locale: java.util.Locale US>;
v = staticinvoke <java.text.Collator: java.text.Collator getInstance(java.util.Locale)>(v);
staticinvoke <java.util.Collections: void sort(java.util.List,java.util.Comparator)>(v, v);
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String join(java.lang.Iterable,java.lang.String)>(v, ", ");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Auto Terminated Relationships", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.util.Map getProperties()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.util.Map getProperties()>();
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.util.Map getRawPropertyValues()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
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()>();
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = specialinvoke v.<org.apache.nifi.audit.ProcessorAuditor: org.apache.nifi.components.PropertyDescriptor locatePropertyDescriptor(java.util.Set,org.apache.nifi.components.PropertyDescriptor)>(v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getDefaultValue()>();
label:
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.String getComments()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getComments()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Comments", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.String getSchedulingStrategy()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: org.apache.nifi.scheduling.SchedulingStrategy getSchedulingStrategy()>();
v = virtualinvoke v.<org.apache.nifi.scheduling.SchedulingStrategy: java.lang.String name()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Scheduling Strategy", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.String getExecutionNode()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: org.apache.nifi.scheduling.ExecutionNode getExecutionNode()>();
v = virtualinvoke v.<org.apache.nifi.scheduling.ExecutionNode: java.lang.String name()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Execution Node", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.Integer getRetryCount()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: int getRetryCount()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Retry Count", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.util.Set getRetriedRelationships()>();
if v == null goto label;
v = new java.util.ArrayList;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.util.Set getRetriedRelationships()>();
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = <java.util.Locale: java.util.Locale US>;
v = staticinvoke <java.text.Collator: java.text.Collator getInstance(java.util.Locale)>(v);
staticinvoke <java.util.Collections: void sort(java.util.List,java.util.Comparator)>(v, v);
v = staticinvoke <org.apache.commons.lang.StringUtils: java.lang.String join(java.lang.Iterable,java.lang.String)>(v, ", ");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Retried Relationships", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.String getBackoffMechanism()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: org.apache.nifi.controller.BackoffMechanism getBackoffMechanism()>();
v = virtualinvoke v.<org.apache.nifi.controller.BackoffMechanism: java.lang.String name()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Backoff Mechanism", v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ProcessorConfigDTO: java.lang.String getMaxBackoffPeriod()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getMaxBackoffPeriod()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("Max Backoff Period", v);
label:
return v;
}
private org.apache.nifi.components.PropertyDescriptor locatePropertyDescriptor(java.util.Set, org.apache.nifi.components.PropertyDescriptor)
{
WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor v;
java.util.Iterator v;
java.util.Set v;
java.lang.Object v;
org.apache.nifi.components.PropertyDescriptor v;
boolean v, v;
v := @this: WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor;
v := @parameter: java.util.Set;
v := @parameter: org.apache.nifi.components.PropertyDescriptor;
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()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return v;
label:
return v;
}
private void getItemPaths(org.w3c.dom.NodeList, java.lang.String, java.util.Map)
{
short v, v, v;
WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor v;
java.util.Map v;
org.w3c.dom.Node v, v, v;
int v, v, v, v;
org.w3c.dom.NamedNodeMap v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
boolean v, v, v;
org.w3c.dom.NodeList v, v;
v := @this: WEB-INF.classes.org.apache.nifi.audit.ProcessorAuditor;
v := @parameter: org.w3c.dom.NodeList;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
if v == null goto label;
v = 0;
label:
v = interfaceinvoke v.<org.w3c.dom.NodeList: int getLength()>();
if v >= v goto label;
v = interfaceinvoke v.<org.w3c.dom.NodeList: org.w3c.dom.Node item(int)>(v);
if v == null goto label;
v = interfaceinvoke v.<org.w3c.dom.Node: short getNodeType()>();
if v == 1 goto label;
v = interfaceinvoke v.<org.w3c.dom.Node: short getNodeType()>();
if v != 3 goto label;
label:
v = interfaceinvoke v.<org.w3c.dom.Node: boolean hasChildNodes()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.w3c.dom.Node: short getNodeType()>();
if v != 1 goto label;
v = interfaceinvoke v.<org.w3c.dom.Node: org.w3c.dom.NodeList getChildNodes()>();
v = interfaceinvoke v.<org.w3c.dom.Node: java.lang.String getNodeName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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:\u0001");
specialinvoke v.<org.apache.nifi.audit.ProcessorAuditor: void getItemPaths(org.w3c.dom.NodeList,java.lang.String,java.util.Map)>(v, v, v);
label:
v = interfaceinvoke v.<org.w3c.dom.Node: boolean hasChildNodes()>();
if v != 0 goto label;
v = interfaceinvoke v.<org.w3c.dom.Node: java.lang.String getNodeName()>();
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = interfaceinvoke v.<org.w3c.dom.Node: java.lang.String getNodeValue()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, 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:\u0001:\u0001");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = interfaceinvoke v.<org.w3c.dom.Node: boolean hasAttributes()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.w3c.dom.Node: org.w3c.dom.NamedNodeMap getAttributes()>();
v = 0;
label:
v = interfaceinvoke v.<org.w3c.dom.NamedNodeMap: int getLength()>();
if v >= v goto label;
v = interfaceinvoke v.<org.w3c.dom.Node: java.lang.String getNodeName()>();
v = interfaceinvoke v.<org.w3c.dom.NamedNodeMap: org.w3c.dom.Node item(int)>(v);
v = interfaceinvoke v.<org.w3c.dom.Node: java.lang.String getNodeName()>();
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = interfaceinvoke v.<org.w3c.dom.NamedNodeMap: org.w3c.dom.Node item(int)>(v);
v = interfaceinvoke v.<org.w3c.dom.Node: java.lang.String getNodeValue()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, 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:\u0001:\u0001:\u0001");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/nifi/audit/ProcessorAuditor;");
<org.apache.nifi.audit.ProcessorAuditor: org.slf4j.Logger logger> = v;
return;
}
}