gvSIG projects pool

/*

 * To change this license header, choose License Headers in Project Properties.

 * To change this template file, choose Tools | Templates

 * and open the template in the editor.

 */

package org.gvsig.online.lib.impl;

import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.net.MalformedURLException;

import java.net.URL;

import java.util.HashMap;

import java.util.Iterator;

import java.util.Map;

import javax.json.JsonArray;

import javax.json.JsonObject;

import javax.json.JsonValue;

import org.apache.commons.io.IOUtils;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.json.Json;

import org.gvsig.json.JsonObjectBuilder;

import org.gvsig.online.lib.api.OnlineDownloader;

import org.gvsig.online.lib.api.OnlineLayer;

import org.gvsig.online.lib.api.OnlineLocator;

import org.gvsig.online.lib.api.OnlineProject;

import org.gvsig.online.lib.api.OnlineSite;

import org.gvsig.online.lib.api.OnlineUserIdentificationRequester;

import org.gvsig.online.lib.api.OnlineUserIdentificationRequester.OnlineUserIdentificationRequesterConfig;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 *

 * @author jjdelcerro

 */

@SuppressWarnings("UseSpecificCatch")

public class OnlineSiteImpl implements OnlineSite {

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

    private JsonObject projects_json;

//    private JsonObject layers_json;

    private Map<String, OnlineLayer> publicLayers;

    private URL urlbase;

    private OnlineDownloaderImpl downloader;

    private String currentUserCode;

    private String currentAuthenticationToken;

    private OnlineUserIdentificationRequesterConfig userIdentificationRequesterConfig;

    public OnlineSiteImpl() {

        clear();

    }

    public OnlineSiteImpl(OnlineUserIdentificationRequesterConfig userIdentificationRequesterConfig, URL url) {

        this();

        this.userIdentificationRequesterConfig = userIdentificationRequesterConfig;

        this.urlbase = url;

    }

    public final void clear() {

        this.userIdentificationRequesterConfig = null;

        this.urlbase = null;

        this.projects_json = null;

        this.publicLayers = null;

        this.downloader = null;

    }

    public OnlineDownloader getDownloader() {

        if( this.downloader == null ) {

            this.downloader = new OnlineDownloaderImpl(this);

        }

        return this.downloader;

    }

    @Override

    public void connect() throws IOException {

        this.connect(this.userIdentificationRequesterConfig,this.urlbase);

    }

    @Override

    public void connect(OnlineUserIdentificationRequesterConfig userIdentificationRequesterConfig, URL url) throws IOException {

        FileInputStream fis = null;

        try {

            this.userIdentificationRequesterConfig = userIdentificationRequesterConfig;

            OnlineDownloader downloader = this.getDownloader();

            File f = downloader.get(new URL(url.toString()+"/api/v1/projects"));

            fis = new FileInputStream(f);

            JsonObject json = Json.createObject(fis);

            this.urlbase = url;

            this.projects_json = json;

            this.publicLayers = null;

        } finally {

            IOUtils.closeQuietly(fis);

        }

    }

    @Override

    public URL getBaseUrl() {

        return this.urlbase;

    }

    @SuppressWarnings("Convert2Lambda")

    @Override

    public Iterable<OnlineProject> projects() {

        OnlineSiteImpl site = this;

        return new Iterable<OnlineProject>() {

            @Override

            public Iterator<OnlineProject> iterator() {

                Iterator<OnlineProject> it = new Iterator<OnlineProject>() {

                    JsonArray projects = projects_json.getJsonArray("content");

                    Iterator<JsonValue> jsonit = projects.iterator();

                    @Override

                    public boolean hasNext() {

                        return jsonit.hasNext();

                    }

                    @Override

                    public OnlineProjectImpl next() {

                        JsonObject jsonproject = (JsonObject) jsonit.next();

                        OnlineProjectImpl project = new OnlineProjectImpl().setSite(site);

                        project.fromJson(jsonproject);

                        return project;

                    }

                };

                return it;

            }

        };

    }

    @Override

    public OnlineProjectImpl getProject(String name) {

        JsonArray projects = projects_json.getJsonArray("content");

        for (JsonValue project0 : projects) {

            JsonObject project = (JsonObject) project0;

            if( StringUtils.equals(project.getString("name", null),name) ) {

                OnlineProjectImpl p = new OnlineProjectImpl().setSite(this);

                p.fromJson(project);

                return p;

            }

        }

        return null;

    }

    @Override

    public OnlineProjectImpl getProject(int id) {

        JsonArray projects = projects_json.getJsonArray("content");

        for (JsonValue project0 : projects) {

            JsonObject project = (JsonObject) project0;

            if( project.getInt("id", -1)==id ) {

                OnlineProjectImpl p = new OnlineProjectImpl().setSite(this);

                p.fromJson(project);

                return p;

            }

        }

        return null;

    }

