public class org.apache.nifi.processors.standard.InvokeHTTPTest extends java.lang.Object { private static final java.lang.String HTTP_LOCALHOST_URL; private static final java.lang.String LOCALHOST; private static final java.lang.String BASE_PATH; private static final java.lang.String POST_FORM_PARAMETER_KEY; private static final java.lang.String DATE_HEADER; private static final java.lang.String ACCEPT_HEADER; private static final java.lang.String AUTHORIZATION_HEADER; private static final java.lang.String CONTENT_LENGTH_HEADER; private static final java.lang.String CONTENT_ENCODING_HEADER; private static final java.lang.String CONTENT_TYPE_HEADER; private static final java.lang.String LOCATION_HEADER; private static final java.lang.String SET_COOKIE_HEADER; private static final java.lang.String COOKIE_HEADER; private static final java.lang.String COOKIE_1; private static final java.lang.String COOKIE_2; private static final java.lang.String TRANSFER_ENCODING_HEADER; private static final java.lang.String USER_AGENT_HEADER; private static final java.lang.String AUTHENTICATE_HEADER; private static final java.lang.String REPEATED_HEADER; private static final java.lang.String TEXT_PLAIN; private static final java.lang.String FLOW_FILE_CONTENT; private static final java.lang.String FLOW_FILE_INITIAL_FILENAME; private static final int TAKE_REQUEST_COMPLETED_TIMEOUT; private static final java.lang.String TLS_CONNECTION_TIMEOUT; private static org.apache.nifi.security.util.TlsConfiguration generatedTlsConfiguration; private static org.apache.nifi.security.util.TlsConfiguration truststoreTlsConfiguration; private okhttp.mockwebserver.MockWebServer mockWebServer; private org.apache.nifi.util.TestRunner runner; public void () { org.apache.nifi.processors.standard.InvokeHTTPTest v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; specialinvoke v.()>(); return; } public static void setStores() { org.apache.nifi.security.util.KeystoreType v; org.apache.nifi.security.util.TlsConfiguration v, v, v, v; org.apache.nifi.security.util.StandardTlsConfiguration v; org.apache.nifi.security.util.TemporaryKeyStoreBuilder v; java.lang.String v, v; v = new org.apache.nifi.security.util.TemporaryKeyStoreBuilder; specialinvoke v.()>(); v = virtualinvoke v.(); = v; v = new org.apache.nifi.security.util.StandardTlsConfiguration; v = ; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,org.apache.nifi.security.util.KeystoreType,java.lang.String,java.lang.String,org.apache.nifi.security.util.KeystoreType)>(null, null, null, v, v, v); = v; return; } public void setRunner() { org.apache.nifi.processors.standard.InvokeHTTP v; org.apache.nifi.util.TestRunner v, v; okhttp.mockwebserver.MockWebServer v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = new okhttp.mockwebserver.MockWebServer; specialinvoke v.()>(); v. = v; v = new org.apache.nifi.processors.standard.InvokeHTTP; specialinvoke v.()>(); v = staticinvoke (v); v. = v; v = v.; v = ; v = staticinvoke (0); interfaceinvoke v.(v, v); return; } public void shutdownServer() throws java.io.IOException { okhttp.mockwebserver.MockWebServer v; org.apache.nifi.processors.standard.InvokeHTTPTest v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; virtualinvoke v.(); return; } public void testNotValidWithDefaultProperties() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.util.TestRunner v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; interfaceinvoke v.(); return; } public void testNotValidWithProxyHostWithoutProxyPort() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v, v, v; java.lang.Class v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; interfaceinvoke v.(v, "http://localhost"); v = v.; v = ; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); return; } public void testNotValidWithProxyUserWithoutProxyPassword() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v, v, v; java.lang.Class v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; interfaceinvoke v.(v, "http://localhost"); v = v.; v = ; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); return; } public void testNotValidWithProxyUserAndPasswordWithoutProxyHost() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.util.TestRunner v, v, v, v; java.lang.Class v, v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; interfaceinvoke v.(v, "http://localhost"); v = v.; v = ; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); return; } public void testNotValidWithPostFormPropertyWithoutFormBodyFormName() { org.apache.nifi.util.TestRunner v, v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.Class v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; interfaceinvoke v.(v, "http://localhost"); v = v.; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.("post:form:parameter", v); v = v.; interfaceinvoke v.(); return; } public void testNotValidWithPostFormPropertyAndFormBodyFormNameWithoutRequestBodyEnabled() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v; java.lang.Boolean v; java.lang.Class v, v; java.lang.String v, v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; interfaceinvoke v.(v, "http://localhost"); v = v.; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.("post:form:parameter", v); v = v.; v = ; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); return; } public void testValidWithMinimumProperties() { org.apache.nifi.util.TestRunner v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; interfaceinvoke v.(v, "http://localhost"); v = v.; interfaceinvoke v.(); return; } public void testRunNoIncomingConnectionsWithNonLoopConnections() { org.apache.nifi.util.TestRunner v, v, v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; interfaceinvoke v.(0); v = v.; interfaceinvoke v.(1); specialinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); return; } public void testRunNoIncomingConnectionsPostMethod() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processors.standard.http.HttpMethod v; org.apache.nifi.util.TestRunner v, v, v, v, v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; interfaceinvoke v.(0); v = v.; interfaceinvoke v.(0); specialinvoke v.(); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); return; } public void testRunGetMalformedUrlExceptionFailureNoIncomingConnections() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v; java.util.List v; org.apache.nifi.util.TestRunner v, v, v, v, v; org.apache.nifi.util.MockComponentLog v; boolean v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; interfaceinvoke v.(0); v = v.; interfaceinvoke v.(0); v = v.; v = ; interfaceinvoke v.(v, "${file.name}"); v = v.; interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); staticinvoke (v); return; } public void testRunGetMalformedUrlExceptionFailure() { java.lang.Object[] v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v, v, v; java.lang.String v, v, v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.Class v, v; org.apache.nifi.util.MockFlowFile v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = newarray (java.lang.Object)[1]; v[0] = "request.url"; v = staticinvoke ("${%s}", v); interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.("request.url", v); v = v.; v = ; interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(1); v = specialinvoke v.(); v = class "Ljava/net/MalformedURLException;"; v = virtualinvoke v.(); virtualinvoke v.("invokehttp.java.exception.class", v); virtualinvoke v.("invokehttp.java.exception.message"); return; } public void testRunGetMethodIllegalArgumentExceptionFailure() { java.lang.Object[] v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v, v, v; java.lang.Class v; java.lang.String v, v, v; org.apache.nifi.util.MockFlowFile v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; specialinvoke v.(); v = v.; v = ; v = newarray (java.lang.Object)[1]; v[0] = "request.method"; v = staticinvoke ("${%s}", v); interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("request.method", null); v = v.; v = ; interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(1); v = specialinvoke v.(); v = class "Ljava/lang/IllegalArgumentException;"; v = virtualinvoke v.(); virtualinvoke v.("invokehttp.java.exception.class", v); virtualinvoke v.("invokehttp.java.exception.message"); return; } public void testRunGetHttp200Success() throws java.lang.InterruptedException { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.processors.standard.http.HttpMethod v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = ; specialinvoke v.(v); return; } public void testRunGetHttp200SuccessResponseBodyIgnoredEnabled() throws java.lang.InterruptedException { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processors.standard.http.HttpMethod v; org.apache.nifi.util.TestRunner v; java.lang.Boolean v; java.lang.String v, v; org.apache.nifi.util.MockFlowFile v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; specialinvoke v.(v); v = specialinvoke v.(); v = virtualinvoke v.(); staticinvoke ("", v); return; } public void testRunGetHttp200SuccessResponseBodyAttributeName() { org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.Class v, v; okhttp.mockwebserver.MockResponse v, v, v; org.apache.nifi.util.MockFlowFile v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, v); specialinvoke v.(); v = class "Ljava/lang/String;"; v = virtualinvoke v.(); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); virtualinvoke v.(v, v); return; } public void testRunGetHttp200SuccessResponseBodyAttributeNameNoIncomingConnections() { org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v; java.util.Iterator v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.util.List v; java.lang.Class v, v; java.lang.Object v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, v); specialinvoke v.(); v = v.; interfaceinvoke v.(0); v = v.; interfaceinvoke v.(0); v = class "Ljava/lang/String;"; v = virtualinvoke v.(); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = ; specialinvoke v.(v, 200); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v, v); return; } public void testRunGetHttp200SuccessNoIncomingConnections() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v; okhttp.mockwebserver.MockWebServer v; okhttp.mockwebserver.MockResponse v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; interfaceinvoke v.(0); v = v.; interfaceinvoke v.(0); specialinvoke v.(); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = ; specialinvoke v.(v, 200); return; } public void testRunGetHttp200SuccessProxyHostPortConfigured() throws java.lang.InterruptedException { java.lang.Object[] v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v, v, v; int v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v, v, v, v, v, v; java.net.URI v; okhttp.mockwebserver.RecordedRequest v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.processors.standard.http.HttpMethod v; okhttp.mockwebserver.MockResponse v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = specialinvoke v.(); v = staticinvoke (v); v = v.; v = ; interfaceinvoke v.(v, v); v = v.; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); virtualinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = v; v = staticinvoke ("%s %s HTTP/1.1", v); staticinvoke (v, v); return; } public void testRunGetHttp200SuccessProxyHostPortUserPasswordConfigured() throws java.lang.InterruptedException { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v; okhttp.mockwebserver.MockWebServer v; java.net.URI v; okhttp.mockwebserver.RecordedRequest v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.processors.standard.http.HttpMethod v; okhttp.mockwebserver.MockResponse v, v; java.lang.Object[] v; org.apache.nifi.processor.Relationship v; int v; java.lang.String v, v, v, v, v, v, v, v, v; java.lang.Class v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = specialinvoke v.(); v = staticinvoke (v); v = v.; v = ; interfaceinvoke v.(v, v); v = v.; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = v.; v = ; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); virtualinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = v; v = staticinvoke ("%s %s HTTP/1.1", v); staticinvoke (v, v); return; } public void testRunGetHttp200SuccessContentTypeHeaderMimeType() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v; okhttp.mockwebserver.MockResponse v, v, v; org.apache.nifi.flowfile.attributes.CoreAttributes v; org.apache.nifi.util.MockFlowFile v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = virtualinvoke v.("Content-Type", "text/plain"); v = v.; virtualinvoke v.(v); specialinvoke v.(); v = v.; v = ; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, "text/plain"); return; } public void testRunGetHttp200SuccessRequestDateHeader() throws java.lang.InterruptedException { okhttp.mockwebserver.RecordedRequest v; java.time.ZonedDateTime v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v; java.util.regex.Matcher v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.time.format.DateTimeFormatter v; java.lang.Boolean v; java.lang.String v, v, v; java.util.regex.Pattern v; boolean v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); specialinvoke v.(200); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = virtualinvoke v.("Date"); staticinvoke (v, "Request Date not found"); v = staticinvoke ("^.+? \\d{4} \\d{2}:\\d{2}:\\d{2} GMT$"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, "Request Date RFC 2616 not matched"); v = ; v = staticinvoke (v, v); staticinvoke (v, "Request Date Parsing Failed"); return; } public void testRunGetHttp200SuccessRequestHeaderAttributesAndDynamicProperties() throws java.lang.InterruptedException { java.lang.Object[] v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v; okhttp.mockwebserver.MockWebServer v, v; java.lang.String v, v, v, v, v, v, v; okhttp.mockwebserver.RecordedRequest v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; okhttp.mockwebserver.MockResponse v, v, v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = newarray (java.lang.Object)[1]; v[0] = "Accept"; v = staticinvoke ("^%s$", v); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.("Default-Content-Type", "application/octet-stream"); specialinvoke v.(); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); virtualinvoke v.(v); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("Accept", "text/plain"); v = v.; v = ; interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = virtualinvoke v.("Accept"); staticinvoke ("text/plain", v); v = virtualinvoke v.("Default-Content-Type"); staticinvoke ("application/octet-stream", v); v = v.; v = ; interfaceinvoke v.(v); v = v.; interfaceinvoke v.("Default-Content-Type"); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); virtualinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = specialinvoke v.(); v = virtualinvoke v.("Accept"); staticinvoke (v, "Accept Header found"); v = virtualinvoke v.("Default-Content-Type"); staticinvoke (v, "Default-Content-Type Header found"); return; } public void testRunGetHttp200SuccessResponseHeaderRequestAttributes() { java.lang.Object[] v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v; okhttp.mockwebserver.MockWebServer v; java.lang.Boolean v; java.lang.String v, v, v, v, v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.Class v, v; okhttp.mockwebserver.MockResponse v, v, v, v; org.apache.nifi.util.MockFlowFile v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; specialinvoke v.(); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = class "Ljava/lang/String;"; v = virtualinvoke v.(); v = class "Ljava/lang/Integer;"; v = virtualinvoke v.(); v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); v = virtualinvoke v.("Repeated", v); v = virtualinvoke v.("Repeated", v); v = v.; virtualinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = staticinvoke (0); virtualinvoke v.("Content-Length", v); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; v = staticinvoke ("%s, %s", v); virtualinvoke v.("Repeated", v); return; } public void testRunGetHttp200SuccessResponseCacheEnabled() throws java.lang.InterruptedException { org.apache.nifi.processors.standard.http.HttpMethod v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.Boolean v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; specialinvoke v.(v); return; } public void testRunGetHttp200SuccessBasicAuthentication() throws java.lang.InterruptedException { okhttp.mockwebserver.RecordedRequest v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v, v; java.util.regex.Matcher v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v; java.lang.Class v, v; java.lang.String v, v, v; java.util.regex.Pattern v; boolean v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); specialinvoke v.(200); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = virtualinvoke v.("Authorization"); staticinvoke (v, "Authorization Header not found"); v = staticinvoke ("^Basic \\S+$"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, "Basic Authentication not matched"); return; } public void testRunGetHttp200SuccessDigestAuthentication() throws java.lang.InterruptedException { java.lang.Object[] v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v; okhttp.mockwebserver.MockWebServer v; java.lang.Boolean v; java.lang.String v, v, v, v, v, v, v, v; boolean v, v; okhttp.mockwebserver.RecordedRequest v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.util.UUID v, v; java.lang.Class v, v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = staticinvoke (); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; v = staticinvoke ("Digest realm=\"%s\", nonce=\"%s\"", v); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(401); v = virtualinvoke v.("WWW-Authenticate", v); virtualinvoke v.(v); specialinvoke v.(200); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = virtualinvoke v.("Authorization"); staticinvoke (v, "Authorization Header found"); v = specialinvoke v.(); v = virtualinvoke v.("Authorization"); staticinvoke (v, "Authorization Header not found"); v = virtualinvoke v.(v); staticinvoke (v, "Digest Realm not found"); v = virtualinvoke v.(v); staticinvoke (v, "Digest Nonce not found"); return; } public void testRunGetHttp200SuccessSslContextServiceServerTrusted() throws org.apache.nifi.reporting.InitializationException, java.security.GeneralSecurityException { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.security.util.TlsConfiguration v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = ; v = ; specialinvoke v.(v, v); return; } public void testRunGetHttp200SuccessSslContextServiceMutualTrusted() throws org.apache.nifi.reporting.InitializationException, java.security.GeneralSecurityException { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.security.util.TlsConfiguration v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = ; v = ; specialinvoke v.(v, v); return; } public void testRunGetSslContextServiceMutualTrustedClientCertificateMissing() throws org.apache.nifi.reporting.InitializationException, java.security.GeneralSecurityException { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.security.util.TlsConfiguration v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v, v; okhttp.mockwebserver.MockWebServer v; java.lang.Boolean v; java.lang.String v, v, v; org.apache.nifi.util.MockFlowFile v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = ; v = ; specialinvoke v.(v, v); v = v.; virtualinvoke v.(); specialinvoke v.(); v = v.; v = ; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v); v = specialinvoke v.(); virtualinvoke v.("invokehttp.java.exception.class"); virtualinvoke v.("invokehttp.java.exception.message"); return; } public void testRunGetHttp200SuccessUserAgentConfigured() throws java.lang.InterruptedException { okhttp.mockwebserver.RecordedRequest v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.util.UUID v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = staticinvoke (); v = virtualinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, v); specialinvoke v.(200); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = virtualinvoke v.("User-Agent"); staticinvoke (v, v); return; } public void testRunGetHttp302NoRetryResponseRedirectsDefaultEnabled() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v; okhttp.mockwebserver.MockWebServer v; java.lang.String v; okhttp.mockwebserver.MockResponse v, v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(302); v = specialinvoke v.(); v = virtualinvoke v.("Location", v); virtualinvoke v.(v); specialinvoke v.(200); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = ; specialinvoke v.(v, 200); return; } public void testRunGetHttp302NoRetryResponseRedirectsDisabled() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v, v; java.lang.Boolean v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); specialinvoke v.(302); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = ; specialinvoke v.(v, 302); return; } public void testRunGetHttp302CookieStrategyAcceptAll() throws java.lang.InterruptedException { java.lang.Object[] v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v, v; okhttp.mockwebserver.MockWebServer v, v, v; java.lang.String v, v, v, v, v; okhttp.mockwebserver.RecordedRequest v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.processors.standard.http.CookieStrategy v; okhttp.mockwebserver.MockResponse v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(302); v = virtualinvoke v.("Set-Cookie", "a=apple"); v = virtualinvoke v.("Set-Cookie", "b=banana"); v = specialinvoke v.(); v = virtualinvoke v.("Location", v); virtualinvoke v.(v); specialinvoke v.(200); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.("Cookie"); staticinvoke (v); v = v.; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = "a=apple"; v[1] = "b=banana"; v = staticinvoke ("%s; %s", v); v = virtualinvoke v.("Cookie"); staticinvoke (v, v); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = ; specialinvoke v.(v, 200); return; } public void testRunGetHttp302CookieStrategyDefaultDisabled() throws java.lang.InterruptedException { org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v; okhttp.mockwebserver.MockWebServer v, v, v; java.lang.String v, v, v; okhttp.mockwebserver.RecordedRequest v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; okhttp.mockwebserver.MockResponse v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(302); v = virtualinvoke v.("Set-Cookie", "a=apple"); v = virtualinvoke v.("Set-Cookie", "b=banana"); v = specialinvoke v.(); v = virtualinvoke v.("Location", v); virtualinvoke v.(v); specialinvoke v.(200); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.("Cookie"); staticinvoke (v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.("Cookie"); staticinvoke (v); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = ; specialinvoke v.(v, 200); return; } public void testRunGetHttp400NoRetryMinimumProperties() { org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; specialinvoke v.(400); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = ; specialinvoke v.(v, 400); return; } public void testRunGetHttp400NoRetryPenalizeNoRetry() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v, v, v; java.lang.Boolean v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); specialinvoke v.(400); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(1); v = ; specialinvoke v.(v, 400); return; } public void testRunGetHttp500RetryMinimumProperties() { org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; specialinvoke v.(500); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = ; specialinvoke v.(v, 500); return; } public void testRunGetHttp500RetryResponseGeneratedRequired() { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v; java.lang.Boolean v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); specialinvoke v.(500); v = v.; v = ; interfaceinvoke v.(v, 0); v = ; specialinvoke v.(v, 500); v = ; specialinvoke v.(v, 500); return; } public void testRunDeleteHttp200Success() throws java.lang.InterruptedException { org.apache.nifi.processors.standard.http.HttpMethod v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; specialinvoke v.(v); return; } public void testRunHeadHttp200Success() throws java.lang.InterruptedException { org.apache.nifi.processors.standard.http.HttpMethod v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; specialinvoke v.(v); return; } public void testRunOptionsHttp200Success() throws java.lang.InterruptedException { org.apache.nifi.processors.standard.http.HttpMethod v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; specialinvoke v.(v); return; } public void testRunPatchHttp200Success() throws java.lang.InterruptedException { org.apache.nifi.processors.standard.http.HttpMethod v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; specialinvoke v.(v); return; } public void testRunPostHttp200Success() throws java.lang.InterruptedException { org.apache.nifi.processors.standard.http.HttpMethod v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; specialinvoke v.(v); return; } public void testRunPostHttp200SuccessContentEncodingGzip() throws java.lang.InterruptedException, java.io.IOException { java.lang.Throwable v; java.util.zip.GZIPInputStream v; org.apache.nifi.components.PropertyDescriptor v, v, v; java.nio.charset.Charset v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v; org.apache.nifi.processors.standard.http.ContentEncodingStrategy v, v; java.lang.Boolean v; java.lang.String v, v, v, v, v, v, v, v, v; okio.Buffer v; okhttp.mockwebserver.RecordedRequest v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.processors.standard.http.HttpMethod v; java.io.InputStream v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); specialinvoke v.(200); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = virtualinvoke v.("Content-Length"); staticinvoke (v, "Content-Length Request Header found"); v = virtualinvoke v.("Content-Encoding"); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v); v = virtualinvoke v.(); v = new java.util.zip.GZIPInputStream; v = virtualinvoke v.(); specialinvoke v.(java.io.InputStream)>(v); label: v = ; v = staticinvoke (v, v); v = ; staticinvoke (v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void testRunPostHttp200SuccessChunkedEncoding() throws java.lang.InterruptedException { okhttp.mockwebserver.RecordedRequest v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processors.standard.http.HttpMethod v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v; java.lang.Boolean v; java.lang.String v, v, v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); specialinvoke v.(200); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = virtualinvoke v.("Content-Length"); staticinvoke (v, "Content-Length Request Header found"); v = virtualinvoke v.("Transfer-Encoding"); staticinvoke ("chunked", v); return; } public void testRunPostHttp200SuccessFormData() throws java.lang.InterruptedException { java.lang.Object[] v; org.apache.nifi.components.PropertyDescriptor v, v; java.util.regex.Matcher v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v, v, v; okhttp.mockwebserver.MockWebServer v; java.lang.String v, v, v, v, v, v; boolean v, v; okio.Buffer v; okhttp.mockwebserver.RecordedRequest v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.processors.standard.http.HttpMethod v; java.lang.Class v; java.util.regex.Pattern v; okhttp.mockwebserver.MockResponse v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "multipart-form"); v = class "Ljava/lang/String;"; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = "post:form"; v[1] = "label"; v = staticinvoke ("%s:%s", v); v = v.; interfaceinvoke v.(v, v); specialinvoke v.(); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); virtualinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = virtualinvoke v.("Content-Type"); staticinvoke (v, "Content Type not found"); v = staticinvoke ("^multipart/form-data.+$"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, "Content Type not matched"); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); staticinvoke (v, "Form Data Parameter not found"); return; } public void testRunPutHttp200Success() throws java.lang.InterruptedException { org.apache.nifi.processors.standard.http.HttpMethod v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; specialinvoke v.(v); return; } public void testResponseFlowFileFilenameExtractedFromRemoteUrl(java.lang.String, java.lang.String, java.lang.String) throws java.net.MalformedURLException { java.net.URL v, v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v; okhttp.mockwebserver.MockWebServer v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.util.List v; okhttp.mockwebserver.MockResponse v, v; java.util.HashMap v; org.apache.nifi.processor.Relationship v; java.lang.String v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.http.FlowFileNamingStrategy v; java.util.Iterator v; java.lang.Object v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = new java.net.URL; v = specialinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = new java.net.URL; specialinvoke v.(java.net.URL,java.lang.String)>(v, v); v = v.; v = ; interfaceinvoke v.(v, v); v = v.; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = ; interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, v); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(200); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); virtualinvoke v.(v, v); return; } private static java.util.stream.Stream testResponseFlowFileFilenameExtractedFromRemoteUrl() { org.junit.jupiter.params.provider.Arguments[] v; org.junit.jupiter.params.provider.Arguments v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.stream.Stream v; org.apache.nifi.processors.standard.http.HttpMethod v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object[] v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; v = newarray (org.junit.jupiter.params.provider.Arguments)[20]; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "file"; v[2] = "file"; v = staticinvoke (v); v[0] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "file/"; v[2] = "file"; v = staticinvoke (v); v[1] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "file.txt"; v[2] = "file.txt"; v = staticinvoke (v); v[2] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "file.txt/"; v[2] = "file.txt"; v = staticinvoke (v); v[3] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "file.txt/?qp=v"; v[2] = "file.txt"; v = staticinvoke (v); v[4] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "f%69%6Cle.txt"; v[2] = "f%69%6Cle.txt"; v = staticinvoke (v); v[5] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "path/to/file.txt"; v[2] = "file.txt"; v = staticinvoke (v); v[6] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = ""; v = ; v[2] = v; v = staticinvoke (v); v[7] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "has/path"; v = ; v[2] = v; v = staticinvoke (v); v[8] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = ""; v = ; v[2] = v; v = staticinvoke (v); v[9] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "has/path"; v = ; v[2] = v; v = staticinvoke (v); v[10] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = ""; v = ; v[2] = v; v = staticinvoke (v); v[11] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = ""; v = ; v[2] = v; v = staticinvoke (v); v[12] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "has/path"; v = ; v[2] = v; v = staticinvoke (v); v[13] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = ""; v = ; v[2] = v; v = staticinvoke (v); v[14] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "has/path"; v = ; v[2] = v; v = staticinvoke (v); v[15] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = ""; v = ; v[2] = v; v = staticinvoke (v); v[16] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "has/path"; v = ; v[2] = v; v = staticinvoke (v); v[17] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = ""; v = ; v[2] = v; v = staticinvoke (v); v[18] = v; v = newarray (java.lang.Object)[3]; v = ; v = virtualinvoke v.(); v[0] = v; v[1] = "has/path"; v = ; v[2] = v; v = staticinvoke (v); v[19] = v; v = staticinvoke (v); return v; } public void testValidWhenOAuth2Set() throws java.lang.Exception { org.mockito.Answers v; org.mockito.stubbing.OngoingStubbing v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v, v; org.apache.nifi.oauth.OAuth2AccessTokenProvider v; java.lang.Object v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = ; v = staticinvoke (class "Lorg/apache/nifi/oauth2/OAuth2AccessTokenProvider;", v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("oauth2AccessTokenProviderId"); v = v.; interfaceinvoke v.("oauth2AccessTokenProviderId", v); v = v.; interfaceinvoke v.(v); specialinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, "oauth2AccessTokenProviderId"); v = v.; interfaceinvoke v.(); return; } public void testInvalidWhenOAuth2AndUserNameSet() throws java.lang.Exception { org.mockito.Answers v; org.mockito.stubbing.OngoingStubbing v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v, v, v, v, v; org.apache.nifi.oauth.OAuth2AccessTokenProvider v; java.lang.Object v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = ; v = staticinvoke (class "Lorg/apache/nifi/oauth2/OAuth2AccessTokenProvider;", v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("oauth2AccessTokenProviderId"); v = v.; interfaceinvoke v.("oauth2AccessTokenProviderId", v); v = v.; interfaceinvoke v.(v); specialinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, "oauth2AccessTokenProviderId"); v = v.; v = ; interfaceinvoke v.(v, "userName"); v = v.; interfaceinvoke v.(); return; } public void testInvalidWhenOAuth2AndPasswordSet() throws java.lang.Exception { org.mockito.Answers v; org.mockito.stubbing.OngoingStubbing v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v, v, v, v, v; org.apache.nifi.oauth.OAuth2AccessTokenProvider v; java.lang.Object v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = ; v = staticinvoke (class "Lorg/apache/nifi/oauth2/OAuth2AccessTokenProvider;", v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("oauth2AccessTokenProviderId"); v = v.; interfaceinvoke v.("oauth2AccessTokenProviderId", v); v = v.; interfaceinvoke v.(v); specialinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, "oauth2AccessTokenProviderId"); v = v.; v = ; interfaceinvoke v.(v, "password"); v = v.; interfaceinvoke v.(); return; } public void testOAuth2AuthorizationHeader() throws java.lang.Exception { org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v, v, v; okhttp.mockwebserver.MockWebServer v, v; java.lang.String v, v, v, v, v; org.mockito.Answers v; okhttp.mockwebserver.RecordedRequest v; org.mockito.stubbing.OngoingStubbing v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.processors.standard.http.HttpHeader v; org.apache.nifi.oauth.AccessToken v; org.apache.nifi.oauth.OAuth2AccessTokenProvider v; java.lang.Object v; okhttp.mockwebserver.MockResponse v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = ; v = staticinvoke (class "Lorg/apache/nifi/oauth2/OAuth2AccessTokenProvider;", v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("oauth2AccessTokenProviderId"); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("access_token"); v = v.; interfaceinvoke v.("oauth2AccessTokenProviderId", v); v = v.; interfaceinvoke v.(v); specialinvoke v.(); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); virtualinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v, "oauth2AccessTokenProviderId"); v = v.; interfaceinvoke v.("unimportant"); v = v.; interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" ("access_token") ("Bearer \u0001"); staticinvoke (v, v); return; } private void setUrlProperty() { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = specialinvoke v.(); interfaceinvoke v.(v, v); return; } private java.lang.String getMockWebServerUrl() { okhttp.HttpUrl$Builder v, v; okhttp.mockwebserver.MockWebServer v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.String v; okhttp.HttpUrl v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = virtualinvoke v.("/"); v = virtualinvoke v.(); v = virtualinvoke v.("localhost"); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } private void enqueueResponseCodeAndRun(int) { org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.util.TestRunner v, v; int v; okhttp.mockwebserver.MockWebServer v; java.lang.String v; okhttp.mockwebserver.MockResponse v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v := @parameter: int; specialinvoke v.(); v = v.; v = new okhttp.mockwebserver.MockResponse; specialinvoke v.()>(); v = virtualinvoke v.(v); virtualinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); return; } private okhttp.mockwebserver.RecordedRequest takeRequestCompleted() throws java.lang.InterruptedException { java.util.concurrent.TimeUnit v; okhttp.mockwebserver.RecordedRequest v; okhttp.mockwebserver.MockWebServer v; org.apache.nifi.processors.standard.InvokeHTTPTest v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = virtualinvoke v.(1L, v); staticinvoke (v, "Request not found"); return v; } private org.apache.nifi.util.MockFlowFile getFailureFlowFile() { java.util.List v; java.util.Iterator v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); return v; } private org.apache.nifi.util.MockFlowFile getRequestFlowFile() { java.util.List v; java.util.Iterator v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); return v; } private org.apache.nifi.util.MockFlowFile getResponseFlowFile() { java.util.List v; java.util.Iterator v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); return v; } private void assertRequestMethodSuccess(org.apache.nifi.processors.standard.http.HttpMethod) throws java.lang.InterruptedException { org.apache.nifi.processors.standard.http.HttpMethod v; okhttp.mockwebserver.RecordedRequest v; org.apache.nifi.processor.Relationship v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v := @parameter: org.apache.nifi.processors.standard.http.HttpMethod; specialinvoke v.(200); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v); return; } private void assertRelationshipStatusCodeEquals(org.apache.nifi.processor.Relationship, int) { java.lang.Object[] v; java.util.Iterator v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.util.List v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; int v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v := @parameter: org.apache.nifi.processor.Relationship; v := @parameter: int; v = v.; v = interfaceinvoke v.(v); v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke ("FlowFiles not found for Relationship [%s]", v); v = interfaceinvoke v.(); staticinvoke (v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); specialinvoke v.(v, v); return; } private void assertStatusCodeEquals(org.apache.nifi.util.MockFlowFile, int) { int v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.String v; org.apache.nifi.util.MockFlowFile v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v := @parameter: org.apache.nifi.util.MockFlowFile; v := @parameter: int; v = staticinvoke (v); virtualinvoke v.("invokehttp.status.code", v); virtualinvoke v.("invokehttp.status.message"); virtualinvoke v.("invokehttp.tx.id"); virtualinvoke v.("invokehttp.request.url"); virtualinvoke v.("invokehttp.request.duration"); virtualinvoke v.("invokehttp.response.url"); return; } private void assertResponseSuccessRelationships() { java.lang.Object[] v; org.apache.nifi.processor.Relationship v, v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v; java.lang.String v, v; boolean v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.util.List v; java.util.stream.Stream v; java.util.Optional v; java.lang.Object v; org.apache.nifi.util.MockComponentLog v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v = virtualinvoke v.(); v[0] = v; v = staticinvoke ("Error Message Logged: %s", v); v = interfaceinvoke v.(); staticinvoke (v, v); label: v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); return; } private void assertResponseSuccessSslContextConfigured(org.apache.nifi.security.util.TlsConfiguration, org.apache.nifi.security.util.TlsConfiguration) throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.security.util.TlsException { java.util.Iterator v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.security.util.TlsConfiguration v, v; java.util.List v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v := @parameter: org.apache.nifi.security.util.TlsConfiguration; v := @parameter: org.apache.nifi.security.util.TlsConfiguration; specialinvoke v.(v, v); specialinvoke v.(200); specialinvoke v.(); v = ; specialinvoke v.(v, 200); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.("invokehttp.remote.dn"); return; } private void setSslContextConfiguration(org.apache.nifi.security.util.TlsConfiguration, org.apache.nifi.security.util.TlsConfiguration) throws org.apache.nifi.reporting.InitializationException, org.apache.nifi.security.util.TlsException { javax.net.ssl.SSLContext v, v, v; org.mockito.stubbing.OngoingStubbing v, v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.ssl.SSLContextService v; org.apache.nifi.security.util.TlsConfiguration v, v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v := @parameter: org.apache.nifi.security.util.TlsConfiguration; v := @parameter: org.apache.nifi.security.util.TlsConfiguration; v = specialinvoke v.(); v = staticinvoke (v); specialinvoke v.(v); v = staticinvoke (v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); return; } private org.apache.nifi.ssl.SSLContextService setSslContextService() throws org.apache.nifi.reporting.InitializationException { org.mockito.stubbing.OngoingStubbing v; org.apache.nifi.processors.standard.InvokeHTTPTest v; org.apache.nifi.ssl.SSLContextService v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v; java.lang.Class v; java.lang.Object v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v = class "Lorg/apache/nifi/ssl/SSLContextService;"; v = virtualinvoke v.(); v = staticinvoke (class "Lorg/apache/nifi/ssl/SSLContextService;"); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "60 s"); v = v.; v = ; interfaceinvoke v.(v, "60 s"); return v; } private void setMockWebServerSslSocketFactory(javax.net.ssl.SSLContext) { javax.net.ssl.SSLContext v; okhttp.mockwebserver.MockWebServer v; org.apache.nifi.processors.standard.InvokeHTTPTest v; java.lang.IllegalArgumentException v; javax.net.ssl.SSLSocketFactory v; v := @this: org.apache.nifi.processors.standard.InvokeHTTPTest; v := @parameter: javax.net.ssl.SSLContext; v = virtualinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Socket Factory not found"); throw v; label: v = v.; virtualinvoke v.(v, 0); return; } static void () { java.lang.Class v, v; java.lang.String v, v; v = class "Ljava/lang/String;"; v = virtualinvoke v.(); = v; v = class "Ljava/lang/Double;"; v = virtualinvoke v.(); = v; return; } }