public class org.apache.nifi.processors.standard.util.SFTPTransfer extends java.lang.Object implements org.apache.nifi.processors.standard.util.FileTransfer { private static final org.apache.nifi.processors.standard.ssh.SSHClientProvider SSH_CLIENT_PROVIDER; private static final java.lang.String DOT_PREFIX; private static final java.lang.String RELATIVE_CURRENT_DIRECTORY; private static final java.lang.String RELATIVE_PARENT_DIRECTORY; private static final java.util.Set DEFAULT_KEY_ALGORITHM_NAMES; private static final java.util.Set DEFAULT_CIPHER_NAMES; private static final java.util.Set DEFAULT_MESSAGE_AUTHENTICATION_CODE_NAMES; private static final java.util.Set DEFAULT_KEY_EXCHANGE_ALGORITHM_NAMES; public static final org.apache.nifi.components.PropertyDescriptor PRIVATE_KEY_PATH; public static final org.apache.nifi.components.PropertyDescriptor PRIVATE_KEY_PASSPHRASE; public static final org.apache.nifi.components.PropertyDescriptor HOST_KEY_FILE; public static final org.apache.nifi.components.PropertyDescriptor STRICT_HOST_KEY_CHECKING; public static final org.apache.nifi.components.PropertyDescriptor PORT; public static final org.apache.nifi.components.PropertyDescriptor USE_KEEPALIVE_ON_TIMEOUT; public static final org.apache.nifi.components.PropertyDescriptor KEY_ALGORITHMS_ALLOWED; public static final org.apache.nifi.components.PropertyDescriptor CIPHERS_ALLOWED; public static final org.apache.nifi.components.PropertyDescriptor MESSAGE_AUTHENTICATION_CODES_ALLOWED; public static final org.apache.nifi.components.PropertyDescriptor KEY_EXCHANGE_ALGORITHMS_ALLOWED; public static final org.apache.nifi.components.PropertyDescriptor DISABLE_DIRECTORY_LISTING; 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.context.PropertyContext ctx; private net.schmizz.sshj.SSHClient sshClient; private net.schmizz.sshj.sftp.SFTPClient sftpClient; private volatile boolean closed; private java.lang.String homeDir; private java.lang.String activeHostname; private java.lang.String activePort; private java.lang.String activeUsername; private java.lang.String activePassword; private java.lang.String activePrivateKeyPath; private java.lang.String activePrivateKeyPassphrase; private final boolean disableDirectoryListing; private static java.lang.String convertFactorySetToString(java.util.Set) { java.util.stream.Stream v, v; java.util.Set v; java.lang.Object v; java.util.stream.Collector v; v := @parameter: java.util.Set; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (", "); v = interfaceinvoke v.(v); return v; } public void (org.apache.nifi.context.PropertyContext, org.apache.nifi.logging.ComponentLog) { org.apache.nifi.logging.ComponentLog v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyValue v; java.lang.Boolean v, v; org.apache.nifi.processors.standard.util.SFTPTransfer v; boolean v; org.apache.nifi.context.PropertyContext v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: org.apache.nifi.context.PropertyContext; v := @parameter: org.apache.nifi.logging.ComponentLog; specialinvoke v.()>(); v. = 0; v. = v; v. = v; v = ; v = interfaceinvoke v.(v); if v != null goto label; v = 0; goto label; label: v = ; v = interfaceinvoke v.(); v = virtualinvoke v.(v); label: 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.SFTPTransfer v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; return "sftp"; } public java.util.List getListing(boolean) throws java.io.IOException { java.lang.Integer v; org.apache.nifi.components.PropertyDescriptor v, v; java.util.ArrayList v; org.apache.nifi.components.PropertyValue v, v, v; int v, v; org.apache.nifi.processors.standard.util.SFTPTransfer v; java.lang.String v; boolean v; org.apache.nifi.context.PropertyContext v, v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: boolean; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v.; v = ; v = interfaceinvoke v.(v); if v != null goto label; v = 2147483647; goto label; label: v = interfaceinvoke v.(); if v != null goto label; v = 2147483647; goto label; label: v = virtualinvoke v.(); label: v = v; label: v = new java.util.ArrayList; specialinvoke v.(int)>(1000); virtualinvoke v.(v, 0, v, v, v); return v; } protected void getListing(java.lang.String, int, int, java.util.List, boolean) throws java.io.IOException { java.lang.Integer v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.processors.standard.util.PermissionDeniedException v; java.util.regex.Matcher v; net.schmizz.sshj.sftp.SFTPClient v; java.nio.file.Path v, v, v; java.lang.Throwable v; java.lang.Object[] v; java.util.ArrayList v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.context.PropertyContext v, v, v, v, v, v; java.io.IOException v, v; java.io.File v; net.schmizz.sshj.sftp.Response$StatusCode v, v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v; int[] v; boolean v, v, v, v, v, v, v, v, v, v, v; net.schmizz.sshj.sftp.RemoteResourceFilter v; java.io.FileNotFoundException v; java.util.List v; java.util.regex.Pattern v, v, v, v; java.lang.String[] v, v, v; org.apache.nifi.logging.ComponentLog v, v; int v, v, v, v, v, v, v; java.lang.Boolean v, v, v; java.util.Iterator v; org.apache.nifi.processors.standard.util.SFTPTransfer v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: java.lang.String; v := @parameter: int; v := @parameter: int; v := @parameter: java.util.List; v := @parameter: boolean; if v < 1 goto label; v = interfaceinvoke v.(); if v < v goto label; label: return; 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; 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 = virtualinvoke v.(null); v = v; if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = new java.util.ArrayList; specialinvoke v.()>(); label: v = staticinvoke (v, v, v, v, v, v, v, v, v, v, v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: virtualinvoke v.(".", v); goto label; label: virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; if v != null goto label; v = "current directory"; goto label; label: v = v; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 1: goto label; case 2: goto label; default: goto label; }; label: v = new java.io.FileNotFoundException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not perform listing on \u because could not find the file on the remote server"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.apache.nifi.processors.standard.util.PermissionDeniedException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not perform listing on \u due to insufficient permissions"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new java.io.IOException; v = newarray (java.lang.Object)[2]; v[0] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[1] = v; v = staticinvoke ("Failed to obtain file listing for %s due to unexpected SSH_FXP_STATUS (%d)", v); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = new java.io.File; specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = virtualinvoke v.(); v = virtualinvoke v.("\\", "/"); label: v = v + 1; virtualinvoke v.(v, v, v, 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); goto label; label: return; catch net.schmizz.sshj.sftp.SFTPException from label to label with label; catch java.io.IOException from label to label with label; } private boolean isIncludedFile(net.schmizz.sshj.sftp.RemoteResourceInfo, boolean) { net.schmizz.sshj.sftp.RemoteResourceInfo v; org.apache.nifi.processors.standard.util.SFTPTransfer v; boolean v, v, v, v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: net.schmizz.sshj.sftp.RemoteResourceInfo; v := @parameter: boolean; v = virtualinvoke v.(); if v != 0 goto label; if v == 0 goto label; v = specialinvoke v.(v); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } private boolean isIncludedDirectory(net.schmizz.sshj.sftp.RemoteResourceInfo, boolean, boolean) { java.lang.Object[] v; net.schmizz.sshj.sftp.FileAttributes v; org.apache.nifi.logging.ComponentLog v; net.schmizz.sshj.sftp.SFTPClient v; java.lang.String v; boolean v, v, v, v, v, v; net.schmizz.sshj.sftp.RemoteResourceInfo v; java.io.IOException v; net.schmizz.sshj.sftp.FileMode$Type v, v; net.schmizz.sshj.sftp.FileMode v; org.apache.nifi.processors.standard.util.SFTPTransfer v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: net.schmizz.sshj.sftp.RemoteResourceInfo; v := @parameter: boolean; v := @parameter: boolean; v = 0; v = virtualinvoke v.(); if v == 0 goto label; v = v; goto label; label: if v == 0 goto label; v = specialinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != v goto label; v = 1; goto label; label: v = 0; label: v = v; label: goto label; label: v := @caughtexception; v = v.; v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Read symbolic link attributes failed [{}]", v); label: return v; catch java.io.IOException from label to label with label; } private boolean isSymlink(net.schmizz.sshj.sftp.RemoteResourceInfo) { net.schmizz.sshj.sftp.FileMode$Type v, v; net.schmizz.sshj.sftp.RemoteResourceInfo v; net.schmizz.sshj.sftp.FileAttributes v; org.apache.nifi.processors.standard.util.SFTPTransfer v; boolean v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: net.schmizz.sshj.sftp.RemoteResourceInfo; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != v goto label; v = 1; goto label; label: v = 0; label: return v; } private org.apache.nifi.processors.standard.util.FileInfo newFileInfo(net.schmizz.sshj.sftp.RemoteResourceInfo, java.lang.String) { boolean v; java.util.Set v; java.lang.StringBuilder v; org.apache.nifi.processors.standard.util.FileInfo v; net.schmizz.sshj.sftp.FileAttributes v, v, v, v, v; long v, v, v; int v, v; java.lang.String 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; net.schmizz.sshj.sftp.RemoteResourceInfo v; net.schmizz.sshj.xfer.FilePermission v, v, v, v, v, v, v, v, v; java.io.File v; org.apache.nifi.processors.standard.util.SFTPTransfer v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: net.schmizz.sshj.sftp.RemoteResourceInfo; 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.(); v = virtualinvoke v.(); v = ; specialinvoke v.(v, v, v, "r"); v = ; specialinvoke v.(v, v, v, "w"); v = ; specialinvoke v.(v, v, v, "x"); v = ; specialinvoke v.(v, v, v, "r"); v = ; specialinvoke v.(v, v, v, "w"); v = ; specialinvoke v.(v, v, v, "x"); v = ; specialinvoke v.(v, v, v, "r"); v = ; specialinvoke v.(v, v, v, "w"); v = ; specialinvoke v.(v, v, v, "x"); 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 = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v * 1000L; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } private void appendPermission(java.lang.StringBuilder, java.util.Set, net.schmizz.sshj.xfer.FilePermission, java.lang.String) { java.util.Set v; net.schmizz.sshj.xfer.FilePermission v; org.apache.nifi.processors.standard.util.SFTPTransfer v; java.lang.StringBuilder v; java.lang.String v; boolean v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: java.lang.StringBuilder; v := @parameter: java.util.Set; v := @parameter: net.schmizz.sshj.xfer.FilePermission; v := @parameter: java.lang.String; v = interfaceinvoke v.(v); if v == 0 goto label; virtualinvoke v.(v); goto label; label: virtualinvoke v.("-"); label: return; } 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, v; org.apache.nifi.processor.io.OutputStreamCallback v; org.apache.nifi.processors.standard.util.PermissionDeniedException v; int[] v; int v, v; net.schmizz.sshj.sftp.SFTPClient v; java.lang.String v, v, v, v; net.schmizz.sshj.sftp.RemoteFile$ReadAheadRemoteFileInputStream v, v; org.apache.nifi.flowfile.FlowFile v, v; java.io.IOException v; org.apache.nifi.processor.ProcessSession v; net.schmizz.sshj.sftp.RemoteFile v; java.io.FileNotFoundException v; net.schmizz.sshj.sftp.Response$StatusCode v; org.apache.nifi.processors.standard.util.SFTPTransfer v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: org.apache.nifi.processor.ProcessSession; v = virtualinvoke v.(v); label: v = virtualinvoke v.(v); v = new net.schmizz.sshj.sftp.RemoteFile$ReadAheadRemoteFileInputStream; virtualinvoke v.(); specialinvoke v.(net.schmizz.sshj.sftp.RemoteFile,int)>(v, 16); v = staticinvoke (v); v = interfaceinvoke v.(v, v); label: return v; label: v := @caughtexception; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 1: goto label; case 2: goto label; default: goto label; }; label: v = new java.io.FileNotFoundException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not find file \u on remote SFTP Server"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.apache.nifi.processors.standard.util.PermissionDeniedException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Insufficient permissions to read file \u from remote SFTP Server"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to obtain file content for \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v := @caughtexception; throw v; catch net.schmizz.sshj.sftp.SFTPException from label to label with label; catch java.lang.Throwable from label to label with label; } public void deleteFile(org.apache.nifi.flowfile.FlowFile, java.lang.String, java.lang.String) throws java.io.IOException { java.lang.Throwable v; org.apache.nifi.processors.standard.util.PermissionDeniedException v; int[] v; int v, v; net.schmizz.sshj.sftp.SFTPClient v; java.lang.String v, v, v, v, v, v, v; boolean v; org.apache.nifi.flowfile.FlowFile v; java.io.IOException v; java.io.FileNotFoundException v; net.schmizz.sshj.sftp.Response$StatusCode v; org.apache.nifi.processors.standard.util.SFTPTransfer v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(v); if v != null goto label; v = v; goto label; label: 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: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 1: goto label; case 2: goto label; default: goto label; }; label: v = new java.io.FileNotFoundException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not find file \u to remove from remote SFTP Server"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.apache.nifi.processors.standard.util.PermissionDeniedException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Insufficient permissions to delete file \u from remote SFTP Server"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to delete remote file \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: return; catch net.schmizz.sshj.sftp.SFTPException from label to label with label; } public void deleteDirectory(org.apache.nifi.flowfile.FlowFile, java.lang.String) throws java.io.IOException { java.lang.Throwable v; org.apache.nifi.flowfile.FlowFile v; net.schmizz.sshj.sftp.SFTPClient v; org.apache.nifi.processors.standard.util.SFTPTransfer v; java.io.IOException v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.lang.String; v = virtualinvoke v.(v); label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to delete remote directory \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: return; catch net.schmizz.sshj.sftp.SFTPException from label to label with label; } public void ensureDirectoryExists(org.apache.nifi.flowfile.FlowFile, java.io.File) throws java.io.IOException { net.schmizz.sshj.sftp.SFTPClient v; boolean v, v; org.apache.nifi.flowfile.FlowFile v; java.lang.Throwable v, v, v; java.lang.Object[] v, v, v; org.apache.nifi.logging.ComponentLog v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.io.IOException v, v, v; java.io.File v, v, v, v; net.schmizz.sshj.sftp.Response$StatusCode v, v, v, v, v, v; org.apache.nifi.processors.standard.util.SFTPTransfer v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.io.File; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.("\\", "/"); v = virtualinvoke v.("^.\\:", ""); v = v.; if v == 0 goto label; label: virtualinvoke v.(v); label: return; label: v := @caughtexception; v = virtualinvoke v.(); v = ; if v != v goto label; v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke ("Could not create %s due to \'No such file\'. Will try to create the parent dir.", v); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = ; if v != v goto label; v = v.; v = specialinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not blindly create remote directory due to \u0001"); interfaceinvoke v.(v, v); return; label: v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not blindly create remote directory due to \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: virtualinvoke v.(v); label: return; label: v := @caughtexception; v = virtualinvoke v.(); v = ; if v == v goto label; v = new java.io.IOException; v = specialinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to determine if remote directory exists at \u due to \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: 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 = v.; v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Remote Directory {} does not exist; creating it", v); label: virtualinvoke v.(v); v = v.; v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Created {}", v); label: goto label; label: v := @caughtexception; v = new java.io.IOException; v = specialinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to create remote directory \u due to \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: return; catch net.schmizz.sshj.sftp.SFTPException from label to label with label; catch net.schmizz.sshj.sftp.SFTPException from label to label with label; catch net.schmizz.sshj.sftp.SFTPException from label to label with label; } private java.lang.String getMessage(net.schmizz.sshj.sftp.SFTPException) { net.schmizz.sshj.sftp.Response$StatusCode v, v; net.schmizz.sshj.sftp.SFTPException v; int v; org.apache.nifi.processors.standard.util.SFTPTransfer v; java.lang.String v, v, v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: net.schmizz.sshj.sftp.SFTPException; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001: \u0001"); return v; label: v = virtualinvoke v.(); return v; } protected net.schmizz.sshj.sftp.SFTPClient getSFTPClient(org.apache.nifi.flowfile.FlowFile) throws java.io.IOException { net.schmizz.sshj.sftp.SFTPEngine v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v; java.lang.Long v; java.util.Map v; net.schmizz.sshj.sftp.SFTPClient v, v, v, v, v, v; java.lang.Object[] v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.context.PropertyContext v, v, v, v, v, v, v, v; java.io.IOException v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.ssh.SSHClientProvider v; boolean v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v; net.schmizz.sshj.SSHClient v, v; org.apache.nifi.logging.ComponentLog v; int v; java.util.concurrent.TimeUnit v; org.apache.nifi.processors.standard.util.SFTPTransfer v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; 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.; 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; v = v.; v = staticinvoke (v, v); if v == 0 goto label; v = v.; v = staticinvoke (v, v); if v == 0 goto label; 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.; v = interfaceinvoke v.(v, v); v. = v; v = new net.schmizz.sshj.sftp.SFTPClient; v = new net.schmizz.sshj.sftp.SFTPEngine; v = v.; specialinvoke v.(net.schmizz.sshj.connection.channel.direct.SessionFactory)>(v); v = virtualinvoke v.(); specialinvoke v.(net.schmizz.sshj.sftp.SFTPEngine)>(v); v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = 0; v = v.; v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(""); v. = v; label: goto label; label: v := @caughtexception; v. = ""; v = v.; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; interfaceinvoke v.("Failed to retrieve home directory due to {}", v); label: v = v.; return v; catch java.io.IOException 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.SFTPTransfer v; java.lang.String v; org.apache.nifi.flowfile.FlowFile v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; virtualinvoke v.(v); v = v.; return v; } public void close() throws java.io.IOException { java.lang.Object[] v, v; org.apache.nifi.logging.ComponentLog v, v; java.lang.Exception v, v; net.schmizz.sshj.SSHClient v, v; net.schmizz.sshj.sftp.SFTPClient v, v; org.apache.nifi.processors.standard.util.SFTPTransfer v; java.lang.String v, v; boolean v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; 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)[1]; v = virtualinvoke v.(); v[0] = v; interfaceinvoke v.("Failed to close SFTPClient due to {}", v, v); label: v. = null; 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)[1]; v = virtualinvoke v.(); v[0] = v; interfaceinvoke v.("Failed to close SSHClient due to {}", v, v); label: v. = null; return; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; } public boolean isClosed() { org.apache.nifi.processors.standard.util.SFTPTransfer v; boolean v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v = v.; return v; } public org.apache.nifi.processors.standard.util.FileInfo getRemoteFileInfo(org.apache.nifi.flowfile.FlowFile, java.lang.String, java.lang.String) throws java.io.IOException { java.lang.Throwable v; org.apache.nifi.processors.standard.util.FileInfo v; net.schmizz.sshj.sftp.SFTPClient v; java.lang.String v, v, v, v; boolean v, v, v; java.util.Iterator v; org.apache.nifi.flowfile.FlowFile v; net.schmizz.sshj.sftp.RemoteResourceInfo v; java.io.IOException v; java.util.List v; net.schmizz.sshj.sftp.Response$StatusCode v, v; org.apache.nifi.processors.standard.util.SFTPTransfer v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(v); label: v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = ; if v != v goto label; return null; label: v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to obtain file listing for \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = null; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v; label: if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; return null; label: v = specialinvoke v.(v, v); return v; catch net.schmizz.sshj.sftp.SFTPException from label to label with label; } 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, v, v; net.schmizz.sshj.sftp.SFTPClient v; java.lang.Exception v, v, v; java.lang.Throwable v, v; java.lang.Object[] v, v, v; java.text.SimpleDateFormat v; net.schmizz.sshj.sftp.FileAttributes v, v; long v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.context.PropertyContext v, v, v, v, v, v; java.io.IOException v, v; net.schmizz.sshj.sftp.SFTPFileTransfer v, v; net.schmizz.sshj.sftp.FileAttributes$Builder v, v; java.util.Date v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v; java.util.Locale v; boolean v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.processors.standard.util.SFTPFlowFileSourceFile v; org.apache.nifi.logging.ComponentLog v, v, v; int v, v, v, v; java.lang.Boolean v; org.apache.nifi.processors.standard.util.SFTPTransfer v; java.io.InputStream v; v := @this: org.apache.nifi.processors.standard.util.SFTPTransfer; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.io.InputStream; v = virtualinvoke v.(v); if v != null goto label; v = v; goto label; label: 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; 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: if v != null goto label; v = v; goto label; label: v = virtualinvoke v.("/"); if v == 0 goto label; v = dynamicinvoke "makeConcatWithConstants" (v, v)