public class org.apache.nifi.processors.standard.util.TestSFTPTransfer extends java.lang.Object
{
public void <init>()
{
org.apache.nifi.processors.standard.util.TestSFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestSFTPTransfer;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
private org.apache.nifi.processors.standard.util.SFTPTransfer createSftpTransfer(org.apache.nifi.processor.ProcessContext, net.schmizz.sshj.sftp.SFTPClient)
{
org.apache.nifi.processors.standard.util.TestSFTPTransfer$1 v;
org.apache.nifi.processor.ProcessContext v;
net.schmizz.sshj.sftp.SFTPClient v;
java.lang.Object v;
org.apache.nifi.processors.standard.util.TestSFTPTransfer v;
v := @this: org.apache.nifi.processors.standard.util.TestSFTPTransfer;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: net.schmizz.sshj.sftp.SFTPClient;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/logging/ComponentLog;");
v = new org.apache.nifi.processors.standard.util.TestSFTPTransfer$1;
specialinvoke v.<org.apache.nifi.processors.standard.util.TestSFTPTransfer$1: void <init>(org.apache.nifi.processors.standard.util.TestSFTPTransfer,org.apache.nifi.context.PropertyContext,org.apache.nifi.logging.ComponentLog,net.schmizz.sshj.sftp.SFTPClient)>(v, v, v, v);
return v;
}
public void testEnsureDirectoryExistsAlreadyExisted() throws java.io.IOException
{
java.io.File v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v, v, v, v;
org.apache.nifi.processors.standard.util.TestSFTPTransfer v;
org.apache.nifi.util.MockFlowFile v;
v := @this: org.apache.nifi.processors.standard.util.TestSFTPTransfer;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/processor/ProcessContext;");
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lnet/schmizz/sshj/sftp/SFTPClient;");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSftpTransfer(org.apache.nifi.processor.ProcessContext,net.schmizz.sshj.sftp.SFTPClient)>(v, v);
v = new org.apache.nifi.util.MockFlowFile;
specialinvoke v.<org.apache.nifi.util.MockFlowFile: void <init>(long)>(0L);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("/dir1/dir2/dir3");
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile,java.io.File)>(v, v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
return;
}
public void testEnsureDirectoryExistsFailedToStat() throws java.io.IOException
{
java.lang.Throwable v;
java.lang.Object[] v;
net.schmizz.sshj.sftp.FileAttributes v;
java.lang.String v;
org.apache.nifi.processors.standard.util.TestSFTPTransfer v;
org.mockito.stubbing.OngoingStubbing v;
java.io.File v;
net.schmizz.sshj.sftp.Response$StatusCode v;
net.schmizz.sshj.sftp.SFTPException v;
org.junit.jupiter.api.function.Executable v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v, v, v, v;
org.apache.nifi.util.MockFlowFile v;
v := @this: org.apache.nifi.processors.standard.util.TestSFTPTransfer;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/processor/ProcessContext;");
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lnet/schmizz/sshj/sftp/SFTPClient;");
v = virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>("/dir1/dir2/dir3");
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = newarray (java.lang.Throwable)[1];
v = new net.schmizz.sshj.sftp.SFTPException;
v = <net.schmizz.sshj.sftp.Response$StatusCode: net.schmizz.sshj.sftp.Response$StatusCode FAILURE>;
specialinvoke v.<net.schmizz.sshj.sftp.SFTPException: void <init>(net.schmizz.sshj.sftp.Response$StatusCode,java.lang.String)>(v, "Failure");
v[0] = v;
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenThrow(java.lang.Throwable[])>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSftpTransfer(org.apache.nifi.processor.ProcessContext,net.schmizz.sshj.sftp.SFTPClient)>(v, v);
v = new org.apache.nifi.util.MockFlowFile;
specialinvoke v.<org.apache.nifi.util.MockFlowFile: void <init>(long)>(0L);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("/dir1/dir2/dir3");
v = staticinvoke <org.apache.nifi.processors.standard.util.TestSFTPTransfer$lambda_testEnsureDirectoryExistsFailedToStat_0__277: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer,org.apache.nifi.util.MockFlowFile,java.io.File)>(v, v, v);
v = staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/IOException;", v);
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Failed to determine if remote directory exists at /dir1/dir2/dir due to 4: Failure", v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
return;
}
public void testEnsureDirectoryExistsNotExisted() throws java.io.IOException
{
java.lang.Object[] v;
net.schmizz.sshj.sftp.FileAttributes v;
org.apache.nifi.processors.standard.util.TestSFTPTransfer v;
org.mockito.stubbing.OngoingStubbing v;
java.io.File v;
net.schmizz.sshj.sftp.Response$StatusCode v;
net.schmizz.sshj.sftp.SFTPException v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v, v, v, v, v, v, v, v;
org.apache.nifi.util.MockFlowFile v;
v := @this: org.apache.nifi.processors.standard.util.TestSFTPTransfer;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/processor/ProcessContext;");
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lnet/schmizz/sshj/sftp/SFTPClient;");
v = virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>("/dir1/dir2/dir3");
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = newarray (java.lang.Throwable)[1];
v = new net.schmizz.sshj.sftp.SFTPException;
v = <net.schmizz.sshj.sftp.Response$StatusCode: net.schmizz.sshj.sftp.Response$StatusCode NO_SUCH_FILE>;
specialinvoke v.<net.schmizz.sshj.sftp.SFTPException: void <init>(net.schmizz.sshj.sftp.Response$StatusCode,java.lang.String)>(v, "No such file");
v[0] = v;
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenThrow(java.lang.Throwable[])>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSftpTransfer(org.apache.nifi.processor.ProcessContext,net.schmizz.sshj.sftp.SFTPClient)>(v, v);
v = new org.apache.nifi.util.MockFlowFile;
specialinvoke v.<org.apache.nifi.util.MockFlowFile: void <init>(long)>(0L);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("/dir1/dir2/dir3");
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile,java.io.File)>(v, v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
return;
}
public void testEnsureDirectoryExistsParentNotExisted() throws java.io.IOException
{
java.lang.Object[] v, v;
net.schmizz.sshj.sftp.FileAttributes v, v;
org.apache.nifi.processors.standard.util.TestSFTPTransfer v;
org.mockito.stubbing.OngoingStubbing v, v;
java.io.File v;
net.schmizz.sshj.sftp.Response$StatusCode v, v;
net.schmizz.sshj.sftp.SFTPException v, v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.util.MockFlowFile v;
v := @this: org.apache.nifi.processors.standard.util.TestSFTPTransfer;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/processor/ProcessContext;");
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lnet/schmizz/sshj/sftp/SFTPClient;");
v = virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>("/dir1/dir2/dir3");
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = newarray (java.lang.Throwable)[1];
v = new net.schmizz.sshj.sftp.SFTPException;
v = <net.schmizz.sshj.sftp.Response$StatusCode: net.schmizz.sshj.sftp.Response$StatusCode NO_SUCH_FILE>;
specialinvoke v.<net.schmizz.sshj.sftp.SFTPException: void <init>(net.schmizz.sshj.sftp.Response$StatusCode,java.lang.String)>(v, "No such file");
v[0] = v;
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenThrow(java.lang.Throwable[])>(v);
v = virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>("/dir1/dir2");
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = newarray (java.lang.Throwable)[1];
v = new net.schmizz.sshj.sftp.SFTPException;
v = <net.schmizz.sshj.sftp.Response$StatusCode: net.schmizz.sshj.sftp.Response$StatusCode NO_SUCH_FILE>;
specialinvoke v.<net.schmizz.sshj.sftp.SFTPException: void <init>(net.schmizz.sshj.sftp.Response$StatusCode,java.lang.String)>(v, "No such file");
v[0] = v;
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenThrow(java.lang.Throwable[])>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSftpTransfer(org.apache.nifi.processor.ProcessContext,net.schmizz.sshj.sftp.SFTPClient)>(v, v);
v = new org.apache.nifi.util.MockFlowFile;
specialinvoke v.<org.apache.nifi.util.MockFlowFile: void <init>(long)>(0L);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("/dir1/dir2/dir3");
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile,java.io.File)>(v, v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
return;
}
public void testEnsureDirectoryExistsNotExistedFailedToCreate() throws java.io.IOException
{
java.lang.Throwable v;
java.lang.Object[] v, v;
net.schmizz.sshj.sftp.FileAttributes v;
org.mockito.stubbing.Stubber v;
java.lang.String v;
org.apache.nifi.processors.standard.util.TestSFTPTransfer v;
org.mockito.stubbing.OngoingStubbing v;
java.io.File v;
net.schmizz.sshj.sftp.Response$StatusCode v, v;
net.schmizz.sshj.sftp.SFTPException v, v;
org.junit.jupiter.api.function.Executable v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.util.MockFlowFile v;
v := @this: org.apache.nifi.processors.standard.util.TestSFTPTransfer;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/processor/ProcessContext;");
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lnet/schmizz/sshj/sftp/SFTPClient;");
v = virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>("/dir1/dir2/dir3");
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = newarray (java.lang.Throwable)[1];
v = new net.schmizz.sshj.sftp.SFTPException;
v = <net.schmizz.sshj.sftp.Response$StatusCode: net.schmizz.sshj.sftp.Response$StatusCode NO_SUCH_FILE>;
specialinvoke v.<net.schmizz.sshj.sftp.SFTPException: void <init>(net.schmizz.sshj.sftp.Response$StatusCode,java.lang.String)>(v, "No such file");
v[0] = v;
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenThrow(java.lang.Throwable[])>(v);
v = newarray (java.lang.Throwable)[1];
v = new net.schmizz.sshj.sftp.SFTPException;
v = <net.schmizz.sshj.sftp.Response$StatusCode: net.schmizz.sshj.sftp.Response$StatusCode FAILURE>;
specialinvoke v.<net.schmizz.sshj.sftp.SFTPException: void <init>(net.schmizz.sshj.sftp.Response$StatusCode,java.lang.String)>(v, "Failed");
v[0] = v;
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.Stubber doThrow(java.lang.Throwable[])>(v);
v = interfaceinvoke v.<org.mockito.stubbing.Stubber: java.lang.Object when(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSftpTransfer(org.apache.nifi.processor.ProcessContext,net.schmizz.sshj.sftp.SFTPClient)>(v, v);
v = new org.apache.nifi.util.MockFlowFile;
specialinvoke v.<org.apache.nifi.util.MockFlowFile: void <init>(long)>(0L);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("/dir1/dir2/dir3");
v = staticinvoke <org.apache.nifi.processors.standard.util.TestSFTPTransfer$lambda_testEnsureDirectoryExistsNotExistedFailedToCreate_1__278: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer,org.apache.nifi.util.MockFlowFile,java.io.File)>(v, v, v);
v = staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/IOException;", v);
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Failed to create remote directory /dir1/dir2/dir due to 4: Failed", v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
return;
}
public void testEnsureDirectoryExistsBlindlyNotExisted() throws java.io.IOException
{
org.apache.nifi.util.MockPropertyValue v;
org.mockito.stubbing.OngoingStubbing v;
java.io.File v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyValue v;
org.mockito.verification.VerificationMode v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v, v, v, v, v, v;
org.apache.nifi.processors.standard.util.TestSFTPTransfer v;
org.apache.nifi.util.MockFlowFile v;
v := @this: org.apache.nifi.processors.standard.util.TestSFTPTransfer;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/processor/ProcessContext;");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor DISABLE_DIRECTORY_LISTING>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = new org.apache.nifi.util.MockPropertyValue;
specialinvoke v.<org.apache.nifi.util.MockPropertyValue: void <init>(java.lang.String)>("true");
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenReturn(java.lang.Object)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lnet/schmizz/sshj/sftp/SFTPClient;");
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSftpTransfer(org.apache.nifi.processor.ProcessContext,net.schmizz.sshj.sftp.SFTPClient)>(v, v);
v = new org.apache.nifi.util.MockFlowFile;
specialinvoke v.<org.apache.nifi.util.MockFlowFile: void <init>(long)>(0L);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("/dir1/dir2/dir3");
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile,java.io.File)>(v, v);
v = staticinvoke <org.mockito.Mockito: org.mockito.verification.VerificationMode times(int)>(0);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object,org.mockito.verification.VerificationMode)>(v, v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
return;
}
public void testEnsureDirectoryExistsBlindlyParentNotExisted() throws java.io.IOException
{
org.apache.nifi.util.MockPropertyValue v;
org.apache.nifi.components.PropertyDescriptor v;
org.mockito.stubbing.Stubber v;
org.apache.nifi.components.PropertyValue v;
org.mockito.stubbing.Answer v;
java.util.concurrent.atomic.AtomicInteger v;
org.apache.nifi.processors.standard.util.TestSFTPTransfer v;
org.mockito.stubbing.OngoingStubbing v;
java.io.File v;
org.mockito.verification.VerificationMode v, v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.util.MockFlowFile v;
v := @this: org.apache.nifi.processors.standard.util.TestSFTPTransfer;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/processor/ProcessContext;");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor DISABLE_DIRECTORY_LISTING>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = new org.apache.nifi.util.MockPropertyValue;
specialinvoke v.<org.apache.nifi.util.MockPropertyValue: void <init>(java.lang.String)>("true");
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenReturn(java.lang.Object)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lnet/schmizz/sshj/sftp/SFTPClient;");
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(0);
v = staticinvoke <org.apache.nifi.processors.standard.util.TestSFTPTransfer$lambda_testEnsureDirectoryExistsBlindlyParentNotExisted_2__279: org.mockito.stubbing.Answer bootstrap$(java.util.concurrent.atomic.AtomicInteger)>(v);
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.Stubber doAnswer(org.mockito.stubbing.Answer)>(v);
v = interfaceinvoke v.<org.mockito.stubbing.Stubber: java.lang.Object when(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSftpTransfer(org.apache.nifi.processor.ProcessContext,net.schmizz.sshj.sftp.SFTPClient)>(v, v);
v = new org.apache.nifi.util.MockFlowFile;
specialinvoke v.<org.apache.nifi.util.MockFlowFile: void <init>(long)>(0L);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("/dir1/dir2/dir3");
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile,java.io.File)>(v, v);
v = staticinvoke <org.mockito.Mockito: org.mockito.verification.VerificationMode times(int)>(0);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object,org.mockito.verification.VerificationMode)>(v, v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: org.mockito.verification.VerificationMode times(int)>(2);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object,org.mockito.verification.VerificationMode)>(v, v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
return;
}
public void testEnsureDirectoryExistsBlindlyAlreadyExisted() throws java.io.IOException
{
java.lang.Object[] v;
org.apache.nifi.util.MockPropertyValue v;
org.apache.nifi.components.PropertyDescriptor v;
org.mockito.stubbing.Stubber v;
org.apache.nifi.components.PropertyValue v;
org.apache.nifi.processors.standard.util.TestSFTPTransfer v;
org.mockito.stubbing.OngoingStubbing v;
java.io.File v;
org.mockito.verification.VerificationMode v;
net.schmizz.sshj.sftp.Response$StatusCode v;
net.schmizz.sshj.sftp.SFTPException v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v, v, v, v, v, v, v, v;
org.apache.nifi.util.MockFlowFile v;
v := @this: org.apache.nifi.processors.standard.util.TestSFTPTransfer;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/processor/ProcessContext;");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor DISABLE_DIRECTORY_LISTING>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = new org.apache.nifi.util.MockPropertyValue;
specialinvoke v.<org.apache.nifi.util.MockPropertyValue: void <init>(java.lang.String)>("true");
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenReturn(java.lang.Object)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lnet/schmizz/sshj/sftp/SFTPClient;");
v = newarray (java.lang.Throwable)[1];
v = new net.schmizz.sshj.sftp.SFTPException;
v = <net.schmizz.sshj.sftp.Response$StatusCode: net.schmizz.sshj.sftp.Response$StatusCode FAILURE>;
specialinvoke v.<net.schmizz.sshj.sftp.SFTPException: void <init>(net.schmizz.sshj.sftp.Response$StatusCode,java.lang.String)>(v, "Failure");
v[0] = v;
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.Stubber doThrow(java.lang.Throwable[])>(v);
v = interfaceinvoke v.<org.mockito.stubbing.Stubber: java.lang.Object when(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSftpTransfer(org.apache.nifi.processor.ProcessContext,net.schmizz.sshj.sftp.SFTPClient)>(v, v);
v = new org.apache.nifi.util.MockFlowFile;
specialinvoke v.<org.apache.nifi.util.MockFlowFile: void <init>(long)>(0L);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("/dir1/dir2/dir3");
virtualinvoke v.<org.apache.nifi.processors.standard.util.SFTPTransfer: void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile,java.io.File)>(v, v);
v = staticinvoke <org.mockito.Mockito: org.mockito.verification.VerificationMode times(int)>(0);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object,org.mockito.verification.VerificationMode)>(v, v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
return;
}
public void testEnsureDirectoryExistsBlindlyFailed() throws java.io.IOException
{
java.lang.Throwable v;
java.lang.Object[] v;
org.apache.nifi.util.MockPropertyValue v;
org.apache.nifi.components.PropertyDescriptor v;
org.mockito.stubbing.Stubber v;
org.apache.nifi.components.PropertyValue v;
java.lang.String v;
org.apache.nifi.processors.standard.util.TestSFTPTransfer v;
org.mockito.stubbing.OngoingStubbing v;
java.io.File v;
org.mockito.verification.VerificationMode v;
net.schmizz.sshj.sftp.Response$StatusCode v;
net.schmizz.sshj.sftp.SFTPException v;
org.junit.jupiter.api.function.Executable v;
org.apache.nifi.processors.standard.util.SFTPTransfer v;
java.lang.Object v, v, v, v, v, v, v, v;
org.apache.nifi.util.MockFlowFile v;
v := @this: org.apache.nifi.processors.standard.util.TestSFTPTransfer;
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lorg/apache/nifi/processor/ProcessContext;");
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor DISABLE_DIRECTORY_LISTING>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.OngoingStubbing when(java.lang.Object)>(v);
v = new org.apache.nifi.util.MockPropertyValue;
specialinvoke v.<org.apache.nifi.util.MockPropertyValue: void <init>(java.lang.String)>("true");
interfaceinvoke v.<org.mockito.stubbing.OngoingStubbing: org.mockito.stubbing.OngoingStubbing thenReturn(java.lang.Object)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object mock(java.lang.Class)>(class "Lnet/schmizz/sshj/sftp/SFTPClient;");
v = newarray (java.lang.Throwable)[1];
v = new net.schmizz.sshj.sftp.SFTPException;
v = <net.schmizz.sshj.sftp.Response$StatusCode: net.schmizz.sshj.sftp.Response$StatusCode PERMISSION_DENIED>;
specialinvoke v.<net.schmizz.sshj.sftp.SFTPException: void <init>(net.schmizz.sshj.sftp.Response$StatusCode,java.lang.String)>(v, "Permission denied");
v[0] = v;
v = staticinvoke <org.mockito.Mockito: org.mockito.stubbing.Stubber doThrow(java.lang.Throwable[])>(v);
v = interfaceinvoke v.<org.mockito.stubbing.Stubber: java.lang.Object when(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.util.TestSFTPTransfer: org.apache.nifi.processors.standard.util.SFTPTransfer createSftpTransfer(org.apache.nifi.processor.ProcessContext,net.schmizz.sshj.sftp.SFTPClient)>(v, v);
v = new org.apache.nifi.util.MockFlowFile;
specialinvoke v.<org.apache.nifi.util.MockFlowFile: void <init>(long)>(0L);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("/dir1/dir2/dir3");
v = staticinvoke <org.apache.nifi.processors.standard.util.TestSFTPTransfer$lambda_testEnsureDirectoryExistsBlindlyFailed_3__280: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.util.SFTPTransfer,org.apache.nifi.util.MockFlowFile,java.io.File)>(v, v, v);
v = staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/io/IOException;", v);
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Could not blindly create remote directory due to Permission denied", v);
v = staticinvoke <org.mockito.Mockito: org.mockito.verification.VerificationMode times(int)>(0);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object,org.mockito.verification.VerificationMode)>(v, v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: net.schmizz.sshj.sftp.FileAttributes stat(java.lang.String)>(v);
v = staticinvoke <org.mockito.Mockito: java.lang.Object verify(java.lang.Object)>(v);
v = staticinvoke <org.mockito.ArgumentMatchers: java.lang.Object eq(java.lang.Object)>("/dir1/dir2/dir3");
virtualinvoke v.<net.schmizz.sshj.sftp.SFTPClient: void mkdir(java.lang.String)>(v);
return;
}
}