brendt/aggregate.stitcher.io

use Support\Rss\Reader;
use Zend\Feed\Reader\Feed\FeedInterface;

final class MockReader implements Reader
{
    private $feedInterface;

    public static function new(): MockReader
    {
        return new self();
    }

    public function __construct()
    {
        $this->feedInterface = new MockFeedInterface();
    }

    public function withPost(string $url = '/test', array $extra = []): MockReader
    {
        $this->feedInterface = $this->feedInterface->withPost($url, $extra);

        return $this;
    }

    public function import(string $url): FeedInterface
    {
        return $this->feedInterface;
    }
}

use Domain\Post\Actions\CreatePostAction;
use Domain\Post\Actions\UpdatePostAction;
use Domain\Post\Models\Post;
use Domain\Source\Actions\SyncSourceAction;
use Support\Rss\Reader;
use Tests\Factories\SourceFactory;
use Tests\Mocks\MockReader;
use Tests\TestCase;

class SyncSourceActionTest extends TestCase
{
    /** @var \Domain\Source\Models\Source */
    private $source;

    protected function setUp(): void
    {
        parent::setUp();

        $this->source = SourceFactory::new()->create();
    }

    /** @test */
    public function it_creates_a_post(): void
    {
        $action = $this->createSyncAction(
            MockReader::new()->withPost()
        );

        $action->__invoke($this->source);

        $this->assertCount(1, Post::all());
    }

    /** @test */
    public function it_wont_create_two_posts_for_the_same_source_on_the_same_day(): void
    {
        $action = $this->createSyncAction(
            MockReader::new()
                ->withPost('/a', [
                    'date' => '2019-01-01',
                ])
                ->withPost('/b', [
                    'date' => '2019-01-01',
                ])
        );

        $action->__invoke($this->source);

        $this->assertCount(1, Post::all());
    }

    /** @test */
    public function it_will_create_two_posts_for_the_same_source_on_separate_days(): void
    {
        $action = $this->createSyncAction(
            MockReader::new()
                ->withPost('/a', [
                    'date' => '2019-01-01',
                ])
                ->withPost('/b', [
                    'date' => '2019-01-02',
                ])
        );

        $action->__invoke($this->source);

        $this->assertCount(2, Post::all());
    }

    /** @test */
    public function it_will_create_two_posts_for_separate_sources_on_the_same_day(): void
    {
        $otherSource = SourceFactory::new()
            ->withUrl('https://other.com')
            ->create();

        $this->createSyncAction(
            MockReader::new()
                ->withPost('/a', [
                    'date' => '2019-01-01',
                ])
        )->__invoke($this->source);

        $this->createSyncAction(
            MockReader::new()
                ->withPost('/a', [
                    'date' => '2019-01-01',
                ])
        )->__invoke($otherSource);

        $this->assertCount(2, Post::all());
    }

    private function createSyncAction(Reader $reader): SyncSourceAction
    {
        return new SyncSourceAction(
            $reader,
            app(CreatePostAction::class),
            app(UpdatePostAction::class)
        );
    }
}