Subversion Repositories bacoAlunos

package pt.estgp.estgweb.web;

import jomm.web.ftp.FileType;

import jomm.web.ftp.IFile;

import jomm.web.ftp.impl.FtpFile;

import org.apache.commons.httpclient.util.URIUtil;

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 org.dom4j.Document;

import org.dom4j.DocumentException;

import org.dom4j.Element;

import pt.estgp.estgweb.domain.UserSession;

import pt.estgp.estgweb.utils.ConfigProperties;

import pt.estgp.estgweb.utils.Dom4jUtil;

import pt.estgp.estgweb.web.exceptions.NotAuthorizedException;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.servlet.jsp.JspWriter;

import java.io.*;

import java.net.*;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.zip.GZIPInputStream;

import java.util.zip.InflaterInputStream;

import java.util.zip.ZipInputStream;

/**

 * @author Jorge Machado

 * @date 26/Fev/2008

 * @time 12:46:16

 * @see pt.estgp.estgweb.web

 */

public class DirWebProxy extends HttpServlet

{

    public static final 1.5.0/docs/api/java/lang/String.html">String FTP_ACTUAL_PATH_KEY = "pt.estgp.estgweb.web.DirWebProxy.FTP_ACTUAL_PATH_KEY";

    /**

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

    protected static 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 element = (1.5.0/docs/api/java/lang/String.html">String) request.getAttribute("element");

        if (element.equals("node"))

        {

            processNode(request, response);

        }

        else

        {

            processLeaf(request, response);

        }

    }

    /**

     * @param request

     * @param response

     * @throws ServletException

     * @throws IOException

     */

    protected static void processNode(HttpServletRequest request, HttpServletResponse response)

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

    {

        styleDirectory(request, response);

    }

    protected static void processLeaf(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 path = (1.5.0/docs/api/java/lang/String.html">String) request.getAttribute("path");

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

        1.5.0/docs/api/java/lang/String.html">String leafUrl = (1.5.0/docs/api/java/lang/String.html">String) request.getAttribute("leaf.url");

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

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

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

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

        1.5.0/docs/api/java/lang/String.html">String proxyHost = (1.5.0/docs/api/java/lang/String.html">String) request.getAttribute("proxy.host");

