Xinwen Deng / aem-src

/*
 * Decompiled with CFR 0_118.
 * 
 * Could not load the following classes:
 *  org.apache.felix.scr.annotations.Activate
 *  org.apache.felix.scr.annotations.Component
 *  org.apache.felix.scr.annotations.Deactivate
 *  org.apache.felix.scr.annotations.Properties
 *  org.apache.felix.scr.annotations.Property
 *  org.apache.felix.scr.annotations.Reference
 *  org.apache.felix.scr.annotations.ReferenceCardinality
 *  org.apache.felix.scr.annotations.ReferencePolicy
 *  org.apache.felix.scr.annotations.Service
 *  org.apache.sling.api.resource.Resource
 *  org.apache.sling.api.resource.ResourceResolver
 *  org.apache.sling.api.resource.ValueMap
 *  org.osgi.framework.BundleContext
 *  org.osgi.framework.ServiceReference
 *  org.osgi.service.component.ComponentContext
 *  org.osgi.util.tracker.ServiceTracker
 *  org.osgi.util.tracker.ServiceTrackerCustomizer
 *  org.slf4j.Logger
 *  org.slf4j.LoggerFactory
 */
package com.day.cq.mcm.impl;

import com.day.cq.mcm.api.Experience;
import com.day.cq.mcm.api.MCMFacade;
import com.day.cq.mcm.api.MCMPlugin;
import com.day.cq.mcm.api.MCMResourceType;
import com.day.cq.mcm.api.Touchpoint;
import com.day.cq.mcm.impl.DirectPluginProvider;
import com.day.cq.mcm.impl.IndirectPluginProvider;
import com.day.cq.mcm.impl.MCMConfiguration;
import com.day.cq.mcm.impl.PluginProvider;
import com.day.cq.mcm.util.NormalizedResource;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Set;
import org.apache.felix.scr.annotations.Activate;
import org.apache.felix.scr.annotations.Component;
import org.apache.felix.scr.annotations.Deactivate;
import org.apache.felix.scr.annotations.Properties;
import org.apache.felix.scr.annotations.Property;
import org.apache.felix.scr.annotations.Reference;
import org.apache.felix.scr.annotations.ReferenceCardinality;
import org.apache.felix.scr.annotations.ReferencePolicy;
import org.apache.felix.scr.annotations.Service;
import org.apache.sling.api.resource.Resource;
import org.apache.sling.api.resource.ResourceResolver;
import org.apache.sling.api.resource.ValueMap;
import org.osgi.framework.BundleContext;
import org.osgi.framework.ServiceReference;
import org.osgi.service.component.ComponentContext;
import org.osgi.util.tracker.ServiceTracker;
import org.osgi.util.tracker.ServiceTrackerCustomizer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@Component(metatype=0)
@Service(value={MCMFacade.class})
@Reference(name="MCMPlugin", referenceInterface=MCMPlugin.class, cardinality=ReferenceCardinality.OPTIONAL_MULTIPLE, policy=ReferencePolicy.DYNAMIC)
@Properties(value={@Property(name="service.description", value={"MCM Facade. An extension point for MCM plugins and provider of methods working on multiple plugins."})})
public class MCMFacadeImpl
implements MCMFacade {
    private static final Logger log = LoggerFactory.getLogger(MCMFacadeImpl.class);
    private HashMap<String, PluginProvider> experienceComponentTypesToPlugins = new HashMap();
    private HashMap<String, PluginProvider> touchpointComponentTypesToPlugins = new HashMap();
    private Set<MCMPlugin> plugins = Collections.synchronizedSet(new HashSet());
    private ServiceTracker configurationServiceTracker;
    private BundleContext bundleContext;
    private HashMap<Object, MCMConfiguration> implementedConfigurations = new HashMap();

    @Override
    public MCMPlugin getPlugin(Resource r) {
        String typeString;
        NormalizedResource nr = new NormalizedResource();
        nr.setResource(r);
        MCMPlugin retval = null;
        if (nr.getResource() != null && (typeString = (String)nr.getContentVals().get("sling:resourceType", String.class)) != null) {
            retval = this.getPluginForType(typeString);
        }
        return retval;
    }

    @Override
    public Collection<MCMPlugin> getPlugins() {
        return this.plugins;
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    @Override
    public Collection<String> getRegisteredExperienceComponents() {
        HashMap<String, PluginProvider> hashMap = this.experienceComponentTypesToPlugins;
        synchronized (hashMap) {
            return new ArrayList<String>(this.experienceComponentTypesToPlugins.keySet());
        }
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    @Override
    public Collection<String> getRegisteredTouchpointComponents() {
        HashMap<String, PluginProvider> hashMap = this.touchpointComponentTypesToPlugins;
        synchronized (hashMap) {
            return new ArrayList<String>(this.touchpointComponentTypesToPlugins.keySet());
        }
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    @Override
    public MCMResourceType getMCMType(String resourceTypeToTest) {
        MCMResourceType retval = null;
        HashMap<String, PluginProvider> hashMap = this.experienceComponentTypesToPlugins;
        synchronized (hashMap) {
            if (this.experienceComponentTypesToPlugins.containsKey(resourceTypeToTest)) {
                retval = MCMResourceType.Experience;
            }
        }
        if (retval == null) {
            hashMap = this.touchpointComponentTypesToPlugins;
            synchronized (hashMap) {
                if (this.touchpointComponentTypesToPlugins.containsKey(resourceTypeToTest)) {
                    retval = MCMResourceType.Touchpoint;
                }
            }
        }
        return retval;
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    @Override
    public MCMPlugin getPluginForType(String typeString) {
        PluginProvider pp = null;
        HashMap<String, PluginProvider> hashMap = this.experienceComponentTypesToPlugins;
        synchronized (hashMap) {
            pp = this.experienceComponentTypesToPlugins.get(typeString);
        }
        if (pp != null) {
            return pp.getPlugin();
        }
        hashMap = this.touchpointComponentTypesToPlugins;
        synchronized (hashMap) {
            pp = this.touchpointComponentTypesToPlugins.get(typeString);
        }
        if (pp != null) {
            return pp.getPlugin();
        }
        return null;
    }

    @Override
    public Iterator<Experience> findExperiences(ResourceResolver rr, Touchpoint t) {
        final MCMPlugin plugin = t.getPlugin();
        String additionalPropertyCondition = t.getXPathAdditionToMatchTouchpointExperience();
        final Iterator<Resource> experiences = this.findResources(rr, plugin.getExperienceRootComponents(), "/content", additionalPropertyCondition);
        return new Iterator<Experience>(){

            @Override
            public void remove() {
                throw new UnsupportedOperationException();
            }

            @Override
            public Experience next() {
                return plugin.makeExperience((Resource)experiences.next());
            }

            @Override
            public boolean hasNext() {
                return experiences.hasNext();
            }
        };
    }

    @Override
    public Iterator<Resource> findResources(ResourceResolver rr, Collection<String> rootComponents, String path, String additionalPropertyCondition) {
        if (rootComponents.size() == 0) {
            return new ArrayList().iterator();
        }
        StringBuilder query = new StringBuilder("/jcr:root");
        String cleanedPath = path.endsWith("/") ? path.substring(0, path.length() - 1) : path;
        query.append(cleanedPath);
        query.append("//*[");
        boolean first = true;
        for (String comp : rootComponents) {
            if (first) {
                query.append("(");
            }
            if (!first) {
                query.append(" or ");
            }
            first = false;
            query.append("@sling:resourceType = ");
            query.append("'").append(comp).append("'");
        }
        if (!first) {
            query.append(")");
        }
        if (additionalPropertyCondition != null && !"".equals(additionalPropertyCondition)) {
            if (!first) {
                query.append(" and ");
            }
            query.append("(");
            query.append(additionalPropertyCondition);
            query.append(")");
        }
        query.append("]");
        String queryString = query.toString();
        Iterator result = rr.findResources(queryString, "xpath");
        return result;
    }

    @Activate
    protected void activate(ComponentContext context) {
        this.bundleContext = context.getBundleContext();
        this.configurationServiceTracker = new ServiceTracker(context.getBundleContext(), MCMConfiguration.class.getName(), (ServiceTrackerCustomizer)new ConfigurationSTCustomizer());
        this.configurationServiceTracker.open();
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    @Deactivate
    protected void deactivate(ComponentContext context) {
        if (this.configurationServiceTracker != null) {
            this.configurationServiceTracker.close();
            this.configurationServiceTracker = null;
        }
        this.plugins.clear();
        HashMap<String, PluginProvider> hashMap = this.experienceComponentTypesToPlugins;
        synchronized (hashMap) {
            this.experienceComponentTypesToPlugins.clear();
        }
        hashMap = this.touchpointComponentTypesToPlugins;
        synchronized (hashMap) {
            this.touchpointComponentTypesToPlugins.clear();
        }
        this.bundleContext = null;
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    protected void bindMCMPlugin(MCMPlugin plugin) {
        log.info("Binding plugin {} to MCMFacadeImpl", (Object)plugin);
        try {
            HashMap<String, PluginProvider> hashMap;
            String m;
            DirectPluginProvider dpp;
            if (!this.plugins.add(plugin)) {
                String m2 = "OSGi passed '" + plugin + "' twice... ";
                throw new RuntimeException(m2);
            }
            for (String type2 : plugin.getExperienceRootComponents()) {
                hashMap = this.experienceComponentTypesToPlugins;
                synchronized (hashMap) {
                    if (this.experienceComponentTypesToPlugins.containsKey(type2)) {
                        m = "MCMPlugin '" + plugin + "' tried to register Experience type " + type2 + ", which is already registered. " + "Aborting bind!";
                        throw new RuntimeException(m);
                    }
                    dpp = new DirectPluginProvider();
                    dpp.setPlugin(plugin);
                    this.experienceComponentTypesToPlugins.put(type2, dpp);
                    continue;
                }
            }
            for (String type2 : plugin.getTouchpointRootComponents()) {
                hashMap = this.touchpointComponentTypesToPlugins;
                synchronized (hashMap) {
                    if (this.touchpointComponentTypesToPlugins.containsKey(type2)) {
                        m = "MCMPlugin '" + plugin + "' tried to register Touchpoint type " + type2 + ", which is already registered. " + "Aborting bind!";
                        throw new RuntimeException(m);
                    }
                    dpp = new DirectPluginProvider();
                    dpp.setPlugin(plugin);
                    this.touchpointComponentTypesToPlugins.put(type2, dpp);
                    continue;
                }
            }
        }
        catch (Exception e) {
            log.error("Failed to bind MCMPlugin " + plugin + ".", (Throwable)e);
        }
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    @Override
    public void addExperienceIndirection(String fromCompType, String toCompType) {
        IndirectPluginProvider ipp = new IndirectPluginProvider();
        ipp.setComponentTypeToProvideFrom(toCompType);
        ipp.setFac(this);
        HashMap<String, PluginProvider> hashMap = this.experienceComponentTypesToPlugins;
        synchronized (hashMap) {
            if (this.experienceComponentTypesToPlugins.containsKey(fromCompType)) {
                log.error("Cannot add indirection from " + fromCompType + " to " + toCompType + ", " + "component type " + fromCompType + " already registered.");
            } else {
                this.experienceComponentTypesToPlugins.put(fromCompType, ipp);
            }
        }
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    @Override
    public void removeExperienceIndirection(String fromCompType) {
        boolean notIndirectProvider = false;
        HashMap<String, PluginProvider> hashMap = this.experienceComponentTypesToPlugins;
        synchronized (hashMap) {
            PluginProvider pp = this.experienceComponentTypesToPlugins.get(fromCompType);
            if (pp != null && !(pp instanceof IndirectPluginProvider)) {
                notIndirectProvider = true;
            } else if (pp != null) {
                this.experienceComponentTypesToPlugins.remove(fromCompType);
            }
        }
        if (notIndirectProvider) {
            String m = "Trying to remove indirection at '" + fromCompType + "' but is not an indirection! Nothing removed.";
            log.error(m);
        }
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    @Override
    public void removeTouchpointIndirection(String fromCompType) {
        boolean notIndirectProvider = false;
        HashMap<String, PluginProvider> hashMap = this.touchpointComponentTypesToPlugins;
        synchronized (hashMap) {
            PluginProvider pp = this.touchpointComponentTypesToPlugins.get(fromCompType);
            if (pp != null && !(pp instanceof IndirectPluginProvider)) {
                notIndirectProvider = true;
            } else if (pp != null) {
                this.touchpointComponentTypesToPlugins.remove(fromCompType);
            }
        }
        if (notIndirectProvider) {
            String m = "Trying to remove indirection at '" + fromCompType + "' but is not an indirection! Nothing removed.";
            log.error(m);
        }
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    @Override
    public void addTouchpointIndirection(String fromCompType, String toCompType) {
        IndirectPluginProvider ipp = new IndirectPluginProvider();
        ipp.setComponentTypeToProvideFrom(toCompType);
        ipp.setFac(this);
        HashMap<String, PluginProvider> hashMap = this.touchpointComponentTypesToPlugins;
        synchronized (hashMap) {
            if (this.touchpointComponentTypesToPlugins.containsKey(fromCompType)) {
                log.error("Cannot add indirection from " + fromCompType + " to " + toCompType + ", " + "component type " + fromCompType + " already registered.");
            } else {
                this.touchpointComponentTypesToPlugins.put(fromCompType, ipp);
            }
        }
    }

    /*
     * WARNING - Removed try catching itself - possible behaviour change.
     */
    protected void unbindMCMPlugin(MCMPlugin plugin) {
        log.info("Unbinding plugin {} from MCMFacadeImpl", (Object)plugin);
        this.plugins.remove(plugin);
        HashMap<String, PluginProvider> hashMap = this.experienceComponentTypesToPlugins;
        synchronized (hashMap) {
            for (String type : plugin.getExperienceRootComponents()) {
                this.experienceComponentTypesToPlugins.remove(type);
            }
        }
        hashMap = this.touchpointComponentTypesToPlugins;
        synchronized (hashMap) {
            for (String type : plugin.getTouchpointRootComponents()) {
                this.touchpointComponentTypesToPlugins.remove(type);
            }
        }
    }

    public class ConfigurationSTCustomizer
    implements ServiceTrackerCustomizer {
        public Object addingService(ServiceReference arg0) {
            Object service = MCMFacadeImpl.this.bundleContext.getService(arg0);
            MCMConfiguration newConfig = this.checkConfig(service);
            if (newConfig != null) {
                this.addConfig(arg0, newConfig);
                return service;
            }
            return null;
        }

        private MCMConfiguration checkConfig(Object service) {
            MCMConfiguration retval = null;
            if (service instanceof MCMConfiguration) {
                retval = (MCMConfiguration)service;
            } else {
                String m = "Tracking misconfigured, got " + service.getClass() + ", " + "and not a MCMConfiguration.";
                log.error(m);
            }
            return retval;
        }

        /*
         * WARNING - Removed try catching itself - possible behaviour change.
         */
        private void logConfig() {
            if (log.isInfoEnabled()) {
                String icM;
                HashMap hashMap = MCMFacadeImpl.this.implementedConfigurations;
                synchronized (hashMap) {
                    icM = MCMFacadeImpl.this.implementedConfigurations.toString();
                }
                log.info("Configuration references: {}", (Object)icM);
                String m = "Configuration now: ";
                HashMap hashMap2 = MCMFacadeImpl.this.experienceComponentTypesToPlugins;
                synchronized (hashMap2) {
                    m = m + "Experiences: " + MCMFacadeImpl.this.experienceComponentTypesToPlugins.toString();
                }
                hashMap2 = MCMFacadeImpl.this.touchpointComponentTypesToPlugins;
                synchronized (hashMap2) {
                    m = m + " Touchpoints: " + MCMFacadeImpl.this.touchpointComponentTypesToPlugins.toString();
                }
                log.info(m);
            }
        }

        /*
         * WARNING - Removed try catching itself - possible behaviour change.
         */
        private void addConfig(ServiceReference arg0, MCMConfiguration newConfig) {
            log.info("Adding configuration {}", arg0.getProperty("service.pid"));
            try {
                MCMConfiguration clone = (MCMConfiguration)newConfig.clone();
                if (clone.getExperienceIndirectionConfig() != null) {
                    MCMFacadeImpl.this.addExperienceIndirection(clone.getExperienceIndirectionConfig()[0], clone.getExperienceIndirectionConfig()[1]);
                }
                if (clone.getTouchpointIndirectionConfig() != null) {
                    MCMFacadeImpl.this.addTouchpointIndirection(clone.getTouchpointIndirectionConfig()[0], clone.getTouchpointIndirectionConfig()[1]);
                }
                HashMap hashMap = MCMFacadeImpl.this.implementedConfigurations;
                synchronized (hashMap) {
                    if (null != MCMFacadeImpl.this.implementedConfigurations.put(arg0.getProperty("service.pid"), clone)) {
                        log.error("Configuration added twice: {}", arg0.getProperty("service.pid"));
                    }
                }
            }
            catch (CloneNotSupportedException e) {
                log.error("Configuration " + arg0.getProperty("service.pid") + " doesn't support clone!");
            }
            this.logConfig();
        }

        /*
         * WARNING - Removed try catching itself - possible behaviour change.
         */
        public void modifiedService(ServiceReference arg0, Object arg1) {
            log.info("Modifying configuration {}", arg0.getProperty("service.pid"));
            try {
                MCMConfiguration modConfig = this.checkConfig(MCMFacadeImpl.this.bundleContext.getService(arg0));
                if (modConfig == null) {
                    throw new RuntimeException("Service not a configuration, cannot modify: " + (Object)arg0);
                }
                boolean update = false;
                MCMConfiguration oldConfig = null;
                HashMap hashMap = MCMFacadeImpl.this.implementedConfigurations;
                synchronized (hashMap) {
                    oldConfig = (MCMConfiguration)MCMFacadeImpl.this.implementedConfigurations.get(arg0.getProperty("service.pid"));
                    if (oldConfig == null) {
                        String m = "Got modification notice for unimplemented configuration: " + arg0.getProperty("service.pid");
                        throw new RuntimeException(m);
                    }
                    if (!oldConfig.equals(modConfig)) {
                        update = true;
                        try {
                            modConfig = (MCMConfiguration)modConfig.clone();
                            MCMFacadeImpl.this.implementedConfigurations.put(arg0.getProperty("service.pid"), modConfig);
                        }
                        catch (CloneNotSupportedException e) {
                            throw new RuntimeException("Configuration cannot be cloned: " + arg0.getProperty("service.pid"));
                        }
                    }
                }
                if (update) {
                    if (oldConfig != null && oldConfig.getExperienceIndirectionConfig() != null) {
                        MCMFacadeImpl.this.removeExperienceIndirection(oldConfig.getExperienceIndirectionConfig()[0]);
                    }
                    if (oldConfig != null && oldConfig.getTouchpointIndirectionConfig() != null) {
                        MCMFacadeImpl.this.removeTouchpointIndirection(oldConfig.getTouchpointIndirectionConfig()[0]);
                    }
                    if (modConfig.getExperienceIndirectionConfig() != null) {
                        MCMFacadeImpl.this.addExperienceIndirection(modConfig.getExperienceIndirectionConfig()[0], modConfig.getExperienceIndirectionConfig()[1]);
                    }
                    if (modConfig.getTouchpointIndirectionConfig() != null) {
                        MCMFacadeImpl.this.addTouchpointIndirection(modConfig.getTouchpointIndirectionConfig()[0], modConfig.getTouchpointIndirectionConfig()[1]);
                    }
                }
            }
            catch (Exception e) {
                log.error("Modification of config failed.", (Throwable)e);
            }
            this.logConfig();
        }

        public void removedService(ServiceReference arg0, Object arg1) {
            log.info("Removing service {}", arg0.getProperty("service.pid"));
            MCMConfiguration remConfig = (MCMConfiguration)MCMFacadeImpl.this.implementedConfigurations.remove(arg0.getProperty("service.pid"));
            if (remConfig != null) {
                if (remConfig.getExperienceIndirectionConfig() != null) {
                    MCMFacadeImpl.this.removeExperienceIndirection(remConfig.getExperienceIndirectionConfig()[0]);
                }
                if (remConfig.getTouchpointIndirectionConfig() != null) {
                    MCMFacadeImpl.this.removeTouchpointIndirection(remConfig.getTouchpointIndirectionConfig()[0]);
                }
            } else {
                log.warn("Configuration to be removed not present: {}", arg0.getProperty("service.pid"));
            }
            this.logConfig();
        }
    }

}