<?php

use openid\services\AssociationService;
use openid\services\OpenIdServiceCatalog;
use utils\services\IAuthService;
use Way\Tests\Factory;
use openid\helpers\AssociationFactory;
use openid\OpenIdProtocol;
use utils\services\UtilsServiceCatalog;
use utils\exceptions\UnacquiredLockException;

class AssociationServiceTest extends TestCase {

	public function __construct(){

	}

	public function tearDown()
	{
		Mockery::close();
	}

	protected function prepareForTests()
	{
		parent::prepareForTests();
	}

	public function testAddPrivateAssociation(){

		$cache_stub = new CacheServiceStub;
		$this->app->instance(UtilsServiceCatalog::CacheService,$cache_stub);

		$lock_manager_service_mock = Mockery::mock('utils\services\ILockManagerService');
		$lock_manager_service_mock->shouldReceive('acquireLock')->once();

		$this->app->instance(UtilsServiceCatalog::LockManagerService ,$lock_manager_service_mock);

		$service = $this->app[OpenIdServiceCatalog::AssociationService];
		$assoc   = AssociationFactory::getInstance()->buildPrivateAssociation('https://www.test.com/', 3600);
		$res     = $service->addAssociation($assoc);

		$this->assertTrue(!is_null($res));
	}


	public function testAddSessionAssociation(){

		$cache_stub = new CacheServiceStub;
		$this->app->instance(UtilsServiceCatalog::CacheService,$cache_stub);

		$lock_manager_service_mock = Mockery::mock('utils\services\ILockManagerService');
		$lock_manager_service_mock->shouldReceive('acquireLock')->once();

		$this->app->instance(UtilsServiceCatalog::LockManagerService ,$lock_manager_service_mock);

		$service = $this->app[OpenIdServiceCatalog::AssociationService];
		$assoc   = AssociationFactory::getInstance()->buildSessionAssociation(OpenIdProtocol::AssociationSessionTypeDHSHA256, 3600);
		$res     = $service->addAssociation($assoc);

		$this->assertTrue(!is_null($res));
	}

	public function testGetSessionAssociationRedisCrash(){

		$cache_mock = Mockery::mock('utils\services\ICacheService');
		$cache_mock->shouldReceive('storeHash')->once();
		$this->app->instance(UtilsServiceCatalog::CacheService,$cache_mock);

		$lock_manager_service_mock = Mockery::mock('utils\services\ILockManagerService');
		$lock_manager_service_mock->shouldReceive('acquireLock')->once();

		$this->app->instance(UtilsServiceCatalog::LockManagerService ,$lock_manager_service_mock);

		$service = $this->app[OpenIdServiceCatalog::AssociationService];
		$assoc   = AssociationFactory::getInstance()->buildSessionAssociation(OpenIdProtocol::AssociationSessionTypeDHSHA256, 3600);
		$res     = $service->addAssociation($assoc);

		$this->assertTrue(!is_null($res));
		$hash = null;
		$cache_mock->shouldReceive('storeHash')->once()->andReturnUsing(function($name, $values, $ttl) use(&$hash){
			$hash = $values;
		});
		$cache_mock->shouldReceive('exists')->once()->andReturn(false);
		$cache_mock->shouldReceive('getHash')->once()->andReturnUsing(function($name, $values) use(&$hash){
			return $hash;
		});

		$res2  = $service->getAssociation($res->getHandle());

		$this->assertTrue(!is_null($res2));

		$this->assertTrue($res2->getSecret()===$res->getSecret());
	}


	/**
	 * @expectedException \openid\exceptions\InvalidAssociation
	 */
	public function testGetSessionAssociationMustFail_InvalidAssociation(){

		$cache_mock = Mockery::mock('utils\services\ICacheService');
		$cache_mock->shouldReceive('storeHash')->once();
		$this->app->instance(UtilsServiceCatalog::CacheService,$cache_mock);

		$lock_manager_service_mock = Mockery::mock('utils\services\ILockManagerService');
		$lock_manager_service_mock->shouldReceive('acquireLock')->once();

		$this->app->instance(UtilsServiceCatalog::LockManagerService ,$lock_manager_service_mock);

		$repo_mock = Mockery::mock('openid\repositories\IOpenIdAssociationRepository');
		$this->app->instance('openid\repositories\IOpenIdAssociationRepository',$repo_mock);
		$repo_mock->shouldReceive('add')->once();
		$repo_mock->shouldReceive('getByHandle')->once()->andReturnNull();

		$service = $this->app[OpenIdServiceCatalog::AssociationService];
		$assoc   = AssociationFactory::getInstance()->buildSessionAssociation(OpenIdProtocol::AssociationSessionTypeDHSHA256, 3600);
		$res     = $service->addAssociation($assoc);

		$this->assertTrue(!is_null($res));
		$hash = null;
		$cache_mock->shouldReceive('exists')->once()->andReturn(false);
		$service->getAssociation($res->getHandle());
	}


