public class org.apache.nifi.processors.standard.TestExecuteStreamCommand extends java.lang.Object { public void () { org.apache.nifi.processors.standard.TestExecuteStreamCommand v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; specialinvoke v.()>(); return; } public void testExecuteJar() throws java.lang.Exception { byte[] v; org.apache.nifi.components.PropertyDescriptor v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v; java.util.List v, v; java.util.regex.Pattern v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v, v; int 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; java.io.File v, v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestSuccess.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = new java.lang.String; specialinvoke v.(byte[])>(v); v = staticinvoke ("Test was a success\r?\n"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.("execution.status"); staticinvoke ("0", v); v = virtualinvoke v.("execution.command"); staticinvoke ("java", v); v = virtualinvoke v.("execution.command.args"); v = virtualinvoke v.(0, 5); staticinvoke ("-jar;", v); v = virtualinvoke v.("execution.command.args"); v = ; v = ; v = ; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("src\u0001test\u0001resources\u0001ExecuteCommand\u0001TestSuccess.jar"); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("execution.status"); v = virtualinvoke v.("execution.status"); staticinvoke (v, v); v = virtualinvoke v.("execution.command"); v = virtualinvoke v.("execution.command"); staticinvoke (v, v); v = virtualinvoke v.("execution.command.args"); v = virtualinvoke v.("execution.command.args"); staticinvoke (v, v); return; } public void testExecuteJarDynamicPropArgs() throws java.lang.Exception { byte[] v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; java.util.regex.Pattern v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v, v; int 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; java.io.File v, v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestSuccess.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = new java.lang.String; specialinvoke v.(byte[])>(v); v = staticinvoke ("Test was a success\r?\n"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.("execution.status"); staticinvoke ("0", v); v = virtualinvoke v.("execution.command"); staticinvoke ("java", v); v = virtualinvoke v.("execution.command.args"); v = virtualinvoke v.(0, 4); v = virtualinvoke v.(); staticinvoke ("-jar", v); v = virtualinvoke v.("execution.command.args"); v = ; v = ; v = ; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("src\u0001test\u0001resources\u0001ExecuteCommand\u0001TestSuccess.jar"); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(v); staticinvoke (v, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("execution.status"); v = virtualinvoke v.("execution.status"); staticinvoke (v, v); v = virtualinvoke v.("execution.command"); v = virtualinvoke v.("execution.command"); staticinvoke (v, v); v = virtualinvoke v.("execution.command.args"); v = virtualinvoke v.("execution.command.args"); staticinvoke (v, v); return; } public void testExecuteJarWithBadPath() throws java.lang.Exception { org.apache.nifi.processors.standard.TestExecuteStreamCommand v; long v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v, v; java.nio.file.Path v; boolean v; java.io.File v, v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/noSuchFile.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); staticinvoke (0L, v); v = virtualinvoke v.("execution.error"); v = virtualinvoke v.(0, 31); staticinvoke ("Error: Unable to access jarfile", v); v = virtualinvoke v.(); staticinvoke (v); return; } public void testExecuteJarWithBadPathDynamicProperties() throws java.lang.Exception { org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; long v; org.apache.nifi.processor.Relationship v, v, v, v; java.lang.String v, v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/noSuchFile.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); staticinvoke (0L, v); v = virtualinvoke v.("execution.error"); v = virtualinvoke v.(0, 31); staticinvoke ("Error: Unable to access jarfile", v); v = virtualinvoke v.(); staticinvoke (v); return; } public void testExecuteIngestAndUpdate() throws java.io.IOException { java.lang.Throwable v; byte[] v, v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.components.PropertyDescriptor v, v; java.util.regex.Matcher v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; int v, v; java.lang.String v, v, v; java.nio.file.Path v, v; boolean v; java.io.FileOutputStream v; java.io.File v, v, v; java.util.List v; java.lang.Object v; java.util.regex.Pattern v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/10MB.txt"); v = new java.io.FileOutputStream; specialinvoke v.(java.io.File)>(v); label: v = virtualinvoke v.(); v = staticinvoke (v); v = lengthof v; staticinvoke (1000, v); v = 0; label: if v >= 10000 goto label; virtualinvoke v.(v, 0, 1000); v = v + 1; goto label; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = new java.lang.String; specialinvoke v.(byte[])>(v); v = staticinvoke ("nifi-standard-processors:ModifiedResult\r?\n"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); return; catch java.lang.Throwable from label to label with label; } public void testExecuteIngestAndUpdateDynamicProperties() throws java.io.IOException { byte[] v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v, v; boolean v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.util.regex.Pattern v; java.lang.Throwable v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v; int v, v; java.lang.String v, v, v; java.io.FileOutputStream v; java.io.File v, v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/10MB.txt"); v = new java.io.FileOutputStream; specialinvoke v.(java.io.File)>(v); label: v = virtualinvoke v.(); v = staticinvoke (v); v = lengthof v; staticinvoke (1000, v); v = 0; label: if v >= 10000 goto label; virtualinvoke v.(v, 0, 1000); v = v + 1; goto label; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = new java.lang.String; specialinvoke v.(byte[])>(v); v = staticinvoke ("nifi-standard-processors:ModifiedResult\r?\n"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); return; catch java.lang.Throwable from label to label with label; } public void testLoggingToStdErr() throws java.io.IOException { org.apache.nifi.processors.standard.TestExecuteStreamCommand v; long v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v; java.nio.file.Path v; boolean v; java.io.File v, v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestLogStdErr.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1mb.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); interfaceinvoke v.(0); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); staticinvoke (0L, v); v = virtualinvoke v.("execution.error"); v = virtualinvoke v.("fffffffffffffffffffffffffffffff"); staticinvoke (v); return; } public void testLoggingToStdErrDynamicProperties() throws java.io.IOException { org.apache.nifi.processors.standard.TestExecuteStreamCommand v; long v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v; java.nio.file.Path v; boolean v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.io.File v, v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestLogStdErr.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1mb.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); interfaceinvoke v.(0); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); staticinvoke (0L, v); v = virtualinvoke v.("execution.error"); v = virtualinvoke v.("fffffffffffffffffffffffffffffff"); staticinvoke (v); return; } public void testExecuteIngestAndUpdateWithWorkingDir() throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.components.PropertyDescriptor v, v, v; java.util.regex.Matcher v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v, v, v, v; java.nio.file.Path v; boolean v; java.io.File v, v; java.util.List v; java.lang.Object v; java.util.regex.Pattern v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = new java.lang.String; specialinvoke v.(byte[])>(v); v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001nifi-standard-processors\u0001target:ModifiedResult\r?\n"); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); return; } public void testExecuteIngestAndUpdateWithWorkingDirDynamicProperties() throws java.io.IOException { byte[] v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.util.regex.Pattern v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v; java.lang.String v, v, v, v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = new java.lang.String; specialinvoke v.(byte[])>(v); v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001nifi-standard-processors\u0001target:ModifiedResult\r?\n"); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); return; } public void testIgnoredStdin() throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v; java.nio.file.Path v; boolean v; java.io.File v, v; java.util.List v; java.lang.Object v; java.util.regex.Pattern v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "true"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = new java.lang.String; specialinvoke v.(byte[])>(v); v = staticinvoke ("target:ModifiedResult\r?\n$"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, "TestIngestAndUpdate.jar should not have received anything to modify"); return; } public void testIgnoredStdinDynamicProperties() throws java.io.IOException { byte[] v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.util.regex.Pattern v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v; java.lang.String v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "true"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = new java.lang.String; specialinvoke v.(byte[])>(v); v = staticinvoke ("target:ModifiedResult\r?\n$"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, "TestIngestAndUpdate.jar should not have received anything to modify"); return; } public void testDynamicEnvironment() throws java.lang.Exception { byte[] v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; java.lang.String[] v; org.apache.nifi.components.PropertyDescriptor v, v, v; java.util.HashSet v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; int v; java.lang.String v, v, v; java.nio.file.Path v; boolean v, v, v; java.io.File v, v; java.util.List v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestDynamicEnvironment.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); interfaceinvoke v.("NIFI_TEST_1", "testvalue1"); interfaceinvoke v.("NIFI_TEST_2", "testvalue2"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = new java.lang.String; specialinvoke v.(byte[])>(v); v = new java.util.HashSet; v = virtualinvoke v.("\r?\n"); v = staticinvoke (v); specialinvoke v.(java.util.Collection)>(v); v = interfaceinvoke v.(); if v >= 2 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v, "Should contain at least two environment variables starting with NIFI"); v = interfaceinvoke v.("NIFI_TEST_1=testvalue1"); staticinvoke (v, "NIFI_TEST_1 environment variable is missing"); v = interfaceinvoke v.("NIFI_TEST_2=testvalue2"); staticinvoke (v, "NIFI_TEST_2 environment variable is missing"); return; } public void testDynamicEnvironmentDynamicProperties() throws java.lang.Exception { byte[] v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v, v, v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; java.lang.String[] v; java.util.HashSet v; org.apache.nifi.processor.Relationship v, v, v; int v; java.lang.String v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestDynamicEnvironment.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); interfaceinvoke v.("NIFI_TEST_1", "testvalue1"); interfaceinvoke v.("NIFI_TEST_2", "testvalue2"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = new java.lang.String; specialinvoke v.(byte[])>(v); v = new java.util.HashSet; v = virtualinvoke v.("\r?\n"); v = staticinvoke (v); specialinvoke v.(java.util.Collection)>(v); v = interfaceinvoke v.(); if v >= 2 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v, "Should contain at least two environment variables starting with NIFI"); v = interfaceinvoke v.("NIFI_TEST_1=testvalue1"); staticinvoke (v, "NIFI_TEST_1 environment variable is missing"); v = interfaceinvoke v.("NIFI_TEST_2=testvalue2"); staticinvoke (v, "NIFI_TEST_2 environment variable is missing"); return; } public void testSmallEchoPutToAttribute() { byte[] v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v, v, v; boolean v, v, v, v; java.io.File v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/hello.txt"); v = virtualinvoke v.(); staticinvoke (v); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = ""; v = virtualinvoke v.(); interfaceinvoke v.(v); v = staticinvoke (); if v == 0 goto label; v = ; interfaceinvoke v.(v, "cmd.exe"); v = ; interfaceinvoke v.(v, "/c;echo Hello"); v = ; interfaceinvoke v.(v, ";"); goto label; label: v = ; interfaceinvoke v.(v, "echo"); v = ; interfaceinvoke v.(v, "Hello"); label: v = ; interfaceinvoke v.(v, "true"); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.(""); v = virtualinvoke v.("executeStreamCommand.output"); v = virtualinvoke v.("Hello"); staticinvoke (v); v = virtualinvoke v.("execution.status"); staticinvoke ("0", v); v = staticinvoke (); if v == 0 goto label; v = "cmd.exe"; goto label; label: v = "echo"; label: v = virtualinvoke v.("execution.command"); staticinvoke (v, v); return; } public void testSmallEchoPutToAttributeDynamicProperties() { byte[] v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; boolean v, v, v, v; org.apache.nifi.expression.ExpressionLanguageScope v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v; java.lang.String v, v, v, v, v, v; java.io.File v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/hello.txt"); v = virtualinvoke v.(); staticinvoke (v); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = ""; v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = staticinvoke (); if v == 0 goto label; v = ; interfaceinvoke v.(v, "cmd.exe"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "/c"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "echo Hello"); v = ; interfaceinvoke v.(v, "/c;echo Hello"); goto label; label: v = ; interfaceinvoke v.(v, "echo"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "Hello"); label: v = ; interfaceinvoke v.(v, "true"); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.(""); v = virtualinvoke v.("executeStreamCommand.output"); v = virtualinvoke v.("Hello"); staticinvoke (v); v = virtualinvoke v.("execution.status"); staticinvoke ("0", v); v = staticinvoke (); if v == 0 goto label; v = "cmd.exe"; goto label; label: v = "echo"; label: v = virtualinvoke v.("execution.command"); staticinvoke (v, v); return; } public void testArgumentsWithQuotesFromAttributeDynamicProperties() throws java.lang.Exception { byte[] v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; com.fasterxml.jackson.databind.JsonNode v, v; boolean v, v, v; org.apache.nifi.expression.ExpressionLanguageScope v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; java.util.HashMap v; java.nio.charset.Charset v; org.apache.nifi.processor.Relationship v, v, v; java.lang.String v, v, v, v, v, v, v; com.fasterxml.jackson.databind.ObjectMapper v; java.io.File v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/TestJson/json-sample.json"); v = virtualinvoke v.(); staticinvoke (v); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = staticinvoke (v, v); interfaceinvoke v.("json.attribute", v); v = ""; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = staticinvoke (); if v == 0 goto label; v = ; interfaceinvoke v.(v, "cmd.exe"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "/c"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "echo"); goto label; label: v = ; interfaceinvoke v.(v, "echo"); label: v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.3"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "${json.attribute}"); v = ; interfaceinvoke v.(v, "true"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = new java.lang.String; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = new com.fasterxml.jackson.databind.ObjectMapper; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); staticinvoke (v, v); v = virtualinvoke v.("execution.status"); staticinvoke ("0", v); v = staticinvoke (); if v == 0 goto label; v = "cmd.exe"; goto label; label: v = "echo"; label: v = virtualinvoke v.("execution.command"); staticinvoke (v, v); return; } public void testExecuteJarPutToAttribute() throws java.lang.Exception { org.apache.nifi.components.PropertyDescriptor v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v; java.util.List v; java.util.regex.Pattern v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v; int v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestSuccess.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("executeStreamCommand.output"); virtualinvoke v.(v); v = staticinvoke ("Test was a success\r?\n"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.("execution.status"); staticinvoke ("0", v); v = virtualinvoke v.("execution.command"); staticinvoke ("java", v); v = virtualinvoke v.("execution.command.args"); v = virtualinvoke v.(0, 5); staticinvoke ("-jar;", v); v = virtualinvoke v.("execution.command.args"); v = ; v = ; v = ; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("src\u0001test\u0001resources\u0001ExecuteCommand\u0001TestSuccess.jar"); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(v); staticinvoke (v, v); return; } public void testExecuteJarPutToAttributeDynamicProperties() throws java.lang.Exception { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.util.regex.Pattern v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v; int v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestSuccess.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("executeStreamCommand.output"); virtualinvoke v.(v); v = staticinvoke ("Test was a success\r?\n"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.("execution.status"); staticinvoke ("0", v); v = virtualinvoke v.("execution.command"); staticinvoke ("java", v); v = virtualinvoke v.("execution.command.args"); v = virtualinvoke v.(0, 4); staticinvoke ("-jar", v); v = virtualinvoke v.("execution.command.args"); v = ; v = ; v = ; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("src\u0001test\u0001resources\u0001ExecuteCommand\u0001TestSuccess.jar"); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(v); staticinvoke (v, v); return; } public void testExecuteJarToAttributeConfiguration() throws java.lang.Exception { byte[] v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; boolean v; java.util.Set v; java.util.List v; java.util.regex.Pattern v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v, v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.ProcessContext v; java.io.File v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestSuccess.jar"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = "small test"; v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "10"); v = ; interfaceinvoke v.(v, "outputDest"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "small test"; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.("outputDest"); v = staticinvoke ("Test was a"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.("execution.status"); staticinvoke ("0", v); v = virtualinvoke v.("execution.command"); staticinvoke ("java", v); v = virtualinvoke v.("execution.command.args"); v = virtualinvoke v.(0, 5); staticinvoke ("-jar;", v); v = virtualinvoke v.("execution.command.args"); v = ; v = ; v = ; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("src\u0001test\u0001resources\u0001ExecuteCommand\u0001TestSuccess.jar"); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(v); staticinvoke (v, v); return; } public void testExecuteJarToAttributeConfigurationDyanmicProperties() throws java.lang.Exception { byte[] v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; boolean v; java.util.Set v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.util.regex.Pattern v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v, v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.ProcessContext v; java.io.File v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestSuccess.jar"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = "small test"; v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "10"); v = ; interfaceinvoke v.(v, "outputDest"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); staticinvoke (1, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = "small test"; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.("outputDest"); v = staticinvoke ("Test was a"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.("execution.status"); staticinvoke ("0", v); v = virtualinvoke v.("execution.command"); staticinvoke ("java", v); v = virtualinvoke v.("execution.command.args"); v = virtualinvoke v.(0, 4); staticinvoke ("-jar", v); v = virtualinvoke v.("execution.command.args"); v = ; v = ; v = ; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("src\u0001test\u0001resources\u0001ExecuteCommand\u0001TestSuccess.jar"); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(v); staticinvoke (v, v); return; } public void testExecuteIngestAndUpdatePutToAttribute() throws java.io.IOException { java.lang.Throwable v; byte[] v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.components.PropertyDescriptor v, v, v; java.util.regex.Matcher v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; int v; java.lang.String v, v, v; java.nio.file.Path v, v; boolean v; java.io.FileOutputStream v; java.io.File v, v, v; java.util.List v; java.lang.Object v; java.util.regex.Pattern v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/10MB.txt"); v = virtualinvoke v.(); v = staticinvoke (v); v = new java.io.FileOutputStream; specialinvoke v.(java.io.File)>(v); label: v = 0; label: if v >= 10000 goto label; virtualinvoke v.(v, 0, 1000); v = v + 1; goto label; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "outputDest"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("outputDest"); v = staticinvoke ("nifi-standard-processors:ModifiedResult\r?\n"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); return; catch java.lang.Throwable from label to label with label; } public void testExecuteIngestAndUpdatePutToAttributeDynamicProperties() throws java.io.IOException { byte[] v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v, v; boolean v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.util.regex.Pattern v; java.lang.Throwable v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v; int v; java.lang.String v, v, v; java.io.FileOutputStream v; java.io.File v, v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/10MB.txt"); v = virtualinvoke v.(); v = staticinvoke (v); v = new java.io.FileOutputStream; specialinvoke v.(java.io.File)>(v); label: v = 0; label: if v >= 10000 goto label; virtualinvoke v.(v, 0, 1000); v = v + 1; goto label; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "outputDest"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("outputDest"); v = staticinvoke ("nifi-standard-processors:ModifiedResult\r?\n"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); return; catch java.lang.Throwable from label to label with label; } public void testLargePutToAttribute() throws java.io.IOException { byte[] v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v, v; java.util.List v; java.util.regex.Pattern v; java.lang.Throwable v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v; int v; java.lang.String v, v, v, v, v; java.io.FileOutputStream v; java.io.File v, v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/10MB.txt"); v = virtualinvoke v.(); v = staticinvoke (v); v = new java.io.FileOutputStream; specialinvoke v.(java.io.File)>(v); label: v = 0; label: if v >= 10000 goto label; virtualinvoke v.(v, 0, 1000); v = v + 1; goto label; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = ""; v = virtualinvoke v.(); interfaceinvoke v.(v); v = staticinvoke (); if v == 0 goto label; v = ; interfaceinvoke v.(v, "cmd.exe"); v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("/c;type \u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, ";"); goto label; label: v = ; interfaceinvoke v.(v, "cat"); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: v = ; interfaceinvoke v.(v, "true"); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); v = ; interfaceinvoke v.(v, "256"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("execution.status", "0"); v = interfaceinvoke v.(0); v = virtualinvoke v.("executeStreamCommand.output"); v = staticinvoke ("a{256}"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); return; catch java.lang.Throwable from label to label with label; } public void testLargePutToAttributeDynamicProperties() throws java.io.IOException { byte[] v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v, v; org.apache.nifi.expression.ExpressionLanguageScope v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.util.regex.Pattern v; java.lang.Throwable v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v; int v; java.lang.String v, v, v, v, v, v; java.io.FileOutputStream v; java.io.File v, v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/10MB.txt"); v = virtualinvoke v.(); v = staticinvoke (v); v = new java.io.FileOutputStream; specialinvoke v.(java.io.File)>(v); label: v = 0; label: if v >= 10000 goto label; virtualinvoke v.(v, 0, 1000); v = v + 1; goto label; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = ""; v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = staticinvoke (); if v == 0 goto label; v = ; interfaceinvoke v.(v, "cmd.exe"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "/c"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("type \u0001"); interfaceinvoke v.(v, v); goto label; label: v = ; interfaceinvoke v.(v, "cat"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: v = ; interfaceinvoke v.(v, "true"); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); v = ; interfaceinvoke v.(v, "256"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("execution.status", "0"); v = interfaceinvoke v.(0); v = virtualinvoke v.("executeStreamCommand.output"); v = staticinvoke ("a{256}"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); return; catch java.lang.Throwable from label to label with label; } public void testExecuteIngestAndUpdateWithWorkingDirPutToAttribute() throws java.io.IOException { org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v, v, v, v; java.nio.file.Path v; boolean v; java.io.File v, v; java.util.List v; java.lang.Object v; java.util.regex.Pattern v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; interfaceinvoke v.(v, "streamOutput"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("streamOutput"); v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001nifi-standard-processors\u0001target:ModifiedResult\r?\n"); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); return; } public void testExecuteIngestAndUpdateWithWorkingDirPutToAttributeDynamicProperties() throws java.io.IOException { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.util.regex.Pattern v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v; java.lang.String v, v, v, v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; interfaceinvoke v.(v, "streamOutput"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("streamOutput"); v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001nifi-standard-processors\u0001target:ModifiedResult\r?\n"); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); return; } public void testIgnoredStdinPutToAttribute() throws java.io.IOException { org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; java.lang.String v, v, v; java.nio.file.Path v; boolean v; java.io.File v, v; java.util.List v; java.lang.Object v; java.util.regex.Pattern v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "true"); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("executeStreamCommand.output"); v = staticinvoke ("target:ModifiedResult\r?\n?"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, "TestIngestAndUpdate.jar should not have received anything to modify"); return; } public void testIgnoredStdinPutToAttributeDynamicProperties() throws java.io.IOException { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; java.util.regex.Matcher v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.util.regex.Pattern v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v; java.lang.String v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestIngestAndUpdate.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "true"); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("executeStreamCommand.output"); v = staticinvoke ("target:ModifiedResult\r?\n?"); v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, "TestIngestAndUpdate.jar should not have received anything to modify"); return; } public void testDynamicEnvironmentPutToAttribute() throws java.lang.Exception { org.apache.nifi.processors.standard.TestExecuteStreamCommand v; java.lang.String[] v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; java.util.HashSet v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; int v; java.lang.String v, v, v; java.nio.file.Path v; boolean v, v, v; java.io.File v, v; java.util.List v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestDynamicEnvironment.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); interfaceinvoke v.("NIFI_TEST_1", "testvalue1"); interfaceinvoke v.("NIFI_TEST_2", "testvalue2"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("executeStreamCommand.output"); v = new java.util.HashSet; v = virtualinvoke v.("\r?\n"); v = staticinvoke (v); specialinvoke v.(java.util.Collection)>(v); v = interfaceinvoke v.(); if v >= 2 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v, "Should contain at least two environment variables starting with NIFI"); v = interfaceinvoke v.("NIFI_TEST_1=testvalue1"); staticinvoke (v, "NIFI_TEST_1 environment variable is missing"); v = interfaceinvoke v.("NIFI_TEST_2=testvalue2"); staticinvoke (v, "NIFI_TEST_2 environment variable is missing"); return; } public void testDynamicEnvironmentPutToAttributeDynamicProperties() throws java.lang.Exception { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v, v, v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; java.lang.String[] v; java.util.HashSet v; org.apache.nifi.processor.Relationship v, v; int v; java.lang.String v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/TestDynamicEnvironment.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); interfaceinvoke v.("NIFI_TEST_1", "testvalue1"); interfaceinvoke v.("NIFI_TEST_2", "testvalue2"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "target"); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("executeStreamCommand.output"); v = new java.util.HashSet; v = virtualinvoke v.("\r?\n"); v = staticinvoke (v); specialinvoke v.(java.util.Collection)>(v); v = interfaceinvoke v.(); if v >= 2 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v, "Should contain at least two environment variables starting with NIFI"); v = interfaceinvoke v.("NIFI_TEST_1=testvalue1"); staticinvoke (v, "NIFI_TEST_1 environment variable is missing"); v = interfaceinvoke v.("NIFI_TEST_2=testvalue2"); staticinvoke (v, "NIFI_TEST_2 environment variable is missing"); return; } public void testQuotedArguments() throws java.lang.Exception { java.util.List v, v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; int v, v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = staticinvoke ("echo -n \"arg arg arg3\"", 32); v = interfaceinvoke v.(); staticinvoke (3, v); v = staticinvoke ("echo;-n;\"arg arg arg3\"", 59); v = interfaceinvoke v.(); staticinvoke (3, v); return; } public void testInvalidDelimiter() throws java.lang.Exception { org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.util.TestRunner v; org.apache.nifi.components.PropertyDescriptor v, v, v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = ; interfaceinvoke v.(v, "echo"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, "foo"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, "f"); interfaceinvoke v.(); return; } public void testExecuteJarPutToAttributeBadPath() throws java.lang.Exception { org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v; java.util.List v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v, v; int v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/noSuchFile.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("-jar;\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("executeStreamCommand.output"); virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.("execution.status"); staticinvoke ("1", v); v = virtualinvoke v.("execution.command"); staticinvoke ("java", v); v = virtualinvoke v.("execution.command.args"); v = virtualinvoke v.(0, 5); staticinvoke ("-jar;", v); v = virtualinvoke v.("execution.command.args"); v = ; v = ; v = ; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("src\u0001test\u0001resources\u0001ExecuteCommand\u0001noSuchFile.jar"); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(v); staticinvoke (v, v); return; } public void testExecuteJarPutToAttributeBadPathDynamicProperties() throws java.lang.Exception { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; java.nio.file.Path v; boolean v; org.apache.nifi.expression.ExpressionLanguageScope v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; org.apache.nifi.processors.standard.TestExecuteStreamCommand v; org.apache.nifi.processor.Relationship v, v, v, v; int v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestExecuteStreamCommand; v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/noSuchFile.jar"); v = new java.io.File; specialinvoke v.(java.lang.String)>("src/test/resources/ExecuteCommand/1000bytes.txt"); v = virtualinvoke v.(); virtualinvoke v.(1); v = staticinvoke (class "Lorg/apache/nifi/processors/standard/ExecuteStreamCommand;"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.(v, "java"); v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.1"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, "-jar"); v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(1); v = virtualinvoke v.("command.argument.2"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "executeStreamCommand.output"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); v = virtualinvoke v.("executeStreamCommand.output"); virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.("execution.status"); staticinvoke ("1", v); v = virtualinvoke v.("execution.command"); staticinvoke ("java", v); v = virtualinvoke v.("execution.command.args"); v = virtualinvoke v.(0, 4); staticinvoke ("-jar", v); v = virtualinvoke v.("execution.command.args"); v = ; v = ; v = ; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("src\u0001test\u0001resources\u0001ExecuteCommand\u0001noSuchFile.jar"); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(v); staticinvoke (v, v); return; } private static boolean isWindows() { java.lang.String v, v; boolean v; v = staticinvoke ("os.name"); v = virtualinvoke v.(); v = virtualinvoke v.("windows"); return v; } }