Ticket #161: rwall_livequery.patch

/home/richard/lib/Divmod/trunk/Axiom/axiom/test/test_livequery.py

@@ +1 @@
+from louie import dispatcher
+
+from twisted.trial.unittest import TestCase
+
+from axiom.item import Item
+from axiom.store import Store
+from axiom.attributes import text
+
+class MyItem(Item):
+    name = text(allowNone = True)
+    
+class TabularDataModel:
+    results = []
+    def __init__(self, store, queryItem):
+        self.store = store
+        self.queryItem = queryItem
+        
+    def updateResults(self):
+        self.results = list(self.store.query(self.queryItem))
+    
+    def onStoreItemAdd(self):
+        self.updateResults()
+
+class LiveQuery(TestCase):
+    def testLiveQueryItemAddObserver(self):
+        
+        s = Store()
+        tdm = TabularDataModel(s, MyItem)
+        dispatcher.connect(tdm.onStoreItemAdd, "itemadd", MyItem)
+        def transaction():          
+            MyItem(store=s, name=u"a")
+
+        count1 = len(tdm.results)
+        s.transact(transaction)
+        count2 = len(tdm.results)
+
+        self.assertEquals(count1, 0)
+        self.assertEquals(count2, 1)
+        s.close()
+

/home/richard/lib/Divmod/trunk/Axiom/axiom/item.py

@@ -1 +1 @@
-# -*- test-case-name: axiom.test -*-
-__metaclass__ = type
+from louie import dispatcher
-
-from twisted.python.reflect import qual
-from twisted.application.service import IService, IServiceCollection, MultiService
@@ -438 +439 @@
-                # TODO: need to measure the performance impact of this, then do
-                # it to make sure things are in fact deleted:
-                # self.store.executeSQL(_schema.APP_VACUUM)
+                dispatcher.send("itemdelete", self.__class__)
-            else:
-                assert self.__legacy__
-
@@ -449 +451 @@
-                # transaction; just don't do anything.
-                return
-            self.store.executeSQL(*self._updateSQL())
+            dispatcher.send("itemupdate", self.__class__)
-        else:
-            # case 2: we are in the middle of creating the object, we've never
-            # been inserted into the db before
@@ -459 +462 @@
-                [self.storeID] +
-                [self.__dirty__.get(a[1].attrname, (None, a[1].default,))[1] for a in attrs])
-            self.__everInserted = True
+            dispatcher.send("itemadd", self.__class__)
-        # In case 1, we're dirty but we did an update, synchronizing the
-        # database, in case 2, we haven't been created but we issue an insert.
-        # In either case, the code in attributes.py sets the attribute *as well