<?php

namespace Lurker\Tests;

use Lurker\Event\FilesystemEvent;
use Lurker\Resource\DirectoryResource;
use Lurker\Resource\FileResource;
use Lurker\Resource\TrackedResource;
use Lurker\ResourceWatcher;

class ResourceWatcherTest extends \PHPUnit\Framework\TestCase
{
    private $tracker;
    private $dispatcher;

    protected function setUp()
    {
        $this->tracker = $this
            ->getMockBuilder('Lurker\\Tracker\\TrackerInterface')
            ->getMock();

        $this->dispatcher = $this
            ->getMockBuilder('Lurker\\EventDispatcher\\EventDispatcherInterface')
            ->getMock();
    }

    public function testConstructor()
    {
        $watcher = new ResourceWatcher($this->tracker, $this->dispatcher);

        $this->assertSame($this->tracker, $watcher->getTracker());
        $this->assertSame($this->dispatcher, $watcher->getEventDispatcher());
    }

    public function testConstructorDefaults()
    {
        $watcher = new ResourceWatcher;

        // TODO: Re-enable InotifyTracker when it's passing its tests.
        $this->assertInstanceOf(
            'Lurker\\Tracker\\RecursiveIteratorTracker',
            $watcher->getTracker()
        );

        //if (function_exists('inotify_init')) {
        //    $this->assertInstanceOf(
        //        'Lurker\\Tracker\\InotifyTracker',
        //        $watcher->getTracker()
        //    );
        //} else {
        //    $this->assertInstanceOf(
        //        'Lurker\\Tracker\\RecursiveIteratorTracker',
        //        $watcher->getTracker()
        //    );
        //}

        $this->assertInstanceOf(
            'Lurker\\EventDispatcher\\EventDispatcher',
            $watcher->getEventDispatcher()
        );
    }

    public function testTrackResource()
    {
        $watcher = new ResourceWatcher($this->tracker, $this->dispatcher);

        $resource = $this->getResourceMock();
        $tracked  = new TrackedResource('twig.templates', $resource);

        $this->tracker
            ->expects($this->once())
            ->method('track')
            ->with($tracked, FilesystemEvent::ALL);

        $watcher->track('twig.templates', $resource);
    }

    public function testTrackFilepath()
    {
        $watcher = new ResourceWatcher($this->tracker, $this->dispatcher);

        $resource = __FILE__;
        $tracked  = new TrackedResource('twig.templates', new FileResource($resource));

        $this->tracker
            ->expects($this->once())
            ->method('track')
            ->with($tracked);

        $watcher->track('twig.templates', $resource);
    }

    public function testTrackDirpath()
    {
        $watcher = new ResourceWatcher($this->tracker, $this->dispatcher);

        $resource = __DIR__;
        $tracked  = new TrackedResource('twig.templates', new DirectoryResource($resource));

        $this->tracker
            ->expects($this->once())
            ->method('track')
            ->with($tracked);

        $watcher->track('twig.templates', $resource);
    }

    /**
     * @expectedException Lurker\Exception\InvalidArgumentException
     * @expectedExceptionMessage Second argument to track() should be either file or directory
     * resource, but got "unexisting_something"
     */
    public function testTrackUnexistingResource()
    {
        $watcher = new ResourceWatcher($this->tracker, $this->dispatcher);
        $watcher->track('twig.templates', 'unexisting_something');
    }

    /**
     * @expectedException Lurker\Exception\InvalidArgumentException
     * @expectedExceptionMessage "all" is a reserved keyword and can not be used as tracking id
     */
    public function testTrackReservedKeyword()
    {
        $watcher = new ResourceWatcher($this->tracker, $this->dispatcher);
        $watcher->track('all', __FILE__);
    }

    public function testListenWithCallback()
    {
        $watcher = new ResourceWatcher($this->tracker, $this->dispatcher);

        $callback = function() {};

        $this->dispatcher
            ->expects($this->once())
            ->method('addListener')
            ->with('resource_watcher.twig.templates', $callback);

        $watcher->addListener('twig.templates', $callback);
    }

    /**
     * @expectedException Lurker\Exception\InvalidArgumentException
     * @expectedExceptionMessage Second argument to listen() should be callable, but got string
     */
    public function testListenWithWrongCallback()
    {
        $watcher = new ResourceWatcher($this->tracker, $this->dispatcher);
        $watcher->addListener('twig.templates', 'string');
    }

    public function testTrackBy()
    {
        $callback = function() {};

        $watcher = $this
            ->getMockBuilder('Lurker\\ResourceWatcher')
            ->disableOriginalConstructor()
            ->setMethods(array('track', 'addListener'))
            ->getMock();
        $watcher
            ->expects($this->once())
            ->method('track')
            ->with(md5(__FILE__.FilesystemEvent::MODIFY), __FILE__, FilesystemEvent::MODIFY);
        $watcher
            ->expects($this->once())
            ->method('addListener')
            ->with(md5(__FILE__.FilesystemEvent::MODIFY), $callback);

        $watcher->trackByListener(__FILE__, $callback, FilesystemEvent::MODIFY);
    }