	/**
	 * @expectedException \openid\exceptions\ReplayAttackException
	 */
	public function testAddPrivateAssociationMustFail_ReplayAttackException(){

		$cache_stub = new CacheServiceStub;
		$this->app->instance(UtilsServiceCatalog::CacheService,$cache_stub);

		$lock_manager_service_mock = Mockery::mock('utils\services\ILockManagerService');
		$lock_manager_service_mock->shouldReceive('acquireLock')->once();

		$this->app->instance(UtilsServiceCatalog::LockManagerService ,$lock_manager_service_mock);

		$service = $this->app[OpenIdServiceCatalog::AssociationService];
		$assoc   = AssociationFactory::getInstance()->buildPrivateAssociation('https://www.test.com/', 3600);
		$res     = $service->addAssociation($assoc);

		$this->assertTrue(!is_null($res));
		$lock_manager_service_mock->shouldReceive('acquireLock')->once()->andThrow(new UnacquiredLockException);
		$service->addAssociation($assoc);
	}

	public function testGetPrivateAssociation(){

		$cache_stub = new CacheServiceStub;
		$this->app->instance(UtilsServiceCatalog::CacheService,$cache_stub);

		$lock_manager_service_mock = Mockery::mock('utils\services\ILockManagerService');
		$lock_manager_service_mock->shouldReceive('acquireLock')->twice();

		$this->app->instance(UtilsServiceCatalog::LockManagerService ,$lock_manager_service_mock);

		$service = $this->app[OpenIdServiceCatalog::AssociationService];
		$assoc   = AssociationFactory::getInstance()->buildPrivateAssociation('https://www.test.com/', 3600);
		$res     = $service->addAssociation($assoc);

		$this->assertTrue(!is_null($res));

		$res2 = $service->getAssociation($res->getHandle(),'https://www.test.com/');

		$this->assertTrue(!is_null($res2));

		$this->assertTrue($res2->getSecret()===$res->getSecret());
	}


	/**
	 * @expectedException \openid\exceptions\OpenIdInvalidRealmException
	 */
	public function testGetPrivateAssociationMustFail_OpenIdInvalidRealmException(){

		$cache_stub = new CacheServiceStub;
		$this->app->instance(UtilsServiceCatalog::CacheService,$cache_stub);

		$lock_manager_service_mock = Mockery::mock('utils\services\ILockManagerService');
		$lock_manager_service_mock->shouldReceive('acquireLock')->once();

		$this->app->instance(UtilsServiceCatalog::LockManagerService ,$lock_manager_service_mock);

		$service = $this->app[OpenIdServiceCatalog::AssociationService];
		$assoc   = AssociationFactory::getInstance()->buildPrivateAssociation('https://www.test.com/', 3600);
		$res     = $service->addAssociation($assoc);

		$this->assertTrue(!is_null($res));

		$service->getAssociation($res->getHandle(),'https://www1.test.com/');
	}

	/**
	 * @expectedException \openid\exceptions\InvalidAssociation
	 */
	public function testGetPrivateAssociationMustFail_InvalidAssociation(){

		$cache_stub = new CacheServiceStub;
		$this->app->instance(UtilsServiceCatalog::CacheService,$cache_stub);

		$lock_manager_service_mock = Mockery::mock('utils\services\ILockManagerService');
		$lock_manager_service_mock->shouldReceive('acquireLock')->once();

		$this->app->instance(UtilsServiceCatalog::LockManagerService ,$lock_manager_service_mock);

		$service = $this->app[OpenIdServiceCatalog::AssociationService];
		$assoc   = AssociationFactory::getInstance()->buildPrivateAssociation('https://www.test.com/', 3600);
		$res     = $service->addAssociation($assoc);

		$this->assertTrue(!is_null($res));

		$service->getAssociation('123456','https://www1.test.com/');
	}


	/**
	 * @expectedException \openid\exceptions\ReplayAttackException
	 */
	public function testGetPrivateAssociationMustFail_ReplayAttackException(){


		$cache_stub = new CacheServiceStub;
		$this->app->instance(UtilsServiceCatalog::CacheService,$cache_stub);

		$lock_manager_service_mock = Mockery::mock('utils\services\ILockManagerService');
		$lock_manager_service_mock->shouldReceive('acquireLock')->times(2);

		$this->app->instance(UtilsServiceCatalog::LockManagerService ,$lock_manager_service_mock);

		$service = $this->app[OpenIdServiceCatalog::AssociationService];
		$assoc   = AssociationFactory::getInstance()->buildPrivateAssociation('https://www.test.com/', 3600);
		$res     = $service->addAssociation($assoc);

		$this->assertTrue(!is_null($res));

		$res2 = $service->getAssociation($res->getHandle(),'https://www.test.com/');

		$this->assertTrue(!is_null($res2));

		$this->assertTrue($res2->getSecret()===$res->getSecret());
		$lock_manager_service_mock->shouldReceive('acquireLock')->once()->andThrow(new UnacquiredLockException);
		$service->getAssociation($res->getHandle(),'https://www.test.com/');
	}
}