public class org.apache.nifi.processors.standard.util.FTPTransfer extends java.lang.Object implements org.apache.nifi.processors.standard.util.FileTransfer { public static final java.lang.String CONNECTION_MODE_ACTIVE; public static final java.lang.String CONNECTION_MODE_PASSIVE; public static final java.lang.String TRANSFER_MODE_ASCII; public static final java.lang.String TRANSFER_MODE_BINARY; public static final java.lang.String FTP_TIMEVAL_FORMAT; public static final java.lang.String PROXY_TYPE_DIRECT; public static final java.lang.String PROXY_TYPE_HTTP; public static final java.lang.String PROXY_TYPE_SOCKS; public static final org.apache.nifi.components.PropertyDescriptor CONNECTION_MODE; public static final org.apache.nifi.components.PropertyDescriptor TRANSFER_MODE; public static final org.apache.nifi.components.PropertyDescriptor PORT; public static final org.apache.nifi.components.PropertyDescriptor PROXY_TYPE; public static final org.apache.nifi.components.PropertyDescriptor PROXY_HOST; public static final org.apache.nifi.components.PropertyDescriptor PROXY_PORT; public static final org.apache.nifi.components.PropertyDescriptor HTTP_PROXY_USERNAME; public static final org.apache.nifi.components.PropertyDescriptor HTTP_PROXY_PASSWORD; public static final org.apache.nifi.components.PropertyDescriptor BUFFER_SIZE; public static final org.apache.nifi.components.PropertyDescriptor UTF8_ENCODING; private static final int REPLY_CODE_FILE_UNAVAILABLE; private static final java.util.regex.Pattern NOT_FOUND_MESSAGE_PATTERN; private static final org.apache.nifi.processors.standard.ftp.FTPClientProvider FTP_CLIENT_PROVIDER; private static final org.apache.nifi.proxy.ProxySpec[] PROXY_SPECS; public static final org.apache.nifi.components.PropertyDescriptor PROXY_CONFIGURATION_SERVICE; private final org.apache.nifi.logging.ComponentLog logger; private final org.apache.nifi.processor.ProcessContext ctx; private boolean closed; private org.apache.commons.net.ftp.FTPClient client; private java.lang.String homeDirectory; private java.lang.String remoteHostName; private java.lang.String remotePort; private java.lang.String remoteUsername; private java.lang.String remotePassword; public void (org.apache.nifi.processor.ProcessContext, org.apache.nifi.logging.ComponentLog) { org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processors.standard.util.FTPTransfer v; org.apache.nifi.logging.ComponentLog v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.logging.ComponentLog; specialinvoke v.()>(); v. = 1; v. = v; v. = v; return; } public static void validateProxySpec(org.apache.nifi.components.ValidationContext, java.util.Collection) { org.apache.nifi.proxy.ProxySpec[] v; org.apache.nifi.components.ValidationContext v; java.util.Collection v; v := @parameter: org.apache.nifi.components.ValidationContext; v := @parameter: java.util.Collection; v = ; staticinvoke (v, v, v); return; } public java.lang.String getProtocolName() { org.apache.nifi.processors.standard.util.FTPTransfer v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; return "ftp"; } public void close() throws java.io.IOException { java.lang.Object[] v; org.apache.nifi.logging.ComponentLog v; java.lang.Exception v; org.apache.nifi.processors.standard.util.FTPTransfer v; org.apache.commons.net.ftp.FTPClient v, v; java.lang.String v; boolean v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v = v.; if v == 0 goto label; return; label: v. = 1; label: v = v.; if null == v goto label; v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = v.; v = newarray (java.lang.Object)[2]; v = virtualinvoke v.(); v[0] = v; v[1] = v; interfaceinvoke v.("Failed to close FTPClient due to {}", v); label: v. = null; return; catch java.lang.Exception from label to label with label; } public java.lang.String getHomeDirectory(org.apache.nifi.flowfile.FlowFile) throws java.io.IOException { org.apache.nifi.processors.standard.util.FTPTransfer v; java.lang.String v; org.apache.nifi.flowfile.FlowFile v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; specialinvoke v.(v); v = v.; return v; } public java.util.List getListing(boolean) throws java.io.IOException { org.apache.nifi.processor.ProcessContext v, v; java.lang.Integer v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.components.PropertyValue v, v, v; org.apache.nifi.processors.standard.util.FTPTransfer v; java.util.List v; int v; java.lang.String v; boolean v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: boolean; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = specialinvoke v.(v, 0, v, v); return v; } private java.util.List getListing(java.lang.String, int, int, boolean) throws java.io.IOException { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; java.util.regex.Matcher v, v; java.nio.file.Path v, v, v; org.apache.nifi.processors.standard.util.FileInfo v; java.util.ArrayList v; org.apache.nifi.processors.standard.util.FTPTransfer v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.io.IOException v, v; java.io.File v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v; org.apache.commons.net.ftp.FTPClient v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.commons.net.ftp.FTPFile[] v, v; java.util.List v; java.util.regex.Pattern v, v, v, v; org.apache.commons.net.ftp.FTPFile v; java.lang.String[] v, v, v; org.apache.nifi.logging.ComponentLog v, v; int v, v, v, v, v, v, v, v; java.lang.Boolean v, v, v; org.apache.nifi.processor.ProcessContext v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: java.lang.String; v := @parameter: int; v := @parameter: int; v := @parameter: boolean; v = new java.util.ArrayList; specialinvoke v.()>(); if v >= 1 goto label; return v; label: if v < 100 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u had to stop recursively searching directories at a recursive depth of \u to avoid memory issues"); interfaceinvoke v.(v); return v; label: v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; v = null; goto label; label: v = staticinvoke (v); label: v = v; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; if v != null goto label; label: v = null; goto label; label: v = staticinvoke (v); label: v = v; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = 1; if v == null goto label; if v != null goto label; v = newarray (java.lang.String)[0]; v = staticinvoke (".", v); goto label; label: v = newarray (java.lang.String)[0]; v = staticinvoke (v, v); label: v = v; if v == null goto label; v = newarray (java.lang.String)[0]; v = staticinvoke (v, v); v = interfaceinvoke v.(v); label: if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.("\\", "/"); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = 0; label: v = specialinvoke v.(null); v = 0; if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.("."); goto label; label: v = virtualinvoke v.(v); label: v = lengthof v; if v != 0 goto label; if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = specialinvoke v.(v); if v != 0 goto label; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot list files for non-existent directory \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = virtualinvoke v.("."); if v != 0 goto label; v = virtualinvoke v.(".."); if v != 0 goto label; if v == 0 goto label; v = virtualinvoke v.("."); if v != 0 goto label; label: v = new java.io.File; specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = virtualinvoke v.(); v = virtualinvoke v.("\\", "/"); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; label: if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = v + 1; v = v - v; v = specialinvoke v.(v, v, v, v); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to get listing from \u; skipping"); interfaceinvoke v.(v, v); label: v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; if v != 0 goto label; if v != 0 goto label; label: if v == null goto label; if v == 0 goto label; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; label: v = specialinvoke v.(v, v); interfaceinvoke v.(v); v = v + 1; label: if v >= v goto label; label: v = v + 1; goto label; label: return v; catch java.io.IOException from label to label with label; } private org.apache.nifi.processors.standard.util.FileInfo newFileInfo(org.apache.commons.net.ftp.FTPFile, java.lang.String) { boolean v, v, v, v, v, v, v, v, v, v; java.lang.StringBuilder v; org.apache.commons.net.ftp.FTPFile v; org.apache.nifi.processors.standard.util.FileInfo v; long v, v; org.apache.nifi.processors.standard.util.FTPTransfer v; java.util.Calendar v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.util.FileInfo$Builder v, v, v, v, v, v, v, v, v; java.io.File v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: org.apache.commons.net.ftp.FTPFile; v := @parameter: java.lang.String; if v != null goto label; return null; label: v = new java.io.File; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = virtualinvoke v.(); v = virtualinvoke v.("\\", "/"); v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.(0, 0); if v == 0 goto label; v = "r"; goto label; label: v = "-"; label: virtualinvoke v.(v); v = virtualinvoke v.(0, 1); if v == 0 goto label; v = "w"; goto label; label: v = "-"; label: virtualinvoke v.(v); v = virtualinvoke v.(0, 2); if v == 0 goto label; v = "x"; goto label; label: v = "-"; label: virtualinvoke v.(v); v = virtualinvoke v.(1, 0); if v == 0 goto label; v = "r"; goto label; label: v = "-"; label: virtualinvoke v.(v); v = virtualinvoke v.(1, 1); if v == 0 goto label; v = "w"; goto label; label: v = "-"; label: virtualinvoke v.(v); v = virtualinvoke v.(1, 2); if v == 0 goto label; v = "x"; goto label; label: v = "-"; label: virtualinvoke v.(v); v = virtualinvoke v.(2, 0); if v == 0 goto label; v = "r"; goto label; label: v = "-"; label: virtualinvoke v.(v); v = virtualinvoke v.(2, 1); if v == 0 goto label; v = "w"; goto label; label: v = "-"; label: virtualinvoke v.(v); v = virtualinvoke v.(2, 2); if v == 0 goto label; v = "x"; goto label; label: v = "-"; label: virtualinvoke v.(v); v = new org.apache.nifi.processors.standard.util.FileInfo$Builder; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public org.apache.nifi.flowfile.FlowFile getRemoteFile(java.lang.String, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException, java.io.IOException { java.lang.Throwable v; org.apache.nifi.processor.io.OutputStreamCallback v; org.apache.nifi.processors.standard.util.FTPTransfer v; org.apache.nifi.processors.standard.util.PermissionDeniedException v; java.util.regex.Matcher v; int v; org.apache.commons.net.ftp.FTPClient v; java.lang.String v, v; boolean v; org.apache.nifi.flowfile.FlowFile v, v; java.io.IOException v, v; org.apache.nifi.processor.ProcessSession v; java.io.FileNotFoundException v; java.util.regex.Pattern v; java.io.InputStream v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: org.apache.nifi.processor.ProcessSession; v = specialinvoke v.(v); v = virtualinvoke v.(v); label: if v != null goto label; v = virtualinvoke v.(); if v != null goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Retrieve File Failed: FTP server response not found"); throw v; label: v = virtualinvoke v.(); if 550 != v goto label; v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = new java.io.FileNotFoundException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.apache.nifi.processors.standard.util.PermissionDeniedException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = staticinvoke (v); v = interfaceinvoke v.(v, v); virtualinvoke v.(); label: virtualinvoke v.(); return v; label: v := @caughtexception; throw v; catch java.lang.Throwable from label to label with label; } public org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile, java.lang.String, java.lang.String) throws java.io.IOException { org.apache.nifi.processors.standard.util.FileInfo v; org.apache.nifi.processors.standard.util.FTPTransfer v; int v, v, v, v; org.apache.commons.net.ftp.FTPClient v; java.lang.String v, v, v; boolean v, v; org.apache.nifi.flowfile.FlowFile v; org.apache.commons.net.ftp.FTPFile[] v; org.apache.commons.net.ftp.FTPFile v, v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = specialinvoke v.(v); if v != null goto label; v = virtualinvoke v.(47); if v < 0 goto label; v = virtualinvoke v.("/"); if v != 0 goto label; v = virtualinvoke v.(0, v); v = v + 1; v = virtualinvoke v.(v); goto label; label: v = ""; label: v = virtualinvoke v.(v); v = null; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v; goto label; label: v = v + 1; goto label; label: if v != null goto label; return null; label: v = specialinvoke v.(v, v); return v; } public void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile, java.io.File) throws java.io.IOException { java.lang.Object[] v; org.apache.nifi.logging.ComponentLog v; org.apache.nifi.processors.standard.util.FTPTransfer v; org.apache.commons.net.ftp.FTPClient v; java.lang.String v, v, v, v, v, v; boolean v, v, v, v; org.apache.nifi.flowfile.FlowFile v; java.io.IOException v; java.io.File v, v, v, v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.io.File; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = new java.io.File; v = ; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v, v); label: v = virtualinvoke v.(); v = virtualinvoke v.("\\", "/"); v = virtualinvoke v.("^.\\:", ""); v = specialinvoke v.(v); v = specialinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Remote Directory not found: created directory [{}]", v); goto label; label: v = specialinvoke v.(v); if v != 0 goto label; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to create remote directory \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } private java.lang.String setAndGetWorkingDirectory(java.lang.String) throws java.io.IOException { org.apache.nifi.processor.exception.ProcessException v; org.apache.nifi.processors.standard.util.FTPTransfer v; org.apache.commons.net.ftp.FTPClient v, v, v; java.lang.String v, v, v, v; boolean v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: java.lang.String; v = v.; v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = new org.apache.nifi.processor.exception.ProcessException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to change working directory to \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = virtualinvoke v.(); return v; } private boolean setWorkingDirectory(java.lang.String) throws java.io.IOException { org.apache.nifi.processors.standard.util.FTPTransfer v; org.apache.commons.net.ftp.FTPClient v, v; java.lang.String v, v; boolean v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: java.lang.String; v = v.; v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); return v; } private boolean resetWorkingDirectory() throws java.io.IOException { org.apache.nifi.processors.standard.util.FTPTransfer v; org.apache.commons.net.ftp.FTPClient v; java.lang.String v; boolean v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v = v.; v = v.; v = virtualinvoke v.(v); return v; } public java.lang.String put(org.apache.nifi.flowfile.FlowFile, java.lang.String, java.lang.String, java.io.InputStream) throws java.io.IOException { org.apache.nifi.components.PropertyDescriptor v, v, v, v; java.lang.Exception v, v; java.lang.Object[] v, v, v, v, v; java.text.SimpleDateFormat v, v; org.apache.nifi.processors.standard.util.FTPTransfer v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.io.IOException v, v, v; java.util.Date v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v; java.util.Locale v, v; org.apache.commons.net.ftp.FTPClient v; boolean v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.logging.ComponentLog v, v, v, v, v; int v; java.lang.Boolean v; org.apache.nifi.processor.ProcessContext v, v, v, v; java.io.InputStream v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.io.InputStream; v = specialinvoke v.(v); if v != null goto label; v = v; goto label; label: v = specialinvoke v.(v); v = virtualinvoke v.("/"); if v == 0 goto label; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001\u0001"); goto label; label: v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001/\u0001"); label: v = v; label: v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) (".\u0001"); goto label; label: v = v; label: v = v; label: v = virtualinvoke v.(v, v); if v != 0 goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Failed to store file \u to \u due to: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; label: v = new java.text.SimpleDateFormat; v = ; specialinvoke v.(java.lang.String,java.util.Locale)>("yyyy-MM-dd\'T\'HH:mm:ssZ", v); v = virtualinvoke v.(v); v = new java.text.SimpleDateFormat; v = ; specialinvoke v.(java.lang.String,java.util.Locale)>("yyyyMMddHHmmss", v); v = virtualinvoke v.(v); v = virtualinvoke v.(v, v); if v != 0 goto label; v = v.; v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Could not set lastModifiedTime on {} to {}", v); label: goto label; label: v := @caughtexception; v = v.; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Failed to set lastModifiedTime on {} to {}", v); label: v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; label: v = virtualinvoke v.(v); if v < 0 goto label; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("chmod \u \u0001"); v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Could not set permission on {} to {}", v); label: goto label; label: v := @caughtexception; v = v.; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Failed to set permission on {} to {}", v); label: v = virtualinvoke v.(v); if v != 0 goto label; label: v = v.; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Renaming remote path from {} to {} for {}", v); v = virtualinvoke v.(v, v); if v != 0 goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Failed to rename temporary file \u to \u due to: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v := @caughtexception; virtualinvoke v.(v); throw v; label: return v; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.io.IOException from label to label with label; } public void rename(org.apache.nifi.flowfile.FlowFile, java.lang.String, java.lang.String) throws java.io.IOException { org.apache.nifi.flowfile.FlowFile v; java.io.IOException v; org.apache.nifi.processors.standard.util.FTPTransfer v; org.apache.commons.net.ftp.FTPClient v; java.lang.String v, v, v, v; boolean v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = specialinvoke v.(v); v = virtualinvoke v.(v, v); if v != 0 goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Failed to rename temporary file \u to \u due to: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } public void deleteFile(org.apache.nifi.flowfile.FlowFile, java.lang.String, java.lang.String) throws java.io.IOException { org.apache.nifi.flowfile.FlowFile v; java.io.IOException v; org.apache.nifi.processors.standard.util.FTPTransfer v; org.apache.commons.net.ftp.FTPClient v; java.lang.String v, v, v, v; boolean v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = specialinvoke v.(v); if v == null goto label; specialinvoke v.(v); label: v = virtualinvoke v.(v); if v != 0 goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to remove file \u due to \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } public void deleteDirectory(org.apache.nifi.flowfile.FlowFile, java.lang.String) throws java.io.IOException { org.apache.nifi.flowfile.FlowFile v; java.io.IOException v; org.apache.nifi.processors.standard.util.FTPTransfer v; org.apache.commons.net.ftp.FTPClient v; java.lang.String v, v, v; boolean v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.lang.String; v = specialinvoke v.(v); v = virtualinvoke v.(v); if v != 0 goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to remove directory \u due to \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } public boolean isClosed() { org.apache.nifi.processors.standard.util.FTPTransfer v; boolean v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v = v.; return v; } public void sendCommands(java.util.List, org.apache.nifi.flowfile.FlowFile) throws java.io.IOException { org.apache.nifi.logging.ComponentLog v; org.apache.nifi.processors.standard.util.FTPTransfer v; int v; org.apache.commons.net.ftp.FTPClient v; java.lang.String v, v, v; boolean v, v, v, v, v; java.util.Iterator v; org.apache.nifi.flowfile.FlowFile v; java.io.IOException v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: java.util.List; v := @parameter: org.apache.nifi.flowfile.FlowFile; v = interfaceinvoke v.(); if v == 0 goto label; return; label: v = specialinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(v); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("\u sent command to the FTP server: \u for \u0001"); interfaceinvoke v.(v); v = staticinvoke (v); if v != 0 goto label; v = staticinvoke (v); if v == 0 goto label; label: v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v) ("\u negative reply back from FTP server cmd: \u reply:\u0001: \u for \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } protected org.apache.commons.net.ftp.FTPClient createClient(org.apache.nifi.context.PropertyContext, java.util.Map) { org.apache.nifi.processors.standard.util.FTPTransfer v; org.apache.nifi.processors.standard.ftp.FTPClientProvider v; java.util.Map v; org.apache.commons.net.ftp.FTPClient v; org.apache.nifi.context.PropertyContext v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: org.apache.nifi.context.PropertyContext; v := @parameter: java.util.Map; v = ; v = interfaceinvoke v.(v, v); return v; } private org.apache.commons.net.ftp.FTPClient getClient(org.apache.nifi.flowfile.FlowFile) throws java.io.IOException { org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v; java.util.Map v; org.apache.commons.net.ftp.FTPClient v, v, v, v, v; boolean v, v, v, v; org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.processors.standard.util.FTPTransfer v; java.lang.String v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.ProcessContext v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = v.; if v == null goto label; v = v.; v = staticinvoke (v, v); if v == 0 goto label; v = v.; v = staticinvoke (v, v); if v == 0 goto label; v = v.; v = staticinvoke (v, v); if v == 0 goto label; v = v.; v = staticinvoke (v, v); if v == 0 goto label; specialinvoke v.(); v = v.; return v; label: virtualinvoke v.(); label: if v != null goto label; v = staticinvoke (); goto label; label: v = interfaceinvoke v.(); label: v = v.; v = virtualinvoke v.(v, v); v. = v; v. = v; v. = v; v. = v; v. = v; v. = 0; v = v.; v = virtualinvoke v.(); v. = v; v = v.; return v; } protected int numberPermissions(java.lang.String) { org.apache.nifi.processors.standard.util.FTPTransfer v; java.util.regex.Matcher v, v; int v, v; java.lang.String v; boolean v, v; char v, v, v, v, v, v, v, v, v; java.lang.NumberFormatException v; java.util.regex.Pattern v, v; v := @this: org.apache.nifi.processors.standard.util.FTPTransfer; v := @parameter: java.lang.String; v = (int) -1; v = v; v = staticinvoke ("^[rwx-]{9}$"); v = staticinvoke ("\\d+"); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = 0; v = virtualinvoke v.(0); if v != 114 goto label; v = 256; label: v = virtualinvoke v.(1); if v != 119 goto label; v = v | 128; label: v = virtualinvoke v.(2); if v != 120 goto label; v = v | 64; label: v = virtualinvoke v.(3); if v != 114 goto label; v = v | 32; label: v = virtualinvoke v.(4); if v != 119 goto label; v = v | 16; label: v = virtualinvoke v.(5); if v != 120 goto label; v = v | 8; label: v = virtualinvoke v.(6); if v != 114 goto label; v = v | 4; label: v = virtualinvoke v.(7); if v != 119 goto label; v = v | 2; label: v = virtualinvoke v.(8); if v != 120 goto label; v = v | 1; goto label; label: v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; label: v = staticinvoke (v, 8); label: goto label; label: v := @caughtexception; label: return v; catch java.lang.NumberFormatException from label to label with label; } public static java.util.function.Supplier createComponentProxyConfigSupplier(org.apache.nifi.context.PropertyContext) { java.util.function.Supplier v; org.apache.nifi.context.PropertyContext v; v := @parameter: org.apache.nifi.context.PropertyContext; v = staticinvoke (v); return v; } static void () { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.proxy.ProxySpec[] v, v; org.apache.nifi.proxy.ProxySpec v, v; java.lang.String v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.expression.ExpressionLanguageScope v, v, v, v, v; java.util.regex.Pattern v; java.lang.String[] v, v, v, v; java.net.Proxy$Type v, v, v; org.apache.nifi.components.Validator v, v, v, v, v, v, v; org.apache.nifi.processors.standard.ftp.StandardFTPClientProvider v; v = ; v = virtualinvoke v.(); = v; v = ; v = virtualinvoke v.(); = v; v = ; v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Connection Mode"); v = virtualinvoke v.("The FTP Connection Mode"); v = newarray (java.lang.String)[2]; v[0] = "Active"; v[1] = "Passive"; v = virtualinvoke v.(v); v = virtualinvoke v.("Passive"); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Transfer Mode"); v = virtualinvoke v.("The FTP Transfer Mode"); v = newarray (java.lang.String)[2]; v[0] = "Binary"; v[1] = "ASCII"; v = virtualinvoke v.(v); v = virtualinvoke v.("Binary"); v = virtualinvoke v.();