| /** | |
| * <copyright> | |
| * | |
| * Copyright (c) 2016-2021 itemis, Siemens and others. | |
| * 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: | |
| * itemis - Initial API and implementation | |
| * Siemens - [577073] URI change detector delegate extension | |
| * | |
| * </copyright> | |
| */ | |
| package org.eclipse.sphinx.tests.emf.workspace.referentialintegrity; | |
| import static org.junit.Assert.assertEquals; | |
| import static org.junit.Assert.assertNotNull; | |
| import static org.junit.Assert.assertSame; | |
| import static org.junit.Assert.assertTrue; | |
| import java.util.Collection; | |
| import java.util.Collections; | |
| import java.util.HashMap; | |
| import java.util.List; | |
| import java.util.Map; | |
| import org.eclipse.emf.common.notify.Notification; | |
| import org.eclipse.emf.common.util.URI; | |
| import org.eclipse.emf.ecore.resource.Resource; | |
| import org.eclipse.emf.ecore.util.EContentAdapter; | |
| import org.eclipse.sphinx.emf.workspace.internal.referentialintegrity.IntermittentRemoveTracker; | |
| import org.eclipse.sphinx.emf.workspace.referentialintegrity.IURIChangeDetectorDelegate; | |
| import org.eclipse.sphinx.emf.workspace.referentialintegrity.URIChangeNotification; | |
| import org.eclipse.sphinx.examples.hummingbird20.ide.internal.referentialintegrity.Hummingbird20URIChangeDetectorDelegate; | |
| import org.eclipse.sphinx.examples.hummingbird20.instancemodel.InstanceModel20Factory; | |
| import org.eclipse.sphinx.examples.hummingbird20.instancemodel.ParameterValue; | |
| import org.eclipse.sphinx.tests.emf.workspace.referentialintegrity.scenarios.Hummingbird20TestModel; | |
| import org.junit.Before; | |
| import org.junit.Test; | |
| @SuppressWarnings({ "nls", "restriction" }) | |
| public class AbstractHierarchicalFragmentURIChangeDetectorDelegateTest { | |
| protected static final int MAX_INTERMITTENT_REMOVE_TEST_INTERVAL = 100; | |
| private static class TestURIChangeDetectorDelegate extends Hummingbird20URIChangeDetectorDelegate { | |
| @Override | |
| protected IntermittentRemoveTracker createIntermittentRemoveTracker() { | |
| IntermittentRemoveTracker intermittentRemoveTracker = super.createIntermittentRemoveTracker(); | |
| intermittentRemoveTracker.setMaxIntermittentRemoveInterval(100); | |
| return intermittentRemoveTracker; | |
| } | |
| } | |
| private static class TestURIChangeDetectorAdapter extends EContentAdapter { | |
| private IURIChangeDetectorDelegate delegate; | |
| private Map<Resource, List<URIChangeNotification>> changedURIs = new HashMap<>(); | |
| public TestURIChangeDetectorAdapter(IURIChangeDetectorDelegate delegate) { | |
| this.delegate = delegate; | |
| } | |
| @Override | |
| public void notifyChanged(Notification notification) { | |
| Map<Resource, List<URIChangeNotification>> changedURIsResult = delegate.detectChangedURIs(Collections.singletonList(notification)); | |
| for (Resource resource : changedURIsResult.keySet()) { | |
| if (changedURIs.containsKey(resource)) { | |
| changedURIs.get(resource).addAll(changedURIsResult.get(resource)); | |
| } else { | |
| changedURIs.put(resource, changedURIsResult.get(resource)); | |
| } | |
| } | |
| } | |
| public Map<Resource, List<URIChangeNotification>> getChangedURIs() { | |
| return changedURIs; | |
| } | |
| public long getChangedURISize() { | |
| return getChangedURIs().values().stream().map(Collection::size).reduce(0, Integer::sum); | |
| } | |
| } | |
| private Hummingbird20TestModel model; | |
| private TestURIChangeDetectorAdapter uriChangeDectector; | |
| @Before | |
| public void setup() { | |
| model = new Hummingbird20TestModel(); | |
| uriChangeDectector = new TestURIChangeDetectorAdapter(new TestURIChangeDetectorDelegate()); | |
| model.resourceSet.eAdapters().add(uriChangeDectector); | |
| } | |
| @Test | |
| public void testDetectChangedURIsNotification_singleLeafObjectChanged() { | |
| model.parameterValue111.setName("parameterValue111_changed"); | |
| Map<Resource, List<URIChangeNotification>> changedURIs = uriChangeDectector.getChangedURIs(); | |
| assertEquals(1, uriChangeDectector.getChangedURISize()); | |
| assertTrue(changedURIs.containsKey(model.resource1)); | |
| assertEquals(1, changedURIs.keySet().size()); | |
| URIChangeNotification uriChangeNotification = changedURIs.get(model.resource1).get(0); | |
| assertSame(model.parameterValue111, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue111"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue111_changed"), uriChangeNotification.getNewURI()); | |
| } | |
| @Test | |
| public void testDetectChangedURIsNotification_multipleLeafObjectsChanged() { | |
| model.parameterValue111.setName("parameterValue111_changed"); | |
| model.parameterValue112.setName("parameterValue112_changed"); | |
| Map<Resource, List<URIChangeNotification>> changedURIs = uriChangeDectector.getChangedURIs(); | |
| assertEquals(2, uriChangeDectector.getChangedURISize()); | |
| assertTrue(changedURIs.containsKey(model.resource1)); | |
| assertEquals(1, changedURIs.keySet().size()); | |
| URIChangeNotification uriChangeNotification = changedURIs.get(model.resource1).get(0); | |
| assertSame(model.parameterValue111, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue111"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue111_changed"), uriChangeNotification.getNewURI()); | |
| uriChangeNotification = changedURIs.get(model.resource1).get(1); | |
| assertSame(model.parameterValue112, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue112"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue112_changed"), uriChangeNotification.getNewURI()); | |
| } | |
| @Test | |
| public void testDetectChangedURIsNotification_containerObjectChanged() { | |
| model.component11.setName("component11_changed"); | |
| Map<Resource, List<URIChangeNotification>> changedURIs = uriChangeDectector.getChangedURIs(); | |
| assertEquals(4, uriChangeDectector.getChangedURISize()); | |
| assertTrue(changedURIs.containsKey(model.resource1)); | |
| assertEquals(1, changedURIs.keySet().size()); | |
| URIChangeNotification uriChangeNotification = changedURIs.get(model.resource1).get(0); | |
| assertSame(model.component11, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource1#//component11"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component11_changed"), uriChangeNotification.getNewURI()); | |
| uriChangeNotification = changedURIs.get(model.resource1).get(1); | |
| assertSame(model.component11ToComponent22Connection, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource1#//component11/component11ToComponent22Connection"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component11_changed/component11ToComponent22Connection"), uriChangeNotification.getNewURI()); | |
| uriChangeNotification = changedURIs.get(model.resource1).get(2); | |
| assertSame(model.parameterValue111, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue111"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component11_changed/parameterValue111"), uriChangeNotification.getNewURI()); | |
| uriChangeNotification = changedURIs.get(model.resource1).get(3); | |
| assertSame(model.parameterValue112, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue112"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component11_changed/parameterValue112"), uriChangeNotification.getNewURI()); | |
| } | |
| @Test | |
| public void testDetectChangedURIsNotification_singleLeafObjectRemovedAndAddedElsewhere() { | |
| model.component22.getParameterValues().remove(model.parameterValue221); | |
| model.component11.getParameterValues().add(model.parameterValue221); | |
| Map<Resource, List<URIChangeNotification>> changedURIs = uriChangeDectector.getChangedURIs(); | |
| assertEquals(1, uriChangeDectector.getChangedURISize()); | |
| assertTrue(changedURIs.containsKey(model.resource1)); | |
| assertEquals(1, changedURIs.keySet().size()); | |
| URIChangeNotification uriChangeNotification = changedURIs.get(model.resource1).get(0); | |
| assertSame(model.parameterValue221, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource2#//component22/parameterValue221"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue221"), uriChangeNotification.getNewURI()); | |
| } | |
| @Test | |
| public void testDetectChangedURIsNotification_multipleLeafObjectsRemovedAndAddedElsewhere() { | |
| model.component11.getParameterValues().remove(model.parameterValue111); | |
| model.component11.getParameterValues().remove(model.parameterValue112); | |
| model.component22.getParameterValues().add(model.parameterValue111); | |
| model.component22.getParameterValues().add(model.parameterValue112); | |
| Map<Resource, List<URIChangeNotification>> changedURIs = uriChangeDectector.getChangedURIs(); | |
| assertEquals(2, uriChangeDectector.getChangedURISize()); | |
| assertTrue(changedURIs.containsKey(model.resource2)); | |
| assertEquals(1, changedURIs.keySet().size()); | |
| URIChangeNotification uriChangeNotification = changedURIs.get(model.resource2).get(0); | |
| assertSame(model.parameterValue111, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue111"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource2#//component22/parameterValue111"), uriChangeNotification.getNewURI()); | |
| uriChangeNotification = changedURIs.get(model.resource2).get(1); | |
| assertSame(model.parameterValue112, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue112"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource2#//component22/parameterValue112"), uriChangeNotification.getNewURI()); | |
| } | |
| @Test | |
| public void testDetectChangedURIsNotification_containerObjectRemovedAndAddedElsewhere() { | |
| model.application2.getComponents().remove(model.component22); | |
| model.application1.getComponents().add(model.component22); | |
| Map<Resource, List<URIChangeNotification>> changedURIs = uriChangeDectector.getChangedURIs(); | |
| assertEquals(3, uriChangeDectector.getChangedURISize()); | |
| assertTrue(changedURIs.containsKey(model.resource1)); | |
| assertEquals(1, changedURIs.keySet().size()); | |
| URIChangeNotification uriChangeNotification = changedURIs.get(model.resource1).get(0); | |
| assertSame(model.component22, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource2#//component22"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component22"), uriChangeNotification.getNewURI()); | |
| uriChangeNotification = changedURIs.get(model.resource1).get(1); | |
| assertSame(model.component22ToComponent11Connection, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource2#//component22/component22ToComponent11Connection"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component22/component22ToComponent11Connection"), uriChangeNotification.getNewURI()); | |
| uriChangeNotification = changedURIs.get(model.resource1).get(2); | |
| assertSame(model.parameterValue221, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource2#//component22/parameterValue221"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component22/parameterValue221"), uriChangeNotification.getNewURI()); | |
| } | |
| @Test | |
| public void testDetectChangedURIsNotification_singleLeafObjectMoved() { | |
| model.component11.getParameterValues().add(model.parameterValue221); | |
| Map<Resource, List<URIChangeNotification>> changedURIs = uriChangeDectector.getChangedURIs(); | |
| assertEquals(1, uriChangeDectector.getChangedURISize()); | |
| assertTrue(changedURIs.containsKey(model.resource1)); | |
| assertEquals(1, changedURIs.keySet().size()); | |
| URIChangeNotification uriChangeNotification = changedURIs.get(model.resource1).get(0); | |
| assertSame(model.parameterValue221, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource2#//component22/parameterValue221"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue221"), uriChangeNotification.getNewURI()); | |
| } | |
| @Test | |
| public void testDetectChangedURIsNotification_multipleObjectsMoved() { | |
| model.component22.getParameterValues().add(model.parameterValue111); | |
| model.component22.getParameterValues().add(model.parameterValue112); | |
| Map<Resource, List<URIChangeNotification>> changedURIs = uriChangeDectector.getChangedURIs(); | |
| assertEquals(2, uriChangeDectector.getChangedURISize()); | |
| assertTrue(changedURIs.containsKey(model.resource2)); | |
| assertEquals(1, changedURIs.keySet().size()); | |
| URIChangeNotification uriChangeNotification = changedURIs.get(model.resource2).get(0); | |
| assertSame(model.parameterValue111, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue111"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource2#//component22/parameterValue111"), uriChangeNotification.getNewURI()); | |
| uriChangeNotification = changedURIs.get(model.resource2).get(1); | |
| assertSame(model.parameterValue112, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource1#//component11/parameterValue112"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource2#//component22/parameterValue112"), uriChangeNotification.getNewURI()); | |
| } | |
| @Test | |
| public void testDetectChangedURIsNotification_containerObjectMoved() { | |
| model.application1.getComponents().add(model.component22); | |
| Map<Resource, List<URIChangeNotification>> changedURIs = uriChangeDectector.getChangedURIs(); | |
| assertEquals(3, uriChangeDectector.getChangedURISize()); | |
| assertTrue(changedURIs.containsKey(model.resource1)); | |
| assertEquals(1, changedURIs.keySet().size()); | |
| URIChangeNotification uriChangeNotification = changedURIs.get(model.resource1).get(0); | |
| assertSame(model.component22, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource2#//component22"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component22"), uriChangeNotification.getNewURI()); | |
| uriChangeNotification = changedURIs.get(model.resource1).get(1); | |
| assertSame(model.component22ToComponent11Connection, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource2#//component22/component22ToComponent11Connection"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component22/component22ToComponent11Connection"), uriChangeNotification.getNewURI()); | |
| uriChangeNotification = changedURIs.get(model.resource1).get(2); | |
| assertSame(model.parameterValue221, uriChangeNotification.getNewEObject()); | |
| assertNotNull(uriChangeNotification.getOldURI()); | |
| assertEquals(URI.createURI("resource2#//component22/parameterValue221"), uriChangeNotification.getOldURI()); | |
| assertNotNull(uriChangeNotification.getNewURI()); | |
| assertEquals(URI.createURI("resource1#//component22/parameterValue221"), uriChangeNotification.getNewURI()); | |
| } | |
| @Test | |
| public void testDetectChangedURIsNotification_unrelatedRemovalsAndAdditions() throws InterruptedException { | |
| assertEquals(2, model.component11.getParameterValues().size()); | |
| assertEquals(1, model.component22.getParameterValues().size()); | |
| // Isolated addition | |
| ParameterValue parameterValue113 = InstanceModel20Factory.eINSTANCE.createParameterValue(); | |
| model.component11.getParameterValues().add(parameterValue113); | |
| assertEquals(3, model.component11.getParameterValues().size()); | |
| assertEquals(1, model.component22.getParameterValues().size()); | |
| assertEquals(0, uriChangeDectector.getChangedURIs().size()); | |
| // Isolated removal | |
| model.component11.getParameterValues().remove(model.parameterValue111); | |
| assertEquals(2, model.component11.getParameterValues().size()); | |
| assertEquals(1, model.component22.getParameterValues().size()); | |
| assertEquals(0, uriChangeDectector.getChangedURIs().size()); | |
| // Addition and removal | |
| ParameterValue parameterValue114 = InstanceModel20Factory.eINSTANCE.createParameterValue(); | |
| model.component11.getParameterValues().add(parameterValue114); | |
| model.component11.getParameterValues().remove(parameterValue114); | |
| assertEquals(2, model.component11.getParameterValues().size()); | |
| assertEquals(1, model.component22.getParameterValues().size()); | |
| assertEquals(0, uriChangeDectector.getChangedURIs().size()); | |
| // Unrelated removal and addition | |
| model.component11.getParameterValues().remove(model.parameterValue112); | |
| Thread.sleep(MAX_INTERMITTENT_REMOVE_TEST_INTERVAL * 2); | |
| model.component22.getParameterValues().add(model.parameterValue112); | |
| assertEquals(1, model.component11.getParameterValues().size()); | |
| assertEquals(2, model.component22.getParameterValues().size()); | |
| assertEquals(0, uriChangeDectector.getChangedURIs().size()); | |
| } | |
| } |