bundles/org.simantics.message/src/org/simantics/message/internal/MessageSchemeManager.java

   1 /*******************************************************************************
   2  * Copyright (c) 2007, 2010 Association for Decentralized Information Management
   3  * in Industry THTH ry.
   4  * All rights reserved. This program and the accompanying materials
   5  * are made available under the terms of the Eclipse Public License v1.0
   6  * which accompanies this distribution, and is available at
   7  * http://www.eclipse.org/legal/epl-v10.html
   8  *
   9  * Contributors:
  10  *     VTT Technical Research Centre of Finland - initial API and implementation
  11  *******************************************************************************/
  12 package org.simantics.message.internal;
  13
  14 import java.util.ArrayList;
  15 import java.util.Arrays;
  16 import java.util.HashMap;
  17 import java.util.HashSet;
  18 import java.util.Map;
  19 import java.util.Set;
  20
  21 import org.eclipse.core.runtime.IConfigurationElement;
  22 import org.eclipse.core.runtime.IExtension;
  23 import org.eclipse.core.runtime.IExtensionPoint;
  24 import org.eclipse.core.runtime.Platform;
  25 import org.eclipse.core.runtime.dynamichelpers.ExtensionTracker;
  26 import org.eclipse.core.runtime.dynamichelpers.IExtensionChangeHandler;
  27 import org.eclipse.core.runtime.dynamichelpers.IExtensionTracker;
  28 import org.eclipse.core.runtime.dynamichelpers.IFilter;
  29 import org.simantics.message.IMessageDataSchemeExtension;
  30 import org.simantics.message.IMessageSchemeManager;
  31
  32 /**
  33  * @author Tuukka Lehtonen
  34  */
  35 public class MessageSchemeManager implements IExtensionChangeHandler, IMessageSchemeManager {
  36
  37     public final static String           NAMESPACE    = "org.simantics.message";
  38     public final static String           ELEMENT_NAME = "scheme";
  39     public final static String           EP_NAME      = "messageDataScheme";
  40
  41     private ExtensionTracker             tracker;
  42
  43     private MessageDataSchemeExtension[] extensions   = new MessageDataSchemeExtension[0];
  44
  45     public MessageSchemeManager() {
  46         tracker = new ExtensionTracker();
  47
  48         // Cache defined actions
  49         IExtensionPoint expt = Platform.getExtensionRegistry().getExtensionPoint(NAMESPACE, EP_NAME);
  50         loadExtensions(expt.getConfigurationElements());
  51
  52         // Start tracking for new and removed extensions
  53         IFilter filter = ExtensionTracker.createExtensionPointFilter(expt);
  54         tracker.registerHandler(this, filter);
  55     }
  56
  57     private String getDescription(IConfigurationElement el) {
  58         for (IConfigurationElement desc : el.getChildren("description")) {
  59             return desc.getValue();
  60         }
  61         return null;
  62     }
  63
  64     private void loadExtensions(IConfigurationElement[] configurationElements) {
  65         Set<MessageDataSchemeExtension> newExtensions = new HashSet<MessageDataSchemeExtension>(Arrays.asList(extensions));
  66
  67         // Initialize id -> extension lookup
  68         Map<String, MessageDataSchemeExtension> schemes = new HashMap<String, MessageDataSchemeExtension>();
  69         for (MessageDataSchemeExtension ext : newExtensions) {
  70             schemes.put(ext.getId(), ext);
  71         }
  72
  73         // 1st pass: load schemes
  74         for (IConfigurationElement el : configurationElements) {
  75             String name = el.getName();
  76             if ("scheme".equals(name)) {
  77                 String id = el.getAttribute("id");
  78                 if (id == null)
  79                     continue;
  80                 String scheme = el.getAttribute("scheme");
  81                 if (scheme == null)
  82                     continue;
  83                 String description = getDescription(el);
  84
  85                 MessageDataSchemeExtension ext = schemes.get(id);
  86                 if (ext != null) {
  87                     // This scheme is already registered, two contributors are contributing the same scheme.
  88                     StringBuilder msg = new StringBuilder();
  89                     msg.append("Multiple contributors for message scheme '" + id + "':");
  90                     msg.append("\n  1st: " + ext.getSchemeElement().getContributor().getName());
  91                     msg.append("\n  2nd: " + el.getContributor().getName());
  92                     msg.append("\nUsing the first one.");
  93                     // TODO: proper logging
  94                     System.err.println(msg.toString());
  95                     continue;
  96                 }
  97
  98                 ext = new MessageDataSchemeExtension(el, id, scheme, description);
  99
 100                 // Start tracking the new extension object, its removal will be notified of
 101                 // with removeExtension(extension, Object[]).
 102                 tracker.registerObject(el.getDeclaringExtension(), ext, IExtensionTracker.REF_STRONG);
 103
 104                 newExtensions.add(ext);
 105                 schemes.put(id, ext);
 106             }
 107         }
 108
 109         // 2nd pass: load handlers
 110         for (IConfigurationElement el : configurationElements) {
 111             String name = el.getName();
 112             if ("handler".equals(name)) {
 113                 String id = el.getAttribute("schemeId");
 114                 if (id == null)
 115                     continue;
 116
 117                 MessageDataSchemeExtension ext = schemes.get(id);
 118                 if (ext == null) {
 119                     // Unusable handler since there is no scheme to use it for.
 120                     StringBuilder msg = new StringBuilder();
 121                     msg.append("No scheme extension for message scheme id '" + id + "'. Ignoring handler '" + el.getAttribute("handler") + "'");
 122                     msg.append("\nUsing the first one.");
 123                     // TODO: proper logging
 124                     System.err.println(msg.toString());
 125                     continue;
 126                 }
 127
 128                 IConfigurationElement prev = ext.getHandlerElement();
 129                 if (prev != null) {
 130                     // Unusable handler since there already exists a handler for this scheme.
 131                     StringBuilder msg = new StringBuilder();
 132                     msg.append("Multiple handler contributors for message scheme '" + id + "':\n");
 133                     msg.append("\n   1st: " + prev.getContributor().getName());
 134                     msg.append("\n   2nd: " + el.getContributor().getName());
 135                     msg.append("\nUsing the first one.");
 136                     // TODO: proper logging
 137                     System.err.println(msg.toString());
 138                     continue;
 139                 }
 140
 141                 ext.setHandlerElement(el);
 142             }
 143         }
 144
 145         // Atomic assignment
 146         this.extensions = newExtensions.toArray(new MessageDataSchemeExtension[newExtensions.size()]);
 147     }
 148
 149     @Override
 150     public void addExtension(IExtensionTracker tracker, IExtension extension) {
 151         loadExtensions(extension.getConfigurationElements());
 152     }
 153
 154     @Override
 155     public void removeExtension(IExtension extension, Object[] objects) {
 156         Set<MessageDataSchemeExtension> newExtensions = new HashSet<MessageDataSchemeExtension>(Arrays.asList(extensions));
 157
 158         for (Object o : objects) {
 159             tracker.unregisterObject(extension, o);
 160             newExtensions.remove((IMessageDataSchemeExtension) o);
 161         }
 162
 163         // Atomic assignment
 164         this.extensions = newExtensions.toArray(new MessageDataSchemeExtension[newExtensions.size()]);
 165     }
 166
 167     @Override
 168     public IMessageDataSchemeExtension[] getByScheme(String scheme) {
 169         if (scheme == null)
 170             throw new IllegalArgumentException("null scheme");
 171
 172         ArrayList<MessageDataSchemeExtension> result = new ArrayList<MessageDataSchemeExtension>();
 173         for (MessageDataSchemeExtension ext : extensions) {
 174             if (scheme.equals(ext.getScheme()))
 175                 result.add(ext);
 176         }
 177         return result.toArray(new MessageDataSchemeExtension[result.size()]);
 178     }
 179
 180 }