gvSIG projects pool

package org.gvsig.online.lib.impl;

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

import java.io.File;

import java.io.FileInputStream;

import java.net.URL;

import java.util.Iterator;

import java.util.function.Predicate;

import javax.json.JsonArray;

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

import javax.json.JsonNumber;

import javax.json.JsonObject;

import javax.json.JsonValue;

import org.apache.commons.io.IOUtils;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.fmap.geom.GeometryUtils;

import org.gvsig.fmap.geom.primitive.Envelope;

import org.gvsig.json.Json;

import org.gvsig.json.JsonObjectBuilder;

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

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

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

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.i18n.I18nManager;

import org.gvsig.tools.library.impl.DefaultLibrariesInitializer;

import org.gvsig.tools.task.SimpleTaskStatus;

/**

 *

 * @author jjdelcerro

 */

@SuppressWarnings("UseSpecificCatch")

public class OnlineProjectImpl implements OnlineProject {

    private JsonObject data;

    private Envelope envelope = null;

    private OnlineSiteImpl site;

    private JsonObject entities_json;

    public OnlineProjectImpl() {

    }

    OnlineProjectImpl setSite(OnlineSiteImpl site) {

        this.site = site;

        return this;

    }

    @Override

    public void fromJson(JsonObject data) {

        JsonObject theSite_json = data.getJsonObject("site");

        if (theSite_json != null) {

            OnlineSiteImpl theSite = new OnlineSiteImpl();

            theSite.fromJson(theSite_json);

            this.data = data.getJsonObject("project");

            this.site = theSite;

        } else {

            this.data = data;

        }

    }

    @Override

    public JsonObjectBuilder toJsonBuilder() {

        JsonObjectBuilder builder = Json.createObjectBuilder();

        builder.add_class(this);

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

        builder.add("project", (JsonValue) data);

        return builder;

    }

    @Override

    public int getId() {

        return this.data.getInt("id", -1);

    }

    @Override

    public String getName() {

        return this.data.getString("name", null);

    }

    @Override

    public String getTitle() {

        return this.data.getString("title", null);

    }

    @Override

    public String getLabel() {

        if (StringUtils.isNotBlank(this.getTitle())) {

            return this.getTitle();

        }

        if (StringUtils.isNotBlank(this.getName())) {

            return this.getName();

        }

        return String.valueOf(this.getId());

    }

    @Override

    public String getDescription() {

        return this.data.getString("description", null);

    }

    @Override

    public Envelope getEnvelope() {

        if (this.envelope == null) {

            JsonNumber extent4326_minx = this.data.getJsonNumber("extent4326_minx");

            JsonNumber extent4326_miny = this.data.getJsonNumber("extent4326_miny");

            JsonNumber extent4326_maxx = this.data.getJsonNumber("extent4326_maxx");

            JsonNumber extent4326_maxy = this.data.getJsonNumber("extent4326_maxy");

            if (extent4326_minx == null || extent4326_miny == null

                    || extent4326_maxx == null || extent4326_maxy == null) {

                return null;

            }

            this.envelope = GeometryUtils.createEnvelope(

                    extent4326_minx.doubleValue(),

                    extent4326_miny.doubleValue(),

                    extent4326_maxx.doubleValue(),

                    extent4326_maxy.doubleValue(),

                    Geometry.SUBTYPES.GEOM2D

            );

        }

        return this.envelope;

    }

    private JsonObject getLayers(SimpleTaskStatus status) {

        if (this.entities_json == null) {

            if (this.site == null) {

                return null;

            }

            FileInputStream fis = null;

            try {

                I18nManager i18n = ToolsLocator.getI18nManager();

                SimpleTaskStatus.push(status);

                SimpleTaskStatus.setIndeterminate(status);

                SimpleTaskStatus.message(status, i18n.getTranslation("_Download_project_layers_information"));

                URL url = this.site.getURL("/api/v1/projects/" + this.getId() + "/layers");

                OnlineDownloader downloader = this.site.getDownloader();

                File f = downloader.get(url);

                fis = new FileInputStream(f);

                JsonObject json = Json.createObject(fis);

                this.entities_json = json;

                SimpleTaskStatus.terminate(status);

            } catch (Exception ex) {

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

            } finally {

                IOUtils.closeQuietly(fis);

                SimpleTaskStatus.pop(status);

            }

        }

        return this.entities_json;

    }

    @Override

    public Iterable<OnlineLayer> layers() {

        return this.layers(null);

    }

    @Override

    public Iterable<OnlineLayer> layers(SimpleTaskStatus status) {

        OnlineProjectImpl theProject = this;

        @SuppressWarnings("Convert2Lambda")

        Iterable<OnlineLayer> iterable = new Iterable<OnlineLayer>() {

            @Override

            public Iterator<OnlineLayer> iterator() {

                JsonArray layers = getLayers(status).getJsonArray("content");

                Iterator<JsonValue> it = layers.iterator();

                return new Iterator<OnlineLayer>() {

                    @Override

                    public boolean hasNext() {

                        return it.hasNext();

                    }

                    @Override

                    public OnlineLayer next() {

                        JsonObject layer_json = (JsonObject) it.next();

                        return new OnlineLayerImpl(theProject, layer_json);

                    }

                };

            }

        };

        return iterable;

    }

    public OnlineLayer getLayer(Predicate<OnlineLayer> filter, SimpleTaskStatus status) {

        JsonArray layers = getLayers(status).getJsonArray("content");

        for (JsonValue layer0 : layers) {

            OnlineLayerImpl layer = new OnlineLayerImpl(site, (JsonObject) layer0);

            if (filter.test(layer)) {

                return layer;

            }

        }

        return null;

    }

    @Override

    public OnlineSiteImpl getSite() {

        return this.site;

    }

    public String getConfigTableName() {

        return "GVSIGD_CONFIG_" + this.getId();

    }

    public String getResourcesTablaName() {

        return "GVSIGD_RESOURCES_" + this.getId();

    }

    public OnlineLayer getConfigTable(SimpleTaskStatus status) {

        return this.getLayer((OnlineLayer t) -> StringUtils.equalsIgnoreCase(t.getName(), this.getConfigTableName()), status);

    }

    public OnlineLayer getResourcesTable(SimpleTaskStatus status) {

        return this.getLayer((OnlineLayer t) -> StringUtils.equalsIgnoreCase(t.getName(), this.getResourcesTablaName()), status);

    }

    public static void selfRegister() {

        Json.registerSerializer(OnlineProjectImpl.class);

    }

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

        new DefaultLibrariesInitializer().fullInitialize();

        String s;

        String siteURL = "https://devel.gvsigonline.com/gvsigonline";

        OnlineManager manager = OnlineLocator.getOnlineManager();

        TestUserIdentificationRequesterFactory userIdentificationRequesterFactory = new TestUserIdentificationRequesterFactory(siteURL);

        manager.addUserIdentificationRequester(userIdentificationRequesterFactory);

        OnlineSiteImpl site = (OnlineSiteImpl) manager.connectSite(

                userIdentificationRequesterFactory.create(),

                new URL(siteURL)

        );

        OnlineProjectImpl proj = site.getProject("jjdctestdesktop");

        s = proj.toJson().toString();

        System.out.println(s);

        proj = new OnlineProjectImpl();

        proj.fromJson(Json.createObject(s));

        s = proj.toJson().toString();

        System.out.println(s);

        System.out.println("Fin");

    }

}