Mercurial > libervia-pubsub

comparison idavoll/memory_storage.py @ 112:72c8812fa1b5

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Fix interpretation of JIDs.
author Ralph Meijer <ralphm@ik.nu>
date Fri, 08 Apr 2005 16:31:09 +0000
parents d252d793f0ed
children 97f10cfea28c
comparison
equal deleted inserted replaced
111:30c580286d27 112:72c8812fa1b5
47 return defer.fail(storage.NodeNotFound()) 47 return defer.fail(storage.NodeNotFound())
48 48
49 return defer.succeed(None) 49 return defer.succeed(None)
50 50
51 def get_affiliations(self, entity): 51 def get_affiliations(self, entity):
52 entity_full = entity.full() 52 entity = entity.userhost()
53 return defer.succeed([(node.id, node._affiliations[entity_full]) 53 return defer.succeed([(node.id, node._affiliations[entity])
54 for name, node in self._nodes.iteritems() 54 for name, node in self._nodes.iteritems()
55 if entity_full in node._affiliations]) 55 if entity in node._affiliations])
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.JID(subscriber)
62 if subscriber.userhostJID() == entity: 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)
67 67
69 69
70 implements(storage.INode) 70 implements(storage.INode)
71 71
72 def __init__(self, node_id, owner, config): 72 def __init__(self, node_id, owner, config):
73 self.id = node_id 73 self.id = node_id
74 self._affiliations = {owner.full(): 'owner'} 74 self._affiliations = {owner.userhost(): 'owner'}
75 self._subscriptions = {} 75 self._subscriptions = {}
76 self._config = config 76 self._config = config
77 77
78 def get_type(self): 78 def get_type(self):
79 return self.type 79 return self.type