# HG changeset patch # User Ralph Meijer # Date 1216026976 0 # Node ID 2c46e6664680bffd773126fa8bb8a35515e715d5 # Parent 77c61e2b8c75d4d03b3f9a4fba2576b2f3edb3fb Match wokkel API change for PubSubClient. diff -r 77c61e2b8c75 -r 2c46e6664680 idavoll/gateway.py --- a/idavoll/gateway.py Wed Jun 25 12:27:55 2008 +0000 +++ b/idavoll/gateway.py Mon Jul 14 09:16:16 2008 +0000 @@ -411,12 +411,12 @@ return defer.succeed(None) - def itemsReceived(self, recipient, service, nodeIdentifier, items): + def itemsReceived(self, event): """ Fire up HTTP client to do callback """ - atomEntries = extractAtomEntries(items) + atomEntries = extractAtomEntries(event.items) # Don't notify if there are no atom entries if not atomEntries: @@ -427,18 +427,21 @@ payload = atomEntries[0] else: contentType = 'application/atom+xml;type=feed' - payload = constructFeed(service, nodeIdentifier, atomEntries, + payload = constructFeed(event.sender, event.nodeIdentifier, + atomEntries, title='Received item collection') - self.callCallbacks(service, nodeIdentifier, payload, contentType) + self.callCallbacks(event.sender, event.nodeIdentifier, payload, + contentType) - def deleteReceived(self, recipient, service, nodeIdentifier): + def deleteReceived(self, event): """ Fire up HTTP client to do callback """ - self.callCallbacks(service, nodeIdentifier, eventType='DELETED') + self.callCallbacks(event.sender, event.nodeIdentifier, + eventType='DELETED') def _postTo(self, callbacks, service, nodeIdentifier,