class org.apache.nifi.processors.standard.TestPutSFTP extends java.lang.Object
{
private static final java.lang.String FLOW_FILE_CONTENTS;
private static final java.lang.String LOCALHOST;
private static final java.lang.String REMOTE_DIRECTORY;
private static final java.lang.String FIRST_FILENAME;
private static final int BATCH_SIZE;
private static final byte[] ZERO_BYTES;
private static final java.lang.String TRANSIT_URI_FORMAT;
private org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer;
private org.apache.nifi.util.TestRunner runner;
void <init>()
{
org.apache.nifi.processors.standard.TestPutSFTP v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
void setRunner() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor 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;
org.apache.nifi.processors.standard.TestPutSFTP v;
int v;
java.lang.Boolean v, v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.util.SSHTestServer v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
v = new org.apache.nifi.processors.standard.util.SSHTestServer;
specialinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: void <init>()>();
v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer> = v;
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: void startServer()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/PutSFTP;");
v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner> = v;
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
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.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PORT>;
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: 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.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor USERNAME>;
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: 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.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor PASSWORD>;
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: 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.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor STRICT_HOST_KEY_CHECKING>;
v = <java.lang.Boolean: java.lang.Boolean FALSE>;
v = virtualinvoke v.<java.lang.Boolean: java.lang.String toString()>();
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.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor BATCH_SIZE>;
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(2);
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.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
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, "nifi_test/");
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REJECT_ZERO_BYTE>;
v = <java.lang.Boolean: java.lang.Boolean TRUE>;
v = virtualinvoke v.<java.lang.Boolean: java.lang.String toString()>();
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.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor CONFLICT_RESOLUTION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "REPLACE");
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor CREATE_DIRECTORY>;
v = <java.lang.Boolean: java.lang.Boolean TRUE>;
v = virtualinvoke v.<java.lang.Boolean: java.lang.String toString()>();
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.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
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.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void setValidateExpressionUsage(boolean)>(0);
return;
}
void clearDirectory() throws java.io.IOException
{
java.lang.String[] v;
org.apache.nifi.processors.standard.TestPutSFTP v;
java.lang.String v;
java.nio.file.Path v;
org.apache.nifi.processors.standard.util.SSHTestServer v, v;
java.io.File v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.processors.standard.util.SSHTestServer sshTestServer>;
virtualinvoke v.<org.apache.nifi.processors.standard.util.SSHTestServer: void stopServer()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: 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: boolean deleteQuietly(java.io.File)>(v);
return;
}
void testRunNewDirectory()
{
java.lang.String[] v, v;
org.apache.nifi.processors.standard.TestPutSFTP v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v, v;
java.util.Map v;
java.lang.String v, v, v, v, v, v;
java.nio.file.Path v, v, v, v;
org.apache.nifi.processors.standard.util.SSHTestServer v, v;
boolean v, v;
java.io.File v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TestPutSFTP: java.lang.String FLOW_FILE_CONTENTS>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, "1.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String,java.util.Map)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: 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[])>("\u0001nifi_test/");
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 = v.<org.apache.nifi.processors.standard.TestPutSFTP: 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[])>("\u0001nifi_test/1.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, "New Directory not created");
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, "New File not created");
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
return;
}
void testRunZeroByteFileRejected()
{
byte[] v;
org.apache.nifi.processors.standard.TestPutSFTP v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v;
java.util.Map v;
java.lang.String v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TestPutSFTP: byte[] ZERO_BYTES>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, "1.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_REJECT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
void testRunZeroByteFileAllowed()
{
byte[] v;
org.apache.nifi.processors.standard.TestPutSFTP v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v, v;
java.util.Map v;
java.lang.Boolean v;
java.lang.String v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor REJECT_ZERO_BYTE>;
v = <java.lang.Boolean: java.lang.Boolean FALSE>;
v = virtualinvoke v.<java.lang.Boolean: java.lang.String toString()>();
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.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TestPutSFTP: byte[] ZERO_BYTES>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, "1.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
void testRunConflictResolutionReplaceStrategy() throws java.io.IOException
{
org.apache.nifi.processors.standard.TestPutSFTP v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v;
java.util.Map v;
java.lang.String v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestPutSFTP: void createRemoteFile()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor CONFLICT_RESOLUTION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "REPLACE");
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TestPutSFTP: java.lang.String FLOW_FILE_CONTENTS>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, "1.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String,java.util.Map)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_REJECT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
return;
}
void testRunConflictResolutionRejectStrategy() throws java.io.IOException
{
org.apache.nifi.processors.standard.TestPutSFTP v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v;
java.util.Map v;
java.lang.String v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestPutSFTP: void createRemoteFile()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor CONFLICT_RESOLUTION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "REJECT");
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TestPutSFTP: java.lang.String FLOW_FILE_CONTENTS>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, "1.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String,java.util.Map)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_REJECT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
return;
}
void testRunConflictResolutionIgnoreStrategy() throws java.io.IOException
{
org.apache.nifi.processors.standard.TestPutSFTP v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v;
java.util.Map v;
java.lang.String v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestPutSFTP: void createRemoteFile()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor CONFLICT_RESOLUTION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "IGNORE");
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TestPutSFTP: java.lang.String FLOW_FILE_CONTENTS>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, "1.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String,java.util.Map)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_REJECT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
return;
}
void testRunConflictResolutionFailStrategy() throws java.io.IOException
{
org.apache.nifi.processors.standard.TestPutSFTP v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v;
java.util.Map v;
java.lang.String v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestPutSFTP: void createRemoteFile()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.util.SFTPTransfer: org.apache.nifi.components.PropertyDescriptor CONFLICT_RESOLUTION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "FAIL");
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TestPutSFTP: java.lang.String FLOW_FILE_CONTENTS>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, "1.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String,java.util.Map)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_REJECT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
void testRunBatching()
{
org.apache.nifi.processors.standard.TestPutSFTP v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v, v;
java.util.Map v;
int v;
java.lang.String v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
v = 1;
label:
if v > 4 goto label;
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TestPutSFTP: java.lang.String FLOW_FILE_CONTENTS>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String,java.util.Map)>(v, v);
v = v + 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: 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 = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: 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 = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertQueueEmpty()>();
return;
}
void testRunTransitUri()
{
java.lang.Object[] v;
org.apache.nifi.processors.standard.TestPutSFTP v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v, v;
java.util.Map v;
java.lang.String v, v, v, v;
boolean v, v;
java.util.Iterator v;
java.util.List v;
java.lang.Object v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TestPutSFTP: java.lang.String FLOW_FILE_CONTENTS>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, "1.txt");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String,java.util.Map)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.PutSFTP: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: org.apache.nifi.util.TestRunner runner>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getProvenanceEvents()>();
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = newarray (java.lang.Object)[1];
v[0] = "localhost";
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("sftp://%s", v);
v = interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceEventRecord: java.lang.String getTransitUri()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(v, "Transit URI not found");
return;
}
private void createRemoteFile() throws java.io.IOException
{
java.lang.String[] v, v;
org.apache.nifi.processors.standard.TestPutSFTP v;
java.nio.file.attribute.FileAttribute[] v, v;
java.lang.String v, v, v;
java.nio.file.Path v, v;
org.apache.nifi.processors.standard.util.SSHTestServer v;
v := @this: org.apache.nifi.processors.standard.TestPutSFTP;
v = v.<org.apache.nifi.processors.standard.TestPutSFTP: 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[])>("\u0001nifi_test/");
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.lang.String toString()>();
v = newarray (java.lang.String)[1];
v[0] = "1.txt";
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = newarray (java.nio.file.attribute.FileAttribute)[0];
staticinvoke <java.nio.file.Files: java.nio.file.Path createDirectory(java.nio.file.Path,java.nio.file.attribute.FileAttribute[])>(v, v);
v = newarray (java.nio.file.attribute.FileAttribute)[0];
staticinvoke <java.nio.file.Files: java.nio.file.Path createFile(java.nio.file.Path,java.nio.file.attribute.FileAttribute[])>(v, v);
return;
}
static void <clinit>()
{
byte[] v;
java.lang.Class v;
java.lang.String v;
v = class "Lorg/apache/nifi/processors/standard/TestPutSFTP;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
<org.apache.nifi.processors.standard.TestPutSFTP: java.lang.String FLOW_FILE_CONTENTS> = v;
v = newarray (byte)[0];
<org.apache.nifi.processors.standard.TestPutSFTP: byte[] ZERO_BYTES> = v;
return;
}
}