Mercurial > libervia-pubsub

comparison sat_pubsub/test/test_storage.py @ 266:560b6cdc50b2 0.1.0

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix the backend and storage tests
author souliane <souliane@mailoo.org>
date Sat, 22 Feb 2014 08:05:03 +0100
parents d55620ceafed
children b757c29b20d7
comparison
equal deleted inserted replaced
265:89493845d3dd 266:560b6cdc50b2
60 from twisted.trial import unittest 60 from twisted.trial import unittest
61 from twisted.words.protocols.jabber import jid 61 from twisted.words.protocols.jabber import jid
62 from twisted.internet import defer 62 from twisted.internet import defer
63 from twisted.words.xish import domish 63 from twisted.words.xish import domish
64 64
65 from sat_pubsub import error, iidavoll 65 from sat_pubsub import error, iidavoll, const
66 66
67 OWNER = jid.JID('owner@example.com/Work') 67 OWNER = jid.JID('owner@example.com/Work')
68 SUBSCRIBER = jid.JID('subscriber@example.com/Home') 68 SUBSCRIBER = jid.JID('subscriber@example.com/Home')
69 SUBSCRIBER_NEW = jid.JID('new@example.com/Home') 69 SUBSCRIBER_NEW = jid.JID('new@example.com/Home')
70 SUBSCRIBER_TO_BE_DELETED = jid.JID('to_be_deleted@example.com/Home') 70 SUBSCRIBER_TO_BE_DELETED = jid.JID('to_be_deleted@example.com/Home')
164 "pubsub#persist_items": True, 164 "pubsub#persist_items": True,
165 "pubsub#deliver_payloads": True, 165 "pubsub#deliver_payloads": True,
166 "pubsub#send_last_published_item": 'on_sub', 166 "pubsub#send_last_published_item": 'on_sub',
167 "pubsub#node_type": 'leaf', 167 "pubsub#node_type": 'leaf',
168 "pubsub#access_model": 'open', 168 "pubsub#access_model": 'open',
169 const.OPT_PUBLISH_MODEL: const.VAL_PMODEL_OPEN
169 } 170 }
170 171
171 def unsetPersistItems(_): 172 def unsetPersistItems(_):
172 config["pubsub#persist_items"] = False 173 config["pubsub#persist_items"] = False
173 174
361 return d 362 return d
362 363
363 364
364 def test_storeItems(self): 365 def test_storeItems(self):
365 def cb1(void): 366 def cb1(void):
366 return self.node.getItemsById(['new']) 367 return self.node.getItemsById("", False, ['new'])
367 368
368 def cb2(result): 369 def cb2(result):
369 self.assertEqual(ITEM_NEW.toXml(), result[0].toXml()) 370 self.assertEqual(ITEM_NEW.toXml(), result[0].toXml())
370 371
371 d = self.node.storeItems([ITEM_NEW], PUBLISHER) 372 d = self.node.storeItems([(const.VAL_AMODEL_DEFAULT, {}, ITEM_NEW)], PUBLISHER)
372 d.addCallback(cb1) 373 d.addCallback(cb1)
373 d.addCallback(cb2) 374 d.addCallback(cb2)
374 return d 375 return d
375 376
376 377
377 def test_storeUpdatedItems(self): 378 def test_storeUpdatedItems(self):
378 def cb1(void): 379 def cb1(void):
379 return self.node.getItemsById(['current']) 380 return self.node.getItemsById("", False, ['current'])
380 381
381 def cb2(result): 382 def cb2(result):
382 self.assertEqual(ITEM_UPDATED.toXml(), result[0].toXml()) 383 self.assertEqual(ITEM_UPDATED.toXml(), result[0].toXml())
383 384
384 d = self.node.storeItems([ITEM_UPDATED], PUBLISHER) 385 d = self.node.storeItems([(const.VAL_AMODEL_DEFAULT, {}, ITEM_UPDATED)], PUBLISHER)
385 d.addCallback(cb1) 386 d.addCallback(cb1)
386 d.addCallback(cb2) 387 d.addCallback(cb2)
387 return d 388 return d
388 389
389 390
390 def test_removeItems(self): 391 def test_removeItems(self):
391 def cb1(result): 392 def cb1(result):
392 self.assertEqual(['to-be-deleted'], result) 393 self.assertEqual(['to-be-deleted'], result)
393 return self.node.getItemsById(['to-be-deleted']) 394 return self.node.getItemsById("", False, ['to-be-deleted'])
394 395
395 def cb2(result): 396 def cb2(result):
396 self.assertEqual(0, len(result)) 397 self.assertEqual(0, len(result))
397 398
398 d = self.node.removeItems(['to-be-deleted']) 399 d = self.node.removeItems(['to-be-deleted'])
412 413
413 def test_getItems(self): 414 def test_getItems(self):
414 def cb(result): 415 def cb(result):
415 items = [item.toXml() for item in result] 416 items = [item.toXml() for item in result]
416 self.assertIn(ITEM.toXml(), items) 417 self.assertIn(ITEM.toXml(), items)
417 418 d = self.node.getItems("", False)
418 d = self.node.getItems()
419 d.addCallback(cb) 419 d.addCallback(cb)
420 return d 420 return d
421 421
422 422
423 def test_lastItem(self): 423 def test_lastItem(self):
424 def cb(result): 424 def cb(result):
425 self.assertEqual(1, len(result)) 425 self.assertEqual(1, len(result))
426 self.assertEqual(ITEM.toXml(), result[0].toXml()) 426 self.assertEqual(ITEM.toXml(), result[0].toXml())
427 427
428 d = self.node.getItems(1) 428 d = self.node.getItems("", False, 1)
429 d.addCallback(cb) 429 d.addCallback(cb)
430 return d 430 return d
431 431
432 432
433 def test_getItemsById(self): 433 def test_getItemsById(self):
434 def cb(result): 434 def cb(result):
435 self.assertEqual(1, len(result)) 435 self.assertEqual(1, len(result))
436 436
437 d = self.node.getItemsById(['current']) 437 d = self.node.getItemsById("", False, ['current'])
438 d.addCallback(cb) 438 d.addCallback(cb)
439 return d 439 return d
440 440
441 441
442 def test_getNonExistingItemsById(self): 442 def test_getNonExistingItemsById(self):
443 def cb(result): 443 def cb(result):
444 self.assertEqual(0, len(result)) 444 self.assertEqual(0, len(result))
445 445
446 d = self.node.getItemsById(['non-existing']) 446 d = self.node.getItemsById("", False, ['non-existing'])
447 d.addCallback(cb) 447 d.addCallback(cb)
448 return d 448 return d
449 449
450 450
451 def test_purge(self): 451 def test_purge(self):
453 d = node.purge() 453 d = node.purge()
454 d.addCallback(lambda _: node) 454 d.addCallback(lambda _: node)
455 return d 455 return d
456 456
457 def cb2(node): 457 def cb2(node):
458 return node.getItems() 458 return node.getItems("", False)
459 459
460 def cb3(result): 460 def cb3(result):
461 self.assertEqual([], result) 461 self.assertEqual([], result)
462 462
463 d = self.s.getNode('to-be-purged') 463 d = self.s.getNode('to-be-purged')