Ticket #2191: messaging.diff

Blendix/blendix/blendix_model.py

@@ -480 +480 @@
-        creation of new blips that the owner of this powerup is interested in.
-        """)
-
+    messageQueue = dependsOn(MessageQueue)
+
-    def activate(self):
-        """
-        Initialize in-memory attributes.
@@ -684 +686 @@
-
-        @rtype: C{NoneType}
-        """
-
-
+
+
+
-
+        # What I believe this method intended to be doing previously:
+#         while 1:
+#             blendixPerson = self._blendixPersonForPerson(person)
+#             if blendixPerson is None:
+#                 break
+#             person.store.query(
+#                 for the share associated with blendixPerson
+#             ).deleteFromStore()
-
+        # Ported to xmantissa.messaging, sort of:
+        everyone = sharing.getEveryoneRole(person.share)
+        sender = Target(u'myshareid', u'mylocalpart', u'mydomain')
+        contentType = u'amp/personlookup+blendix'
+        contentBody = (
+            '\x00\x04_ask'     '\x00\x011'
+            '\x00\x08_command' '\x00\x06delete'
+            '\x00\x00'         '\x00\x00')
+        for share in person.store.query(
+            Share, AND(Share.sharedItem == person,
+                       Share.sharedTo.oneOf(list(everyone.allRoles())))):
+
+            receipient = Target(
+                share.shareID, u'blendixlocalpart', u'blendixdomain')
+            self.messageQueue.queueMessage(
+                sender, recipient, contentType, contentBody)
+            # To be correct, share deletion needs to be 
+            # If I wanted, I could use the consequence feature of queueMessage to
+            # delay unsharing until unindexing has happened.  This would avoid
+            # someone being in the index when they're not shared, which will
+            # probably be an error on some page somewhere.  However, that should
+            # just be handled gracefully.  I am making a policy decision that
+            # unsharing should happen instantly when the user requests it. -exarkun
+            share.deleteFromStore()
+
+
+
+
-    def _getShare(self, person):
-        """
-        Find the L{Share} associated with the given L{Person} for the everyone
@@ -729 +768 @@
-        Find an existing L{BlendixPerson} associated with the given L{Person}
-        and update its I{name} attribute.
-        """
+        
-        blendixPerson = self._blendixPersonForPerson(person)
-        if blendixPerson is not None:
-            blendixPerson.name = person.name