Mercurial > libervia-backend
comparison sat/test/test_plugin_misc_groupblog.py @ 2765:378188abe941
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 |