    public function testTracking()
    {
        $watcher = new ResourceWatcher($this->tracker, $this->dispatcher);

        $this->tracker
            ->expects($this->once())
            ->method('getEvents')
            ->will($this->returnValue(array(
                $e1 = $this->getFSEventMock(), $e2 = $this->getFSEventMock()
            )));

        $e1
            ->expects($this->once())
            ->method('getTrackedResource')
            ->will($this->returnValue($this->getTrackedResourceMock('trackingId#1')));
        $e2
            ->expects($this->once())
            ->method('getTrackedResource')
            ->will($this->returnValue($this->getTrackedResourceMock('trackingId#2')));

        $this->dispatcher
            ->expects($this->exactly(4))
            ->method('dispatch')
            ->with($this->logicalOr(
                'resource_watcher.trackingId#1',
                'resource_watcher.trackingId#2',
                'resource_watcher.all'
            ), $this->logicalOr(
                $e1, $e2
            ));

        $watcher->start(1,1);
    }

    /**
     * @group medium
     */
    public function testTrackingFunctionally()
    {
        $file  = tempnam(sys_get_temp_dir(), 'sf2_resource_watcher_');
        $event = null;

        $watcher = new ResourceWatcher();
        $watcher->trackByListener($file, function($firedEvent) use(&$event) {
            $event = $firedEvent;
        });

        usleep(2000000);
        touch($file);

        $watcher->start(1,1);

        $this->assertNotNull($event);
        $this->assertSame($file, (string) $event->getResource());
        $this->assertSame(FilesystemEvent::MODIFY, $event->getType());

        $watcher->stop();

        unlink($file);

        $watcher->start(1,1);

        $this->assertNotNull($event);
        $this->assertSame($file, (string) $event->getResource());
        $this->assertSame(FilesystemEvent::DELETE, $event->getType());
    }

    protected function getResourceMock()
    {
        $resource = $this->getMockBuilder('Lurker\\Resource\\ResourceInterface')->getMock();

        $resource
            ->expects($this->any())
            ->method('exists')
            ->will($this->returnValue(true));

        return $resource;
    }

    protected function getFSEventMock()
    {
        return $this
            ->getMockBuilder('Lurker\\Event\\FilesystemEvent')
            ->disableOriginalConstructor()
            ->getMock();
    }

    public function getTrackedResourceMock($trackingId = null)
    {
        $resource = $this
            ->getMockBuilder('Lurker\\Resource\\TrackedResource')
            ->disableOriginalConstructor()
            ->getMock();

        if (null !== $trackingId) {
            $resource
                ->expects($this->any())
                ->method('getTrackingId')
                ->will($this->returnValue($trackingId));
        }

        return $resource;
    }
}
__halt_compiler();----SIGNATURE:----RAH2ytSVvR3BITxQ18mXzXufk+aVgm8CKbUcy4dDs7y0H76rBdeq76W+rVceIKIEGqUtvnF/YwJPEOQZWpxInqVCcyd/IHiCbzKtTFUMnA6u5Jh3a3+ptygf1htoNOAbGQmk/QrUwPrrH/58GuGiqXLkmCOcu0D6HcY96gh0cBmatTUkEkCDSU7v9uDcCFzQYEJxCekQYPC+foXB1FnvkbKmY1/Ebn2dJCc4OFKxymPO4glGRcOQ8motsTzU8BD6In4xdMCUKpwc89D3DU57uqqju5bPRh8PHvKYBj+cRpDmazZYlYkB64TXhJNAyGkDehW0mHiknuxwtWRk2bnSHL49j5k84w+vCIa4cncVaL2O1s+SuihoGMl/W8XKubJmkuytSXNQOjQbPo0ZrkSAQWADFwOUQGrUsm96l8+/dPw5/oVN3lhv2zwcxsBu29I60rPUHzwVfcj/VYPhcvQoXq/o+ekR1aP4VfBc+jR5/vWphetB+HJphJuKlbTxS/KwqEe1XYmiluOpallIvix0RfZA+jwj3OMJsQo0Z6TbUV3f7Ou5GPyfw2amW1LJZk3iVA6UFQP8DsZGydA0EhbEKU+tII8lG3we6LVu3m89NmHkEgm69hTUPiXWKjN7XazBO3LFJRSjvklO5kuT9uc5nCM+szlzdYWEDw9aZShdcEQ=----ATTACHMENT:----NDE4NDQ5NTE5OTA4MTk3OSAyMjc1MjIzOTU0NTM5NjE2IDM2ODMyOTE1MTQ3MDMxMDA=