<?php declare(strict_types = 1);

namespace Amp\Test;

use Amp;
use Amp\{ Failure, Success };
use Interop\Async\Promise;

class PromiseMock {
    /** @var \Interop\Async\Promise */
    private $promise;

    public function __construct(Promise $promise) {
        $this->promise = $promise;
    }

    public function then(callable $onFulfilled = null, callable $onRejected = null) {
        $this->promise->when(function ($exception, $value) use ($onFulfilled, $onRejected) {
            if ($exception) {
                if ($onRejected) {
                    $onRejected($exception);
                }
                return;
            }

            if ($onFulfilled) {
                $onFulfilled($value);
            }
        });
    }
}

class AdaptTest extends \PHPUnit_Framework_TestCase {
    public function testThenCalled() {
        $mock = $this->getMockBuilder(PromiseMock::class)
            ->disableOriginalConstructor()
            ->getMock();
        
        $mock->expects($this->once())
            ->method("then")
            ->with(
                $this->callback(function ($resolve) {
                    return is_callable($resolve);
                }),
                $this->callback(function ($reject) {
                    return is_callable($reject);
                })
            );
        
        $promise = Amp\adapt($mock);
        
        $this->assertInstanceOf(Promise::class, $promise);
    }
    
    /**
     * @depends testThenCalled
     */
    public function testPromiseFulfilled() {
        $value = 1;

        $promise = new PromiseMock(new Success($value));

        $promise = Amp\adapt($promise);

        $promise->when(function ($exception, $value) use (&$result) {
            $result = $value;
        });

        $this->assertSame($value, $result);
    }
    
    /**
     * @depends testThenCalled
     */
    public function testPromiseRejected() {
        $exception = new \Exception;

        $promise = new PromiseMock(new Failure($exception));

        $promise = Amp\adapt($promise);

        $promise->when(function ($exception, $value) use (&$reason) {
            $reason = $exception;
        });

        $this->assertSame($exception, $reason);
    }

    /**
     * @expectedException \Error
     */
    public function testScalarValue() {
        Amp\adapt(1);
    }

    /**
     * @expectedException \Error
     */
    public function testNonThenableObject() {
        Amp\adapt(new \stdClass);
    }
}