diff options
author | Jeremy Benoist <jeremy.benoist@gmail.com> | 2016-09-09 21:02:03 +0200 |
---|---|---|
committer | Jeremy Benoist <jeremy.benoist@gmail.com> | 2016-09-11 21:58:56 +0200 |
commit | b3437d58ae224121375c99e9288d8b808524e624 (patch) | |
tree | 94ce3446aed4396ba9304b8c97e421eba35e4edf /tests/Wallabag/ImportBundle/Import/PocketImportTest.php | |
parent | 7f7531171f6e49110b5842f869e37c766a682473 (diff) | |
download | wallabag-b3437d58ae224121375c99e9288d8b808524e624.tar.gz wallabag-b3437d58ae224121375c99e9288d8b808524e624.tar.zst wallabag-b3437d58ae224121375c99e9288d8b808524e624.zip |
Enable Redis async import
- using javibravo/simpleue
- internal config value are now `import_with_redis` & `import_with_rabbit` which are more clear
- if both option are enable rabbit will be choosen
- services imports related to async are now splitted into 2 files: `redis.yml` & `rabbit.yml`
-
Diffstat (limited to 'tests/Wallabag/ImportBundle/Import/PocketImportTest.php')
-rw-r--r-- | tests/Wallabag/ImportBundle/Import/PocketImportTest.php | 86 |
1 files changed, 85 insertions, 1 deletions
diff --git a/tests/Wallabag/ImportBundle/Import/PocketImportTest.php b/tests/Wallabag/ImportBundle/Import/PocketImportTest.php index 1750e3a1..425fa321 100644 --- a/tests/Wallabag/ImportBundle/Import/PocketImportTest.php +++ b/tests/Wallabag/ImportBundle/Import/PocketImportTest.php | |||
@@ -9,8 +9,11 @@ use GuzzleHttp\Client; | |||
9 | use GuzzleHttp\Subscriber\Mock; | 9 | use GuzzleHttp\Subscriber\Mock; |
10 | use GuzzleHttp\Message\Response; | 10 | use GuzzleHttp\Message\Response; |
11 | use GuzzleHttp\Stream\Stream; | 11 | use GuzzleHttp\Stream\Stream; |
12 | use Wallabag\ImportBundle\Redis\Producer; | ||
12 | use Monolog\Logger; | 13 | use Monolog\Logger; |
13 | use Monolog\Handler\TestHandler; | 14 | use Monolog\Handler\TestHandler; |
15 | use Simpleue\Queue\RedisQueue; | ||
16 | use M6Web\Component\RedisMock\RedisMockFactory; | ||
14 | 17 | ||
15 | class PocketImportTest extends \PHPUnit_Framework_TestCase | 18 | class PocketImportTest extends \PHPUnit_Framework_TestCase |
16 | { | 19 | { |
@@ -442,7 +445,7 @@ JSON; | |||
442 | ->with(json_encode($bodyAsArray)); | 445 | ->with(json_encode($bodyAsArray)); |
443 | 446 | ||
444 | $pocketImport->setClient($client); | 447 | $pocketImport->setClient($client); |
445 | $pocketImport->setRabbitmqProducer($producer); | 448 | $pocketImport->setProducer($producer); |
446 | $pocketImport->authorize('wunderbar_code'); | 449 | $pocketImport->authorize('wunderbar_code'); |
447 | 450 | ||
448 | $res = $pocketImport->setMarkAsRead(true)->import(); | 451 | $res = $pocketImport->setMarkAsRead(true)->import(); |
@@ -451,6 +454,87 @@ JSON; | |||
451 | $this->assertEquals(['skipped' => 0, 'imported' => 1], $pocketImport->getSummary()); | 454 | $this->assertEquals(['skipped' => 0, 'imported' => 1], $pocketImport->getSummary()); |
452 | } | 455 | } |
453 | 456 | ||
457 | /** | ||
458 | * Will sample results from https://getpocket.com/developer/docs/v3/retrieve. | ||
459 | */ | ||
460 | public function testImportWithRedis() | ||
461 | { | ||
462 | $client = new Client(); | ||
463 | |||
464 | $body = <<<'JSON' | ||
465 | { | ||
466 | "item_id": "229279689", | ||
467 | "resolved_id": "229279689", | ||
468 | "given_url": "http://www.grantland.com/blog/the-triangle/post/_/id/38347/ryder-cup-preview", | ||
469 | "given_title": "The Massive Ryder Cup Preview - The Triangle Blog - Grantland", | ||
470 | "favorite": "1", | ||
471 | "status": "1", | ||
472 | "time_added": "1473020899", | ||
473 | "time_updated": "1473020899", | ||
474 | "time_read": "0", | ||
475 | "time_favorited": "0", | ||
476 | "sort_id": 0, | ||
477 | "resolved_title": "The Massive Ryder Cup Preview", | ||
478 | "resolved_url": "http://www.grantland.com/blog/the-triangle/post/_/id/38347/ryder-cup-preview", | ||
479 | "excerpt": "The list of things I love about the Ryder Cup is so long that it could fill a (tedious) novel, and golf fans can probably guess most of them.", | ||
480 | "is_article": "1", | ||
481 | "has_video": "0", | ||
482 | "has_image": "0", | ||
483 | "word_count": "3197" | ||
484 | } | ||
485 | JSON; | ||
486 | |||
487 | $mock = new Mock([ | ||
488 | new Response(200, ['Content-Type' => 'application/json'], Stream::factory(json_encode(['access_token' => 'wunderbar_token']))), | ||
489 | new Response(200, ['Content-Type' => 'application/json'], Stream::factory(' | ||
490 | { | ||
491 | "status": 1, | ||
492 | "list": { | ||
493 | "229279690": '.$body.' | ||
494 | } | ||
495 | } | ||
496 | ')), | ||
497 | ]); | ||
498 | |||
499 | $client->getEmitter()->attach($mock); | ||
500 | |||
501 | $pocketImport = $this->getPocketImport(); | ||
502 | |||
503 | $entryRepo = $this->getMockBuilder('Wallabag\CoreBundle\Repository\EntryRepository') | ||
504 | ->disableOriginalConstructor() | ||
505 | ->getMock(); | ||
506 | |||
507 | $entryRepo->expects($this->never()) | ||
508 | ->method('findByUrlAndUserId'); | ||
509 | |||
510 | $this->em | ||
511 | ->expects($this->never()) | ||
512 | ->method('getRepository'); | ||
513 | |||
514 | $entry = new Entry($this->user); | ||
515 | |||
516 | $this->contentProxy | ||
517 | ->expects($this->never()) | ||
518 | ->method('updateEntry'); | ||
519 | |||
520 | $factory = new RedisMockFactory(); | ||
521 | $redisMock = $factory->getAdapter('Predis\Client', true); | ||
522 | |||
523 | $queue = new RedisQueue($redisMock, 'pocket'); | ||
524 | $producer = new Producer($queue); | ||
525 | |||
526 | $pocketImport->setClient($client); | ||
527 | $pocketImport->setProducer($producer); | ||
528 | $pocketImport->authorize('wunderbar_code'); | ||
529 | |||
530 | $res = $pocketImport->setMarkAsRead(true)->import(); | ||
531 | |||
532 | $this->assertTrue($res); | ||
533 | $this->assertEquals(['skipped' => 0, 'imported' => 1], $pocketImport->getSummary()); | ||
534 | |||
535 | $this->assertNotEmpty($redisMock->lpop('pocket')); | ||
536 | } | ||
537 | |||
454 | public function testImportBadResponse() | 538 | public function testImportBadResponse() |
455 | { | 539 | { |
456 | $client = new Client(); | 540 | $client = new Client(); |