Application: gvSIG desktop

package org.gvsig.downloader.lib.impl;

import java.io.IOException;

/**

 *

 * @author jjdelcerro

 */

public class IOExceptionWithStatus extends IOException {

    private final int status;

    public IOExceptionWithStatus(int status, String message, Throwable cause) {

        super(message, cause);

        this.status = status;

    }

    public IOExceptionWithStatus(int status, String message) {

        this(status, message, null);

    }

    public int getStatus() {

        return status;

    }

    @Override

    public String getMessage() {

        return super.getMessage() + ". status = " + this.status;

    }

}

    private static final String METHOD_PUT = "PUT";

    private static final String METHOD_POST = "POST";

    private static final String METHOD_GET = "GET";

    private static final String METHOD_DELETE = "DELETE";

    public File send(String method) throws IOException {

        int status = 500;

        URL theUrl = url;

        try {

            int numretries = 3;

            for (int retries = 0; retries < numretries; retries++) {    

                HttpRequestBase request;

                switch (method.toUpperCase()) {

                    case METHOD_DELETE:

                        request = new HttpDelete(theUrl.toURI());

                        break;

                    case METHOD_GET:

                    default:

                        request = new HttpGet(theUrl.toURI());

                        break;

                }

//                request.setHeader("User-Agent","Mozilla/5.0 (gvSIG) like Gecko");

                request.setHeader("User-Agent","gvSIG-desktop");

                request.setHeader("Referer","http://www.gvsig.com");

                LOGGER.info("RETRY "+retries);

                DownloaderResponseHandler responseHandler = executeRequest(request);

                status = responseHandler.getStatus();

                if(status >= 200 && status < 300) {

                    //2xx success

                    return this.dstFile;

                } else if(status == 307 || status == 308) {

                    String redirection = responseHandler.getRedirectionLocation();

                    if(StringUtils.isBlank(redirection)) {

                        throw new IOExceptionWithStatus(status, "Can't call method "+method+" "+Objects.toString(theUrl)+"' HTTPStatus = "+status+" redirect to blank URL.");

                    }

                    try {

                        theUrl = new URL(redirection);

                    } catch (Exception ex) {

                        throw new IOExceptionWithStatus(status, "Can't call method "+method+" "+Objects.toString(theUrl)+"' HTTPStatus = "+status+" redirect to invalid URL "+redirection);

                    }

                } else if(status >= 300 && status < 400) {

                    // 3xx redirection

                    throw new IOExceptionWithStatus(status, "Can't call method "+method+" "+Objects.toString(theUrl)+"' HTTPStatus = "+status);

                } else if(status == 401 || status == 403) {

                    // "401 Unauthorized" indicates that the request lacks valid authentication credentials

                    // "403 Forbidden" the client doesn't have permission to access the requested resource

                    // https://www.permit.io/blog/401-vs-403-error-whats-the-difference

                    if( retries < numretries-1 ) {

                        authorize(theUrl);

                    }

                } else if(status >= 400 && status < 500) {

                    // 4xx client errors

                    throw new IOExceptionWithStatus(status, "Can't call method "+method+" "+Objects.toString(theUrl)+"' HTTPStatus = "+status);

                } else if(status >= 500 && status < 600) {

                    // 5xx server errors

                    throw new IOExceptionWithStatus(status, "Can't call method "+method+" "+Objects.toString(theUrl)+"' HTTPStatus = "+status);

                } else {

                    //Unknown

                    throw new IOExceptionWithStatus(status, "Can't call method "+method+" "+Objects.toString(theUrl)+"' HTTPStatus = "+status);

                }

            }

            throw new IOExceptionWithStatus(status, "Can't call method "+method+" "+Objects.toString(theUrl)+"' too many retries, last status " + status);

        } catch (IOExceptionWithStatus ex) {

            throw ex;

        } catch (Throwable ex) {

            throw new IOExceptionWithStatus(status, "Can't call method "+method+" "+Objects.toString(theUrl)+"' last status " + status, ex);

        }

    }

                HttpEntityEnclosingRequestBase request;

                    case METHOD_PUT:

                    case METHOD_POST:

                    default:

                request.setEntity(new StringEntity(data, contentType));

                request.setHeader("Content-type", contentType.getMimeType());                

            if (data != null) {

                send(METHOD_POST, ContentType.TEXT_XML, this.data);

            } else {

                send(METHOD_GET);

            }

//        LOGGER.debug("downloading '" + url.toString() + "' to: " + dstFile.getAbsolutePath());

//        if (data != null) {

//            LOGGER.debug("using POST, request = " + data);

//        }

//        int timeout = this.getTimeout();

//

//        try {

//            OutputStreamWriter os = null;

//            HttpURLConnection connection = null;

//

//            //If the used protocol is HTTPS

//            if (url.getProtocol().equals("https")) {

//                disableHttsValidation();

//            }

//            connection = (HttpURLConnection) url.openConnection();

//            connection.setUseCaches(false);

//            connection.setRequestProperty("User-Agent", "Mozilla/5.0 (gvSIG) like Gecko");

//            connection.setConnectTimeout(timeout);

//            

//            //If it uses a HTTP POST

//            if (data != null) {

//                connection.setRequestProperty("SOAPAction", "post");

//                connection.setRequestMethod("POST");

//                connection.setDoOutput(true);

//                connection.setRequestProperty("Content-Type", "text/xml; charset=UTF-8");

//                os = new OutputStreamWriter(connection.getOutputStream());

//                os.write(data);

//                os.flush();

//            }

//            download(connection.getInputStream());

//

//            if (os != null) {

//                os.close();

//            }

//            

//            postdownload();

//

//        } catch (Exception e) {

//            exception(e);

//        }

                executorUI.execute(() -> {

                    r.setValue(requestAuthorization(executorUI));

                });