GeoKnow/Jassa-Core

var Class = require('../ext/Class');

var MappedConceptSource = require('./MappedConceptSource');

var MappedConcept = require('./MappedConcept');
var AggUtils = require('./AggUtils');

var ObjectUtils = require('../util/ObjectUtils');
var RefSpec = require('./RefSpec');

var BindingMapperExpr = require('./binding_mapper/BindingMapperExpr');
var ExprVar = require('../sparql/expr/ExprVar');

var AggMap = require('./agg/AggMap');


var forEach = require('lodash.foreach');


/**
 * A sponate context is a container for mappings, prefixes
 * and configuration options
 */
var Context = Class.create({
    initialize: function(prefixMapping) {
        this.prefixMapping = prefixMapping;
        this.nameToSource = {};

        // This is for the registration of templates
        // Maybe should be moved to StoreFacade
        //this.nameToMappedConcept = nameToMappedConcept || {};
    },

    /*
    getMappedConcept: function(name) {
        return this.nameToMappedConcept[name];
    },
    */

    getSource: function(name) {
        return this.nameToSource[name];
    },
//    addMappedConcept: function() {
//
//    },

    createResolvedContext: function() {
        var result = new Context(this.prefixMapping);

        forEach(this.nameToSource, function(source, name) {

            var mc = source.getMappedConcept();
            var agg = mc.getAgg();
            var aggClone = agg.clone();

            var b = new MappedConcept(mc.getConcept(), aggClone);
            var s = new MappedConceptSource(b, source.getSparqlService());

            result.addSource(name, s);
        });

        forEach(result.nameToSource, function(source, name) {
            result.processRefs(name, source);
        });


        return result;
    },

    processRefs: function(baseName, source) {
        var mappedConcept = source.getMappedConcept();
        var sparqlService = source.getSparqlService();
        var agg = mappedConcept.getAgg();

        var refs = AggUtils.getRefs(agg);

        var self = this;

        refs.forEach(function(ref) {
            var refSpec = ref.getRefSpec();
            //console.log('TEMPLATE REF SPEC ' + JSON.stringify(refSpec));

            var target = refSpec.getTarget();

            // Evaluate function targets
            if(ObjectUtils.isFunction(target)) {
                target = target();
            }

            if(target instanceof MappedConcept) {
                // TODO mappedConcepts used as references are AggObject,
                // however we expect AggMap's - so we have to wrap them

                var aggMap = target.getAgg();
                var aggObject = aggMap.getSubAgg();//target.getAgg();

                //var aggObject = target.getAgg();

                var attrToAgg = aggObject.getAttrToAgg();
                var aggIdLiteral = AggUtils.unwrapAggTransform(attrToAgg.id);
                var idMapper = aggIdLiteral.getBindingMapper();


                aggMap = new AggMap(idMapper, aggObject);

                var newTarget = new MappedConcept(target.getConcept(), aggMap);

                // Allocate a new name and source for this anonymous mapped concept
                var i = 0;
                var name;
                while(self.getSource(name = (baseName + '_fn_' + i))) {
                    ++i;
                }

                ref.setRefSpec(new RefSpec(name, refSpec.getAttr()));
                //console.log('NEW REF SPEC: ' + JSON.stringify(ref));
                //refSpec.setTarget(name);

                var bindingMapper = ref.getBindingMapper();
                if(!bindingMapper) {
                    var c = mappedConcept.getConcept();//newTarget.getConcept();
                    var v = c.getVar();
                    bindingMapper = new BindingMapperExpr(new ExprVar(v));
                    ref.setBindingMapper(bindingMapper);
                }

                var newSource = new MappedConceptSource(newTarget, sparqlService);
                self.nameToSource[name] = newSource;


                //console.log('STATE: ' + JSON.stringify(self.nameToSource, null, 4));
            }
            else if(!ObjectUtils.isString(target)) {
                throw new Error('Unknown target type: ', target);
            }
        });
    },

//    addTemplate: function(spec) {
//        var name = spec.name;
//        if(!name) {
//            throw new Error('Sponate spec must have a name');
//        }
//
//        var mappedConcept = SponateUtils.parseSpec(spec, this.prefixMapping);
//
//        this.nameToMappedConcept[name] = mappedConcept;
//    },
//
    addSource: function(name, source) {
        this.nameToSource[name] = source;

        //console.log('MAPPED CONCEPT ' + name + ': ' + JSON.stringify(mappedConcept, null, null));

//        var source = new MappedConceptSource(mappedConcept, sparqlService);

        //this.processRefs(name, source);
    },
});

module.exports = Context;