public class org.apache.nifi.processors.standard.ParseCEF extends org.apache.nifi.processor.AbstractProcessor
{
private static final java.time.format.DateTimeFormatter dateTimeFormatter;
private final java.text.SimpleDateFormat simpleDateFormat;
private java.lang.String tzId;
private static final com.fasterxml.jackson.databind.ObjectMapper mapper;
public static final java.lang.String DESTINATION_CONTENT;
public static final java.lang.String DESTINATION_ATTRIBUTES;
public static final org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION;
public static final org.apache.nifi.components.PropertyDescriptor APPEND_RAW_MESSAGE_TO_JSON;
public static final org.apache.nifi.components.PropertyDescriptor INCLUDE_CUSTOM_EXTENSIONS;
public static final org.apache.nifi.components.PropertyDescriptor ACCEPT_EMPTY_EXTENSIONS;
public static final org.apache.nifi.components.PropertyDescriptor VALIDATE_DATA;
public static final java.lang.String UTC;
public static final java.lang.String LOCAL_TZ;
public static final org.apache.nifi.components.PropertyDescriptor TIME_REPRESENTATION;
public static final org.apache.nifi.components.PropertyDescriptor DATETIME_REPRESENTATION;
static final org.apache.nifi.processor.Relationship REL_FAILURE;
static final org.apache.nifi.processor.Relationship REL_SUCCESS;
final javax.validation.Validator validator;
public void <init>()
{
javax.validation.bootstrap.ProviderSpecificBootstrap v;
javax.validation.Configuration v;
java.text.SimpleDateFormat v;
javax.validation.Validator v;
javax.validation.ValidatorFactory v;
org.apache.nifi.processors.standard.ParseCEF v;
v := @this: org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
v = new java.text.SimpleDateFormat;
specialinvoke v.<java.text.SimpleDateFormat: void <init>(java.lang.String)>("yyyy-MM-dd\'T\'HH:mm:ss.SSSZ");
v.<org.apache.nifi.processors.standard.ParseCEF: java.text.SimpleDateFormat simpleDateFormat> = v;
v.<org.apache.nifi.processors.standard.ParseCEF: java.lang.String tzId> = null;
v = staticinvoke <javax.validation.Validation: javax.validation.bootstrap.ProviderSpecificBootstrap byProvider(java.lang.Class)>(class "Lorg/apache/bval/jsr/ApacheValidationProvider;");
v = interfaceinvoke v.<javax.validation.bootstrap.ProviderSpecificBootstrap: javax.validation.Configuration configure()>();
v = interfaceinvoke v.<org.apache.bval.jsr.ApacheValidatorConfiguration: javax.validation.ValidatorFactory buildValidatorFactory()>();
v = interfaceinvoke v.<javax.validation.ValidatorFactory: javax.validation.Validator getValidator()>();
v.<org.apache.nifi.processors.standard.ParseCEF: javax.validation.Validator validator> = v;
return;
}
public java.util.List getSupportedPropertyDescriptors()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v;
java.util.ArrayList v;
org.apache.nifi.processors.standard.ParseCEF v;
v := @this: org.apache.nifi.processors.standard.ParseCEF;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor APPEND_RAW_MESSAGE_TO_JSON>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor INCLUDE_CUSTOM_EXTENSIONS>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor ACCEPT_EMPTY_EXTENSIONS>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor VALIDATE_DATA>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor TIME_REPRESENTATION>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor DATETIME_REPRESENTATION>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return v;
}
public java.util.Set getRelationships()
{
java.util.HashSet v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processors.standard.ParseCEF v;
v := @this: org.apache.nifi.processors.standard.ParseCEF;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
return v;
}
public void OnScheduled(org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.processors.standard.ParseCEF$MacAddressToStringSerializer v;
java.text.SimpleDateFormat v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyValue v;
com.fasterxml.jackson.databind.module.SimpleModule v, v;
byte v;
int v;
java.lang.String v, v;
org.apache.nifi.processors.standard.ParseCEF v;
boolean v, v;
java.util.TimeZone v, v, v;
com.fasterxml.jackson.databind.ObjectMapper v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
v := @this: org.apache.nifi.processors.standard.ParseCEF;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = new com.fasterxml.jackson.databind.module.SimpleModule;
specialinvoke v.<com.fasterxml.jackson.databind.module.SimpleModule: void <init>()>();
v = new org.apache.nifi.processors.standard.ParseCEF$MacAddressToStringSerializer;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF$MacAddressToStringSerializer: void <init>(org.apache.nifi.processors.standard.ParseCEF)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.module.SimpleModule: com.fasterxml.jackson.databind.module.SimpleModule addSerializer(java.lang.Class,com.fasterxml.jackson.databind.JsonSerializer)>(class "Lcom/fluenda/parcefone/event/MacAddress;", v);
v = <org.apache.nifi.processors.standard.ParseCEF: com.fasterxml.jackson.databind.ObjectMapper mapper>;
virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.ObjectMapper registerModule(com.fasterxml.jackson.databind.Module)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: com.fasterxml.jackson.databind.ObjectMapper mapper>;
v = v.<org.apache.nifi.processors.standard.ParseCEF: java.text.SimpleDateFormat simpleDateFormat>;
virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.ObjectMapper setDateFormat(java.text.DateFormat)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor TIME_REPRESENTATION>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case 84356: goto label;
case 1857591395: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("Local Timezone (system Default)");
if v == 0 goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("UTC");
if v == 0 goto label;
v = 1;
label:
lookupswitch(v)
{
case 0: goto label;
case 1: goto label;
default: goto label;
};
label:
v = <org.apache.nifi.processors.standard.ParseCEF: com.fasterxml.jackson.databind.ObjectMapper mapper>;
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getDefault()>();
virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.ObjectMapper setTimeZone(java.util.TimeZone)>(v);
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getDefault()>();
v = virtualinvoke v.<java.util.TimeZone: java.lang.String getID()>();
v.<org.apache.nifi.processors.standard.ParseCEF: java.lang.String tzId> = v;
goto label;
label:
v = <org.apache.nifi.processors.standard.ParseCEF: com.fasterxml.jackson.databind.ObjectMapper mapper>;
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getTimeZone(java.lang.String)>("UTC");
virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.ObjectMapper setTimeZone(java.util.TimeZone)>(v);
v.<org.apache.nifi.processors.standard.ParseCEF: java.lang.String tzId> = "UTC";
label:
return;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
byte[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
byte v;
java.util.Map v, v, v, v;
com.fasterxml.jackson.databind.JsonNode v, v, v;
java.util.Set v, v;
javax.validation.Validator v;
java.lang.Exception v;
org.apache.nifi.processors.standard.ParseCEF$2 v;
org.apache.nifi.processors.standard.ParseCEF$1 v;
java.lang.Throwable v;
java.lang.Object[] v, v, v;
long v;
org.apache.nifi.provenance.ProvenanceReporter v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.ParseCEF v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v;
java.util.Locale v;
boolean v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v;
com.fluenda.parcefone.parser.CEFParser v;
com.fluenda.parcefone.event.CommonEvent v;
java.util.HashMap v;
org.apache.nifi.logging.ComponentLog v, v, v;
com.fasterxml.jackson.databind.node.ObjectNode v;
int v;
java.lang.Boolean v, v, v, v;
java.util.Iterator v, v;
com.fasterxml.jackson.databind.ObjectMapper v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
java.lang.Object v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.ParseCEF;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
v = new com.fluenda.parcefone.parser.CEFParser;
v = v.<org.apache.nifi.processors.standard.ParseCEF: javax.validation.Validator validator>;
specialinvoke v.<com.fluenda.parcefone.parser.CEFParser: void <init>(javax.validation.Validator)>(v);
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = newarray (byte)[v];
v = new org.apache.nifi.processors.standard.ParseCEF$1;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF$1: void <init>(org.apache.nifi.processors.standard.ParseCEF,byte[])>(v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void read(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.InputStreamCallback)>(v, v);
label:
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor DATETIME_REPRESENTATION>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <java.util.Locale: java.util.Locale forLanguageTag(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor VALIDATE_DATA>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor ACCEPT_EMPTY_EXTENSIONS>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = virtualinvoke v.<com.fluenda.parcefone.parser.CEFParser: com.fluenda.parcefone.event.CommonEvent parse(byte[],boolean,boolean,java.util.Locale)>(v, v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("CEF Parsing Failed: {}", v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
if v != null goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Failed to parse {} as a CEF message: it does not conform to the CEF standard; routing to failure", v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor INCLUDE_CUSTOM_EXTENSIONS>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case -1375719367: goto label;
case -1029800618: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("flowfile-attribute");
if v == 0 goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("flowfile-content");
if v == 0 goto label;
v = 1;
label:
lookupswitch(v)
{
case 0: goto label;
case 1: goto label;
default: goto label;
};
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = virtualinvoke v.<com.fluenda.parcefone.event.CommonEvent: java.util.Map getHeader()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
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$Entry: java.lang.Object getKey()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(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[])>("cef.header.\u0001");
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = v.<org.apache.nifi.processors.standard.ParseCEF: java.lang.String tzId>;
v = specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: java.lang.String prettyResult(java.lang.Object,java.lang.String)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<com.fluenda.parcefone.event.CommonEvent: java.util.Map getExtension(boolean,boolean)>(1, v);
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
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$Entry: java.lang.Object getKey()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(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[])>("cef.extension.\u0001");
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = v.<org.apache.nifi.processors.standard.ParseCEF: java.lang.String tzId>;
v = specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: java.lang.String prettyResult(java.lang.Object,java.lang.String)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAllAttributes(org.apache.nifi.flowfile.FlowFile,java.util.Map)>(v, v);
goto label;
label:
v = <org.apache.nifi.processors.standard.ParseCEF: com.fasterxml.jackson.databind.ObjectMapper mapper>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.node.ObjectNode createObjectNode()>();
v = <org.apache.nifi.processors.standard.ParseCEF: com.fasterxml.jackson.databind.ObjectMapper mapper>;
v = virtualinvoke v.<com.fluenda.parcefone.event.CommonEvent: java.util.Map getHeader()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode valueToTree(java.lang.Object)>(v);
virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.JsonNode set(java.lang.String,com.fasterxml.jackson.databind.JsonNode)>("header", v);
v = <org.apache.nifi.processors.standard.ParseCEF: com.fasterxml.jackson.databind.ObjectMapper mapper>;
v = virtualinvoke v.<com.fluenda.parcefone.event.CommonEvent: java.util.Map getExtension(boolean,boolean)>(1, v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode valueToTree(java.lang.Object)>(v);
virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.JsonNode set(java.lang.String,com.fasterxml.jackson.databind.JsonNode)>("extension", v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor APPEND_RAW_MESSAGE_TO_JSON>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.ParseCEF: com.fasterxml.jackson.databind.ObjectMapper mapper>;
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode valueToTree(java.lang.Object)>(v);
virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.JsonNode set(java.lang.String,com.fasterxml.jackson.databind.JsonNode)>("_raw", v);
label:
v = new org.apache.nifi.processors.standard.ParseCEF$2;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF$2: void <init>(org.apache.nifi.processors.standard.ParseCEF,com.fasterxml.jackson.databind.node.ObjectNode)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile write(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.OutputStreamCallback)>(v, v);
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, "application/json");
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void modifyContent(org.apache.nifi.flowfile.FlowFile,java.lang.String)>(v, "Replaced content with parsed CEF fields and values");
label:
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Reading CEF Event Failed: {}", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void route(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
return;
catch java.lang.Exception from label to label with label;
catch com.fluenda.parcefone.event.CEFHandlingException from label to label with label;
}
private java.lang.String prettyResult(java.lang.Object, java.lang.String)
{
java.time.ZonedDateTime v, v;
java.time.Instant v;
java.time.ZoneId v;
java.time.format.DateTimeFormatter v;
java.lang.Object v;
java.lang.String v, v, v, v, v;
org.apache.nifi.processors.standard.ParseCEF v;
boolean v, v;
v := @this: org.apache.nifi.processors.standard.ParseCEF;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.String;
v = v instanceof java.net.InetAddress;
if v == 0 goto label;
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
return v;
label:
v = v instanceof java.util.Date;
if v == 0 goto label;
v = virtualinvoke v.<java.util.Date: java.time.Instant toInstant()>();
v = staticinvoke <java.time.ZoneId: java.time.ZoneId of(java.lang.String)>(v);
v = virtualinvoke v.<java.time.Instant: java.time.ZonedDateTime atZone(java.time.ZoneId)>(v);
v = staticinvoke <java.time.ZonedDateTime: java.time.ZonedDateTime 'from'(java.time.temporal.TemporalAccessor)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: java.time.format.DateTimeFormatter dateTimeFormatter>;
v = virtualinvoke v.<java.time.ZonedDateTime: java.lang.String format(java.time.format.DateTimeFormatter)>(v);
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
return v;
label:
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
return v;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.components.PropertyDescriptor$Builder 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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String[] v, v, v, v, v;
org.apache.nifi.processors.standard.ParseCEF$ValidateLocale v;
org.apache.nifi.components.Validator v, v, v, v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v;
java.time.format.DateTimeFormatter v;
v = staticinvoke <java.time.format.DateTimeFormatter: java.time.format.DateTimeFormatter ofPattern(java.lang.String)>("yyyy-MM-dd\'T\'HH:mm:ss.SSSZ");
<org.apache.nifi.processors.standard.ParseCEF: java.time.format.DateTimeFormatter dateTimeFormatter> = v;
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
<org.apache.nifi.processors.standard.ParseCEF: com.fasterxml.jackson.databind.ObjectMapper mapper> = v;
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)>("FIELDS_DESTINATION");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Parsed fields destination");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Indicates whether the results of the CEF parser are written to the FlowFile content or a FlowFile attribute; if using flowfile-attributeattribute, fields will be populated as attributes. If set to flowfile-content, the CEF extension field will be converted into a flat JSON object.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[2];
v[0] = "flowfile-content";
v[1] = "flowfile-attribute";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("flowfile-content");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION> = v;
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)>("APPEND_RAW_MESSAGE_TO_JSON");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Append raw message to JSON");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("When using flowfile-content (i.e. JSON output), add the original CEF message to the resulting JSON object. The original message is added as a string to _raw.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("true");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor APPEND_RAW_MESSAGE_TO_JSON> = v;
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)>("INCLUDE_CUSTOM_EXTENSIONS");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Include custom extensions");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If set to true, custom extensions (not specified in the CEF specifications) will be included in the generated data/attributes.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("false");
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor INCLUDE_CUSTOM_EXTENSIONS> = v;
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)>("ACCEPT_EMPTY_EXTENSIONS");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Accept empty extensions");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If set to true, empty extensions will be accepted and will be associated to a null value.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("false");
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor ACCEPT_EMPTY_EXTENSIONS> = v;
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)>("VALIDATE_DATA");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Validate the CEF event");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If set to true, the event will be validated against the CEF standard (revision 23). If the event is invalid, the FlowFile will be routed to the failure relationship. If this property is set to false, the event will be processed without validating the data.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("true");
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor VALIDATE_DATA> = v;
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)>("TIME_REPRESENTATION");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Timezone");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Timezone to be used when representing date fields. UTC will convert all dates to UTC, while Local Timezone will convert them to the timezone used by NiFi.");
v = newarray (java.lang.String)[2];
v[0] = "UTC";
v[1] = "Local Timezone (system Default)";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("Local Timezone (system Default)");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor TIME_REPRESENTATION> = v;
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)>("DATETIME_REPRESENTATION");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("DateTime Locale");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The IETF BCP 47 representation of the Locale to be used when parsing date fields with long or short month names (e.g. may <en-US> vs. mai. <fr-FR>. The defaultvalue is generally safe. Only change if having issues parsing CEF messages");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = new org.apache.nifi.processors.standard.ParseCEF$ValidateLocale;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF$ValidateLocale: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("en-US");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor DATETIME_REPRESENTATION> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("Any FlowFile that could not be parsed as a CEF message will be transferred to this Relationship without any attributes being added");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("success");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("Any FlowFile that is successfully parsed as a CEF message will be transferred to this Relationship.");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS> = v;
return;
}
}