123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160 |
- <?php
- /**
- * SPDX-FileCopyrightText: 2016-2024 Nextcloud GmbH and Nextcloud contributors
- * SPDX-FileCopyrightText: 2016 ownCloud, Inc.
- * SPDX-License-Identifier: AGPL-3.0-only
- */
- namespace OCA\FederatedFileSharing\Tests;
- use OCA\FederatedFileSharing\AddressHandler;
- use OCA\FederatedFileSharing\Notifications;
- use OCP\BackgroundJob\IJobList;
- use OCP\EventDispatcher\IEventDispatcher;
- use OCP\Federation\ICloudFederationFactory;
- use OCP\Federation\ICloudFederationProviderManager;
- use OCP\Http\Client\IClientService;
- use OCP\OCS\IDiscoveryService;
- use PHPUnit\Framework\MockObject\MockObject;
- use Psr\Log\LoggerInterface;
- class NotificationsTest extends \Test\TestCase {
- /** @var AddressHandler|MockObject */
- private $addressHandler;
- /** @var IClientService|MockObject */
- private $httpClientService;
- /** @var IDiscoveryService|MockObject */
- private $discoveryService;
- /** @var IJobList|MockObject */
- private $jobList;
- /** @var ICloudFederationProviderManager|MockObject */
- private $cloudFederationProviderManager;
- /** @var ICloudFederationFactory|MockObject */
- private $cloudFederationFactory;
- /** @var IEventDispatcher|MockObject */
- private $eventDispatcher;
- /** @var LoggerInterface|MockObject */
- private $logger;
- protected function setUp(): void {
- parent::setUp();
- $this->jobList = $this->getMockBuilder('OCP\BackgroundJob\IJobList')->getMock();
- $this->discoveryService = $this->getMockBuilder(IDiscoveryService::class)->getMock();
- $this->httpClientService = $this->getMockBuilder('OCP\Http\Client\IClientService')->getMock();
- $this->addressHandler = $this->getMockBuilder('OCA\FederatedFileSharing\AddressHandler')
- ->disableOriginalConstructor()->getMock();
- $this->logger = $this->createMock(LoggerInterface::class);
- $this->cloudFederationProviderManager = $this->createMock(ICloudFederationProviderManager::class);
- $this->cloudFederationFactory = $this->createMock(ICloudFederationFactory::class);
- $this->eventDispatcher = $this->createMock(IEventDispatcher::class);
- }
- /**
- * get instance of Notifications class
- *
- * @param array $mockedMethods methods which should be mocked
- * @return Notifications | \PHPUnit\Framework\MockObject\MockObject
- */
- private function getInstance(array $mockedMethods = []) {
- if (empty($mockedMethods)) {
- $instance = new Notifications(
- $this->addressHandler,
- $this->httpClientService,
- $this->discoveryService,
- $this->jobList,
- $this->cloudFederationProviderManager,
- $this->cloudFederationFactory,
- $this->eventDispatcher,
- $this->logger,
- );
- } else {
- $instance = $this->getMockBuilder('OCA\FederatedFileSharing\Notifications')
- ->setConstructorArgs(
- [
- $this->addressHandler,
- $this->httpClientService,
- $this->discoveryService,
- $this->jobList,
- $this->cloudFederationProviderManager,
- $this->cloudFederationFactory,
- $this->eventDispatcher,
- $this->logger,
- ]
- )->setMethods($mockedMethods)->getMock();
- }
- return $instance;
- }
- /**
- * @dataProvider dataTestSendUpdateToRemote
- *
- * @param int $try
- * @param array $httpRequestResult
- * @param bool $expected
- */
- public function testSendUpdateToRemote($try, $httpRequestResult, $expected): void {
- $remote = 'http://remote';
- $id = 42;
- $timestamp = 63576;
- $token = 'token';
- $action = 'unshare';
- $instance = $this->getInstance(['tryHttpPostToShareEndpoint', 'getTimestamp']);
- $instance->expects($this->any())->method('getTimestamp')->willReturn($timestamp);
- $instance->expects($this->once())->method('tryHttpPostToShareEndpoint')
- ->with($remote, '/'.$id.'/unshare', ['token' => $token, 'data1Key' => 'data1Value', 'remoteId' => $id], $action)
- ->willReturn($httpRequestResult);
- // only add background job on first try
- if ($try === 0 && $expected === false) {
- $this->jobList->expects($this->once())->method('add')
- ->with(
- 'OCA\FederatedFileSharing\BackgroundJob\RetryJob',
- [
- 'remote' => $remote,
- 'remoteId' => $id,
- 'action' => 'unshare',
- 'data' => json_encode(['data1Key' => 'data1Value']),
- 'token' => $token,
- 'try' => $try,
- 'lastRun' => $timestamp
- ]
- );
- } else {
- $this->jobList->expects($this->never())->method('add');
- }
- $this->assertSame($expected,
- $instance->sendUpdateToRemote($remote, $id, $token, $action, ['data1Key' => 'data1Value'], $try)
- );
- }
- public function dataTestSendUpdateToRemote() {
- return [
- // test if background job is added correctly
- [0, ['success' => true, 'result' => json_encode(['ocs' => ['meta' => ['statuscode' => 200]]])], true],
- [1, ['success' => true, 'result' => json_encode(['ocs' => ['meta' => ['statuscode' => 200]]])], true],
- [0, ['success' => false, 'result' => json_encode(['ocs' => ['meta' => ['statuscode' => 200]]])], false],
- [1, ['success' => false, 'result' => json_encode(['ocs' => ['meta' => ['statuscode' => 200]]])], false],
- // test all combinations of 'statuscode' and 'success'
- [0, ['success' => true, 'result' => json_encode(['ocs' => ['meta' => ['statuscode' => 200]]])], true],
- [0, ['success' => true, 'result' => json_encode(['ocs' => ['meta' => ['statuscode' => 100]]])], true],
- [0, ['success' => true, 'result' => json_encode(['ocs' => ['meta' => ['statuscode' => 400]]])], false],
- [0, ['success' => false, 'result' => json_encode(['ocs' => ['meta' => ['statuscode' => 200]]])], false],
- [0, ['success' => false, 'result' => json_encode(['ocs' => ['meta' => ['statuscode' => 100]]])], false],
- [0, ['success' => false, 'result' => json_encode(['ocs' => ['meta' => ['statuscode' => 400]]])], false],
- ];
- }
- }
|