public class org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder extends java.lang.Object
{
private static final java.lang.String HOME_DIRECTORY;
private java.util.concurrent.atomic.AtomicReference sessionFactory;
private java.util.concurrent.CountDownLatch sessionFactorySetSignal;
private org.apache.nifi.processor.Relationship relationshipSuccess;
private java.lang.String bindAddress;
private int port;
private java.lang.String username;
private java.lang.String password;
private org.apache.nifi.ssl.SSLContextService sslContextService;
public void <init>()
{
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder sessionFactory(java.util.concurrent.atomic.AtomicReference)
{
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: java.util.concurrent.atomic.AtomicReference;
v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: java.util.concurrent.atomic.AtomicReference sessionFactory> = v;
return v;
}
public org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder sessionFactorySetSignal(java.util.concurrent.CountDownLatch)
{
java.util.concurrent.CountDownLatch v;
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: java.util.concurrent.CountDownLatch;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: java.util.concurrent.CountDownLatch sessionFactorySetSignal> = v;
return v;
}
public org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder relationshipSuccess(org.apache.nifi.processor.Relationship)
{
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
org.apache.nifi.processor.Relationship v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: org.apache.nifi.processor.Relationship;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: org.apache.nifi.processor.Relationship relationshipSuccess> = v;
return v;
}
public org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder bindAddress(java.lang.String)
{
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: java.lang.String;
v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: java.lang.String bindAddress> = v;
return v;
}
public org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder port(int)
{
int v;
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: int;
v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: int port> = v;
return v;
}
public org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder username(java.lang.String)
{
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: java.lang.String;
v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: java.lang.String username> = v;
return v;
}
public org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder password(java.lang.String)
{
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: java.lang.String;
v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: java.lang.String password> = v;
return v;
}
public org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder sslContextService(org.apache.nifi.ssl.SSLContextService)
{
org.apache.nifi.ssl.SSLContextService v;
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: org.apache.nifi.ssl.SSLContextService;
v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: org.apache.nifi.ssl.SSLContextService sslContextService> = v;
return v;
}
public org.apache.nifi.processors.standard.ftp.NifiFtpServer build() throws org.apache.nifi.processor.exception.ProcessException
{
java.util.concurrent.atomic.AtomicReference v;
org.apache.nifi.processor.exception.ProcessException v;
org.apache.nifi.processor.Relationship v;
java.util.Map v;
int v;
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
java.lang.String v, v, v, v;
org.apache.ftpserver.ConnectionConfig v;
org.apache.ftpserver.listener.Listener v;
boolean v;
org.apache.nifi.processors.standard.ftp.commands.CommandMapFactory v;
org.apache.nifi.ssl.SSLContextService v;
org.apache.nifi.processors.standard.ftp.NifiFtpServer v;
java.lang.Exception v;
java.util.concurrent.CountDownLatch v;
org.apache.nifi.processors.standard.ftp.filesystem.VirtualFileSystemFactory v;
org.apache.ftpserver.ftplet.User v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
label:
v = v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: java.lang.String username>;
if v != null goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = new org.apache.nifi.processors.standard.ftp.filesystem.VirtualFileSystemFactory;
specialinvoke v.<org.apache.nifi.processors.standard.ftp.filesystem.VirtualFileSystemFactory: void <init>()>();
v = new org.apache.nifi.processors.standard.ftp.commands.CommandMapFactory;
v = v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: java.util.concurrent.atomic.AtomicReference sessionFactory>;
v = v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: java.util.concurrent.CountDownLatch sessionFactorySetSignal>;
v = v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: org.apache.nifi.processor.Relationship relationshipSuccess>;
specialinvoke v.<org.apache.nifi.processors.standard.ftp.commands.CommandMapFactory: void <init>(java.util.concurrent.atomic.AtomicReference,java.util.concurrent.CountDownLatch,org.apache.nifi.processor.Relationship)>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.ftp.commands.CommandMapFactory: java.util.Map createCommandMap()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: org.apache.ftpserver.ConnectionConfig createConnectionConfig(boolean)>(v);
v = v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: java.lang.String bindAddress>;
v = v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: int port>;
v = v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: org.apache.nifi.ssl.SSLContextService sslContextService>;
v = specialinvoke v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: org.apache.ftpserver.listener.Listener createListener(java.lang.String,int,org.apache.nifi.ssl.SSLContextService)>(v, v, v);
v = v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: java.lang.String username>;
v = v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: java.lang.String password>;
v = specialinvoke v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: org.apache.ftpserver.ftplet.User createUser(java.lang.String,java.lang.String,java.lang.String)>(v, v, "/virtual/ftproot");
v = new org.apache.nifi.processors.standard.ftp.NifiFtpServer;
specialinvoke v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer: void <init>(java.util.Map,org.apache.ftpserver.ftplet.FileSystemFactory,org.apache.ftpserver.ConnectionConfig,org.apache.ftpserver.listener.Listener,org.apache.ftpserver.ftplet.User)>(v, v, v, v, v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.nifi.processor.exception.ProcessException;
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.String,java.lang.Throwable)>("FTP server could not be started.", v);
throw v;
catch java.lang.Exception from label to label with label;
}
private org.apache.ftpserver.ConnectionConfig createConnectionConfig(boolean)
{
org.apache.ftpserver.ConnectionConfigFactory v;
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
org.apache.ftpserver.ConnectionConfig v;
boolean v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: boolean;
v = new org.apache.ftpserver.ConnectionConfigFactory;
specialinvoke v.<org.apache.ftpserver.ConnectionConfigFactory: void <init>()>();
virtualinvoke v.<org.apache.ftpserver.ConnectionConfigFactory: void setAnonymousLoginEnabled(boolean)>(v);
v = virtualinvoke v.<org.apache.ftpserver.ConnectionConfigFactory: org.apache.ftpserver.ConnectionConfig createConnectionConfig()>();
return v;
}
private org.apache.ftpserver.listener.Listener createListener(java.lang.String, int, org.apache.nifi.ssl.SSLContextService) throws org.apache.ftpserver.FtpServerConfigurationException
{
org.apache.ftpserver.DataConnectionConfiguration v;
org.apache.ftpserver.DataConnectionConfigurationFactory v;
java.lang.String[] v;
int v;
org.apache.ftpserver.listener.ListenerFactory v;
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.ftpserver.listener.Listener v;
org.apache.ftpserver.ssl.SslConfiguration v;
org.apache.nifi.ssl.SSLContextService v;
org.apache.ftpserver.ssl.SslConfigurationFactory v;
java.io.File v, v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: org.apache.nifi.ssl.SSLContextService;
v = new org.apache.ftpserver.listener.ListenerFactory;
specialinvoke v.<org.apache.ftpserver.listener.ListenerFactory: void <init>()>();
virtualinvoke v.<org.apache.ftpserver.listener.ListenerFactory: void setServerAddress(java.lang.String)>(v);
virtualinvoke v.<org.apache.ftpserver.listener.ListenerFactory: void setPort(int)>(v);
if v == null goto label;
v = new org.apache.ftpserver.ssl.SslConfigurationFactory;
specialinvoke v.<org.apache.ftpserver.ssl.SslConfigurationFactory: void <init>()>();
v = new java.io.File;
v = interfaceinvoke v.<org.apache.nifi.ssl.SSLContextService: java.lang.String getKeyStoreFile()>();
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.ftpserver.ssl.SslConfigurationFactory: void setKeystoreFile(java.io.File)>(v);
v = interfaceinvoke v.<org.apache.nifi.ssl.SSLContextService: java.lang.String getKeyStorePassword()>();
virtualinvoke v.<org.apache.ftpserver.ssl.SslConfigurationFactory: void setKeystorePassword(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.nifi.ssl.SSLContextService: java.lang.String getKeyPassword()>();
virtualinvoke v.<org.apache.ftpserver.ssl.SslConfigurationFactory: void setKeyPassword(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.nifi.ssl.SSLContextService: java.lang.String getKeyStoreType()>();
virtualinvoke v.<org.apache.ftpserver.ssl.SslConfigurationFactory: void setKeystoreType(java.lang.String)>(v);
v = newarray (java.lang.String)[1];
v = interfaceinvoke v.<org.apache.nifi.ssl.SSLContextService: java.lang.String getSslAlgorithm()>();
v[0] = v;
virtualinvoke v.<org.apache.ftpserver.ssl.SslConfigurationFactory: void setSslProtocol(java.lang.String[])>(v);
v = interfaceinvoke v.<org.apache.nifi.ssl.SSLContextService: java.lang.String getTrustStoreFile()>();
if v == null goto label;
virtualinvoke v.<org.apache.ftpserver.ssl.SslConfigurationFactory: void setClientAuthentication(java.lang.String)>("NEED");
v = new java.io.File;
v = interfaceinvoke v.<org.apache.nifi.ssl.SSLContextService: java.lang.String getTrustStoreFile()>();
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.ftpserver.ssl.SslConfigurationFactory: void setTruststoreFile(java.io.File)>(v);
v = interfaceinvoke v.<org.apache.nifi.ssl.SSLContextService: java.lang.String getTrustStorePassword()>();
virtualinvoke v.<org.apache.ftpserver.ssl.SslConfigurationFactory: void setTruststorePassword(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.nifi.ssl.SSLContextService: java.lang.String getTrustStoreType()>();
virtualinvoke v.<org.apache.ftpserver.ssl.SslConfigurationFactory: void setTruststoreType(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.ftpserver.ssl.SslConfigurationFactory: org.apache.ftpserver.ssl.SslConfiguration createSslConfiguration()>();
virtualinvoke v.<org.apache.ftpserver.listener.ListenerFactory: void setSslConfiguration(org.apache.ftpserver.ssl.SslConfiguration)>(v);
virtualinvoke v.<org.apache.ftpserver.listener.ListenerFactory: void setImplicitSsl(boolean)>(1);
v = new org.apache.ftpserver.DataConnectionConfigurationFactory;
specialinvoke v.<org.apache.ftpserver.DataConnectionConfigurationFactory: void <init>()>();
virtualinvoke v.<org.apache.ftpserver.DataConnectionConfigurationFactory: void setImplicitSsl(boolean)>(1);
virtualinvoke v.<org.apache.ftpserver.DataConnectionConfigurationFactory: void setSslConfiguration(org.apache.ftpserver.ssl.SslConfiguration)>(v);
v = virtualinvoke v.<org.apache.ftpserver.DataConnectionConfigurationFactory: org.apache.ftpserver.DataConnectionConfiguration createDataConnectionConfiguration()>();
virtualinvoke v.<org.apache.ftpserver.listener.ListenerFactory: void setDataConnectionConfiguration(org.apache.ftpserver.DataConnectionConfiguration)>(v);
label:
v = virtualinvoke v.<org.apache.ftpserver.listener.ListenerFactory: org.apache.ftpserver.listener.Listener createListener()>();
return v;
}
private org.apache.ftpserver.ftplet.User createUser(java.lang.String, java.lang.String, java.lang.String)
{
org.apache.ftpserver.usermanager.impl.WritePermission v, v;
java.util.List v, v;
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
java.lang.String v, v, v;
org.apache.ftpserver.ftplet.User v, v;
boolean v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
if v != null goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v == 0 goto label;
v = new org.apache.ftpserver.usermanager.impl.WritePermission;
specialinvoke v.<org.apache.ftpserver.usermanager.impl.WritePermission: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: org.apache.ftpserver.ftplet.User createAnonymousUser(java.lang.String,java.util.List)>(v, v);
return v;
label:
v = new org.apache.ftpserver.usermanager.impl.WritePermission;
specialinvoke v.<org.apache.ftpserver.usermanager.impl.WritePermission: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder: org.apache.ftpserver.ftplet.User createNamedUser(java.lang.String,java.lang.String,java.lang.String,java.util.List)>(v, v, v, v);
return v;
}
private org.apache.ftpserver.ftplet.User createAnonymousUser(java.lang.String, java.util.List)
{
org.apache.ftpserver.usermanager.impl.BaseUser v;
java.util.List v;
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
java.lang.String v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v = new org.apache.ftpserver.usermanager.impl.BaseUser;
specialinvoke v.<org.apache.ftpserver.usermanager.impl.BaseUser: void <init>()>();
virtualinvoke v.<org.apache.ftpserver.usermanager.impl.BaseUser: void setName(java.lang.String)>("anonymous");
virtualinvoke v.<org.apache.ftpserver.usermanager.impl.BaseUser: void setHomeDirectory(java.lang.String)>(v);
virtualinvoke v.<org.apache.ftpserver.usermanager.impl.BaseUser: void setAuthorities(java.util.List)>(v);
return v;
}
private org.apache.ftpserver.ftplet.User createNamedUser(java.lang.String, java.lang.String, java.lang.String, java.util.List)
{
org.apache.ftpserver.usermanager.impl.BaseUser v;
java.util.List v;
org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder v;
java.lang.String v, v, v;
v := @this: org.apache.nifi.processors.standard.ftp.NifiFtpServer$Builder;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v = new org.apache.ftpserver.usermanager.impl.BaseUser;
specialinvoke v.<org.apache.ftpserver.usermanager.impl.BaseUser: void <init>()>();
virtualinvoke v.<org.apache.ftpserver.usermanager.impl.BaseUser: void setName(java.lang.String)>(v);
virtualinvoke v.<org.apache.ftpserver.usermanager.impl.BaseUser: void setPassword(java.lang.String)>(v);
virtualinvoke v.<org.apache.ftpserver.usermanager.impl.BaseUser: void setHomeDirectory(java.lang.String)>(v);
virtualinvoke v.<org.apache.ftpserver.usermanager.impl.BaseUser: void setAuthorities(java.util.List)>(v);
return v;
}
}