public class org.apache.nifi.processors.standard.TestGetSFTP extends java.lang.Object
{
private org.apache.nifi.util.TestRunner getSFTPRunner;
private static org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer;
public void <init>()
{
org.apache.nifi.processors.standard.TestGetSFTP v;
v := @this: org.apache.nifi.processors.standard.TestGetSFTP;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static void setupSSHD() throws java.io.IOException
{
org.apache.nifi.processors.standard.util.SSHTestServer v, v;
v = new org.apache.nifi.processors.standard.util.SSHTestServer;
specialinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: void <init>()>();
<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer> = v;
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: void startServer()>();
return;
}
public static void cleanupSSHD() throws java.io.IOException
{
org.apache.nifi.processors.standard.util.SSHTestServer v;
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: void stopServer()>();
return;
}
public void setup()
{
org.apache.nifi.processors.standard.TestGetSFTP v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
int v;
java.lang.String v, v, v;
org.apache.nifi.processors.standard.util.SSHTestServer v, v, v;
v := @this: org.apache.nifi.processors.standard.TestGetSFTP;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/GetSFTP;");
v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner> = v;
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor HOSTNAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "localhost");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PORT>;
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: int getSSHPort()>();
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor USERNAME>;
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getUsername()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PASSWORD>;
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getPassword()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor STRICT_HOST_KEY_CHECKING>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor DATA_TIMEOUT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "30 sec");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_PATH>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "/");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor FILE_FILTER_REGEX>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: boolean removeProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PATH_FILTER_REGEX>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor POLLING_INTERVAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "60 sec");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor RECURSIVE_SEARCH>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor IGNORE_DOTTED_FILES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor DELETE_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor MAX_SELECTS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "100");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_POLL_BATCH_SIZE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "5000");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void setValidateExpressionUsage(boolean)>(0);
return;
}
public void testGetSFTPFileBasicRead() throws java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.processors.standard.TestGetSFTP v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
java.nio.file.Path v, v;
org.apache.nifi.processors.standard.util.SSHTestServer v, v, v, v, v;
boolean v;
java.io.File v;
v := @this: org.apache.nifi.processors.standard.TestGetSFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void emptyTestDirectory()>();
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001testFile.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void touchFile(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001testFile.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void touchFile(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001testFile.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void touchFile(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001testFile.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void touchFile(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.GetSFTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 4);
v = 1;
label:
if v >= 5 goto label;
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/testFile\u.txt");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path toAbsolutePath()>();
v = interfaceinvoke v.<java.nio.file.Path: java.io.File toFile()>();
v = virtualinvoke v.<java.io.File: boolean exists()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean,java.lang.String)>(v, "File not deleted.");
v = v + 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
return;
}
public void testGetSFTPShouldNotThrowIOExceptionIfUserHomeDirNotExixts() throws java.io.IOException
{
java.lang.Throwable v;
java.lang.String[] v;
org.apache.nifi.processors.standard.TestGetSFTP v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v;
int v;
java.lang.String v, v, v, v, v, v, v;
java.nio.file.Path v, v;
org.apache.nifi.processors.standard.util.SSHTestServer v, v, v;
boolean v;
java.io.File v;
v := @this: org.apache.nifi.processors.standard.TestGetSFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void emptyTestDirectory()>();
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("user.home");
label:
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("user.home", "/not_existdir");
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001testFile.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void touchFile(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001testFile.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void touchFile(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.GetSFTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = 1;
label:
if v >= 3 goto label;
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/testFile\u.txt");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path toAbsolutePath()>();
v = interfaceinvoke v.<java.nio.file.Path: java.io.File toFile()>();
v = virtualinvoke v.<java.io.File: boolean exists()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean,java.lang.String)>(v, "File not deleted.");
v = v + 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
label:
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("user.home", v);
goto label;
label:
v := @caughtexception;
staticinvoke <java.lang.System: java.lang.String setProperty(java.lang.String,java.lang.String)>("user.home", v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testGetSFTPIgnoreDottedFiles() throws java.io.IOException
{
org.apache.nifi.processors.standard.TestGetSFTP v;
org.apache.nifi.util.TestRunner v, v, v;
java.nio.file.Path v, v, v, v, v, v, v, v;
boolean v, v, v, v;
java.lang.String[] v, v, v, v;
org.apache.nifi.processor.Relationship v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.util.SSHTestServer v, v, v, v, v, v, v, v;
java.io.File v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestGetSFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void emptyTestDirectory()>();
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001testFile.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void touchFile(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u.testFile.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void touchFile(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001testFile.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void touchFile(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u.testFile.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestGetSFTP: void touchFile(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
v = <org.apache.nifi.processors.standard.GetSFTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/testFile.txt");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path toAbsolutePath()>();
v = interfaceinvoke v.<java.nio.file.Path: java.io.File toFile()>();
v = virtualinvoke v.<java.io.File: boolean exists()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean,java.lang.String)>(v, "File not deleted.");
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/testFile.txt");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path toAbsolutePath()>();
v = interfaceinvoke v.<java.nio.file.Path: java.io.File toFile()>();
v = virtualinvoke v.<java.io.File: boolean exists()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean,java.lang.String)>(v, "File not deleted.");
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/.testFile.txt");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path toAbsolutePath()>();
v = interfaceinvoke v.<java.nio.file.Path: java.io.File toFile()>();
v = virtualinvoke v.<java.io.File: boolean exists()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "File deleted.");
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/.testFile.txt");
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path toAbsolutePath()>();
v = interfaceinvoke v.<java.nio.file.Path: java.io.File toFile()>();
v = virtualinvoke v.<java.io.File: boolean exists()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "File deleted.");
v = v.<org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.util.TestRunner getSFTPRunner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
return;
}
private void touchFile(java.lang.String) throws java.io.IOException
{
java.lang.String v;
org.apache.nifi.processors.standard.TestGetSFTP v;
java.io.File v;
v := @this: org.apache.nifi.processors.standard.TestGetSFTP;
v := @parameter: java.lang.String;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
staticinvoke <org.apache.commons.io.FileUtils: void writeStringToFile(java.io.File,java.lang.String,java.lang.String)>(v, "", "UTF-8");
return;
}
private void emptyTestDirectory() throws java.io.IOException
{
java.lang.String[] v;
java.lang.String v;
org.apache.nifi.processors.standard.TestGetSFTP v;
java.nio.file.Path v;
org.apache.nifi.processors.standard.util.SSHTestServer v;
java.io.File v;
v := @this: org.apache.nifi.processors.standard.TestGetSFTP;
v = <org.apache.nifi.processors.standard.TestGetSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: java.lang.String getVirtualFileSystemPath()>();
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = interfaceinvoke v.<java.nio.file.Path: java.io.File toFile()>();
staticinvoke <org.apache.commons.io.FileUtils: void cleanDirectory(java.io.File)>(v);
return;
}
}