Subversion Repositories bacoAlunos

package pt.estgp.estgweb.web;

import org.apache.commons.net.ftp.FTPClient;

import org.apache.log4j.Logger;

import pt.estgp.estgweb.domain.UserSession;

import pt.estgp.estgweb.domain.UserSessionImpl;

import javax.servlet.http.HttpServletRequest;

import java.io.IOException;

import java.io.InputStream;

import java.net.MalformedURLException;

import java.net.URL;

import java.util.HashMap;

/**

 * @author Jorge

 * @date 18/Jan/2009

 * @time 18:35:11

 */

public class FtpServer

{

    private static final 1.5.0/docs/api/java/util/logging/Logger.html">Logger logger = 1.5.0/docs/api/java/util/logging/Logger.html">Logger.getLogger(FtpServer.class);

    private static HashMap<String, FtpServer> servers = new HashMap<String, FtpServer>();

    1.5.0/docs/api/java/lang/String.html">String host = null;

    int port = 21;

    1.5.0/docs/api/java/lang/String.html">String username = null;

    1.5.0/docs/api/java/lang/String.html">String password = null;

    1.5.0/docs/api/java/lang/String.html">String errorMsg = "";

    public FtpServer(1.5.0/docs/api/java/lang/String.html">String host, int port)

    {

        this.host = host;

        if (port > 0)

            this.port = port;

    }

    public FtpServer(1.5.0/docs/api/java/lang/String.html">String host, int port, 1.5.0/docs/api/java/lang/String.html">String username, 1.5.0/docs/api/java/lang/String.html">String password)

    {

        this.host = host;

        this.port = port;

        this.username = username;

        this.password = password;

    }

    public static FtpServer getFtpServerForCurrentUser(1.5.0/docs/api/java/lang/String.html">String urlStr, HttpServletRequest request) throws 1.5.0/docs/api/java/net/MalformedURLException.html">MalformedURLException

    {

        1.5.0/docs/api/java/net/URL.html">URL url = new 1.5.0/docs/api/java/net/URL.html">URL(urlStr);

        int port = url.getPort();

        if (port <= 0)

            port = 21;

        1.5.0/docs/api/java/lang/String.html">String host = url.getHost();

        UserSession userSession = UserSessionProxy.loadUserSessionFromRequest(request);

        1.5.0/docs/api/java/lang/String.html">String username = userSession.getUsername();

        1.5.0/docs/api/java/lang/String.html">String password = ((UserSessionImpl)userSession).getUserPasswordInSession();

        return new FtpServer(host,port,username,password);

    }

    private static final int FTP_TIMEOUT_SECONDS = pt.estgp.estgweb.Globals.FTP_TIMEOUT_SECONDS;

    public FTPClient getClient() throws 1.5.0/docs/api/java/io/IOException.html">IOException

    {

        errorMsg = null;

        final FTPClient ftp = new MyFTPClient();

        logger.info("CONNECTING... waiting " + FTP_TIMEOUT_SECONDS + " seconds");

        1.5.0/docs/api/java/lang/Thread.html">Thread t = new 1.5.0/docs/api/java/lang/Thread.html">Thread(new 1.5.0/docs/api/java/lang/Runnable.html">Runnable() {

            @1.5.0/docs/api/java/lang/Override.html">Override

            public void run() {

                try {

                    ftp.connect(host, port);

                } catch (1.5.0/docs/api/java/io/IOException.html">IOException e) {

                    logger.error(e,e);

                }

            }

        });

        t.start();

        try {

            for(int i=0;i<FTP_TIMEOUT_SECONDS;i++)

            {

                1.5.0/docs/api/java/lang/Thread.html">Thread.sleep(1000);

                if(!t.isAlive())

                {

                    if(ftp.isConnected())

                        break;

                }

            }

            if(!ftp.isConnected())

            {

                errorMsg = "errors.ftp.timeout";

                logger.info("Not Connected will interrupt");

                t.interrupt();

                return null;

            }

        } catch (1.5.0/docs/api/java/lang/InterruptedException.html">InterruptedException e) {

           logger.error(e,e);

           errorMsg = "errors.ftp.interrupt";

        }

        if (username != null && password != null)

        {

            if(ftp.login(username,password))

            {

                return ftp;

            }

            else

            {

                errorMsg = "errors.ftp.no.permission";

                logger.warn("Cant login user: " + username);

            }

        }

        if(errorMsg == null)

            errorMsg = "errors.ftp.unknown.error";

        return null;

        /* estava assim

        if (username != null)

            ftp.user(username);

        if (password != null)

            ftp.pass(password);*/

        //return ftp;

    }

    public 1.5.0/docs/api/java/lang/String.html">String getErrorMsg() {

        return errorMsg;

    }

    public 1.5.0/docs/api/java/lang/String.html">String getHost()

    {

        return host;

    }

    public void setHost(1.5.0/docs/api/java/lang/String.html">String host)

    {

        this.host = host;

    }

    public int getPort()

    {

        return port;

    }

    public void setPort(int port)

    {

        this.port = port;

    }

    public 1.5.0/docs/api/java/lang/String.html">String getUsername()

    {

        return username;

    }

    public void setUsername(1.5.0/docs/api/java/lang/String.html">String username)

    {

        this.username = username;

    }

    public 1.5.0/docs/api/java/lang/String.html">String getPassword()

    {

        return password;

    }

    public void setPassword(1.5.0/docs/api/java/lang/String.html">String password)

    {

        this.password = password;

    }

    public static FtpServer getServer(1.5.0/docs/api/java/lang/String.html">String urlStr, 1.5.0/docs/api/java/lang/String.html">String user, 1.5.0/docs/api/java/lang/String.html">String pass)

    {

        FtpServer ftpServer = servers.get(urlStr);

        if (ftpServer == null)

            ftpServer = addServer(urlStr, user, pass);

        return ftpServer;

    }

    public static FtpServer getNewServer(1.5.0/docs/api/java/lang/String.html">String urlStr, 1.5.0/docs/api/java/lang/String.html">String user, 1.5.0/docs/api/java/lang/String.html">String pass)

    {

        try

        {

            1.5.0/docs/api/java/net/URL.html">URL url = new 1.5.0/docs/api/java/net/URL.html">URL(urlStr);

            1.5.0/docs/api/java/lang/String.html">String host = url.getHost();

            int port = url.getPort();

            if (port <= 0)

                port = 21;

            logger.info("Connecting to " + host + "in port:" + port);

            return new FtpServer(host, port, user, pass);

        }

        catch (1.5.0/docs/api/java/net/MalformedURLException.html">MalformedURLException e)

        {

            logger.error(e, e);

        }

        catch (1.5.0/docs/api/java/io/IOException.html">IOException e)

        {

            logger.error(e, e);

        }

        return null;

    }

    /**

     * Add a ftpServer to Cache

     *

     * @param urlStr to parse

     * @param user   username

     * @param pass   password

     * @return ftpServer

     */

    private static synchronized FtpServer addServer(1.5.0/docs/api/java/lang/String.html">String urlStr, 1.5.0/docs/api/java/lang/String.html">String user, 1.5.0/docs/api/java/lang/String.html">String pass)

    {

        try

        {

            1.5.0/docs/api/java/net/URL.html">URL url = new 1.5.0/docs/api/java/net/URL.html">URL(urlStr);

            1.5.0/docs/api/java/lang/String.html">String host = url.getHost();

            int port = url.getPort();

            if (port <= 0)

                port = 21;

            logger.info("Connecting to " + host + " in port:" + port);

            FtpServer ftpServer = new FtpServer(host, port, user, pass);

            servers.put(urlStr, ftpServer);

            return ftpServer;

        }

        catch (1.5.0/docs/api/java/net/MalformedURLException.html">MalformedURLException e)

        {

            logger.error(e, e);

        }

        catch (1.5.0/docs/api/java/io/IOException.html">IOException e)

        {

            logger.error(e, e);

        }

        return null;

    }

    public static final int FTP_DATA_STORE_TIMEOUT_SECONDS = pt.estgp.estgweb.Globals.FTP_DATA_STORE_TIMEOUT_SECONDS;

    public class MyFTPClient extends FTPClient implements 1.5.0/docs/api/java/lang/Runnable.html">Runnable

    {

        1.5.0/docs/api/java/lang/String.html">String remote = "";

        5+0%2Fdocs%2Fapi+InputStream">InputStream local = null;

        boolean storeResult = false;

        public void run() {

            try {

                storeResult = super.storeFile(remote, local);

            } catch (1.5.0/docs/api/java/io/IOException.html">IOException e) {

                logger.error(e,e);

            }

        }

        @1.5.0/docs/api/java/lang/Override.html">Override

        public boolean storeFile(1.5.0/docs/api/java/lang/String.html">String remote, 5+0%2Fdocs%2Fapi+InputStream">InputStream local) throws 1.5.0/docs/api/java/io/IOException.html">IOException

        {

            logger.info("FTP store Timeout protection of " + FTP_DATA_STORE_TIMEOUT_SECONDS + " seconds");

            this.remote = remote;

            this.local = local;

            1.5.0/docs/api/java/lang/Thread.html">Thread t = new 1.5.0/docs/api/java/lang/Thread.html">Thread(this);

            t.start();

            try {

                for(int i=0;i<FTP_DATA_STORE_TIMEOUT_SECONDS;i++)

                {

                    1.5.0/docs/api/java/lang/Thread.html">Thread.sleep(1000);

                    if(!t.isAlive())

                    {

                       break;

                    }

                }

                if(t.isAlive())

                {

                    logger.info("Timeout expired will interrupt");

                    t.interrupt();

                    return false;

                }

            } catch (1.5.0/docs/api/java/lang/InterruptedException.html">InterruptedException e) {

                logger.error(e,e);

            }

            return storeResult;

        }

    }

}