public class org.apache.nifi.processors.standard.TestParseCEF extends java.lang.Object
{
private java.text.SimpleDateFormat sdf;
private static final java.lang.String sample;
private static final java.lang.String sample;
public void <init>()
{
java.text.SimpleDateFormat v;
org.apache.nifi.processors.standard.TestParseCEF v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
specialinvoke v.<java.lang.Object: 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.TestParseCEF: java.text.SimpleDateFormat sdf> = v;
return;
}
public void testInvalidMessage()
{
byte[] v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestParseCEF v;
java.lang.String v;
org.apache.nifi.processors.standard.ParseCEF v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
v = new org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = "test test test chocolate\n";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testSuccessfulParseToAttributes() throws java.io.IOException
{
byte[] v, v;
java.util.Date v, v;
java.text.SimpleDateFormat v, v, v;
org.apache.nifi.processors.standard.TestParseCEF v;
long v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v, v, v, v;
org.apache.nifi.processors.standard.ParseCEF v;
java.util.TimeZone v, v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
v = new org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label=Test Long cn3=9223372036854775807 cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt=1234 agt=123.123.0.124 dlat=40.366633";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(1423441663000L);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.rt", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.cn3Label", "Test Long");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.cn3", "9223372036854775807");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.cfp1", "1.234");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.cfp1Label", "Test FP Number");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.smac", "00:00:0c:07:ac:00");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.c6a3", "2001:cdba:0:0:0:0:3257:9652");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.c6a3Label", "Test IPv6");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.cs1Label", "Test String");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.cs1", "test test test chocolate");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.destinationTranslatedAddress", "123.123.123.123");
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label=Test Long cn3=9223372036854775807 cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt=1234 agt=123.123.0.124 dlat=40.366633";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(byte[])>(v);
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getDefault()>();
v = virtualinvoke v.<java.util.TimeZone: int getOffset(long)>(1423229263000L);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getDefault()>();
virtualinvoke v.<java.text.SimpleDateFormat: void setTimeZone(java.util.TimeZone)>(v);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = new java.util.Date;
v = 1423229263000L - v;
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.deviceCustomDate1", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.dpt", "1234");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.agt", "123.123.0.124");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.dlat", "40.366633");
return;
}
public void testSuccessfulParseToAttributesWithUTC() throws java.io.IOException
{
byte[] v, v;
java.util.Date v, v;
java.text.SimpleDateFormat v, v, v, v;
org.apache.nifi.processors.standard.TestParseCEF v;
long v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v, v, v, v;
org.apache.nifi.processors.standard.ParseCEF v;
java.util.TimeZone v, v, v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
v = new org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor TIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UTC");
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label=Test Long cn3=9223372036854775807 cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt=1234 agt=123.123.0.124 dlat=40.366633";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getTimeZone(java.lang.String)>("UTC");
virtualinvoke v.<java.text.SimpleDateFormat: void setTimeZone(java.util.TimeZone)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(1423441663000L);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.rt", v);
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getDefault()>();
v = virtualinvoke v.<java.util.TimeZone: int getOffset(long)>(1423229263000L);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getTimeZone(java.lang.String)>("UTC");
virtualinvoke v.<java.text.SimpleDateFormat: void setTimeZone(java.util.TimeZone)>(v);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = new java.util.Date;
v = 1423229263000L - v;
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.deviceCustomDate1", v);
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label=Test Long cn3=9223372036854775807 cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt=1234 agt=123.123.0.124 dlat=40.366633";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(byte[])>(v);
return;
}
public void testSuccessfulParseToContent() throws java.io.IOException
{
byte[] v, v;
java.util.Date v;
org.apache.nifi.processors.standard.TestParseCEF v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.util.TestRunner v;
com.fasterxml.jackson.databind.JsonNode v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.List v;
float v;
java.text.SimpleDateFormat v;
long v;
org.apache.nifi.processor.Relationship v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.ParseCEF v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
v = new org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label=Test Long cn3=9223372036854775807 cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt=1234 agt=123.123.0.124 dlat=40.366633";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(byte[])>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("header");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("extension");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("deviceVendor");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("TestVendor", v);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(1423441663000L);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("rt");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cn3Label");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Test Long", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cn3");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: long asLong()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(9223372036854775807L, v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cfp1");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: float floatValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(float,float)>(v, 1.234F);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cfp1Label");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Test FP Number", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("smac");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("00:00:0c:07:ac:00", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("c6a3");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("2001:cdba:0:0:0:0:3257:9652", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("c6a3Label");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Test IPv6", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("destinationTranslatedAddress");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("123.123.123.123", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cs1Label");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Test String", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cs1");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("test test test chocolate", v);
return;
}
public void testSuccessfulParseToContentWhenCEFContainsJSON() throws java.io.IOException
{
byte[] v, v;
java.util.Date v;
org.apache.nifi.processors.standard.TestParseCEF v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.util.TestRunner v;
com.fasterxml.jackson.databind.JsonNode v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.List v;
float v;
java.text.SimpleDateFormat v;
long v;
org.apache.nifi.processor.Relationship v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.ParseCEF v;
com.fasterxml.jackson.databind.ObjectMapper v, v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
v = new org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label=Test Long cn3=9223372036854775807 cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt=1234 agt=123.123.0.124 dlat=40.366633 cs2Label=JSON payload cs2={\"test_test_test\": \"chocolate!\", \"what?!?\": \"Simple! test test test chocolate!\"}";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(byte[])>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("header");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("extension");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("deviceVendor");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("TestVendor", v);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(1423441663000L);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("rt");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cn3Label");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Test Long", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cn3");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: long asLong()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(9223372036854775807L, v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cfp1");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: float floatValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(float,float)>(v, 1.234F);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cfp1Label");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Test FP Number", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("smac");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("00:00:0c:07:ac:00", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("c6a3");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("2001:cdba:0:0:0:0:3257:9652", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("c6a3Label");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Test IPv6", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cs1Label");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Test String", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cs1");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("test test test chocolate", v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("destinationTranslatedAddress");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("123.123.123.123", v);
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cs2");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(java.lang.String)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("test_test_test");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("chocolate!", v);
return;
}
public void testSuccessfulParseToContentUTC() throws java.io.IOException
{
byte[] v, v;
java.util.Date v, v;
org.apache.nifi.processors.standard.TestParseCEF v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.util.TestRunner v;
com.fasterxml.jackson.databind.JsonNode v, v, v, v;
java.util.TimeZone v, v, v;
java.util.List v;
java.text.SimpleDateFormat v, v, v, v;
long v;
org.apache.nifi.processor.Relationship v, v;
int v;
java.lang.String v, v, v, v, v;
org.apache.nifi.processors.standard.ParseCEF v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
v = new org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor TIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UTC");
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label=Test Long cn3=9223372036854775807 cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt=1234 agt=123.123.0.124 dlat=40.366633";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(byte[])>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("extension");
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getTimeZone(java.lang.String)>("UTC");
virtualinvoke v.<java.text.SimpleDateFormat: void setTimeZone(java.util.TimeZone)>(v);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(1423441663000L);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("rt");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getDefault()>();
v = virtualinvoke v.<java.util.TimeZone: int getOffset(long)>(1423229263000L);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getTimeZone(java.lang.String)>("UTC");
virtualinvoke v.<java.text.SimpleDateFormat: void setTimeZone(java.util.TimeZone)>(v);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = new java.util.Date;
v = 1423229263000L - v;
specialinvoke v.<java.util.Date: void <init>(long)>(v);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("deviceCustomDate1");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void testNonEnglishDate()
{
java.util.Date v, v, v;
org.apache.nifi.processors.standard.TestParseCEF v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
java.lang.Long v;
org.apache.nifi.util.TestRunner v;
java.util.Locale v;
java.util.List v, v, v;
java.text.SimpleDateFormat v, v, v, v;
org.apache.nifi.processor.Relationship v, 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;
java.lang.Object v, v, v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
v = new org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor DATETIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "fr-FR");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label=Test Long cn3=9223372036854775807 cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt=1234 agt=123.123.0.124 dlat=40.366633";
v = virtualinvoke v.<java.lang.String: java.lang.String replace(java.lang.CharSequence,java.lang.CharSequence)>("Feb", "f\u00e9vr.");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(1423441663000L);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.rt", v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor DATETIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "et-EE");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label=Test Long cn3=9223372036854775807 cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt=1234 agt=123.123.0.124 dlat=40.366633";
v = virtualinvoke v.<java.lang.String: java.lang.String replace(java.lang.CharSequence,java.lang.CharSequence)>("Feb", "veebr");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(1423441663000L);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.rt", v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor DATETIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "ja-JP");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = new java.text.SimpleDateFormat;
v = staticinvoke <java.util.Locale: java.util.Locale forLanguageTag(java.lang.String)>("ja-JP");
specialinvoke v.<java.text.SimpleDateFormat: void <init>(java.lang.String,java.util.Locale)>("LLLL", v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(1423441663000L);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.lang.Object)>(v);
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label=Test Long cn3=9223372036854775807 cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt=1234 agt=123.123.0.124 dlat=40.366633";
v = virtualinvoke v.<java.lang.String: java.lang.String replace(java.lang.CharSequence,java.lang.CharSequence)>("Feb", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 3);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = v.<org.apache.nifi.processors.standard.TestParseCEF: java.text.SimpleDateFormat sdf>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>(long)>(1423441663000L);
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("cef.extension.rt", v);
return;
}
public void testCustomValidator()
{
java.util.Locale[] v;
org.apache.nifi.processors.standard.TestParseCEF v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.util.Locale v;
int v, v;
java.lang.String v, v;
org.apache.nifi.processors.standard.ParseCEF v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
v = new org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor TIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UTC");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor DATETIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "SPANGLISH");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertNotValid()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor DATETIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "en-US");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = staticinvoke <java.util.Locale: java.util.Locale[] getAvailableLocales()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.util.Locale: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = virtualinvoke v.<java.util.Locale: java.lang.String toLanguageTag()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor DATETIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
label:
v = v + 1;
goto label;
label:
return;
}
public void testIncludeCustomExtensions() throws java.lang.Exception
{
byte[] v, v;
org.apache.nifi.processors.standard.TestParseCEF v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
int v;
com.fasterxml.jackson.databind.JsonNode v, v, v;
java.lang.String v;
org.apache.nifi.processors.standard.ParseCEF v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
v = "<159>Aug 09 08:56:28 8.8.8.8 CEF:0|x|Security|x.x.0|20|Transaction blocked|7| act=blocked app=https dvc=8.8.8.8 dst=8.8.8.8 dhost=www.flynas.com dpt=443 src=8.8.8.8 spt=53475 suser=x UserPath=LDAP://8.8.8.8 OU\\\\=1 - x x x x,OU\\\\=x x,DC\\\\=x,DC\\\\=com/x destinationTranslatedPort=36436 rt=1628488588000 in=65412 out=546 requestMethod=GET  category=20 http_response=200 http_proxy_status_code=302 duration=13 requestClientApplication=Mozilla/5.0 (Windows NT 10.0; WOW64; Trident/7.0;) like Gecko reason=-  cs1Label=Policy cs1=x x**x cs2Label=DynCat cs2=0 cs3Label=ContentType cs3=font/otf cn1Label=DispositionCode cn1=1047 cn2Label=ScanDuration cn2=13 request=https://www.flynas.com/css/fonts/GothamRounded-Book.otf URLRefer=https://www.flynas.com/en";
v = new org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor TIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UTC");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor INCLUDE_CUSTOM_EXTENSIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(byte[])>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("extension");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("http_response");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: int asInt()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(200, v);
return;
}
public void testAcceptEmptyExtensions() throws java.lang.Exception
{
byte[] v, v;
org.apache.nifi.processors.standard.TestParseCEF v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
com.fasterxml.jackson.databind.JsonNode v, v, v, v;
java.lang.String v, v;
org.apache.nifi.processors.standard.ParseCEF v;
boolean v, v, v, v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label= cn3= cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt= agt= dlat=";
v = new org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor TIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UTC");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor INCLUDE_CUSTOM_EXTENSIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor ACCEPT_EMPTY_EXTENSIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor VALIDATE_DATA>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(byte[])>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("extension");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: boolean has(java.lang.String)>("cn3");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cn3");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: boolean isNull()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: boolean has(java.lang.String)>("cn3Label");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("cn3Label");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testDataValidation() throws java.lang.Exception
{
byte[] v, v, v;
org.apache.nifi.processors.standard.TestParseCEF v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v;
com.fasterxml.jackson.databind.JsonNode v, v, v;
java.lang.String v, v;
org.apache.nifi.processors.standard.ParseCEF v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestParseCEF;
v = "CEF:0|TestVendor|TestProduct|TestVersion|TestEventClassID|TestName|Low|rt=Feb 09 2015 00:27:43 UTC cn3Label=Test Long cn3=9223372036854775807 cfp1=1.234 cfp1Label=Test FP Number smac=00:00:0c:07:ac:00 c6a3=2001:cdba::3257:9652 c6a3Label=Test IPv cs1Label=Test String cs1=test test test chocolate destinationTranslatedAddress=123.123.123.123 deviceCustomDate1=Feb 06 2015 13:27:43 dpt=1234 agt=123.123.0.124 dlat=40.366633 proto=ICMP";
v = new org.apache.nifi.processors.standard.ParseCEF;
specialinvoke v.<org.apache.nifi.processors.standard.ParseCEF: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor FIELDS_DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor TIME_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "UTC");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.components.PropertyDescriptor VALIDATE_DATA>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.ParseCEF: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(byte[])>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("extension");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>("proto");
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("ICMP", v);
return;
}
}