Mercurial > libervia-backend

comparison sat/test/test_plugin_misc_groupblog.py @ 2765:378188abe941

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
misc: replaced all "dummy" by the more conventional and readable "__" ("_" being used for gettext)
author Goffi <goffi@goffi.org>
date Fri, 11 Jan 2019 11:13:15 +0100
parents 56f94936df1e
children 003b8b4b56a7
comparison
equal deleted inserted replaced
2764:92af49cde255 2765:378188abe941
186 def test_sendGroupBlog(self): 186 def test_sendGroupBlog(self):
187 self._initialise(C.PROFILE[0]) 187 self._initialise(C.PROFILE[0])
188 d = self.psclient.items(SERVICE, NODE_ID) 188 d = self.psclient.items(SERVICE, NODE_ID)
189 d.addCallback(lambda items: self.assertEqual(len(items), 0)) 189 d.addCallback(lambda items: self.assertEqual(len(items), 0))
190 d.addCallback( 190 d.addCallback(
191 lambda dummy: self.plugin.sendGroupBlog( 191 lambda __: self.plugin.sendGroupBlog(
192 "PUBLIC", [], "test", {}, C.PROFILE[0] 192 "PUBLIC", [], "test", {}, C.PROFILE[0]
193 ) 193 )
194 ) 194 )
195 d.addCallback(lambda dummy: self.psclient.items(SERVICE, NODE_ID)) 195 d.addCallback(lambda __: self.psclient.items(SERVICE, NODE_ID))
196 return d.addCallback(lambda items: self.assertEqual(len(items), 1)) 196 return d.addCallback(lambda items: self.assertEqual(len(items), 1))
197 197
198 def test_deleteGroupBlog(self): 198 def test_deleteGroupBlog(self):
199 pub_data = (SERVICE, NODE_ID, ITEM_ID_1) 199 pub_data = (SERVICE, NODE_ID, ITEM_ID_1)
200 self.host.bridge.expectCall( 200 self.host.bridge.expectCall(
205 C.PROFILE[0], 205 C.PROFILE[0],
206 ) 206 )
207 207
208 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 208 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
209 d.addCallback( 209 d.addCallback(
210 lambda dummy: self.plugin.deleteGroupBlog( 210 lambda __: self.plugin.deleteGroupBlog(
211 pub_data, COMMENTS_NODE_URL_1, profile_key=C.PROFILE[0] 211 pub_data, COMMENTS_NODE_URL_1, profile_key=C.PROFILE[0]
212 ) 212 )
213 ) 213 )
214 return d.addCallback(self.assertEqual, None) 214 return d.addCallback(self.assertEqual, None)
215 215
218 new_text = u"silfu23RFWUP)IWNOEIOEFÖ" 218 new_text = u"silfu23RFWUP)IWNOEIOEFÖ"
219 219
220 self._initialise(C.PROFILE[0]) 220 self._initialise(C.PROFILE[0])
221 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 221 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
222 d.addCallback( 222 d.addCallback(
223 lambda dummy: self.plugin.updateGroupBlog( 223 lambda __: self.plugin.updateGroupBlog(
224 pub_data, COMMENTS_NODE_URL_1, new_text, {}, profile_key=C.PROFILE[0] 224 pub_data, COMMENTS_NODE_URL_1, new_text, {}, profile_key=C.PROFILE[0]
225 ) 225 )
226 ) 226 )
227 d.addCallback(lambda dummy: self.psclient.items(SERVICE, NODE_ID)) 227 d.addCallback(lambda __: self.psclient.items(SERVICE, NODE_ID))
228 return d.addCallback( 228 return d.addCallback(
229 lambda items: self.assertEqual( 229 lambda items: self.assertEqual(
230 "".join(items[0].entry.title.children), new_text 230 "".join(items[0].entry.title.children), new_text
231 ) 231 )
232 ) 232 )
234 def test_sendGroupBlogComment(self): 234 def test_sendGroupBlogComment(self):
235 self._initialise(C.PROFILE[0]) 235 self._initialise(C.PROFILE[0])
236 d = self.psclient.items(SERVICE, NODE_ID) 236 d = self.psclient.items(SERVICE, NODE_ID)
237 d.addCallback(lambda items: self.assertEqual(len(items), 0)) 237 d.addCallback(lambda items: self.assertEqual(len(items), 0))
238 d.addCallback( 238 d.addCallback(
239 lambda dummy: self.plugin.sendGroupBlogComment( 239 lambda __: self.plugin.sendGroupBlogComment(
240 COMMENTS_NODE_URL_1, "test", {}, profile_key=C.PROFILE[0] 240 COMMENTS_NODE_URL_1, "test", {}, profile_key=C.PROFILE[0]
241 ) 241 )
242 ) 242 )
243 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1)) 243 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1))
244 return d.addCallback(lambda items: self.assertEqual(len(items), 1)) 244 return d.addCallback(lambda items: self.assertEqual(len(items), 1))
245 245
246 def test_getGroupBlogs(self): 246 def test_getGroupBlogs(self):
247 self._initialise(C.PROFILE[0]) 247 self._initialise(C.PROFILE[0])
248 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 248 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
249 d.addCallback( 249 d.addCallback(
250 lambda dummy: self.plugin.getGroupBlogs(PUBLISHER, profile_key=C.PROFILE[0]) 250 lambda __: self.plugin.getGroupBlogs(PUBLISHER, profile_key=C.PROFILE[0])
251 ) 251 )
252 result = ( 252 result = (
253 [ITEM_DATA_1()], 253 [ITEM_DATA_1()],
254 {"count": "1", "index": "0", "first": ITEM_ID_1, "last": ITEM_ID_1}, 254 {"count": "1", "index": "0", "first": ITEM_ID_1, "last": ITEM_ID_1},
255 ) 255 )
257 257
258 def test_getGroupBlogsNoCount(self): 258 def test_getGroupBlogsNoCount(self):
259 self._initialise(C.PROFILE[0]) 259 self._initialise(C.PROFILE[0])
260 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 260 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
261 d.addCallback( 261 d.addCallback(
262 lambda dummy: self.plugin.getGroupBlogs( 262 lambda __: self.plugin.getGroupBlogs(
263 PUBLISHER, count_comments=False, profile_key=C.PROFILE[0] 263 PUBLISHER, count_comments=False, profile_key=C.PROFILE[0]
264 ) 264 )
265 ) 265 )
266 result = ( 266 result = (
267 [ITEM_DATA_1(DO_NOT_COUNT_COMMENTS)], 267 [ITEM_DATA_1(DO_NOT_COUNT_COMMENTS)],
271 271
272 def test_getGroupBlogsWithIDs(self): 272 def test_getGroupBlogsWithIDs(self):
273 self._initialise(C.PROFILE[0]) 273 self._initialise(C.PROFILE[0])
274 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 274 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
275 d.addCallback( 275 d.addCallback(
276 lambda dummy: self.plugin.getGroupBlogs( 276 lambda __: self.plugin.getGroupBlogs(
277 PUBLISHER, [ITEM_ID_1], profile_key=C.PROFILE[0] 277 PUBLISHER, [ITEM_ID_1], profile_key=C.PROFILE[0]
278 ) 278 )
279 ) 279 )
280 result = ( 280 result = (
281 [ITEM_DATA_1()], 281 [ITEM_DATA_1()],
285 285
286 def test_getGroupBlogsWithRSM(self): 286 def test_getGroupBlogsWithRSM(self):
287 self._initialise(C.PROFILE[0]) 287 self._initialise(C.PROFILE[0])
288 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 288 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
289 d.addCallback( 289 d.addCallback(
290 lambda dummy: self.plugin.getGroupBlogs( 290 lambda __: self.plugin.getGroupBlogs(
291 PUBLISHER, rsm_data={"max_": 1}, profile_key=C.PROFILE[0] 291 PUBLISHER, rsm_data={"max_": 1}, profile_key=C.PROFILE[0]
292 ) 292 )
293 ) 293 )
294 result = ( 294 result = (
295 [ITEM_DATA_1()], 295 [ITEM_DATA_1()],
299 299
300 def test_getGroupBlogsWithComments(self): 300 def test_getGroupBlogsWithComments(self):
301 self._initialise(C.PROFILE[0]) 301 self._initialise(C.PROFILE[0])
302 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 302 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
303 d.addCallback( 303 d.addCallback(
304 lambda dummy: self.psclient.publish(SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1]) 304 lambda __: self.psclient.publish(SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1])
305 ) 305 )
306 d.addCallback( 306 d.addCallback(
307 lambda dummy: self.plugin.getGroupBlogsWithComments( 307 lambda __: self.plugin.getGroupBlogsWithComments(
308 PUBLISHER, [], profile_key=C.PROFILE[0] 308 PUBLISHER, [], profile_key=C.PROFILE[0]
309 ) 309 )
310 ) 310 )
311 result = ( 311 result = (
312 [ 312 [
329 329
330 def test_getGroupBlogsWithComments2(self): 330 def test_getGroupBlogsWithComments2(self):
331 self._initialise(C.PROFILE[0]) 331 self._initialise(C.PROFILE[0])
332 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 332 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
333 d.addCallback( 333 d.addCallback(
334 lambda dummy: self.psclient.publish( 334 lambda __: self.psclient.publish(
335 SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1, COMMENT_2] 335 SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1, COMMENT_2]
336 ) 336 )
337 ) 337 )
338 d.addCallback( 338 d.addCallback(
339 lambda dummy: self.plugin.getGroupBlogsWithComments( 339 lambda __: self.plugin.getGroupBlogsWithComments(
340 PUBLISHER, [], profile_key=C.PROFILE[0] 340 PUBLISHER, [], profile_key=C.PROFILE[0]
341 ) 341 )
342 ) 342 )
343 result = ( 343 result = (
344 [ 344 [
362 362
363 def test_getGroupBlogsAtom(self): 363 def test_getGroupBlogsAtom(self):
364 self._initialise(C.PROFILE[0]) 364 self._initialise(C.PROFILE[0])
365 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 365 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
366 d.addCallback( 366 d.addCallback(
367 lambda dummy: self.plugin.getGroupBlogsAtom( 367 lambda __: self.plugin.getGroupBlogsAtom(
368 PUBLISHER, {"max_": 1}, profile_key=C.PROFILE[0] 368 PUBLISHER, {"max_": 1}, profile_key=C.PROFILE[0]
369 ) 369 )
370 ) 370 )
371 371
372 def cb(atom): 372 def cb(atom):
377 377
378 def test_getMassiveGroupBlogs(self): 378 def test_getMassiveGroupBlogs(self):
379 self._initialise(C.PROFILE[0]) 379 self._initialise(C.PROFILE[0])
380 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 380 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
381 d.addCallback( 381 d.addCallback(
382 lambda dummy: self.plugin.getMassiveGroupBlogs( 382 lambda __: self.plugin.getMassiveGroupBlogs(
383 "JID", [jid.JID(PUBLISHER)], {"max_": 1}, profile_key=C.PROFILE[0] 383 "JID", [jid.JID(PUBLISHER)], {"max_": 1}, profile_key=C.PROFILE[0]
384 ) 384 )
385 ) 385 )
386 result = { 386 result = {
387 PUBLISHER: ( 387 PUBLISHER: (
401 401
402 def test_getMassiveGroupBlogsWithComments(self): 402 def test_getMassiveGroupBlogsWithComments(self):
403 self._initialise(C.PROFILE[0]) 403 self._initialise(C.PROFILE[0])
404 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 404 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
405 d.addCallback( 405 d.addCallback(
406 lambda dummy: self.psclient.publish( 406 lambda __: self.psclient.publish(
407 SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1, COMMENT_2] 407 SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1, COMMENT_2]
408 ) 408 )
409 ) 409 )
410 d.addCallback( 410 d.addCallback(
411 lambda dummy: self.plugin.getMassiveGroupBlogs( 411 lambda __: self.plugin.getMassiveGroupBlogs(
412 "JID", [jid.JID(PUBLISHER)], {"max_": 1}, profile_key=C.PROFILE[0] 412 "JID", [jid.JID(PUBLISHER)], {"max_": 1}, profile_key=C.PROFILE[0]
413 ) 413 )
414 ) 414 )
415 result = { 415 result = {
416 PUBLISHER: ( 416 PUBLISHER: (
430 430
431 def test_getGroupBlogComments(self): 431 def test_getGroupBlogComments(self):
432 self._initialise(C.PROFILE[0]) 432 self._initialise(C.PROFILE[0])
433 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 433 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
434 d.addCallback( 434 d.addCallback(
435 lambda dummy: self.psclient.publish(SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1]) 435 lambda __: self.psclient.publish(SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1])
436 ) 436 )
437 d.addCallback( 437 d.addCallback(
438 lambda dummy: self.plugin.getGroupBlogComments( 438 lambda __: self.plugin.getGroupBlogComments(
439 SERVICE, COMMENTS_NODE_ID_1, {"max_": 1}, profile_key=C.PROFILE[0] 439 SERVICE, COMMENTS_NODE_ID_1, {"max_": 1}, profile_key=C.PROFILE[0]
440 ) 440 )
441 ) 441 )
442 result = ( 442 result = (
443 [COMMENT_DATA_1], 443 [COMMENT_DATA_1],
472 """Delete our main node and associated comments node""" 472 """Delete our main node and associated comments node"""
473 self._initialise(C.PROFILE[0]) 473 self._initialise(C.PROFILE[0])
474 self.host.profiles[C.PROFILE[0]].roster.addItem(jid.JID(OTHER_PUBLISHER)) 474 self.host.profiles[C.PROFILE[0]].roster.addItem(jid.JID(OTHER_PUBLISHER))
475 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 475 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
476 d.addCallback( 476 d.addCallback(
477 lambda dummy: self.psclient.publish( 477 lambda __: self.psclient.publish(
478 SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1, COMMENT_2] 478 SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1, COMMENT_2]
479 ) 479 )
480 ) 480 )
481 d.addCallback(lambda dummy: self.psclient.items(SERVICE, NODE_ID)) 481 d.addCallback(lambda __: self.psclient.items(SERVICE, NODE_ID))
482 d.addCallback(lambda items: self.assertEqual(len(items), 1)) 482 d.addCallback(lambda items: self.assertEqual(len(items), 1))
483 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1)) 483 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1))
484 d.addCallback(lambda items: self.assertEqual(len(items), 2)) 484 d.addCallback(lambda items: self.assertEqual(len(items), 2))
485 485
486 d.addCallback( 486 d.addCallback(
487 lambda dummy: self.psclient.publish(SERVICE, OTHER_NODE_ID, [ITEM_2]) 487 lambda __: self.psclient.publish(SERVICE, OTHER_NODE_ID, [ITEM_2])
488 ) 488 )
489 d.addCallback( 489 d.addCallback(
490 lambda dummy: self.psclient.publish( 490 lambda __: self.psclient.publish(
491 SERVICE, COMMENTS_NODE_ID_2, [COMMENT_1, COMMENT_2] 491 SERVICE, COMMENTS_NODE_ID_2, [COMMENT_1, COMMENT_2]
492 ) 492 )
493 ) 493 )
494 d.addCallback(lambda dummy: self.psclient.items(SERVICE, OTHER_NODE_ID)) 494 d.addCallback(lambda __: self.psclient.items(SERVICE, OTHER_NODE_ID))
495 d.addCallback(lambda items: self.assertEqual(len(items), 1)) 495 d.addCallback(lambda items: self.assertEqual(len(items), 1))
496 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2)) 496 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2))
497 d.addCallback(lambda items: self.assertEqual(len(items), 2)) 497 d.addCallback(lambda items: self.assertEqual(len(items), 2))
498 498
499 def clean(res): 499 def clean(res):
500 del self.host.plugins["XEP-0060"].node_cache[ 500 del self.host.plugins["XEP-0060"].node_cache[
501 C.PROFILE[0] + "@found@" + SERVICE 501 C.PROFILE[0] + "@found@" + SERVICE
502 ] 502 ]
503 return res 503 return res
504 504
505 d.addCallback(lambda dummy: self.plugin.deleteAllGroupBlogs(C.PROFILE[0])) 505 d.addCallback(lambda __: self.plugin.deleteAllGroupBlogs(C.PROFILE[0]))
506 d.addCallback(clean) 506 d.addCallback(clean)
507 507
508 d.addCallback(lambda dummy: self.psclient.items(SERVICE, NODE_ID)) 508 d.addCallback(lambda __: self.psclient.items(SERVICE, NODE_ID))
509 d.addCallback(lambda items: self.assertEqual(len(items), 0)) 509 d.addCallback(lambda items: self.assertEqual(len(items), 0))
510 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1)) 510 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1))
511 d.addCallback(lambda items: self.assertEqual(len(items), 0)) 511 d.addCallback(lambda items: self.assertEqual(len(items), 0))
512 512
513 d.addCallback(lambda dummy: self.psclient.items(SERVICE, OTHER_NODE_ID)) 513 d.addCallback(lambda __: self.psclient.items(SERVICE, OTHER_NODE_ID))
514 d.addCallback(lambda items: self.assertEqual(len(items), 1)) 514 d.addCallback(lambda items: self.assertEqual(len(items), 1))
515 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2)) 515 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2))
516 d.addCallback(lambda items: self.assertEqual(len(items), 2)) 516 d.addCallback(lambda items: self.assertEqual(len(items), 2))
517 return d 517 return d
518 518
519 def test_deleteAllGroupBlogsComments(self): 519 def test_deleteAllGroupBlogsComments(self):
520 """Delete the comments we posted on other node's""" 520 """Delete the comments we posted on other node's"""
521 self._initialise(C.PROFILE[0]) 521 self._initialise(C.PROFILE[0])
522 self.host.profiles[C.PROFILE[0]].roster.addItem(jid.JID(OTHER_PUBLISHER)) 522 self.host.profiles[C.PROFILE[0]].roster.addItem(jid.JID(OTHER_PUBLISHER))
523 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 523 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
524 d.addCallback( 524 d.addCallback(
525 lambda dummy: self.psclient.publish( 525 lambda __: self.psclient.publish(
526 SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1, COMMENT_2] 526 SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1, COMMENT_2]
527 ) 527 )
528 ) 528 )
529 d.addCallback(lambda dummy: self.psclient.items(SERVICE, NODE_ID)) 529 d.addCallback(lambda __: self.psclient.items(SERVICE, NODE_ID))
530 d.addCallback(lambda items: self.assertEqual(len(items), 1)) 530 d.addCallback(lambda items: self.assertEqual(len(items), 1))
531 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1)) 531 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1))
532 d.addCallback(lambda items: self.assertEqual(len(items), 2)) 532 d.addCallback(lambda items: self.assertEqual(len(items), 2))
533 533
534 d.addCallback( 534 d.addCallback(
535 lambda dummy: self.psclient.publish(SERVICE, OTHER_NODE_ID, [ITEM_2]) 535 lambda __: self.psclient.publish(SERVICE, OTHER_NODE_ID, [ITEM_2])
536 ) 536 )
537 d.addCallback( 537 d.addCallback(
538 lambda dummy: self.psclient.publish( 538 lambda __: self.psclient.publish(
539 SERVICE, COMMENTS_NODE_ID_2, [COMMENT_1, COMMENT_2] 539 SERVICE, COMMENTS_NODE_ID_2, [COMMENT_1, COMMENT_2]
540 ) 540 )
541 ) 541 )
542 d.addCallback(lambda dummy: self.psclient.items(SERVICE, OTHER_NODE_ID)) 542 d.addCallback(lambda __: self.psclient.items(SERVICE, OTHER_NODE_ID))
543 d.addCallback(lambda items: self.assertEqual(len(items), 1)) 543 d.addCallback(lambda items: self.assertEqual(len(items), 1))
544 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2)) 544 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2))
545 d.addCallback(lambda items: self.assertEqual(len(items), 2)) 545 d.addCallback(lambda items: self.assertEqual(len(items), 2))
546 546
547 def clean(res): 547 def clean(res):
548 del self.host.plugins["XEP-0060"].node_cache[ 548 del self.host.plugins["XEP-0060"].node_cache[
549 C.PROFILE[0] + "@found@" + SERVICE 549 C.PROFILE[0] + "@found@" + SERVICE
550 ] 550 ]
551 return res 551 return res
552 552
553 d.addCallback(lambda dummy: self.plugin.deleteAllGroupBlogsComments(C.PROFILE[0])) 553 d.addCallback(lambda __: self.plugin.deleteAllGroupBlogsComments(C.PROFILE[0]))
554 d.addCallback(clean) 554 d.addCallback(clean)
555 555
556 d.addCallback(lambda dummy: self.psclient.items(SERVICE, NODE_ID)) 556 d.addCallback(lambda __: self.psclient.items(SERVICE, NODE_ID))
557 d.addCallback(lambda items: self.assertEqual(len(items), 1)) 557 d.addCallback(lambda items: self.assertEqual(len(items), 1))
558 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1)) 558 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1))
559 d.addCallback(lambda items: self.assertEqual(len(items), 2)) 559 d.addCallback(lambda items: self.assertEqual(len(items), 2))
560 560
561 d.addCallback(lambda dummy: self.psclient.items(SERVICE, OTHER_NODE_ID)) 561 d.addCallback(lambda __: self.psclient.items(SERVICE, OTHER_NODE_ID))
562 d.addCallback(lambda items: self.assertEqual(len(items), 1)) 562 d.addCallback(lambda items: self.assertEqual(len(items), 1))
563 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2)) 563 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2))
564 d.addCallback(lambda items: self.assertEqual(len(items), 0)) 564 d.addCallback(lambda items: self.assertEqual(len(items), 0))
565 return d 565 return d
566 566
567 def test_deleteAllGroupBlogsAndComments(self): 567 def test_deleteAllGroupBlogsAndComments(self):
568 self._initialise(C.PROFILE[0]) 568 self._initialise(C.PROFILE[0])
569 self.host.profiles[C.PROFILE[0]].roster.addItem(jid.JID(OTHER_PUBLISHER)) 569 self.host.profiles[C.PROFILE[0]].roster.addItem(jid.JID(OTHER_PUBLISHER))
570 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1]) 570 d = self.psclient.publish(SERVICE, NODE_ID, [ITEM_1])
571 d.addCallback( 571 d.addCallback(
572 lambda dummy: self.psclient.publish( 572 lambda __: self.psclient.publish(
573 SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1, COMMENT_2] 573 SERVICE, COMMENTS_NODE_ID_1, [COMMENT_1, COMMENT_2]
574 ) 574 )
575 ) 575 )
576 d.addCallback(lambda dummy: self.psclient.items(SERVICE, NODE_ID)) 576 d.addCallback(lambda __: self.psclient.items(SERVICE, NODE_ID))
577 d.addCallback(lambda items: self.assertEqual(len(items), 1)) 577 d.addCallback(lambda items: self.assertEqual(len(items), 1))
578 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1)) 578 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1))
579 d.addCallback(lambda items: self.assertEqual(len(items), 2)) 579 d.addCallback(lambda items: self.assertEqual(len(items), 2))
580 580
581 d.addCallback( 581 d.addCallback(
582 lambda dummy: self.psclient.publish(SERVICE, OTHER_NODE_ID, [ITEM_2]) 582 lambda __: self.psclient.publish(SERVICE, OTHER_NODE_ID, [ITEM_2])
583 ) 583 )
584 d.addCallback( 584 d.addCallback(
585 lambda dummy: self.psclient.publish( 585 lambda __: self.psclient.publish(
586 SERVICE, COMMENTS_NODE_ID_2, [COMMENT_1, COMMENT_2] 586 SERVICE, COMMENTS_NODE_ID_2, [COMMENT_1, COMMENT_2]
587 ) 587 )
588 ) 588 )
589 d.addCallback(lambda dummy: self.psclient.items(SERVICE, OTHER_NODE_ID)) 589 d.addCallback(lambda __: self.psclient.items(SERVICE, OTHER_NODE_ID))
590 d.addCallback(lambda items: self.assertEqual(len(items), 1)) 590 d.addCallback(lambda items: self.assertEqual(len(items), 1))
591 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2)) 591 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2))
592 d.addCallback(lambda items: self.assertEqual(len(items), 2)) 592 d.addCallback(lambda items: self.assertEqual(len(items), 2))
593 593
594 def clean(res): 594 def clean(res):
595 del self.host.plugins["XEP-0060"].node_cache[ 595 del self.host.plugins["XEP-0060"].node_cache[
596 C.PROFILE[0] + "@found@" + SERVICE 596 C.PROFILE[0] + "@found@" + SERVICE
597 ] 597 ]
598 return res 598 return res
599 599
600 d.addCallback( 600 d.addCallback(
601 lambda dummy: self.plugin.deleteAllGroupBlogsAndComments(C.PROFILE[0]) 601 lambda __: self.plugin.deleteAllGroupBlogsAndComments(C.PROFILE[0])
602 ) 602 )
603 d.addCallback(clean) 603 d.addCallback(clean)
604 604
605 d.addCallback(lambda dummy: self.psclient.items(SERVICE, NODE_ID)) 605 d.addCallback(lambda __: self.psclient.items(SERVICE, NODE_ID))
606 d.addCallback(lambda items: self.assertEqual(len(items), 0)) 606 d.addCallback(lambda items: self.assertEqual(len(items), 0))
607 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1)) 607 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_1))
608 d.addCallback(lambda items: self.assertEqual(len(items), 0)) 608 d.addCallback(lambda items: self.assertEqual(len(items), 0))
609 609
610 d.addCallback(lambda dummy: self.psclient.items(SERVICE, OTHER_NODE_ID)) 610 d.addCallback(lambda __: self.psclient.items(SERVICE, OTHER_NODE_ID))
611 d.addCallback(lambda items: self.assertEqual(len(items), 1)) 611 d.addCallback(lambda items: self.assertEqual(len(items), 1))
612 d.addCallback(lambda dummy: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2)) 612 d.addCallback(lambda __: self.psclient.items(SERVICE, COMMENTS_NODE_ID_2))
613 d.addCallback(lambda items: self.assertEqual(len(items), 0)) 613 d.addCallback(lambda items: self.assertEqual(len(items), 0))
614 return d 614 return d