public class org.apache.nifi.processors.standard.TestFetchFTP extends java.lang.Object
{
private org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc;
private org.apache.nifi.util.TestRunner runner;
public void <init>()
{
org.apache.nifi.processors.standard.TestFetchFTP v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void setUp() throws java.lang.Exception
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v;
org.apache.nifi.processors.standard.TestFetchFTP v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.components.PropertyDescriptor[] v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
v = new org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: void <init>()>();
v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc> = v;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner> = v;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void setValidateExpressionUsage(boolean)>(0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: 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.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor UNDEFAULTED_PORT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "11");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor REMOTE_FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "${filename}");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.processor.ProcessContext getProcessContext()>();
v = newarray (org.apache.nifi.components.PropertyDescriptor)[5];
v = <org.apache.nifi.processors.standard.util.FTPTransfer: org.apache.nifi.components.PropertyDescriptor BUFFER_SIZE>;
v[0] = v;
v = <org.apache.nifi.processors.standard.util.FTPTransfer: org.apache.nifi.components.PropertyDescriptor DATA_TIMEOUT>;
v[1] = v;
v = <org.apache.nifi.processors.standard.util.FTPTransfer: org.apache.nifi.components.PropertyDescriptor CONNECTION_TIMEOUT>;
v[2] = v;
v = <org.apache.nifi.processors.standard.util.FTPTransfer: org.apache.nifi.components.PropertyDescriptor CONNECTION_MODE>;
v[3] = v;
v = <org.apache.nifi.processors.standard.util.FTPTransfer: org.apache.nifi.components.PropertyDescriptor TRANSFER_MODE>;
v[4] = v;
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void setDefaultValues(org.apache.nifi.util.MockProcessContext,org.apache.nifi.components.PropertyDescriptor[])>(v, v);
v = <org.apache.nifi.processors.standard.util.FTPTransfer: org.apache.nifi.components.PropertyDescriptor USERNAME>;
virtualinvoke v.<org.apache.nifi.util.MockProcessContext: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "foo");
v = <org.apache.nifi.processors.standard.util.FTPTransfer: org.apache.nifi.components.PropertyDescriptor PASSWORD>;
virtualinvoke v.<org.apache.nifi.util.MockProcessContext: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "bar");
return;
}
private transient void setDefaultValues(org.apache.nifi.util.MockProcessContext, org.apache.nifi.components.PropertyDescriptor[])
{
java.util.function.Consumer v;
java.util.stream.Stream v;
org.apache.nifi.util.MockProcessContext v;
org.apache.nifi.processors.standard.TestFetchFTP v;
org.apache.nifi.components.PropertyDescriptor[] v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
v := @parameter: org.apache.nifi.util.MockProcessContext;
v := @parameter: org.apache.nifi.components.PropertyDescriptor[];
v = staticinvoke <java.util.Arrays: java.util.stream.Stream stream(java.lang.Object[])>(v);
v = staticinvoke <org.apache.nifi.processors.standard.TestFetchFTP$lambda_setDefaultValues_0__84: java.util.function.Consumer bootstrap$(org.apache.nifi.util.MockProcessContext)>(v);
interfaceinvoke v.<java.util.stream.Stream: void forEach(java.util.function.Consumer)>(v);
return;
}
private void addFileAndEnqueue(java.lang.String)
{
byte[] v, v;
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v;
org.apache.nifi.processors.standard.TestFetchFTP v;
org.apache.nifi.util.TestRunner v;
java.util.Map v;
java.lang.String v, v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
v := @parameter: java.lang.String;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = "world";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: void addContent(java.lang.String,byte[])>(v, v);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = newarray (byte)[0];
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>("filename", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
return;
}
public void testContentFetched()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v;
org.apache.nifi.processors.standard.TestFetchFTP v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v, v, v;
java.lang.Object v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean isClosed>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("world");
return;
}
public void testFilenameContainsPath()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v;
org.apache.nifi.processors.standard.TestFetchFTP v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v, v, v;
java.lang.Object v;
java.lang.String v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v, v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("./here/is/my/path/hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean isClosed>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("world");
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes PATH>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>(v);
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes PATH>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "./here/is/my/path");
return;
}
public void testContentNotFound()
{
byte[] v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v;
java.util.Map v;
org.apache.nifi.processors.standard.TestFetchFTP v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = newarray (byte)[0];
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>("filename", "hello.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.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_NOT_FOUND>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testInsufficientPermissions()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v;
org.apache.nifi.processors.standard.TestFetchFTP v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean allowAccess> = 0;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_PERMISSION_DENIED>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testInsufficientPermissionsDoesNotCloseConnection()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v, v, v;
org.apache.nifi.processors.standard.TestFetchFTP v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v;
int v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean allowAccess> = 0;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(2, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_PERMISSION_DENIED>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: int numberOfFileTransfers>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean isClosed>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
return;
}
public void testFileNotFoundDoesNotCloseConnection()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v, v, v;
org.apache.nifi.processors.standard.TestFetchFTP v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v;
int v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean isFileNotFound> = 1;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(2, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_NOT_FOUND>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: int numberOfFileTransfers>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean isClosed>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
return;
}
public void testCommunicationFailureClosesConnection()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v, v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v;
org.apache.nifi.processors.standard.TestFetchFTP v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean isCommFailure> = 1;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_COMMS_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean isClosed>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testMoveFileWithNoTrailingSlashDirName()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v, v, v;
java.util.Map v, v;
int v;
java.lang.String v;
org.apache.nifi.processors.standard.TestFetchFTP v;
org.apache.nifi.components.AllowableValue v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.AllowableValue COMPLETION_MOVE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
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.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor MOVE_DESTINATION_DIR>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "/moved");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor MOVE_CREATE_DIRECTORY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: java.util.Map fileContents>;
interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("/moved/hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: java.util.Map fileContents>;
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
return;
}
public void testMoveFileWithTrailingSlashDirName()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v, v;
org.apache.nifi.processors.standard.TestFetchFTP v;
org.apache.nifi.components.AllowableValue v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v, v;
java.util.Map v, v;
int v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.AllowableValue COMPLETION_MOVE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
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.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor MOVE_DESTINATION_DIR>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "/moved/");
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: java.util.Map fileContents>;
interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("/moved/hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: java.util.Map fileContents>;
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
return;
}
public void testDeleteFile()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v;
org.apache.nifi.processors.standard.TestFetchFTP v;
org.apache.nifi.components.AllowableValue v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v;
java.util.Map v;
java.lang.String v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.AllowableValue COMPLETION_DELETE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: java.util.Map fileContents>;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testDeleteFails()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v, v;
org.apache.nifi.processors.standard.TestFetchFTP v;
org.apache.nifi.components.AllowableValue v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v;
java.util.Map v;
java.lang.String v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.AllowableValue COMPLETION_DELETE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
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.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean allowDelete> = 0;
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: java.util.Map fileContents>;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertFalse(boolean)>(v);
return;
}
public void testRenameFails()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v, v, v, v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v, v;
java.util.Map v, v;
int v;
java.lang.String v;
boolean v;
org.apache.nifi.processors.standard.TestFetchFTP v;
org.apache.nifi.components.AllowableValue v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.AllowableValue COMPLETION_MOVE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
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.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor MOVE_DESTINATION_DIR>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "/moved/");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean allowDelete> = 0;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean allowRename> = 0;
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: java.util.Map fileContents>;
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: java.util.Map fileContents>;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("hello.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testCreateDirFails()
{
org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP v, v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v, v, v, v, v;
java.util.Map v, v;
int v;
java.lang.String v;
boolean v;
org.apache.nifi.processors.standard.TestFetchFTP v;
org.apache.nifi.components.AllowableValue v;
v := @this: org.apache.nifi.processors.standard.TestFetchFTP;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor COMPLETION_STRATEGY>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.AllowableValue COMPLETION_MOVE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
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.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor MOVE_DESTINATION_DIR>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "/moved/");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.components.PropertyDescriptor MOVE_CREATE_DIRECTORY>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
specialinvoke v.<org.apache.nifi.processors.standard.TestFetchFTP: void addFileAndEnqueue(java.lang.String)>("hello.txt");
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: boolean allowCreateDir> = 0;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 0);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.FetchFileTransfer: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: java.util.Map fileContents>;
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
v = v.<org.apache.nifi.processors.standard.TestFetchFTP: org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP proc>;
v = v.<org.apache.nifi.processors.standard.TestFetchFTP$TestableFetchFTP: java.util.Map fileContents>;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("hello.txt");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
}