    @Override

    public Map<String, OnlineLayer> getPublicLayers() {

        if( this.publicLayers == null ) {

            FileInputStream fis = null;

            try {

                OnlineDownloader downloader = this.getDownloader();

                File f = downloader.get(new URL(urlbase.toString()+"/api/v1/layers"));

                fis = new FileInputStream(f);

                JsonObject json = Json.createObject(fis);

                this.publicLayers = new HashMap<>();

                for (JsonValue layer_json : json.getJsonArray("content")) {

                    OnlineLayerImpl layer = new OnlineLayerImpl(this, (JsonObject) layer_json);

                    this.publicLayers.put(String.valueOf(layer.getId()), layer);

                }

            } catch(Exception ex) {

                throw new RuntimeException("Can't download layers from "+urlbase, ex);

            } finally {

                IOUtils.closeQuietly(fis);

            }

        }

        return this.publicLayers;

    }

    public boolean isPublicLayer(OnlineLayer layer) {

        return this.getPublicLayers().containsKey(String.valueOf(layer.getId()));

    }

//    public static void main(String[] args) throws Exception {

//        new DefaultLibrariesInitializer().fullInitialize();

//        

//        URL url = new URL("https://devel.gvsigonline.com/gvsigonline");

//        OnlineSiteImpl site = new OnlineSiteImpl();

//        site.connect(url);

//        for (OnlineProject project : site.projects()) {

//            System.out.println(project.getId()+", "+project.getName()+", "+project.getEnvelope());

//        }

//        System.out.println("-----------");

//        OnlineProjectImpl project = site.getProject("cartagena");

//        System.out.println(project.getId()+", "+project.getName()+", "+project.getEnvelope());

//        project = site.getProject(27);

//        System.out.println(project.getId()+", "+project.getName()+", "+project.getEnvelope());

//        

//        System.out.println("Fin");

//    }

    @Override

    public void fromJson(JsonObject json) {

        try {

//            String s = json.getString("url", null);

//            if( s == null ) {

//                throw new IllegalArgumentException("url is required");

//            }

//            URL url = new URL(s);

            URL url = (URL) Json.toObject(json, "url");

            JsonObject uirc = json.getJsonObject("userIdentificationRequesterConfig");

            if( uirc == null ) {

                this.userIdentificationRequesterConfig = null;

            } else {

                this.userIdentificationRequesterConfig = OnlineLocator.getOnlineManager().getUserIdentificationRequester(uirc);

            }

            this.clear();

            this.urlbase = url;

        } catch (Exception ex) {

            throw new IllegalArgumentException("url is required", ex);

        }

    }

    @Override

    public JsonObjectBuilder toJsonBuilder() {

        JsonObjectBuilder builder = Json.createObjectBuilder();

        builder.add("url", this.urlbase);

        if( this.userIdentificationRequesterConfig == null ) {

            builder.addNull("userIdentificationRequesterConfig");

        } else {

            builder.add("userIdentificationRequesterConfig",this.userIdentificationRequesterConfig.toJsonBuilder());

        }

        return builder;

    }

    public URL getURL(String s) {

        try {

            String base_s = StringUtils.removeEnd(this.urlbase.toString(), "/");

            if( StringUtils.startsWith(s, "/") ) {

                return new URL(base_s+s);

            }

            return new URL(base_s+"/"+s);

        } catch (MalformedURLException ex) {

            throw new RuntimeException("Can't get URL",ex);

        }

    }

    @Override

    public URL getGeoserverURL(String s) {

        try {

            String base_s = StringUtils.removeEnd(this.urlbase.toString(), "/");

            base_s = StringUtils.left(base_s, StringUtils.lastIndexOf(base_s, '/'));

            if( StringUtils.startsWith(s, "/") ) {

                return new URL(base_s+"/geoserver"+s);

            }

            return new URL(base_s+"/geoserver/"+s);

        } catch (Exception ex) {

            throw new RuntimeException("Can't get geoserver URL",ex);

        }

    }

    @Override

    public void setCurrentUserCode(String userCode) {

        this.currentUserCode = userCode;

    }

    @Override

    public String getCurrentUserCode() {

        return currentUserCode;

    }

    @Override

    public String getCurrentAuthorizationToken() {    

        return this.currentAuthenticationToken;        

    }

    @Override

    public void setCurrentAuthorizationToken(String authenticationToken) {

        this.currentAuthenticationToken = authenticationToken;

    }

    public OnlineUserIdentificationRequester getUserIdentificationRequester() {

        OnlineUserIdentificationRequester identificationRequester = this.userIdentificationRequesterConfig.createUserIdentificationRequester();

        return identificationRequester;

    }

    @Override

    public void logout() {

        this.currentAuthenticationToken = null;

    }

}