Mercurial > libervia-pubsub

comparison idavoll/memory_storage.py @ 148:b03e5ad81173

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Change all calls to jid.JID to jid.internJID to avoid redoing stringprep.
author Ralph Meijer <ralphm@ik.nu>
date Wed, 31 Aug 2005 12:58:50 +0000
parents b4490bdc77e5
children 5191ba7c4df8
comparison
equal deleted inserted replaced
147:fee92e499d6d 148:b03e5ad81173
56 56
57 def get_subscriptions(self, entity): 57 def get_subscriptions(self, entity):
58 subscriptions = [] 58 subscriptions = []
59 for node in self._nodes.itervalues(): 59 for node in self._nodes.itervalues():
60 for subscriber, subscription in node._subscriptions.iteritems(): 60 for subscriber, subscription in node._subscriptions.iteritems():
61 subscriber = jid.JID(subscriber) 61 subscriber = jid.internJID(subscriber)
62 if subscriber.userhostJID() == entity.userhostJID(): 62 if subscriber.userhostJID() == entity.userhostJID():
63 subscriptions.append((node.id, subscriber, 63 subscriptions.append((node.id, subscriber,
64 subscription.state)) 64 subscription.state))
65 65
66 return defer.succeed(subscriptions) 66 return defer.succeed(subscriptions)
120 return defer.fail(storage.SubscriptionNotFound()) 120 return defer.fail(storage.SubscriptionNotFound())
121 121
122 return defer.succeed(None) 122 return defer.succeed(None)
123 123
124 def get_subscribers(self): 124 def get_subscribers(self):
125 subscribers = [jid.JID(subscriber) for subscriber, subscription 125 subscribers = [jid.internJID(subscriber) for subscriber, subscription
126 in self._subscriptions.iteritems() 126 in self._subscriptions.iteritems()
127 if subscription.state == 'subscribed'] 127 if subscription.state == 'subscribed']
128 128
129 return defer.succeed(subscribers) 129 return defer.succeed(subscribers)
130 130
131 def is_subscribed(self, entity): 131 def is_subscribed(self, entity):
132 for subscriber, subscription in self._subscriptions.iteritems(): 132 for subscriber, subscription in self._subscriptions.iteritems():
133 if jid.JID(subscriber).userhost() == entity.userhost() and \ 133 if jid.internJID(subscriber).userhost() == entity.userhost() and \
134 subscription.state == 'subscribed': 134 subscription.state == 'subscribed':
135 return defer.succeed(True) 135 return defer.succeed(True)
136 136
137 return defer.succeed(False) 137 return defer.succeed(False)
138 138
139 def get_affiliations(self): 139 def get_affiliations(self):
140 affiliations = [(jid.JID(entity), affiliation) for entity, affiliation 140 affiliations = [(jid.internJID(entity), affiliation) for entity, affiliation
141 in self._affiliations.iteritems()] 141 in self._affiliations.iteritems()]
142 142
143 return defer.succeed(affiliations) 143 return defer.succeed(affiliations)
144 144
145 class LeafNodeMixin: 145 class LeafNodeMixin: