Mercurial > libervia-pubsub
annotate idavoll/test/test_storage.py @ 139:8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Twisted Xish 0.1.0.
| author | Ralph Meijer <ralphm@ik.nu> |
|---|---|
| date | Wed, 27 Apr 2005 19:45:41 +0000 |
| parents | 635e433810ef |
| children | 812300cdbc22 |
| rev | line source |
|---|---|
| 114 | 1 from twisted.trial import unittest |
| 2 from twisted.trial.assertions import * | |
| 3 from twisted.words.protocols.jabber import jid | |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
4 from twisted.internet import defer |
| 131 | 5 from twisted.xish import domish |
| 114 | 6 |
| 131 | 7 from idavoll import storage, pubsub |
| 114 | 8 |
| 9 OWNER = jid.JID('owner@example.com') | |
| 10 SUBSCRIBER = jid.JID('subscriber@example.com/Home') | |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
11 SUBSCRIBER_NEW = jid.JID('new@example.com/Home') |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
12 SUBSCRIBER_TO_BE_DELETED = jid.JID('to_be_deleted@example.com/Home') |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
13 SUBSCRIBER_PENDING = jid.JID('pending@example.com/Home') |
| 131 | 14 PUBLISHER = jid.JID('publisher@example.com') |
| 15 ITEM = domish.Element((pubsub.NS_PUBSUB, 'item'), pubsub.NS_PUBSUB) | |
| 16 ITEM['id'] = 'current' | |
| 17 ITEM.addElement(('testns', 'test'), content=u'Test \u2083 item') | |
| 18 ITEM_NEW = domish.Element((pubsub.NS_PUBSUB, 'item'), pubsub.NS_PUBSUB) | |
| 19 ITEM_NEW['id'] = 'new' | |
| 20 ITEM_NEW.addElement(('testns', 'test'), content=u'Test \u2083 item') | |
| 21 ITEM_UPDATED = domish.Element((pubsub.NS_PUBSUB, 'item'), pubsub.NS_PUBSUB) | |
| 22 ITEM_UPDATED['id'] = 'current' | |
| 23 ITEM_UPDATED.addElement(('testns', 'test'), content=u'Test \u2084 item') | |
| 24 ITEM_TO_BE_DELETED = domish.Element((pubsub.NS_PUBSUB, 'item'), | |
| 25 pubsub.NS_PUBSUB) | |
| 26 ITEM_TO_BE_DELETED['id'] = 'to-be-deleted' | |
| 27 ITEM_TO_BE_DELETED.addElement(('testns', 'test'), content=u'Test \u2083 item') | |
| 28 ITEM_TO_NOT_BE_DELETED = domish.Element((pubsub.NS_PUBSUB, 'item'), | |
| 29 pubsub.NS_PUBSUB) | |
| 30 ITEM_TO_NOT_BE_DELETED['id'] = 'to-not-be-deleted' | |
| 31 ITEM_TO_NOT_BE_DELETED.addElement(('testns', 'test'), | |
| 32 content=u'Test \u2083 item') | |
| 114 | 33 |
|
139
8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Ralph Meijer <ralphm@ik.nu>
parents:
138
diff
changeset
|
34 def decode(object): |
|
8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Ralph Meijer <ralphm@ik.nu>
parents:
138
diff
changeset
|
35 if isinstance(object, str): |
|
8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Ralph Meijer <ralphm@ik.nu>
parents:
138
diff
changeset
|
36 object = object.decode('utf-8') |
|
8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Ralph Meijer <ralphm@ik.nu>
parents:
138
diff
changeset
|
37 return object |
|
8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Ralph Meijer <ralphm@ik.nu>
parents:
138
diff
changeset
|
38 |
| 114 | 39 class StorageTests: |
| 40 | |
|
117
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
41 def _assignTestNode(self, node): |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
42 self.node = node |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
43 |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
44 def setUpClass(self): |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
45 d = self.s.get_node('pre-existing') |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
46 d.addCallback(self._assignTestNode) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
47 return d |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
48 |
| 114 | 49 def testGetNode(self): |
| 50 return self.s.get_node('pre-existing') | |
| 51 | |
| 52 def testGetNonExistingNode(self): | |
| 53 d = self.s.get_node('non-existing') | |
| 54 assertFailure(d, storage.NodeNotFound) | |
| 55 return d | |
| 56 | |
| 57 def testGetNodeIDs(self): | |
| 58 def cb(node_ids): | |
| 59 assertIn('pre-existing', node_ids) | |
| 60 assertNotIn('non-existing', node_ids) | |
| 61 | |
| 62 return self.s.get_node_ids().addCallback(cb) | |
| 63 | |
| 64 def testCreateExistingNode(self): | |
| 65 d = self.s.create_node('pre-existing', OWNER) | |
| 66 assertFailure(d, storage.NodeExists) | |
| 67 return d | |
| 68 | |
| 69 def testCreateNode(self): | |
| 70 def cb(void): | |
| 71 d = self.s.get_node('new 1') | |
| 72 return d | |
| 73 | |
| 74 d = self.s.create_node('new 1', OWNER) | |
| 75 d.addCallback(cb) | |
| 76 return d | |
| 77 | |
| 78 def testDeleteNonExistingNode(self): | |
| 79 d = self.s.delete_node('non-existing') | |
| 80 assertFailure(d, storage.NodeNotFound) | |
| 81 return d | |
| 82 | |
| 83 def testDeleteNode(self): | |
| 84 def cb(void): | |
| 85 d = self.s.get_node('to-be-deleted') | |
| 86 assertFailure(d, storage.NodeNotFound) | |
| 87 return d | |
| 88 | |
| 89 d = self.s.delete_node('to-be-deleted') | |
| 90 d.addCallback(cb) | |
| 91 return d | |
| 92 | |
| 93 def testGetAffiliations(self): | |
| 94 def cb(affiliations): | |
| 95 assertIn(('pre-existing', 'owner'), affiliations) | |
| 96 | |
| 97 d = self.s.get_affiliations(OWNER) | |
| 98 d.addCallback(cb) | |
| 99 return d | |
| 100 | |
| 101 def testGetSubscriptions(self): | |
| 102 def cb(subscriptions): | |
| 103 assertIn(('pre-existing', SUBSCRIBER, 'subscribed'), subscriptions) | |
| 104 | |
| 105 d = self.s.get_subscriptions(SUBSCRIBER) | |
| 106 d.addCallback(cb) | |
| 107 return d | |
| 108 | |
|
117
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
109 # Node tests |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
110 |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
111 def testGetType(self): |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
112 assertEqual(self.node.get_type(), 'leaf') |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
113 |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
114 def testGetConfiguration(self): |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
115 config = self.node.get_configuration() |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
116 assertIn('pubsub#persist_items', config.iterkeys()) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
117 assertIn('pubsub#deliver_payloads', config.iterkeys()) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
118 assertEqual(config['pubsub#persist_items'], True) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
119 assertEqual(config['pubsub#deliver_payloads'], True) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
120 |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
121 def testSetConfiguration(self): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
122 def get_config(node): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
123 d = node.set_configuration({'pubsub#persist_items': False}) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
124 d.addCallback(lambda _: node) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
125 return d |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
126 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
127 def check_object_config(node): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
128 config = node.get_configuration() |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
129 assertEqual(config['pubsub#persist_items'], False) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
130 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
131 def get_node(void): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
132 return self.s.get_node('to-be-reconfigured') |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
133 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
134 def check_storage_config(node): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
135 config = node.get_configuration() |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
136 assertEqual(config['pubsub#persist_items'], False) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
137 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
138 d = self.s.get_node('to-be-reconfigured') |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
139 d.addCallback(get_config) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
140 d.addCallback(check_object_config) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
141 d.addCallback(get_node) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
142 d.addCallback(check_storage_config) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
143 return d |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
144 |
|
117
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
145 def testGetMetaData(self): |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
146 meta_data = self.node.get_meta_data() |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
147 for key, value in self.node.get_configuration().iteritems(): |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
148 assertIn(key, meta_data.iterkeys()) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
149 assertEqual(value, meta_data[key]) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
150 assertIn('pubsub#node_type', meta_data.iterkeys()) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
151 assertEqual(meta_data['pubsub#node_type'], 'leaf') |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
152 |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
153 def testGetAffiliation(self): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
154 def cb(affiliation): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
155 assertEqual(affiliation, 'owner') |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
156 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
157 d = self.node.get_affiliation(OWNER) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
158 d.addCallback(cb) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
159 return d |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
160 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
161 def testGetNonExistingAffiliation(self): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
162 def cb(affiliation): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
163 assertEqual(affiliation, None) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
164 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
165 d = self.node.get_affiliation(SUBSCRIBER) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
166 d.addCallback(cb) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
167 return d |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
168 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
169 def testAddSubscription(self): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
170 def cb1(void): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
171 return self.node.get_subscription(SUBSCRIBER_NEW) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
172 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
173 def cb2(state): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
174 assertEqual(state, 'pending') |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
175 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
176 d = self.node.add_subscription(SUBSCRIBER_NEW, 'pending') |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
177 d.addCallback(cb1) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
178 d.addCallback(cb2) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
179 return d |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
180 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
181 def testAddExistingSubscription(self): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
182 d = self.node.add_subscription(SUBSCRIBER, 'pending') |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
183 assertFailure(d, storage.SubscriptionExists) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
184 return d |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
185 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
186 def testGetSubscription(self): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
187 def cb(subscriptions): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
188 assertEquals(subscriptions[0][1], 'subscribed') |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
189 assertEquals(subscriptions[1][1], 'pending') |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
190 assertEquals(subscriptions[2][1], None) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
191 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
192 d = defer.DeferredList([self.node.get_subscription(SUBSCRIBER), |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
193 self.node.get_subscription(SUBSCRIBER_PENDING), |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
194 self.node.get_subscription(OWNER)]) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
195 d.addCallback(cb) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
196 return d |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
197 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
198 def testRemoveSubscription(self): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
199 return self.node.remove_subscription(SUBSCRIBER_TO_BE_DELETED) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
200 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
201 def testRemoveNonExistingSubscription(self): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
202 d = self.node.remove_subscription(OWNER) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
203 assertFailure(d, storage.SubscriptionNotFound) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
204 return d |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
205 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
206 def testGetSubscribers(self): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
207 def cb(subscribers): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
208 assertIn(SUBSCRIBER, subscribers) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
209 assertNotIn(SUBSCRIBER_PENDING, subscribers) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
210 assertNotIn(OWNER, subscribers) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
211 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
212 d = self.node.get_subscribers() |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
213 d.addCallback(cb) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
214 return d |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
215 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
216 def testIsSubscriber(self): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
217 def cb(subscribed): |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
218 assertEquals(subscribed[0][1], True) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
219 assertEquals(subscribed[1][1], False) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
220 assertEquals(subscribed[2][1], False) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
221 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
222 d = defer.DeferredList([self.node.is_subscribed(SUBSCRIBER), |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
223 self.node.is_subscribed(SUBSCRIBER_PENDING), |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
224 self.node.is_subscribed(OWNER)]) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
225 d.addCallback(cb) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
226 return d |
|
117
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
227 |
| 131 | 228 def testStoreItems(self): |
|
138
635e433810ef
Actually test whether the item was indeed stored.
Ralph Meijer <ralphm@ik.nu>
parents:
137
diff
changeset
|
229 def cb1(void): |
|
635e433810ef
Actually test whether the item was indeed stored.
Ralph Meijer <ralphm@ik.nu>
parents:
137
diff
changeset
|
230 return self.node.get_items_by_id(['new']) |
|
635e433810ef
Actually test whether the item was indeed stored.
Ralph Meijer <ralphm@ik.nu>
parents:
137
diff
changeset
|
231 |
|
635e433810ef
Actually test whether the item was indeed stored.
Ralph Meijer <ralphm@ik.nu>
parents:
137
diff
changeset
|
232 def cb2(result): |
|
139
8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Ralph Meijer <ralphm@ik.nu>
parents:
138
diff
changeset
|
233 assertEqual(result[0], decode(ITEM_NEW.toXml())) |
|
138
635e433810ef
Actually test whether the item was indeed stored.
Ralph Meijer <ralphm@ik.nu>
parents:
137
diff
changeset
|
234 |
|
635e433810ef
Actually test whether the item was indeed stored.
Ralph Meijer <ralphm@ik.nu>
parents:
137
diff
changeset
|
235 d = self.node.store_items([ITEM_NEW], PUBLISHER) |
|
635e433810ef
Actually test whether the item was indeed stored.
Ralph Meijer <ralphm@ik.nu>
parents:
137
diff
changeset
|
236 d.addCallback(cb1) |
|
635e433810ef
Actually test whether the item was indeed stored.
Ralph Meijer <ralphm@ik.nu>
parents:
137
diff
changeset
|
237 d.addCallback(cb2) |
|
635e433810ef
Actually test whether the item was indeed stored.
Ralph Meijer <ralphm@ik.nu>
parents:
137
diff
changeset
|
238 return d |
| 131 | 239 |
| 240 def testStoreUpdatedItems(self): | |
| 241 def cb1(void): | |
| 242 return self.node.get_items_by_id(['current']) | |
| 243 | |
| 244 def cb2(result): | |
|
139
8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Ralph Meijer <ralphm@ik.nu>
parents:
138
diff
changeset
|
245 assertEqual(result[0], decode(ITEM_UPDATED.toXml())) |
| 131 | 246 |
| 247 d = self.node.store_items([ITEM_UPDATED], PUBLISHER) | |
| 248 d.addCallback(cb1) | |
| 249 d.addCallback(cb2) | |
| 250 return d | |
| 251 | |
| 252 def testRemoveItems(self): | |
| 253 def cb1(void): | |
| 254 return self.node.get_items_by_id(['to-be-deleted']) | |
| 255 | |
| 256 def cb2(result): | |
| 257 assertEqual(len(result), 0) | |
| 258 | |
| 259 d = self.node.remove_items(['to-be-deleted']) | |
| 260 d.addCallback(cb1) | |
| 261 d.addCallback(cb2) | |
| 262 return d | |
| 263 | |
| 264 def testRemoveNonExistingItems(self): | |
| 265 d = self.node.remove_items(['to-not-be-deleted', 'non-existing']) | |
| 266 assertFailure(d, storage.ItemNotFound) | |
| 267 return d | |
| 268 | |
| 269 def testGetItems(self): | |
| 270 def cb(result): | |
|
139
8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Ralph Meijer <ralphm@ik.nu>
parents:
138
diff
changeset
|
271 assertIn(decode(ITEM.toXml()), result) |
| 131 | 272 |
| 273 d = self.node.get_items() | |
| 274 d.addCallback(cb) | |
| 275 return d | |
| 276 | |
| 277 def testLastItem(self): | |
| 278 def cb(result): | |
|
139
8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Ralph Meijer <ralphm@ik.nu>
parents:
138
diff
changeset
|
279 assertEqual([decode(ITEM.toXml())], result) |
| 131 | 280 |
| 281 d = self.node.get_items(1) | |
| 282 d.addCallback(cb) | |
| 283 return d | |
| 284 | |
| 285 def testGetItemsById(self): | |
| 286 def cb(result): | |
| 287 assertEqual(len(result), 1) | |
| 288 | |
| 289 d = self.node.get_items_by_id(['current']) | |
| 290 d.addCallback(cb) | |
| 291 return d | |
| 292 | |
| 293 def testGetNonExistingItemsById(self): | |
| 294 def cb(result): | |
| 295 assertEqual(len(result), 0) | |
| 296 | |
| 297 d = self.node.get_items_by_id(['non-existing']) | |
| 298 d.addCallback(cb) | |
| 299 return d | |
| 300 | |
| 301 def testPurge(self): | |
| 302 def cb1(node): | |
| 303 d = node.purge() | |
| 304 d.addCallback(lambda _: node) | |
| 305 return d | |
| 306 | |
| 307 def cb2(node): | |
| 308 return node.get_items() | |
| 309 | |
| 310 def cb3(result): | |
| 311 assertEqual([], result) | |
| 312 | |
| 313 d = self.s.get_node('to-be-purged') | |
| 314 d.addCallback(cb1) | |
| 315 d.addCallback(cb2) | |
| 316 d.addCallback(cb3) | |
| 317 return d | |
| 318 | |
| 114 | 319 class MemoryStorageStorageTestCase(unittest.TestCase, StorageTests): |
| 320 | |
| 321 def setUpClass(self): | |
|
117
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
322 from idavoll.memory_storage import Storage, LeafNode, Subscription, \ |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
323 default_config |
| 114 | 324 self.s = Storage() |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
325 self.s._nodes['pre-existing'] = \ |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
326 LeafNode('pre-existing', OWNER, default_config) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
327 self.s._nodes['to-be-deleted'] = \ |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
328 LeafNode('to-be-deleted', OWNER, None) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
329 self.s._nodes['to-be-reconfigured'] = \ |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
330 LeafNode('to-be-reconfigured', OWNER, default_config) |
| 131 | 331 self.s._nodes['to-be-purged'] = \ |
| 332 LeafNode('to-be-purged', OWNER, None) | |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
333 |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
334 subscriptions = self.s._nodes['pre-existing']._subscriptions |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
335 subscriptions[SUBSCRIBER.full()] = Subscription('subscribed') |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
336 subscriptions[SUBSCRIBER_TO_BE_DELETED.full()] = \ |
| 114 | 337 Subscription('subscribed') |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
338 subscriptions[SUBSCRIBER_PENDING.full()] = \ |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
339 Subscription('pending') |
| 114 | 340 |
|
139
8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Ralph Meijer <ralphm@ik.nu>
parents:
138
diff
changeset
|
341 item = (decode(ITEM_TO_BE_DELETED.toXml()), PUBLISHER) |
| 131 | 342 self.s._nodes['pre-existing']._items['to-be-deleted'] = item |
| 343 self.s._nodes['pre-existing']._itemlist.append(item) | |
| 344 self.s._nodes['pre-existing']._items['to-not-be-deleted'] = item | |
| 345 self.s._nodes['pre-existing']._itemlist.append(item) | |
| 346 self.s._nodes['to-be-purged']._items['to-be-deleted'] = item | |
| 347 self.s._nodes['to-be-purged']._itemlist.append(item) | |
|
139
8f6956b9a688
Follow API change in Twisted Xish, while still being compatible with
Ralph Meijer <ralphm@ik.nu>
parents:
138
diff
changeset
|
348 item = (decode(ITEM.toXml()), PUBLISHER) |
| 131 | 349 self.s._nodes['pre-existing']._items['current'] = item |
| 350 self.s._nodes['pre-existing']._itemlist.append(item) | |
| 351 | |
|
117
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
352 return StorageTests.setUpClass(self) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
353 |
| 114 | 354 class PgsqlStorageStorageTestCase(unittest.TestCase, StorageTests): |
|
117
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
355 def _callSuperSetUpClass(self, void): |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
356 return StorageTests.setUpClass(self) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
357 |
| 114 | 358 def setUpClass(self): |
| 359 from idavoll.pgsql_storage import Storage | |
| 360 self.s = Storage('ralphm', 'pubsub_test') | |
| 361 self.s._dbpool.start() | |
|
117
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
362 d = self.s._dbpool.runInteraction(self.init) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
363 d.addCallback(self._callSuperSetUpClass) |
|
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
364 return d |
| 114 | 365 |
| 366 def tearDownClass(self): | |
| 131 | 367 #return self.s._dbpool.runInteraction(self.cleandb) |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
368 pass |
| 114 | 369 |
| 370 def init(self, cursor): | |
| 371 self.cleandb(cursor) | |
| 372 cursor.execute("""INSERT INTO nodes (node) VALUES ('pre-existing')""") | |
| 373 cursor.execute("""INSERT INTO nodes (node) VALUES ('to-be-deleted')""") | |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
374 cursor.execute("""INSERT INTO nodes (node) VALUES ('to-be-reconfigured')""") |
| 131 | 375 cursor.execute("""INSERT INTO nodes (node) VALUES ('to-be-purged')""") |
| 114 | 376 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
377 OWNER.userhost()) |
| 114 | 378 cursor.execute("""INSERT INTO affiliations |
| 379 (node_id, entity_id, affiliation) | |
| 380 SELECT nodes.id, entities.id, 'owner' | |
| 381 FROM nodes, entities | |
| 382 WHERE node='pre-existing' AND jid=%s""", | |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
383 OWNER.userhost()) |
| 114 | 384 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
385 SUBSCRIBER.userhost()) |
| 114 | 386 cursor.execute("""INSERT INTO subscriptions |
| 387 (node_id, entity_id, resource, subscription) | |
| 388 SELECT nodes.id, entities.id, %s, 'subscribed' | |
| 389 FROM nodes, entities | |
| 390 WHERE node='pre-existing' AND jid=%s""", | |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
391 (SUBSCRIBER.resource, |
|
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
392 SUBSCRIBER.userhost())) |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
393 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
394 SUBSCRIBER_TO_BE_DELETED.userhost()) |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
395 cursor.execute("""INSERT INTO subscriptions |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
396 (node_id, entity_id, resource, subscription) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
397 SELECT nodes.id, entities.id, %s, 'subscribed' |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
398 FROM nodes, entities |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
399 WHERE node='pre-existing' AND jid=%s""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
400 (SUBSCRIBER_TO_BE_DELETED.resource, |
|
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
401 SUBSCRIBER_TO_BE_DELETED.userhost())) |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
402 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
403 SUBSCRIBER_PENDING.userhost()) |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
404 cursor.execute("""INSERT INTO subscriptions |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
405 (node_id, entity_id, resource, subscription) |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
406 SELECT nodes.id, entities.id, %s, 'pending' |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
407 FROM nodes, entities |
|
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
408 WHERE node='pre-existing' AND jid=%s""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
409 (SUBSCRIBER_PENDING.resource, |
|
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
410 SUBSCRIBER_PENDING.userhost())) |
| 131 | 411 cursor.execute("""INSERT INTO entities (jid) VALUES (%s)""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
412 PUBLISHER.userhost()) |
| 131 | 413 cursor.execute("""INSERT INTO items |
| 414 (node_id, publisher, item, data, date) | |
| 415 SELECT nodes.id, %s, 'to-be-deleted', %s, | |
| 416 now() - interval '1 day' | |
| 417 FROM nodes | |
| 418 WHERE node='pre-existing'""", | |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
419 (PUBLISHER.userhost(), |
| 131 | 420 ITEM_TO_BE_DELETED.toXml())) |
| 421 cursor.execute("""INSERT INTO items | |
| 422 (node_id, publisher, item, data, date) | |
| 423 SELECT nodes.id, %s, 'to-not-be-deleted', %s, | |
| 424 now() - interval '1 day' | |
| 425 FROM nodes | |
| 426 WHERE node='pre-existing'""", | |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
427 (PUBLISHER.userhost(), |
| 131 | 428 ITEM_TO_NOT_BE_DELETED.toXml())) |
| 429 cursor.execute("""INSERT INTO items (node_id, publisher, item, data) | |
| 430 SELECT nodes.id, %s, 'to-be-deleted', %s | |
| 431 FROM nodes | |
| 432 WHERE node='to-be-purged'""", | |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
433 (PUBLISHER.userhost(), |
| 131 | 434 ITEM_TO_BE_DELETED.toXml())) |
| 435 cursor.execute("""INSERT INTO items (node_id, publisher, item, data) | |
| 436 SELECT nodes.id, %s, 'current', %s | |
| 437 FROM nodes | |
| 438 WHERE node='pre-existing'""", | |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
439 (PUBLISHER.userhost(), |
| 131 | 440 ITEM.toXml())) |
| 114 | 441 |
| 442 def cleandb(self, cursor): | |
| 443 cursor.execute("""DELETE FROM nodes WHERE node in | |
|
117
bc872c33e88c
Added test cases for a few of the Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
114
diff
changeset
|
444 ('non-existing', 'pre-existing', 'to-be-deleted', |
| 131 | 445 'new 1', 'new 2', 'new 3', 'to-be-reconfigured', |
| 446 'to-be-purged')""") | |
| 114 | 447 cursor.execute("""DELETE FROM entities WHERE jid=%s""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
448 OWNER.userhost()) |
| 114 | 449 cursor.execute("""DELETE FROM entities WHERE jid=%s""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
450 SUBSCRIBER.userhost()) |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
451 cursor.execute("""DELETE FROM entities WHERE jid=%s""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
452 SUBSCRIBER_TO_BE_DELETED.userhost()) |
|
123
8f99b4f7aea2
Add tests for all Node methods.
Ralph Meijer <ralphm@ik.nu>
parents:
117
diff
changeset
|
453 cursor.execute("""DELETE FROM entities WHERE jid=%s""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
454 SUBSCRIBER_PENDING.userhost()) |
| 131 | 455 cursor.execute("""DELETE FROM entities WHERE jid=%s""", |
|
137
aca904a41a43
Discover client_encoding parameter to pyPgSQL.
Ralph Meijer <ralphm@ik.nu>
parents:
131
diff
changeset
|
456 PUBLISHER.userhost()) |