1 files changed, 186 insertions, 0 deletions
diff --git a/sdo-java/branches/emf-2.5/impl/src/test/java/org/apache/tuscany/sdo/test/NotificationTestCase.java b/sdo-java/branches/emf-2.5/impl/src/test/java/org/apache/tuscany/sdo/test/NotificationTestCase.java
new file mode 100644
index 0000000000..5d1637865b
--- /dev/null
+++ b/sdo-java/branches/emf-2.5/impl/src/test/java/org/apache/tuscany/sdo/test/NotificationTestCase.java
@@ -0,0 +1,186 @@
+/**
+ *
+ *   Licensed to the Apache Software Foundation (ASF) under one
+ *   or more contributor license agreements.  See the NOTICE file
+ *   distributed with this work for additional information
+ *  regarding copyright ownership.  The ASF licenses this file
+ *   to you under the Apache License, Version 2.0 (the
+ *   "License"); you may not use this file except in compliance
+ *   with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *   Unless required by applicable law or agreed to in writing,
+ *   software distributed under the License is distributed on an
+ *   "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ *   KIND, either express or implied.  See the License for the
+ *   specific language governing permissions and limitations
+ *   under the License.
+ *
+ */
+package org.apache.tuscany.sdo.test;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URL;
+import java.util.ArrayList;
+import java.util.List;
+
+import junit.framework.TestCase;
+
+import org.apache.tuscany.sdo.api.SDOUtil;
+import org.apache.tuscany.sdo.api.Event;
+import org.apache.tuscany.sdo.impl.ListenerBase;
+
+import commonj.sdo.DataObject;
+import commonj.sdo.Type;
+import commonj.sdo.helper.HelperContext;
+import commonj.sdo.helper.TypeHelper;
+
+/**
+ * Test DataObject Property value change notification
+ */
+public class NotificationTestCase extends TestCase {
+
+  HelperContext hc;
+  TypeHelper th;
+
+  private class Observer extends ListenerBase {
+
+    private int notificationCount;
+    private Event lastEvent;
+
+    public int getNotificationCount() {
+      return notificationCount;
+    }
+
+    public Event getLastEvent() {
+      return lastEvent;
+    }
+
+    public Observer() {
+      notificationCount = 0;
+    }
+
+    public void eventNotification(Event e) {
+
+      if (e.getEventType() != Event.REMOVE_LISTENER) {
+        notificationCount++;
+        lastEvent = e;
+      }
+    }
+
+  }
+
+  public void testTransitions() throws IOException {
+    final String TEST_MODEL = "/simple.xsd";
+    final String TEST_NAMESPACE = "http://www.example.com/simple";
+
+    // Populate the meta data for the test (Stock Quote) model
+    URL url = getClass().getResource(TEST_MODEL);
+    InputStream inputStream = url.openStream();
+    hc.getXSDHelper().define(inputStream, url.toString());
+    inputStream.close();
+
+    Type quoteType = th.getType(TEST_NAMESPACE, "Quote");
+    DataObject quote = hc.getDataFactory().create(quoteType);
+    Observer o = new Observer();
+    SDOUtil.addChangeListener(quote, o);
+
+    Event e;
+
+    String firstName = "FlyByNightTechnology";
+
+    int changeCount = 0;
+    
+    quote.setString("companyName", firstName);
+    assertEquals(++changeCount, o.getNotificationCount());
+    e = o.getLastEvent();
+    assertEquals(Event.SET, e.getEventType());
+    assertEquals(null, e.getOldValue());
+    assertFalse(e.wasSet());
+
+    quote.setString("companyName", "FBNT");
+    e = o.getLastEvent();
+    assertTrue(e.wasSet());
+
+    assertEquals(firstName, e.getOldValue());
+    assertEquals(++changeCount, o.getNotificationCount());
+    assertEquals("companyName", e.getProperty().getName());
+
+    SDOUtil.removeChangeListener(quote, o);
+
+    quote.setString("companyName", "3rdValue");
+    e = o.getLastEvent();
+
+    assertEquals(firstName, e.getOldValue());
+    assertEquals(changeCount /* no ++ */, o.getNotificationCount());
+
+    SDOUtil.addChangeListener(quote, o);
+
+    quote.setString("companyName", "3rdValue");
+    assertEquals(++changeCount, o.getNotificationCount());
+    e = o.getLastEvent();
+    assertTrue(e.isTouch());
+    assertTrue(e.wasSet());
+
+    quote.unset("companyName");
+    assertEquals(++changeCount, o.getNotificationCount());
+    e = o.getLastEvent();
+    assertTrue(e.wasSet());
+   
+
+    quote.set("companyName", "4thValue");
+    assertEquals(++changeCount, o.getNotificationCount());
+    e = o.getLastEvent();
+    assertFalse(e.wasSet());
+    
+    assertEquals(Event.NO_INDEX, e.getPosition());
+    
+    DataObject child = quote.createDataObject("quotes");
+    assertEquals(++changeCount, o.getNotificationCount());
+    e = o.getLastEvent();
+    assertFalse(e.wasSet());
+    assertEquals(0, e.getPosition());
+    assertEquals(Event.ADD, e.getEventType());
+    
+    DataObject child2 = quote.createDataObject("quotes");
+    assertEquals(++changeCount, o.getNotificationCount());
+    e = o.getLastEvent();
+    assertTrue(e.wasSet());  // the quotes property was previously set to a non empty list
+    assertEquals(1, e.getPosition());
+    
+    child2.setString("companyName", "subsidiary");
+    
+    assertEquals(changeCount /* no ++ */, o.getNotificationCount()); // not monitoring the child
+    
+    quote.getList("quotes").clear();
+    e = o.getLastEvent();
+    assertEquals(++changeCount, o.getNotificationCount());
+    assertEquals(Event.REMOVE_MANY, e.getEventType());
+    
+    List newList = new ArrayList();
+    
+    newList.add(hc.getDataFactory().create(quoteType));
+    newList.add(hc.getDataFactory().create(quoteType));
+    
+    quote.getList("quotes").addAll(newList);
+    e = o.getLastEvent();
+    assertEquals(++changeCount, o.getNotificationCount());
+    assertEquals(Event.ADD_MANY, e.getEventType());
+    
+
+    
+
+  }
+  
+
+  protected void setUp() throws Exception {
+    super.setUp();
+
+    hc = SDOUtil.createHelperContext();
+    th = hc.getTypeHelper();
+
+  }
+
+}