        1.5.0/docs/api/java/lang/String.html">String proxyPort = (1.5.0/docs/api/java/lang/String.html">String) request.getAttribute("proxy.port");

        boolean style = 1.5.0/docs/api/java/lang/Boolean.html">Boolean.parseBoolean((1.5.0/docs/api/java/lang/String.html">String) request.getAttribute("style"));

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

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

        logger.info("server:" + server);

        logger.info("path:" + path);

        logger.info("startPath:" + startPath);

        logger.info("proxyKey:" + proxyKey);

        logger.info("proxyHost:" + proxyHost);

        logger.info("proxyPort:" + proxyPort);

        logger.info("xml:" + xml);

        logger.info("style:" + style);

        logger.info("label:" + label);

        logger.info("useOutputStream:" + useOutputStream);

        if (path != null)

        {

            try

            {

                5+0%2Fdocs%2Fapi+Proxy">Proxy proxy = null;

                if (proxyHost != null && proxyHost.length() > 0)

                {

                    proxy = new 5+0%2Fdocs%2Fapi+Proxy">Proxy(5+0%2Fdocs%2Fapi+Proxy">Proxy.1.5.0/docs/api/java/lang/reflect/Type.html">Type.HTTP, new 1.5.0/docs/api/java/net/InetSocketAddress.html">InetSocketAddress(proxyHost, 1.5.0/docs/api/java/lang/Integer.html">Integer.parseInt(proxyPort)));

                }

                if (!server.startsWith("ftp://"))

                {

                    if(path.equals(startPath) )

                        path += leafUrl;

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

                    if(leafUrl.indexOf("?")>0)

                        finalURL = server + leafUrl;

                    else

                        finalURL = server + URIUtil.encodePath(path, "ISO-8859-1");

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

                    if (useOutputStream != null && useOutputStream.equals("true"))

                    {

                        5+0%2Fdocs%2Fapi+InputStream">InputStream stream = openStream(finalURL, proxy);

                        1.5.0/docs/api/java/net/URLConnection.html">URLConnection con = url.openConnection();

                        response.setContentType(con.getContentType());

                        if (xml == null || xml.equals("false"))

                            response.setCharacterEncoding(encoding);

                        response.setContentLength(con.getContentLength());

                        writeDirectStream(response, stream);

                    }

                    else if (xml == null || xml.equals("false"))

                    {

                        5+0%2Fdocs%2Fapi+InputStream">InputStream stream = openStream(finalURL, proxy);

                        1.5.0/docs/api/java/lang/String.html">String content = readContent2String(stream, encoding);

                        generateOutputLeaf(response, request, content, style);

                    }

                    else

                    {

                        1.5.0/docs/api/java/net/URLConnection.html">URLConnection con = new 1.5.0/docs/api/java/net/URL.html">URL(finalURL).openConnection();

                        con.connect();

                        if (con.getContentLength() > 0)

                        {

//                      Document dom = Dom4jUtil.parse(stream);

                            generateOutputLeafXml(response, request, finalURL, proxy, style);

                        }

                    }

                }

                else

                {

                    5+0%2Fdocs%2Fapi+Document">Document directoryDocument = (5+0%2Fdocs%2Fapi+Document">Document) request.getAttribute("directoryDocument");

                    if(leafUrl != null && leafUrl.length() > 0)

                    {

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

                        if(startPath != null)

                        {

                            endPath = path.substring(startPath.length());

                        }

                        if(leafUrl.endsWith("/") && endPath.startsWith("/"))

                        {

                            path = startPath + leafUrl.substring(0,leafUrl.length()-1) + endPath;

                        }

                        else

                            path = startPath + leafUrl + endPath;

                    }

                    if(!extendDiretoryDocument(request, response, path, proxyKey, server, startPath + leafUrl, directoryDocument))

                        return;

                    styleDirectory(request, response);

                }

            }

            catch (NotAuthorizedException e)

            {

                UserSession userSession = UserSessionProxy.loadUserSessionFromRequest(request);

                1.5.0/docs/api/java/lang/String.html">String username = userSession != null ? userSession.getUsername() : "UNKNOWN";

                logger.warn(username + ":" + request.getRemoteAddr() + " cant access this area server:" + server + " and path:" + path + " " + request.getRemoteUser() + " " + request.getRequestURL() + " spath " + request.getServletPath() + " queryString " + request.getQueryString() ,e);

                response.sendError(401);

            }

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

            {

                logger.warn("url not found for server:" + server + " and path:" + path + " " + "REMOTE USER" + request.getRemoteUser() + " " + request.getRequestURL());

                response.sendError(404);

            }

            catch (1.5.0/docs/api/java/lang/Exception.html">Exception e)

            {

                logger.error(e, e);

                throw new 1.5.0/docs/api/java/io/IOException.html">IOException(e.toString());

            }

        }

        else

        {

            logger.warn("url not found for server:" + server + " and path:" + path);

            response.sendError(404);

        }

    }

    public static 1.5.0/docs/api/java/lang/String.html">String FTP_FILE_PREFIX = "FTP_";

    public static void addAttribute(5+0%2Fdocs%2Fapi+Element">Element element, 1.5.0/docs/api/java/lang/String.html">String name, 1.5.0/docs/api/java/lang/String.html">String value)

    {

        element.addAttribute(name, value);

    }

    protected static boolean extendDiretoryDocument(HttpServletRequest request,HttpServletResponse response, 1.5.0/docs/api/java/lang/String.html">String path, 1.5.0/docs/api/java/lang/String.html">String server, 1.5.0/docs/api/java/lang/String.html">String serverUrl, 1.5.0/docs/api/java/lang/String.html">String startPath, 5+0%2Fdocs%2Fapi+Document">Document directoryDocument)

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

    {

        try

        {

            UserSession userSession = UserSessionProxy.loadUserSessionFromRequest(request);

            FTPFileProxy.UserCredentialsForFtp u = FTPFileProxy.getUserCredentialsForFtp(server, userSession);

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

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

            if(username == null || password == null) //NAO PODE LIGAR

            {

                response.sendError(401);

                return false;

            }

            if (path != null)

            {

                FtpServer ftpServer = FtpServer.getServer(serverUrl, username, password);

                FTPClient client = FTPFileProxy.getFtpClient(ftpServer, userSession, server, serverUrl);

                if(client == null)

                {

                    return false;

                }

                5+0%2Fdocs%2Fapi+Element">Element actualNode = (5+0%2Fdocs%2Fapi+Element">Element) request.getAttribute("actualNode");

                if(startPath.equals("/"))

                    startPath = "";

                request.setAttribute(FTP_ACTUAL_PATH_KEY,startPath);

                if (path.equals(startPath))

                {

                    if(!client.changeWorkingDirectory(path))

                    {

                        throw new NotAuthorizedException();

                    }

                    FTPFile[] files = client.listFiles();

                    List<IFile> iFiles = FtpFile.init(files, serverUrl, path);

                    //root

                    for (IFile iFile : iFiles)

                    {

                        5+0%2Fdocs%2Fapi+Element">Element iFileElem = actualNode.addElement("leaf");

                        addAttribute(iFileElem, "node", "false");

                        addAttribute(iFileElem, "id", FTP_FILE_PREFIX + "0_" + iFile.getName());

                        addAttribute(iFileElem, "idPrefixSize","" +  (FTP_FILE_PREFIX + "0_").length());

                        addAttribute(iFileElem, "label", iFile.getName());

                        addAttribute(iFileElem, "visualization", "filesystem");

                        addAttribute(iFileElem, "size", "" + iFile.getSize());

                        addAttribute(iFileElem, "lastModification", "" + iFile.getLastUpdate().toString());

                        if (iFile.getType() == FileType.DIRECTORY)

                        {

                            addAttribute(iFileElem, "ftpDirectory", "true");

                        }

                        else

                        {

                            addAttribute(iFileElem, "extension", iFile.getExtension());

                            addAttribute(iFileElem, "ftpDirectory", "false");

                            addAttribute(iFileElem, "absolute", "true");

                            addAttribute(iFileElem, "url", iFile.getCompleteUrl());

                        }

                    }

                }

                else

                {

                    1.5.0/docs/api/java/lang/String.html">String pathAux = path.substring(startPath.length());

                    1.5.0/docs/api/java/lang/String.html">String[] pathFragments;

                    if(pathAux.startsWith("/"))

                        pathFragments = pathAux.substring(1).split("/");

                    else

                        pathFragments = pathAux.split("/");

                     if(!client.changeWorkingDirectory(startPath))

                    {

                        throw new NotAuthorizedException();

                    }

                    FTPFile[] files = client.listFiles();

                    List<IFile> iFiles = FtpFile.init(files, serverUrl, path);

                    5+0%2Fdocs%2Fapi+Element">Element goDeepElement = null;

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

                    for (IFile iFile : iFiles)

                    {

                        5+0%2Fdocs%2Fapi+Element">Element iFileElem = actualNode.addElement("leaf");

                        addAttribute(iFileElem, "node", "true");

                        addAttribute(iFileElem, "id", FTP_FILE_PREFIX + "0_" + iFile.getName());

                        addAttribute(iFileElem, "idPrefixSize","" +  (FTP_FILE_PREFIX + "0_").length());

                        addAttribute(iFileElem, "label", iFile.getName());

                        addAttribute(iFileElem, "visualization", "filesystem");

                        addAttribute(iFileElem, "size", "" + iFile.getSize());

                        addAttribute(iFileElem, "lastModification", "" + iFile.getLastUpdate().toString());

                        if (iFile.getType() == FileType.DIRECTORY)

                        {

                            addAttribute(iFileElem, "ftpDirectory", "true");

                        }

                        else

                        {

                            addAttribute(iFileElem, "extension", iFile.getExtension());

                            addAttribute(iFileElem, "ftpDirectory", "false");

                            addAttribute(iFileElem, "absolute", "true");

                            addAttribute(iFileElem, "url", iFile.getCompleteUrl());

                        }

                        if (iFile.getName().equals(pathFragments[0]))

                        {

                            actualId = FTP_FILE_PREFIX + "0_" + iFile.getName();

                            goDeepElement = iFileElem;

                        }

                    }

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

                    for (int i = 0; i < pathFragments.length; i++)

                    {

                        5+0%2Fdocs%2Fapi+Element">Element nextGoDeepElement = null;

                        1.5.0/docs/api/java/lang/String.html">String d = pathFragments[i];

                        startPathAux = startPathAux + "/" + d;

                        if(!client.changeWorkingDirectory(startPathAux))

                        {

                            throw new NotAuthorizedException();

                        }

                        files = client.listFiles();

                        iFiles = FtpFile.init(files, serverUrl, path);

                        for (IFile iFile : iFiles)

                        {

                            5+0%2Fdocs%2Fapi+Element">Element iFileElem;

                            if(i == pathFragments.length - 1)

                            {

                                iFileElem = goDeepElement.addElement("leaf");

                                addAttribute(iFileElem, "node","false");

                            }

                            else

                            {

                                iFileElem = goDeepElement.addElement("leaf");

                                addAttribute(iFileElem, "node","true");

                            }

                            addAttribute(iFileElem, "id", FTP_FILE_PREFIX + (i+1) + "_" + iFile.getName());

                            addAttribute(iFileElem, "idPrefixSize","" +  (FTP_FILE_PREFIX + (i+1) + "_").length());

                            addAttribute(iFileElem, "label", iFile.getName());

                            addAttribute(iFileElem, "visualization", "filesystem");

                            addAttribute(iFileElem, "size", "" + iFile.getSize());

                            addAttribute(iFileElem, "lastModification", "" + iFile.getLastUpdate().toString());

                            if (iFile.getType() == FileType.DIRECTORY)

                            {

                                addAttribute(iFileElem, "ftpDirectory", "true");

                            }

                            else

                            {

                                addAttribute(iFileElem, "extension", iFile.getExtension());

                                addAttribute(iFileElem, "ftpDirectory", "false");

                                addAttribute(iFileElem, "absolute", "true");

                                addAttribute(iFileElem, "url", iFile.getCompleteUrl());

                            }

                            if (i < pathFragments.length - 1 && iFile.getName().equals(pathFragments[i + 1]))

                            {

                                nextGoDeepElement = iFileElem;

                                actualId = FTP_FILE_PREFIX + (i+1) + "_" + iFile.getName();

                            }

                        }

                        goDeepElement = nextGoDeepElement;

                    }

                    request.setAttribute("ACTUAL_REMOTE_CHILD",actualId);

                }

                client.quit();

                client.disconnect();

            }

            else

            {

                throw new 1.5.0/docs/api/java/io/FileNotFoundException.html">FileNotFoundException("url not found for server:" + serverUrl + " and path:" + path);

            }

        }

        catch (1.5.0/docs/api/java/lang/Throwable.html">Throwable e)

        {

            if(e instanceof NotAuthorizedException)

                throw (NotAuthorizedException)e;

            logger.error(e, e);

        }

        return true;

    }

    private static void generateOutputLeafXml(HttpServletResponse response, HttpServletRequest request, 1.5.0/docs/api/java/lang/String.html">String finalURL, 5+0%2Fdocs%2Fapi+Proxy">Proxy proxy, boolean style) throws 1.5.0/docs/api/java/io/IOException.html">IOException, DocumentException

    {

        if (style)

        {

            Map<String, Object> parameters = new HashMap<String, Object>();

//            OutputFormat outputFormat = new OutputFormat();

//            outputFormat.setSuppressDeclaration(true);

//            outputFormat.setEncoding("UTF-8");

//            StringWriter writer = new StringWriter();

//            Dom4jUtil.write(dom,writer, outputFormat);

//            org.w3c.dom.Document d = new org.dom4j.io.DOMWriter().write(dom);

//            parameters.put("body",dom.selectSingleNode("/"));

            parameters.put("includeXML", finalURL);

            styleDirectory(request, response, parameters, null);

        }

        else

        {

            5+0%2Fdocs%2Fapi+InputStream">InputStream stream = openStream(finalURL, proxy);

            5+0%2Fdocs%2Fapi+Document">Document dom = Dom4jUtil.parse(stream);

            Dom4jUtil.write(dom, response.getWriter());

        }

    }

    private static void generateOutputLeaf(HttpServletResponse response, HttpServletRequest request, 1.5.0/docs/api/java/lang/String.html">String content, boolean style) throws 1.5.0/docs/api/java/io/IOException.html">IOException

    {

        if (style)

        {

//            Map<String,Object> parameters = new HashMap<String,Object>();

//            parameters.put("body",content);

            styleDirectory(request, response, new HashMap<String, Object>(), content);

        }

        else

        {

            response.getWriter().write(content);

        }

    }

    private static void styleDirectory(HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/io/IOException.html">IOException

    {

        styleDirectory(request, response, new HashMap<String, Object>(), null);

    }

//    private static String normalizeXmlId(String id)

//    {

//        StringBuilder strBuilder = new StringBuilder();

//        strBuilder.append('_');

//        for(int i = 0; i < id.length();i++)

//        {

//            char c = id.charAt(i);

//            if((c >= 'a' && c <= 'z') || (c >= 'A' && c <= 'Z') || (c >= '0' && c <= '9'))

//            {

//                strBuilder.append(c);

//            }

//            else

//            {

//                strBuilder.append('.');

//            }

//        }

//        return strBuilder.toString();

//    }

    private static void styleDirectory(HttpServletRequest request, HttpServletResponse response, Map<String, Object> parameters, 1.5.0/docs/api/java/lang/String.html">String bodyContent) throws 1.5.0/docs/api/java/io/IOException.html">IOException

    {

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

        5+0%2Fdocs%2Fapi+Document">Document directoryDocument = (5+0%2Fdocs%2Fapi+Document">Document) request.getAttribute("directoryDocument");

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

        1.5.0/docs/api/java/lang/String.html">String actualRemoteNodeId = (1.5.0/docs/api/java/lang/String.html">String) request.getAttribute("ACTUAL_REMOTE_CHILD");

        UserSession userSession = UserSessionProxy.loadUserSessionFromRequest(request);

        1.5.0/docs/api/java/lang/System.html">System.out.println("Using stylesheet = " + stylesheet);

        parameters.put("contextPath", request.getContextPath());

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

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

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

        if (userSession != null && userSession.getUsername() != null)

            username = userSession.getUsername();

        if (userSession != null && userSession.getName() != null)

            name = userSession.getName();

        if (userSession != null && userSession.getUser() != null)

            roles = userSession.getUser().getRoles();

        parameters.put("username", username);

        parameters.put("name", name);

        parameters.put("roles", roles);

        parameters.put("ACTUAL", actualNodeId);

        parameters.put("ACTUAL_REMOTE_CHILD", actualRemoteNodeId);

        try

        {

            1.5.0/docs/api/java/lang/String.html">String html = Dom4jUtil.styleDocument(directoryDocument, stylesheet, parameters);

            if (bodyContent != null)

                html = html.replace("@@BODY_CONTENT@@", bodyContent);

            response.getWriter().write(html);

        }

        catch (1.5.0/docs/api/java/lang/Exception.html">Exception e)

        {

            logger.error(e, e);

            response.sendError(500);

        }

    }

    private static 1.5.0/docs/api/java/lang/String.html">String readContent2String(5+0%2Fdocs%2Fapi+InputStream">InputStream stream, 1.5.0/docs/api/java/lang/String.html">String encoding) throws 1.5.0/docs/api/java/io/IOException.html">IOException

    {

        byte[] buf = new byte[1024];

        int readedBytes;

        1.5.0/docs/api/java/io/StringWriter.html">StringWriter writer = new 1.5.0/docs/api/java/io/StringWriter.html">StringWriter();

        while ((readedBytes = stream.read(buf)) > 0)

        {

            1.5.0/docs/api/java/lang/String.html">String s = new 1.5.0/docs/api/java/lang/String.html">String(buf, 0, readedBytes, encoding);

            writer.write(s);

        }

        return writer.toString();

    }

    private static void writeDirectStream(HttpServletResponse response, 5+0%2Fdocs%2Fapi+InputStream">InputStream stream) throws 1.5.0/docs/api/java/io/IOException.html">IOException

    {

        byte[] buf = new byte[1024];

        int readedBytes;

        5+0%2Fdocs%2Fapi+OutputStream">OutputStream os = response.getOutputStream();

        while ((readedBytes = stream.read(buf)) > 0)

        {

            os.write(buf, 0, readedBytes);

        }

        os.close();

    }

    private static 5+0%2Fdocs%2Fapi+InputStream">InputStream openStream(1.5.0/docs/api/java/lang/String.html">String requestURL, 5+0%2Fdocs%2Fapi+Proxy">Proxy proxy) throws 1.5.0/docs/api/java/io/IOException.html">IOException

    {

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

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

        1.5.0/docs/api/java/net/HttpURLConnection.html">HttpURLConnection con = null;

        int responseCode = 0;

        do

        {

            if (proxy != null)

                con = (1.5.0/docs/api/java/net/HttpURLConnection.html">HttpURLConnection) url.openConnection(proxy);

            else

                con = (1.5.0/docs/api/java/net/HttpURLConnection.html">HttpURLConnection) url.openConnection();

            con.setRequestProperty("User-Agent", "ESTG-Baco/1.0");

            con.setRequestProperty("Accept-Encoding", "compress, gzip, identify");

            try

            {

                responseCode = con.getResponseCode();

                logger.debug("responseCode=" + responseCode);

            }

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

            {

                // assume it's a 503 response

                logger.info(requestURL, e);

                responseCode = 1.5.0/docs/api/java/net/HttpURLConnection.html">HttpURLConnection.HTTP_UNAVAILABLE;

            }

            if (responseCode == 1.5.0/docs/api/java/net/HttpURLConnection.html">HttpURLConnection.HTTP_UNAVAILABLE)

            {

                long retrySeconds = con.getHeaderFieldInt("Retry-After", -1);

                if (retrySeconds == -1)

                {

                    long now = (new 5+0%2Fdocs%2Fapi+Date">Date()).getTime();

                    long retryDate = con.getHeaderFieldDate("Retry-After", now);

                    retrySeconds = retryDate - now;

                }

                if (retrySeconds == 0)

                { // Apparently, it's a bad URL

                    throw new 1.5.0/docs/api/java/io/FileNotFoundException.html">FileNotFoundException("Bad URL?");

                }

                logger.error("Server response: Retry-After=" + retrySeconds);

                if (retrySeconds > 0)

                {

                    try

                    {

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

                    }

                    catch (1.5.0/docs/api/java/lang/InterruptedException.html">InterruptedException ex)

                    {

                        ex.printStackTrace();

                    }

                }

            }

        }

        while (responseCode == 1.5.0/docs/api/java/net/HttpURLConnection.html">HttpURLConnection.HTTP_UNAVAILABLE);

        1.5.0/docs/api/java/lang/String.html">String contentEncoding = con.getHeaderField("Content-Encoding");

        logger.debug("contentEncoding=" + contentEncoding);

        if ("compress".equals(contentEncoding))

        {

            1.5.0/docs/api/java/util/zip/ZipInputStream.html">ZipInputStream zis = new 1.5.0/docs/api/java/util/zip/ZipInputStream.html">ZipInputStream(con.getInputStream());

            zis.getNextEntry();

            in = zis;

        }

        else if ("gzip".equals(contentEncoding))

        {

            in = new 1.5.0/docs/api/java/util/zip/GZIPInputStream.html">GZIPInputStream(con.getInputStream());

        }

        else if ("deflate".equals(contentEncoding))

        {

            in = new 1.5.0/docs/api/java/util/zip/InflaterInputStream.html">InflaterInputStream(con.getInputStream());

        }

        else

        {

            in = con.getInputStream();

        }

        return in;

    }

    public static void processHttpRequestService(JspWriter out, 1.5.0/docs/api/java/lang/String.html">String server, 1.5.0/docs/api/java/lang/String.html">String path) throws 1.5.0/docs/api/java/io/IOException.html">IOException, ServletException

    {

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

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

        1.5.0/docs/api/java/lang/String.html">String confStartPath = ConfigProperties.getProperty("server." + server + ".start.path");

        if (confStartPath != null)

            path = confStartPath + path;

        try

        {

            1.5.0/docs/api/java/net/URL.html">URL url = new 1.5.0/docs/api/java/net/URL.html">URL(serverUrl + URIUtil.encodePath(path, "ISO-8859-1"));

            1.5.0/docs/api/java/net/URLConnection.html">URLConnection con = url.openConnection();

            5+0%2Fdocs%2Fapi+InputStream">InputStream stream = con.getInputStream();

            byte[] buf = new byte[1024];

            int readedBytes;

            while ((readedBytes = stream.read(buf)) > 0)

            {

                1.5.0/docs/api/java/lang/String.html">String str = new 1.5.0/docs/api/java/lang/String.html">String(buf, 0, readedBytes, serverEncoding);

                out.print(str);

            }

        }

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

        {

            throw new 1.5.0/docs/api/java/io/FileNotFoundException.html">FileNotFoundException("url not found for server:" + server + " and path:" + path);

        }

        catch (1.5.0/docs/api/java/lang/Exception.html">Exception e)

        {

            throw new 1.5.0/docs/api/java/io/IOException.html">IOException(e.toString());

        }

    }

    // <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 forward to HTTP or FTP Proxy";

    }

    public static void main(1.5.0/docs/api/java/lang/String.html">String[]args) throws 1.5.0/docs/api/java/io/IOException.html">IOException

    {

        FtpServer server = FtpServer.getServer("ftp://www.global.estgp.pt","jmachado","linux5631");

        FTPClient client = server.getClient();

        if(client == null)

        {

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

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

        }

        client.setFileType(FTP.BINARY_FILE_TYPE);

        1.5.0/docs/api/java/io/FileInputStream.html">FileInputStream teste = new 1.5.0/docs/api/java/io/FileInputStream.html">FileInputStream("D:\\resources.properties");

        client.changeWorkingDirectory("/Engenharia.Informatica.9119/AnoLectivo.2008-2009/Semestre1/Engenharia.Do.Software");

        client.makeDirectory("ttt");

        1.5.0/docs/api/java/lang/System.html">System.out.println(client.storeFile("resources.properties",teste));

        client.quit();

        client.disconnect();

    }

    // </editor-fold>

}