Subversion Repositories bacoAlunos

package pt.estgp.estgweb.web;

import jomm.utils.DesUtils;

import jomm.utils.MimeTypeGuesser;

import jomm.utils.StreamsUtils;

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

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

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

import org.apache.log4j.Logger;

import pt.estgp.estgweb.domain.UserSession;

import pt.estgp.estgweb.domain.UserSessionImpl;

import pt.estgp.estgweb.services.ftpservices.FtpService;

import pt.estgp.estgweb.utils.ConfigProperties;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import java.io.IOException;

import java.io.InputStream;

/**

 * @author Jorge Machado

 * @date 26/Fev/2008

 * @time 12:46:16

 * @see pt.estgp.estgweb.web

 */

public class FTPFileProxy extends HttpServlet {

    /** sss requests for both HTTP <code>GET</code> and <code>POST</code> methods.

     * @param request servlet request

     * @param response servlet response

     */

    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(FTPFileProxy.class);

    protected void processRequest(HttpServletRequest request, HttpServletResponse response)

            throws ServletException, 1.5.0/docs/api/java/io/IOException.html">IOException

    {

        1.5.0/docs/api/java/lang/String.html">String objectRequired = request.getPathInfo();

        objectRequired = objectRequired.substring(1);

        1.5.0/docs/api/java/lang/String.html">String server = objectRequired.substring(0,objectRequired.indexOf("/"));

        1.5.0/docs/api/java/lang/String.html">String path = objectRequired.substring(objectRequired.indexOf("/"));

        UserSession userSession = UserSessionProxy.loadUserSessionFromRequest(request);

        1.5.0/docs/api/java/lang/String.html">String username = ConfigProperties.getProperty(server + ".user");

        1.5.0/docs/api/java/lang/String.html">String passwordUserInSession = ConfigProperties.getProperty(server + ".pass");

        boolean useDefaultCredentialsRead = ConfigProperties.getBooleanProperty(server + ".use.default.credentials.to.read");

        if(!useDefaultCredentialsRead)

        {

            1.5.0/docs/api/java/lang/String.html">String passwordUserInSessionCript = (1.5.0/docs/api/java/lang/String.html">String) ((UserSessionImpl)userSession).get(FtpService.FTP_PASSWORD);

            if(passwordUserInSession == null || userSession.getUser() == null)

            {

                logger.warn("There is no user authenticated, is configured to use not default credentials, but will use default password for server " + server);

            }

            else

            {

                username = userSession.getUsername();

                passwordUserInSession = DesUtils.getInstance().decrypt(passwordUserInSessionCript);

                logger.warn("Will use User Credentials for server " + server + " and user " + username);

            }

        }

        if(username == null || passwordUserInSession == null)

        {

           response.sendError(401);

           return;

        }

        if(path != null)

        {

            server = pt.estgp.estgweb.utils.ConfigProperties.getProperty("server." + server);

            1.5.0/docs/api/java/lang/String.html">String remoteName = path.substring(path.lastIndexOf("/")+1);

            1.5.0/docs/api/java/lang/String.html">String remoteDirectory = path.substring(0,path.lastIndexOf("/"));

            FtpServer ftpServer = FtpServer.getNewServer(server,username,passwordUserInSession);

            FTPClient client = null;

            try

            {

                client = ftpServer.getClient();

                if(client == null)

                {

                    logger.warn("###################");

                    logger.warn("################### > CANT CONNECT FTP");

                    response.sendError(408);

                    return;

                }

                client.changeWorkingDirectory(remoteDirectory);

                FTPFile[] files = client.listFiles();

                boolean found = false;

                for (FTPFile file : files) {

                    if (!file.isFile() || !file.getName().equals(remoteName)) {

                        continue;

                    }

                    found = true;

                    client.setFileType(FTP.BINARY_FILE_TYPE);

                    5+0%2Fdocs%2Fapi+InputStream">InputStream stream = client.retrieveFileStream(file.getName());

                    response.setContentLength((int)file.getSize());

                    response.setContentType(MimeTypeGuesser.getInstance().guessMimeType(file.getName()));

                    response.setHeader("Content-disposition","inline; filename=" + file.getName());

                    StreamsUtils.inputStream2OutputStream(stream, response.getOutputStream());

                    stream.close();

                }

                logger.info("Quiting Proxy");

                client.quit();

                client.disconnect();

                logger.info("Finnish Proxy");

                if(!found)

                {

                    response.sendError(404);

                    return;

                }

            }

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

            {

                if(client != null && client.isConnected())

                {

                    client.quit();

                    client.disconnect();

                }

                response.sendError(404);

                return;

            }

            finally {

                if(client != null && client.isConnected())

                {

                    client.quit();

                    client.disconnect();

                }

            }

            logger.info("Closing");

        }

    }

    // <editor-fold defaultstate="collapsed" desc="HttpServlet methods. Click on the + sign on the left to edit the code.">

    /** Handles the HTTP <code>GET</code> method.

     * @param request servlet request

     * @param response servlet response

     */

    protected void doGet(HttpServletRequest request, HttpServletResponse response)

            throws ServletException, 1.5.0/docs/api/java/io/IOException.html">IOException {

        processRequest(request, response);

    }

    /** Handles the HTTP <code>POST</code> method.

     * @param request servlet request

     * @param response servlet response

     */

    protected void doPost(HttpServletRequest request, HttpServletResponse response)

            throws ServletException, 1.5.0/docs/api/java/io/IOException.html">IOException {

        processRequest(request, response);

    }

    /** Returns a short description of the servlet.

     */

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

        return "Proxy Servlet to get pages form static web page servers";

    }

    // </editor-fold>

}