-/*******************************************************************************\r
- * Copyright (c) 2007, 2010 Association for Decentralized Information Management\r
- * in Industry THTH ry.\r
- * All rights reserved. This program and the accompanying materials\r
- * are made available under the terms of the Eclipse Public License v1.0\r
- * which accompanies this distribution, and is available at\r
- * http://www.eclipse.org/legal/epl-v10.html\r
- *\r
- * Contributors:\r
- * VTT Technical Research Centre of Finland - initial API and implementation\r
- *******************************************************************************/\r
-package org.simantics.diagram.ui;\r
-\r
-import java.util.ArrayList;\r
-import java.util.Collections;\r
-import java.util.Optional;\r
-import java.util.concurrent.CopyOnWriteArrayList;\r
-import java.util.concurrent.TimeUnit;\r
-\r
-import org.eclipse.jface.viewers.IPostSelectionProvider;\r
-import org.eclipse.jface.viewers.ISelection;\r
-import org.eclipse.jface.viewers.ISelectionChangedListener;\r
-import org.eclipse.jface.viewers.SelectionChangedEvent;\r
-import org.eclipse.jface.viewers.StructuredSelection;\r
-import org.eclipse.ui.IWorkbenchPartSite;\r
-import org.simantics.db.exception.DatabaseException;\r
-import org.simantics.diagram.elements.AdaptableImmutableProxyElement;\r
-import org.simantics.g2d.canvas.ICanvasContext;\r
-import org.simantics.g2d.canvas.impl.AbstractCanvasParticipant;\r
-import org.simantics.g2d.canvas.impl.DependencyReflection.Dependency;\r
-import org.simantics.g2d.canvas.impl.HintReflection.HintListener;\r
-import org.simantics.g2d.diagram.participant.ElementJSON;\r
-import org.simantics.g2d.diagram.participant.Selection;\r
-import org.simantics.g2d.element.ElementHints;\r
-import org.simantics.g2d.element.IElement;\r
-import org.simantics.ui.selection.WorkbenchSelectionUtils;\r
-import org.simantics.utils.datastructures.hints.IHintContext.Key;\r
-import org.simantics.utils.datastructures.hints.IHintObservable;\r
-import org.simantics.utils.threads.IThreadWorkQueue;\r
-import org.simantics.utils.threads.ThreadUtils;\r
-import org.slf4j.Logger;\r
-import org.slf4j.LoggerFactory;\r
-\r
-/**\r
- * A canvas participant that listens to the #0 mouse selection and provides it\r
- * forward through the {@link IPostSelectionProvider} interface.\r
- * \r
- * @author Tuukka Lehtonen\r
- */\r
-public class WorkbenchSelectionProvider extends AbstractCanvasParticipant implements IPostSelectionProvider, ElementJSON {\r
-\r
- private static final Logger LOGGER = LoggerFactory.getLogger(WorkbenchSelectionProvider.class);\r
-\r
- private static final long POST_SELECTION_DELAY = 300;\r
-\r
- @Dependency protected Selection selection;\r
-\r
- protected IThreadWorkQueue swt;\r
- protected IWorkbenchPartSite site;\r
- protected ISelection currentSelection = StructuredSelection.EMPTY;\r
- protected CopyOnWriteArrayList<ISelectionChangedListener> listeners = new CopyOnWriteArrayList<ISelectionChangedListener>();\r
- protected CopyOnWriteArrayList<ISelectionChangedListener> postListeners = new CopyOnWriteArrayList<ISelectionChangedListener>();\r
-\r
- public WorkbenchSelectionProvider(IThreadWorkQueue swt) {\r
- this(swt, null);\r
- }\r
-\r
- public WorkbenchSelectionProvider(IThreadWorkQueue swt, IWorkbenchPartSite site) {\r
- this.swt = swt;\r
- this.site = site;\r
- if (site != null)\r
- site.setSelectionProvider(this);\r
- }\r
-\r
- @Override\r
- public void addedToContext(ICanvasContext ctx) {\r
- super.addedToContext(ctx);\r
- if (site != null && site.getSelectionProvider() != this) {\r
- swt.asyncExec(new Runnable() {\r
- @Override\r
- public void run() {\r
- if (site.getSelectionProvider() != WorkbenchSelectionProvider.this)\r
- site.setSelectionProvider(WorkbenchSelectionProvider.this);\r
- }\r
- });\r
- }\r
- }\r
-\r
- @Override\r
- public void removedFromContext(ICanvasContext ctx) {\r
- if (site != null && site.getSelectionProvider() == this) {\r
- swt.asyncExec(new Runnable() {\r
- @Override\r
- public void run() {\r
- if (site.getSelectionProvider() == WorkbenchSelectionProvider.this)\r
- site.setSelectionProvider(null);\r
- }\r
- });\r
- }\r
- super.removedFromContext(ctx);\r
- }\r
-\r
- @HintListener(Class = Selection.class, Field = "SELECTION0")\r
- public void hintChanged(IHintObservable sender, Key key, Object oldValue, Object newValue) {\r
- Iterable<?> selection = (Iterable<?>) newValue;\r
- final ISelection s = constructAdaptableSelection(selection);\r
- swt.asyncExec(new Runnable() {\r
- @Override\r
- public void run() {\r
- currentSelection = s;\r
- fireSelectionChanged(s);\r
- schedulePostSelectionChanged(s);\r
- }\r
- });\r
- }\r
-\r
- @HintListener(Class = Selection.class, Field = "SELECTION0")\r
- public void hintRemoved(IHintObservable sender, Key key, Object oldValue) {\r
- //System.out.println("selection removed: " + oldValue);\r
- final ISelection s = constructAdaptableSelection(Collections.emptyList());\r
- swt.asyncExec(new Runnable() {\r
- @Override\r
- public void run() {\r
- currentSelection = s;\r
- fireSelectionChanged(s);\r
- schedulePostSelectionChanged(s);\r
- }\r
- });\r
- }\r
-\r
- // Post selection changed scheduling helper.\r
- private int modCount = 0;\r
-\r
- protected void schedulePostSelectionChanged(final ISelection s) {\r
- final int count = ++modCount;\r
- ThreadUtils.getNonBlockingWorkExecutor().schedule(new Runnable() {\r
- @Override\r
- public void run() {\r
- int newCount = modCount;\r
- if (count != newCount)\r
- return;\r
- if (isRemoved())\r
- return;\r
- swt.asyncExec(new Runnable() {\r
- @Override\r
- public void run() {\r
- if (isRemoved())\r
- return;\r
- firePostSelectionChanged(s);\r
- }\r
- });\r
- }\r
- }, POST_SELECTION_DELAY, TimeUnit.MILLISECONDS);\r
- }\r
-\r
- protected ISelection constructAdaptableSelection(Iterable<?> selection) {\r
- ArrayList<Object> objects = new ArrayList<Object>();\r
- for (Object o : selection) {\r
- if (o instanceof IElement) {\r
- IElement e = (IElement) o;\r
- Object object = e.getHint(ElementHints.KEY_OBJECT);\r
- if (object != null) {\r
- objects.add(new AdaptableImmutableProxyElement(e));\r
- } else {\r
- System.out.println(" discarding element from selection, null object for " + e);\r
- }\r
- } else {\r
- System.out.println(" unrecognized selection: " + o.getClass() + ": " + o);\r
- }\r
- }\r
- return new StructuredSelection(objects);\r
- }\r
-\r
- void fireSelectionChanged(ISelection selection) {\r
- SelectionChangedEvent e = new SelectionChangedEvent(this, selection);\r
- for (ISelectionChangedListener l : listeners)\r
- l.selectionChanged(e);\r
- }\r
-\r
- void firePostSelectionChanged(ISelection selection) {\r
- SelectionChangedEvent e = new SelectionChangedEvent(this, selection);\r
- for (ISelectionChangedListener l : postListeners)\r
- l.selectionChanged(e);\r
- }\r
-\r
- @Override\r
- public void addPostSelectionChangedListener(ISelectionChangedListener listener) {\r
- postListeners.add(listener);\r
- }\r
-\r
- @Override\r
- public void removePostSelectionChangedListener(ISelectionChangedListener listener) {\r
- postListeners.remove(listener);\r
- }\r
-\r
- @Override\r
- public void addSelectionChangedListener(ISelectionChangedListener listener) {\r
- listeners.add(listener);\r
- }\r
-\r
- @Override\r
- public void removeSelectionChangedListener(ISelectionChangedListener listener) {\r
- listeners.remove(listener);\r
- }\r
-\r
- @Override\r
- public ISelection getSelection() {\r
- return currentSelection;\r
- }\r
-\r
- @Override\r
- public void setSelection(ISelection selection) {\r
- System.out.println("WorkbenchSelectionProvider: TODO: set selection: " + selection);\r
- }\r
-\r
- @Override\r
- public Optional<String> getJSON(IElement element) {\r
- ISelection sel = constructAdaptableSelection(Collections.singleton(element));\r
- try {\r
- return Optional.ofNullable( WorkbenchSelectionUtils.getPossibleJSON(sel) );\r
- } catch (DatabaseException e) {\r
- LOGGER.error("Unexpected failure while constructing JSON from element " + element, e);\r
- return Optional.empty();\r
- }\r
- }\r
-\r
-}\r
+/*******************************************************************************
+ * Copyright (c) 2007, 2017 Association for Decentralized Information Management
+ * in Industry THTH ry.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * VTT Technical Research Centre of Finland - initial API and implementation
+ * Semantum Oy - #7586
+ *******************************************************************************/
+package org.simantics.diagram.ui;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.Optional;
+import java.util.concurrent.CopyOnWriteArrayList;
+import java.util.concurrent.TimeUnit;
+
+import org.eclipse.jface.viewers.IPostSelectionProvider;
+import org.eclipse.jface.viewers.ISelection;
+import org.eclipse.jface.viewers.ISelectionChangedListener;
+import org.eclipse.jface.viewers.SelectionChangedEvent;
+import org.eclipse.jface.viewers.StructuredSelection;
+import org.eclipse.ui.IWorkbenchPartSite;
+import org.simantics.db.exception.DatabaseException;
+import org.simantics.diagram.elements.AdaptableImmutableProxyElement;
+import org.simantics.g2d.canvas.ICanvasContext;
+import org.simantics.g2d.canvas.impl.AbstractCanvasParticipant;
+import org.simantics.g2d.canvas.impl.DependencyReflection.Dependency;
+import org.simantics.g2d.canvas.impl.HintReflection.HintListener;
+import org.simantics.g2d.diagram.participant.ElementJSON;
+import org.simantics.g2d.diagram.participant.Selection;
+import org.simantics.g2d.element.ElementHints;
+import org.simantics.g2d.element.IElement;
+import org.simantics.ui.selection.WorkbenchSelectionUtils;
+import org.simantics.utils.datastructures.hints.IHintContext.Key;
+import org.simantics.utils.datastructures.hints.IHintObservable;
+import org.simantics.utils.threads.IThreadWorkQueue;
+import org.simantics.utils.threads.ThreadUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * A canvas participant that listens to the #0 mouse selection and provides it
+ * forward through the {@link IPostSelectionProvider} interface.
+ *
+ * @author Tuukka Lehtonen
+ */
+public class WorkbenchSelectionProvider extends AbstractCanvasParticipant implements IPostSelectionProvider, ElementJSON {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(WorkbenchSelectionProvider.class);
+
+ private static final long POST_SELECTION_DELAY = 300;
+
+ @Dependency protected Selection selection;
+
+ protected IThreadWorkQueue swt;
+ protected IWorkbenchPartSite site;
+ protected ISelection currentSelection = StructuredSelection.EMPTY;
+ protected CopyOnWriteArrayList<ISelectionChangedListener> listeners = new CopyOnWriteArrayList<ISelectionChangedListener>();
+ protected CopyOnWriteArrayList<ISelectionChangedListener> postListeners = new CopyOnWriteArrayList<ISelectionChangedListener>();
+
+ public WorkbenchSelectionProvider(IThreadWorkQueue swt) {
+ this(swt, null);
+ }
+
+ public WorkbenchSelectionProvider(IThreadWorkQueue swt, IWorkbenchPartSite site) {
+ this.swt = swt;
+ this.site = site;
+ if (site != null)
+ site.setSelectionProvider(this);
+ }
+
+ @Override
+ public void addedToContext(ICanvasContext ctx) {
+ super.addedToContext(ctx);
+ swt.asyncExec(() -> {
+ if (site != null && site.getSelectionProvider() != WorkbenchSelectionProvider.this)
+ site.setSelectionProvider(WorkbenchSelectionProvider.this);
+ });
+ }
+
+ @Override
+ public void removedFromContext(ICanvasContext ctx) {
+ swt.asyncExec(() -> {
+ if (site != null && site.getSelectionProvider() == WorkbenchSelectionProvider.this)
+ site.setSelectionProvider(null);
+ });
+ super.removedFromContext(ctx);
+ }
+
+ public void fireSelection(Iterable<?> selection) {
+ final ISelection s = constructAdaptableSelection(selection);
+ swt.asyncExec(() -> {
+ currentSelection = s;
+ fireSelectionChanged(s);
+ schedulePostSelectionChanged(s);
+ });
+ }
+
+ @HintListener(Class = Selection.class, Field = "SELECTION0")
+ public void hintChanged(IHintObservable sender, Key key, Object oldValue, Object newValue) {
+ Iterable<?> selection = (Iterable<?>) newValue;
+ fireSelection(selection);
+ }
+
+ @HintListener(Class = Selection.class, Field = "SELECTION0")
+ public void hintRemoved(IHintObservable sender, Key key, Object oldValue) {
+ //System.out.println("selection removed: " + oldValue);
+ fireSelection(Collections.emptyList());
+ }
+
+ // Post selection changed scheduling helper.
+ private int modCount = 0;
+
+ protected void schedulePostSelectionChanged(final ISelection s) {
+ final int count = ++modCount;
+ ThreadUtils.getNonBlockingWorkExecutor().schedule(() -> {
+ int newCount = modCount;
+ if (count != newCount)
+ return;
+ if (isRemoved())
+ return;
+ swt.asyncExec(() -> {
+ if (!isRemoved())
+ firePostSelectionChanged(s);
+ });
+ }, POST_SELECTION_DELAY, TimeUnit.MILLISECONDS);
+ }
+
+ protected ISelection constructAdaptableSelection(Iterable<?> selection) {
+ ArrayList<Object> objects = new ArrayList<Object>();
+ for (Object o : selection) {
+ if (o instanceof IElement) {
+ IElement e = (IElement) o;
+ Object object = e.getHint(ElementHints.KEY_OBJECT);
+ if (object != null) {
+ objects.add(new AdaptableImmutableProxyElement(e));
+ } else {
+ System.out.println(" discarding element from selection, null object for " + e);
+ }
+ } else {
+ System.out.println(" unrecognized selection: " + o.getClass() + ": " + o);
+ }
+ }
+ return new StructuredSelection(objects);
+ }
+
+ void fireSelectionChanged(ISelection selection) {
+ SelectionChangedEvent e = new SelectionChangedEvent(this, selection);
+ for (ISelectionChangedListener l : listeners)
+ l.selectionChanged(e);
+ }
+
+ void firePostSelectionChanged(ISelection selection) {
+ SelectionChangedEvent e = new SelectionChangedEvent(this, selection);
+ for (ISelectionChangedListener l : postListeners)
+ l.selectionChanged(e);
+ }
+
+ @Override
+ public void addPostSelectionChangedListener(ISelectionChangedListener listener) {
+ postListeners.add(listener);
+ }
+
+ @Override
+ public void removePostSelectionChangedListener(ISelectionChangedListener listener) {
+ postListeners.remove(listener);
+ }
+
+ @Override
+ public void addSelectionChangedListener(ISelectionChangedListener listener) {
+ listeners.add(listener);
+ }
+
+ @Override
+ public void removeSelectionChangedListener(ISelectionChangedListener listener) {
+ listeners.remove(listener);
+ }
+
+ @Override
+ public ISelection getSelection() {
+ return currentSelection;
+ }
+
+ @Override
+ public void setSelection(ISelection selection) {
+ System.out.println("WorkbenchSelectionProvider: TODO: set selection: " + selection);
+ }
+
+ @Override
+ public Optional<String> getJSON(IElement element) {
+ ISelection sel = constructAdaptableSelection(Collections.singleton(element));
+ try {
+ return Optional.ofNullable( WorkbenchSelectionUtils.getPossibleJSON(sel) );
+ } catch (DatabaseException e) {
+ LOGGER.error("Unexpected failure while constructing JSON from element " + element, e);
+ return Optional.empty();
+ }
+ }
+
+}