gvSIG data provider for OpenStreetMap (raster)

/* OSM layers for gvSIG.

 * Geographic Information System of the Valencian Government

*

* Copyright (C) 2012 Nacho Brodin

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

* MA  02110-1301, USA.

*

*/

package org.gvsig.raster.osm.downloader;

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.net.MalformedURLException;

import java.net.URI;

import java.net.URISyntaxException;

import java.net.URL;

import org.apache.commons.io.IOUtils;

import org.apache.http.HttpResponse;

import org.apache.http.client.ClientProtocolException;

import org.apache.http.client.ResponseHandler;

import org.apache.http.client.config.RequestConfig;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.impl.client.CloseableHttpClient;

import org.apache.http.impl.client.HttpClientBuilder;

import org.gvsig.compat.net.ICancellable;

import org.gvsig.fmap.dal.coverage.store.RasterDataStore;

import org.gvsig.raster.cache.tile.Tile;

import org.gvsig.raster.cache.tile.exception.TileGettingException;

import org.gvsig.raster.impl.provider.tile.BaseTileDownloader;

import org.gvsig.raster.osm.io.OSMDataParameters;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * Tile getter for Open Street Map

 * @author Nacho Brodin (nachobrodin@gmail.com)

 */

public class TileDownloaderForOSM extends BaseTileDownloader {

        private String server   = null;

        private String suffix   = null;

        private final String slash    = "/";

        private static final Logger LOGGER = LoggerFactory.getLogger(TileDownloaderForOSM.class);

        public TileDownloaderForOSM(RasterDataStore store,

                        int tileSize) {

                super(store, tileSize, tileSize);

                server = ((OSMDataParameters)store.getParameters()).getURI().toString();

                suffix = ((OSMDataParameters)store.getParameters()).getTileSuffix();

        }

    @Override

        public synchronized Tile downloadTile(Tile tile) throws TileGettingException {

                int level = tile.getLevel();

                int y = tile.getRow();

                int x = tile.getCol();

                try {

                        String stringUri = server +

            (server.endsWith(slash) ? "" : slash) +

            level + slash +

            x + slash +

            y + "." + suffix;

                        //logger.info("OSM URI = "+stringUri);

            URI uri = new URI(stringUri);

                        URL url = uri.toURL();

            downloadFile(url, tile.getFile(), tile.getCancelled());

                } catch (MalformedURLException | URISyntaxException e) {

                        throw new TileGettingException(e);

                }

                readTileFromDisk(tile);

                return tile;

        }

    public synchronized void downloadFile(URL url, File file, ICancellable cancel) throws TileGettingException {

        int timeout = 30000;

        try {

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

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

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

            RequestConfig config = RequestConfig.custom()

                .setConnectTimeout(timeout)

                .setConnectionRequestTimeout(timeout)

                .setSocketTimeout(timeout).build();

            CloseableHttpClient httpClient = HttpClientBuilder.create()

                .setDefaultRequestConfig(config)

                .build();

            httpClient.execute(request, new ResponseHandler<Object>() {

                @Override

                public Object handleResponse(HttpResponse response) throws ClientProtocolException, IOException {

                    FileOutputStream fs = null;

                    try {

                        fs = new FileOutputStream(file);

                        InputStream content = response.getEntity().getContent();

                        IOUtils.copy(content, fs);

                    } catch (IOException ex) {

                        throw ex;

                    } catch (Exception ex) {

                        throw new IOException(ex);

                    } finally {

                        IOUtils.closeQuietly(fs);

                    }

                    return null;

                }

            });

        } catch (Exception e) {

            throw new TileGettingException(e);

        }

    }

}