LayerCopy.groovy

/*
 * Copyright (C) 2016 Atlas of Living Australia
 * All Rights Reserved.
 *
 * The contents of this file are subject to the Mozilla Public
 * License Version 1.1 (the "License"); you may not use this file
 * except in compliance with the License. You may obtain a copy of
 * the License at http://www.mozilla.org/MPL/
 *
 * Software distributed under the License is distributed on an "AS
 * IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
 * implied. See the License for the specific language governing
 * rights and limitations under the License.
 */

package au.org.ala.spatial.process

import au.org.ala.spatial.Util
import au.org.ala.spatial.Fields
import au.org.ala.spatial.Layers
import grails.converters.JSON
import groovy.util.logging.Slf4j
import org.grails.web.json.JSONObject

@Slf4j
class LayerCopy extends SlaveProcess {

    void start() {
        String layerId = getInput('layerId')
        String fieldId = getInput('fieldId')
        String sourceUrl = getInput('sourceUrl')
        String sourceJwt = getInput('jwt')

        Fields field = getField(fieldId)
        Layers layer = getLayer(layerId)
        //get style
        if (fieldId.toString().startsWith("cl")) {
            //getFile("/layer/${fieldId}.sld", sourceUrl)
            addOutput('sld', '/layer/' + fieldId + ".sld")
        } else {
            //getFile("/layer/${layer.name}.sld", sourceUrl)
            addOutput('sld', '/layer/' + layer.name + ".sld")
        }

        //get layer files
        getFile("/layer/${layer.name}", sourceUrl, sourceJwt)
        addOutputFiles("/layer/${layer.name}", true)

        //get standardized files
        taskLog("get standardized files")
        def resolutions
        if (layer.type == 'Contextual') resolutions = spatialConfig.shpResolutions
        else resolutions = spatialConfig.grdResolutions
        if (!(resolutions instanceof List)) {
            // comma separated or JSON list
            if (resolutions.toString().startsWith("[")) {
                resolutions = new org.json.simple.parser.JSONParser().parse(resolutions.toString())
            } else {
                resolutions = Arrays.asList(resolutions.toString().split(","))
            }
        }

        resolutions.each { res ->
            getFile("/standard_layer/${res}/${field.id}", sourceUrl, sourceJwt)
            addOutputFiles("/standard_layer/${res}/${field.id}")
        }

        //get layerdistances
        taskLog("get layer distances")
        getFile('/public/layerDistances.properties', sourceUrl, sourceJwt)
        JSONObject dists = JSON.parse(Util.getUrl(sourceUrl + "/layerDistances/layerdistancesJSON.json")) as JSONObject
        def distString = ''
        for (def f : getFields()) {
            if ("e".equalsIgnoreCase(f.type) && f.id != field.id) {
                String c = (f.id.compareTo(field.id) < 0 ? f.id + " " + field.id : field.id + " " + f.id)

                if (dists.containsKey(c)) {
                    if (distString.length() > 0) distString += '\n'
                    distString += f.id + ' ' + field.id + '=' + dists.get(c).toString()
                }
            }
        }
        if (distString.length() > 0) {
            addOutput('append', '/public/layerDistances.properties?' + distString)
        }

        def m = [fieldId: String.valueOf(field.id), uploadId: layer.id, skipSLDCreation: true]
        addOutput("process", "FieldCreation " + (m as JSON))
        addOutput("process", "Thumbnails " + ([] as JSON))
    }
}