public class org.apache.nifi.processors.standard.ITestHandleHttpRequest extends java.lang.Object
{
private org.apache.nifi.processors.standard.HandleHttpRequest processor;
private static javax.net.ssl.SSLContext keyStoreSslContext;
private static javax.net.ssl.SSLContext trustStoreSslContext;
public void <init>()
{
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static void configureServices() throws org.apache.nifi.security.util.TlsException
{
javax.net.ssl.SSLContext v, v;
v = staticinvoke <org.apache.nifi.web.util.ssl.SslContextUtils: javax.net.ssl.SSLContext createKeyStoreSslContext()>();
<org.apache.nifi.processors.standard.ITestHandleHttpRequest: javax.net.ssl.SSLContext keyStoreSslContext> = v;
v = staticinvoke <org.apache.nifi.web.util.ssl.SslContextUtils: javax.net.ssl.SSLContext createTrustStoreSslContext()>();
<org.apache.nifi.processors.standard.ITestHandleHttpRequest: javax.net.ssl.SSLContext trustStoreSslContext> = v;
return;
}
public void setUp() throws java.lang.Exception
{
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
return;
}
public void tearDown() throws java.lang.Exception
{
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
org.apache.nifi.processors.standard.HandleHttpRequest v, v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
if v == null goto label;
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
virtualinvoke v.<org.apache.nifi.processors.standard.HandleHttpRequest: void shutdown()>();
label:
return;
}
public void testRequestAddedToService() throws org.apache.nifi.reporting.InitializationException
{
org.apache.nifi.processors.standard.ITestHandleHttpRequest$1 v;
org.apache.nifi.processors.standard.HandleHttpRequest v, v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Thread v;
int v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
java.util.concurrent.CountDownLatch v, v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest createProcessor(java.util.concurrent.CountDownLatch,java.util.concurrent.CountDownLatch)>(v, v);
v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor> = v;
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
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.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor PORT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: void <init>()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("http-context-map", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "http-context-map");
v = new java.lang.Thread;
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$1;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$1: void <init>(org.apache.nifi.processors.standard.ITestHandleHttpRequest,java.util.concurrent.CountDownLatch,org.apache.nifi.util.TestRunner,java.util.concurrent.CountDownLatch)>(v, v, v, v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean)>(1, 0);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: 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 = virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: 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);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.query.param.query", "true");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.query.param.value1", "value1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.query.param.value2", "");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.query.param.value3", "");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.query.param.value4", "apple=orange");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.headers.header1", "value1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.headers.header3", "apple=orange");
return;
}
public void testMultipartFormDataRequest() throws org.apache.nifi.reporting.InitializationException
{
org.apache.nifi.processors.standard.HandleHttpRequest v, v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Thread v;
int v;
java.lang.String v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$2 v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
java.util.concurrent.CountDownLatch v, v;
java.util.List v;
org.apache.nifi.util.MockFlowFile v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest createProcessor(java.util.concurrent.CountDownLatch,java.util.concurrent.CountDownLatch)>(v, v);
v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor> = v;
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
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.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor PORT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: void <init>()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("http-context-map", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "http-context-map");
v = new java.lang.Thread;
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$2;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$2: void <init>(org.apache.nifi.processors.standard.ITestHandleHttpRequest,java.util.concurrent.CountDownLatch,org.apache.nifi.util.TestRunner,java.util.concurrent.CountDownLatch)>(v, v, v, v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 5);
v = virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: 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 = virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.util.MockFlowFile findFlowFile(java.util.List,java.lang.String,java.lang.String)>(v, "http.multipart.name", "p1");
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: java.lang.String getAttribute(java.lang.String)>("http.context.identifier");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.name", "p1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.multipart.size");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.fragments.sequence.number", "1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.fragments.total.number", "5");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.headers.multipart.content-disposition");
v = virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.util.MockFlowFile findFlowFile(java.util.List,java.lang.String,java.lang.String)>(v, "http.multipart.name", "p2");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.context.identifier", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.name", "p2");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.multipart.size");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.multipart.fragments.sequence.number");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.fragments.total.number", "5");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.headers.multipart.content-disposition");
v = virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.util.MockFlowFile findFlowFile(java.util.List,java.lang.String,java.lang.String)>(v, "http.multipart.name", "file1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.context.identifier", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.name", "file1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.filename", "my-file-text.txt");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.headers.multipart.content-type", "text/plain");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.multipart.size");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.multipart.fragments.sequence.number");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.fragments.total.number", "5");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.headers.multipart.content-disposition");
v = virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.util.MockFlowFile findFlowFile(java.util.List,java.lang.String,java.lang.String)>(v, "http.multipart.name", "file2");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.context.identifier", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.name", "file2");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.filename", "my-file-data.json");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.headers.multipart.content-type", "application/json");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.multipart.size");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.multipart.fragments.sequence.number");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.fragments.total.number", "5");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.headers.multipart.content-disposition");
v = virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.util.MockFlowFile findFlowFile(java.util.List,java.lang.String,java.lang.String)>(v, "http.multipart.name", "file3");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.context.identifier", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.name", "file3");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.filename", "my-file-binary.bin");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.headers.multipart.content-type", "application/octet-stream");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.multipart.size");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.multipart.fragments.sequence.number");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.fragments.total.number", "5");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.headers.multipart.content-disposition");
return;
}
public void testMultipartFormDataRequestCaptureFormAttributes() throws org.apache.nifi.reporting.InitializationException
{
java.lang.Object[] v, v;
org.apache.nifi.processors.standard.HandleHttpRequest v, v;
java.lang.Integer v, v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Thread v;
int v, v;
java.lang.String v, v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$3 v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
java.util.concurrent.CountDownLatch v, v;
java.util.List v;
org.apache.nifi.util.MockFlowFile v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest createProcessor(java.util.concurrent.CountDownLatch,java.util.concurrent.CountDownLatch)>(v, v);
v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor> = v;
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
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.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor PORT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor PARAMETERS_TO_ATTRIBUTES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "p,p2");
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: void <init>()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("http-context-map", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "http-context-map");
v = new java.lang.Thread;
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$3;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$3: void <init>(org.apache.nifi.processors.standard.ITestHandleHttpRequest,java.util.concurrent.CountDownLatch,org.apache.nifi.util.TestRunner,java.util.concurrent.CountDownLatch)>(v, v, v, v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: 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 = virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: 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 = 1;
label:
if v >= 4 goto label;
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("p%d", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.util.MockFlowFile findFlowFile(java.util.List,java.lang.String,java.lang.String)>(v, "http.multipart.name", v);
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("p%d", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.multipart.name", v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.param.p1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.param.p1", "v1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>("http.param.p2");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.param.p2", "v2");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeNotExists(java.lang.String)>("http.param.p3");
v = v + 1;
goto label;
label:
return;
}
public void testMultipartFormDataRequestFailToRegisterContext() throws org.apache.nifi.reporting.InitializationException, java.lang.InterruptedException
{
org.apache.nifi.processors.standard.HandleHttpRequest v, v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
java.lang.Thread v;
int v, v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$4 v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
java.util.concurrent.CountDownLatch v, v, v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest createProcessor(java.util.concurrent.CountDownLatch,java.util.concurrent.CountDownLatch)>(v, v);
v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor> = v;
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
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.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor PORT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: void <init>()>();
virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: void setRegisterSuccessfully(boolean)>(0);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("http-context-map", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "http-context-map");
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(0);
v = new java.lang.Thread;
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$4;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$4: void <init>(org.apache.nifi.processors.standard.ITestHandleHttpRequest,java.util.concurrent.CountDownLatch,org.apache.nifi.util.TestRunner,java.util.concurrent.atomic.AtomicInteger,java.util.concurrent.CountDownLatch,java.util.concurrent.CountDownLatch)>(v, v, v, v, v, v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(0, v);
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(503, v);
return;
}
private byte[] generateRandomBinaryData()
{
byte[] v;
java.util.Random v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v = newarray (byte)[100];
v = new java.util.Random;
specialinvoke v.<java.util.Random: void <init>()>();
virtualinvoke v.<java.util.Random: void nextBytes(byte[])>(v);
return v;
}
private transient java.io.File createTextFile(java.lang.String[]) throws java.io.IOException
{
java.io.PrintWriter v;
java.lang.Throwable v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
java.io.FileWriter v;
java.lang.String[] v;
java.io.File v;
int v, v;
java.lang.Class v;
java.lang.String v, v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v := @parameter: java.lang.String[];
v = new java.io.File;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
virtualinvoke v.<java.io.File: void deleteOnExit()>();
v = new java.io.PrintWriter;
v = new java.io.FileWriter;
specialinvoke v.<java.io.FileWriter: void <init>(java.io.File)>(v);
specialinvoke v.<java.io.PrintWriter: void <init>(java.io.Writer)>(v);
label:
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<java.io.PrintWriter: void println(java.lang.String)>(v);
v = v + 1;
goto label;
label:
virtualinvoke v.<java.io.PrintWriter: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return v;
catch java.lang.Throwable from label to label with label;
}
protected org.apache.nifi.util.MockFlowFile findFlowFile(java.util.List, java.lang.String, java.lang.String)
{
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
java.util.function.Predicate v;
java.util.List v;
java.util.stream.Stream v, v;
java.util.Optional v;
java.lang.Object v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.nifi.processors.standard.ITestHandleHttpRequest$lambda_findFlowFile_0__31: java.util.function.Predicate bootstrap$(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.Optional findFirst()>();
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
return v;
}
public void testFailToRegister() throws org.apache.nifi.reporting.InitializationException, java.lang.InterruptedException
{
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
org.apache.nifi.processors.standard.HandleHttpRequest v, v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.concurrent.CountDownLatch v, v, v;
int[] v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
java.lang.Thread v;
int v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$5 v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest createProcessor(java.util.concurrent.CountDownLatch,java.util.concurrent.CountDownLatch)>(v, v);
v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor> = v;
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
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.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor PORT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: void <init>()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("http-context-map", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "http-context-map");
virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: void setRegisterSuccessfully(boolean)>(0);
v = newarray (int)[1];
v = new java.lang.Thread;
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$5;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$5: void <init>(org.apache.nifi.processors.standard.ITestHandleHttpRequest,java.util.concurrent.CountDownLatch,org.apache.nifi.util.TestRunner,java.util.concurrent.CountDownLatch,int[],java.util.concurrent.CountDownLatch)>(v, v, v, v, v, v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v[0];
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(503, v);
return;
}
public void testOnPrimaryNodeChangePrimaryNodeRevoked() throws java.lang.Exception
{
org.apache.nifi.processors.standard.HandleHttpRequest v, v, v, v, v;
java.lang.Integer v;
java.lang.Runnable v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.'annotation'.notification.PrimaryNodeState v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
java.util.concurrent.CountDownLatch v, v;
okhttp.OkHttpClient$Builder v;
java.lang.Object[] v;
java.util.concurrent.atomic.AtomicReference v;
int v, v;
java.lang.String v, v;
java.util.concurrent.ExecutorService v;
org.mockito.stubbing.OngoingStubbing v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.scheduling.ExecutionNode v, v;
okhttp.OkHttpClient v;
java.lang.Class v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v = new org.apache.nifi.processors.standard.HandleHttpRequest;
specialinvoke v.<org.apache.nifi.processors.standard.HandleHttpRequest: void <init>()>();
v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor> = v;
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
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.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor PORT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: void <init>()>();
v = class "Lorg/apache/nifi/processors/standard/ITestHandleHttpRequest$MockHttpContextMap;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.processor.ProcessContext getProcessContext()>();
v = staticinvoke <org.mockito.Mockito: java.lang.Object spy(java.lang.Object)>(v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.scheduling.ExecutionNode getExecutionNode()>();
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = <org.apache.nifi.scheduling.ExecutionNode: org.apache.nifi.scheduling.ExecutionNode PRIMARY>;
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenReturn(java.lang.Object)>(v);
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
virtualinvoke v.<org.apache.nifi.processors.standard.HandleHttpRequest: void initializeServer(org.apache.nifi.processor.ProcessContext)>(v);
v = new okhttp.OkHttpClient$Builder;
specialinvoke v.<okhttp.OkHttpClient$Builder: void <init>()>();
v = virtualinvoke v.<okhttp.OkHttpClient$Builder: okhttp.OkHttpClient build()>();
v = newarray (java.lang.Object)[1];
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.HandleHttpRequest: int getPort()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("http://localhost:%d", v);
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ExecutorService newSingleThreadExecutor()>();
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>()>();
v = staticinvoke <org.apache.nifi.processors.standard.ITestHandleHttpRequest$lambda_testOnPrimaryNodeChangePrimaryNodeRevoked_1__32: java.lang.Runnable bootstrap$(org.apache.nifi.processors.standard.ITestHandleHttpRequest,java.lang.String,okhttp.OkHttpClient,java.util.concurrent.atomic.AtomicReference,java.util.concurrent.CountDownLatch,java.util.concurrent.atomic.AtomicInteger,java.util.concurrent.CountDownLatch)>(v, v, v, v, v, v, v);
interfaceinvoke v.<java.util.concurrent.ExecutorService: void execute(java.lang.Runnable)>(v);
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
staticinvoke <java.lang.Thread: void sleep(long)>(1000L);
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
v = <org.apache.nifi.'annotation'.notification.PrimaryNodeState: org.apache.nifi.'annotation'.notification.PrimaryNodeState PRIMARY_NODE_REVOKED>;
virtualinvoke v.<org.apache.nifi.processors.standard.HandleHttpRequest: void onPrimaryNodeChange(org.apache.nifi.'annotation'.notification.PrimaryNodeState)>(v);
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object,java.lang.String)>(v, "HTTP Request Exception found");
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(503, v, "HTTP Status not matched");
return;
}
public void testSecure() throws java.lang.Exception
{
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: void secureTest(boolean)>(0);
return;
}
public void testSecureTwoWaySsl() throws java.lang.Exception
{
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: void secureTest(boolean)>(1);
return;
}
private void secureTest(boolean) throws java.lang.Exception
{
javax.net.ssl.SSLContext v, v;
org.apache.nifi.processors.standard.HandleHttpRequest v, v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Thread v;
int v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$7 v;
java.lang.String v, v;
boolean v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
org.mockito.stubbing.OngoingStubbing v, v;
java.util.concurrent.CountDownLatch v, v;
java.util.List v;
java.lang.Class v;
java.lang.Object v, v;
org.apache.nifi.ssl.RestrictedSSLContextService v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v := @parameter: boolean;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v = specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest createProcessor(java.util.concurrent.CountDownLatch,java.util.concurrent.CountDownLatch)>(v, v);
v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor> = v;
v = v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: org.apache.nifi.processors.standard.HandleHttpRequest processor>;
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.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor PORT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: void <init>()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>("http-context-map", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "http-context-map");
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/ssl/RestrictedSSLContextService;");
v = class "Lorg/apache/nifi/ssl/RestrictedSSLContextService;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = interfaceinvoke v.<org.apache.nifi.ssl.RestrictedSSLContextService: java.lang.String getIdentifier()>();
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenReturn(java.lang.Object)>(v);
v = interfaceinvoke v.<org.apache.nifi.ssl.RestrictedSSLContextService: javax.net.ssl.SSLContext createContext()>();
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ITestHandleHttpRequest: javax.net.ssl.SSLContext keyStoreSslContext>;
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenReturn(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void addControllerService(java.lang.String,org.apache.nifi.controller.ControllerService)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enableControllerService(org.apache.nifi.controller.ControllerService)>(v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = new java.lang.Thread;
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$7;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$7: void <init>(org.apache.nifi.processors.standard.ITestHandleHttpRequest,java.util.concurrent.CountDownLatch,org.apache.nifi.util.TestRunner,boolean,java.util.concurrent.CountDownLatch)>(v, v, v, v, v);
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: 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 = virtualinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$MockHttpContextMap: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = <org.apache.nifi.processors.standard.HandleHttpRequest: 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);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.query.param.query", "true");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.query.param.value1", "value1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.query.param.value2", "");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.query.param.value3", "");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.query.param.value4", "apple=orange");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.headers.header1", "value1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.headers.header3", "apple=orange");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("http.protocol", "HTTP/1.1");
return;
}
private org.apache.nifi.processors.standard.HandleHttpRequest createProcessor(java.util.concurrent.CountDownLatch, java.util.concurrent.CountDownLatch)
{
java.util.concurrent.CountDownLatch v, v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$8 v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v := @parameter: java.util.concurrent.CountDownLatch;
v := @parameter: java.util.concurrent.CountDownLatch;
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$8;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$8: void <init>(org.apache.nifi.processors.standard.ITestHandleHttpRequest,java.util.concurrent.CountDownLatch,java.util.concurrent.CountDownLatch)>(v, v, v);
return v;
}
private void sendRequest(java.net.HttpURLConnection, java.util.concurrent.CountDownLatch) throws java.lang.Exception
{
java.net.HttpURLConnection v;
java.util.concurrent.CountDownLatch v;
java.util.concurrent.Future v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
java.util.concurrent.Callable v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v := @parameter: java.net.HttpURLConnection;
v := @parameter: java.util.concurrent.CountDownLatch;
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ExecutorService newSingleThreadExecutor()>();
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.nifi.processors.standard.ITestHandleHttpRequest$getInputStream__33: java.util.concurrent.Callable bootstrap$(java.net.HttpURLConnection)>(v);
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.concurrent.Future submit(java.util.concurrent.Callable)>(v);
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
interfaceinvoke v.<java.util.concurrent.Future: java.lang.Object get()>();
return;
}
private void sendRequest(okhttp.OkHttpClient, okhttp.Request, java.util.concurrent.CountDownLatch)
{
java.util.concurrent.CountDownLatch v;
okhttp.Request v;
okhttp.OkHttpClient v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest$9 v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v := @parameter: okhttp.OkHttpClient;
v := @parameter: okhttp.Request;
v := @parameter: java.util.concurrent.CountDownLatch;
v = new org.apache.nifi.processors.standard.ITestHandleHttpRequest$9;
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest$9: void <init>(org.apache.nifi.processors.standard.ITestHandleHttpRequest)>(v);
specialinvoke v.<org.apache.nifi.processors.standard.ITestHandleHttpRequest: void sendRequest(okhttp.OkHttpClient,okhttp.Request,okhttp.Callback,java.util.concurrent.CountDownLatch)>(v, v, v, v);
return;
}
private void sendRequest(okhttp.OkHttpClient, okhttp.Request, okhttp.Callback, java.util.concurrent.CountDownLatch)
{
java.util.concurrent.CountDownLatch v;
okhttp.Request v;
okhttp.OkHttpClient v;
org.apache.nifi.processors.standard.ITestHandleHttpRequest v;
okhttp.Call v;
okhttp.Callback v;
v := @this: org.apache.nifi.processors.standard.ITestHandleHttpRequest;
v := @parameter: okhttp.OkHttpClient;
v := @parameter: okhttp.Request;
v := @parameter: okhttp.Callback;
v := @parameter: java.util.concurrent.CountDownLatch;
v = virtualinvoke v.<okhttp.OkHttpClient: okhttp.Call newCall(okhttp.Request)>(v);
interfaceinvoke v.<okhttp.Call: void enqueue(okhttp.Callback)>(v);
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
return;
}
}