MemcachedBackendTest.php

Go to the documentation of this file.

<?php
 
/*
 * This file is part of the TYPO3 CMS project.
 *
 * It is free software; you can redistribute it and/or modify it under
 * the terms of the GNU General Public License, either version 2
 * of the License, or any later version.
 *
 * For the full copyright and license information, please read the
 * LICENSE.txt file that was distributed with this source code.
 *
 * The TYPO3 project - inspiring people to share!
 */
 
namespace ‪TYPO3\CMS\Core\Tests\Functional\Cache\Backend;
 
use ‪TYPO3\CMS\Core\Cache\Backend\MemcachedBackend;
use ‪TYPO3\CMS\Core\Cache\Exception;
use ‪TYPO3\CMS\Core\Cache\Frontend\FrontendInterface;
use ‪TYPO3\CMS\Core\Utility\StringUtility;
use TYPO3\TestingFramework\Core\Functional\FunctionalTestCase;
 
class ‪MemcachedBackendTest extends FunctionalTestCase
{
    protected function ‪setUp(): void
    {
        if (!extension_loaded('memcache') && !extension_loaded('memcached')) {
            self::markTestSkipped('Neither "memcache" nor "memcached" extension was available');
        }
        if (!getenv('typo3TestingMemcachedHost')) {
            self::markTestSkipped('environment variable "typo3TestingMemcachedHost" must be set to run this test');
        }
        // Note we assume that if that typo3TestingMemcachedHost env is set, we can use that for testing,
        // there is no test to see if the daemon is actually up and running. Tests will fail if env
        // is set but daemon is down.
 
        parent::setUp();
    }
 
    protected function ‪initializeSubject(): ‪MemcachedBackend
    {
        // We know this env is set, otherwise setUp() would skip the tests
        $memcachedHost = getenv('typo3TestingMemcachedHost');
        // If typo3TestingMemcachedPort env is set, use it, otherwise fall back to standard port
        $env = getenv('typo3TestingMemcachedPort');
        $memcachedPort = is_string($env) ? (int)$env : 11211;
 
        $subject = new ‪MemcachedBackend('Testing', [ 'servers' => [$memcachedHost . ':' . $memcachedPort] ]);
        $subject->initializeObject();
        return $subject;
    }
 
    public function ‪setThrowsExceptionIfNoFrontEndHasBeenSet()
    {
        $subject = $this->‪initializeSubject();
 
        $this->expectException(Exception::class);
        $this->expectExceptionCode(1207149215);
 
        $subject->set(‪StringUtility::getUniqueId('MyIdentifier'), 'some data');
    }
 
    public function ‪initializeObjectThrowsExceptionIfNoMemcacheServerIsConfigured()
    {
        $subject = new ‪MemcachedBackend('Testing');
        $this->expectException(Exception::class);
        $this->expectExceptionCode(1213115903);
        $subject->initializeObject();
    }
 
    public function ‪itIsPossibleToSetAndCheckExistenceInCache()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $identifier = ‪StringUtility::getUniqueId('MyIdentifier');
        $subject->set($identifier, 'Some data');
        self::assertTrue($subject->has($identifier));
    }
 
    public function ‪itIsPossibleToSetAndGetEntry()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $data = 'Some data';
        $identifier = ‪StringUtility::getUniqueId('MyIdentifier');
        $subject->set($identifier, $data);
        self::assertEquals($data, $subject->get($identifier));
    }
 
    public function ‪getReturnsPreviouslySetDataWithVariousTypes()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $data = [
            'string' => 'Serialize a string',
            'integer' => 0,
            'anotherIntegerValue' => 123456,
            'float' => 12.34,
            'bool' => true,
            'array' => [
                0 => 'test',
                1 => 'another test',
            ],
        ];
 
        $subject->set('myIdentifier', $data);
        self::assertSame($data, $subject->get('myIdentifier'));
    }
 
    public function ‪largeDataIsStored()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $data = str_repeat('abcde', 1024 * 1024);
        $subject->set('tooLargeData', $data);
        self::assertTrue($subject->has('tooLargeData'));
        self::assertEquals($subject->get('tooLargeData'), $data);
    }
 
    public function ‪itIsPossibleToRemoveEntryFromCache()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $data = 'Some data';
        $identifier = ‪StringUtility::getUniqueId('MyIdentifier');
        $subject->set($identifier, $data);
        $subject->remove($identifier);
        self::assertFalse($subject->has($identifier));
    }
 
    public function ‪itIsPossibleToOverwriteAnEntryInTheCache()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $data = 'Some data';
        $identifier = ‪StringUtility::getUniqueId('MyIdentifier');
        $subject->set($identifier, $data);
        $otherData = 'some other data';
        $subject->set($identifier, $otherData);
        self::assertEquals($otherData, $subject->get($identifier));
    }
 
    public function ‪findIdentifiersByTagFindsCacheEntriesWithSpecifiedTag()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $data = 'Some data';
        $identifier = ‪StringUtility::getUniqueId('MyIdentifier');
        $subject->set($identifier, $data, ['UnitTestTag%tag1', 'UnitTestTag%tag2']);
        $retrieved = $subject->findIdentifiersByTag('UnitTestTag%tag1');
        self::assertEquals($identifier, $retrieved[0]);
        $retrieved = $subject->findIdentifiersByTag('UnitTestTag%tag2');
        self::assertEquals($identifier, $retrieved[0]);
    }
 
    public function ‪setRemovesTagsFromPreviousSet()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $data = 'Some data';
        $identifier = ‪StringUtility::getUniqueId('MyIdentifier');
        $subject->set($identifier, $data, ['UnitTestTag%tag1', 'UnitTestTag%tag2']);
        $subject->set($identifier, $data, ['UnitTestTag%tag3']);
        self::assertEquals([], $subject->findIdentifiersByTag('UnitTestTag%tagX'));
    }
 
    public function ‪hasReturnsFalseIfTheEntryDoesntExist()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $identifier = ‪StringUtility::getUniqueId('NonExistingIdentifier');
        self::assertFalse($subject->has($identifier));
    }
 
    public function ‪removeReturnsFalseIfTheEntryDoesntExist()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $identifier = ‪StringUtility::getUniqueId('NonExistingIdentifier');
        self::assertFalse($subject->remove($identifier));
    }
 
    public function ‪flushByTagRemovesCacheEntriesWithSpecifiedTag()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $data = 'some data' . microtime();
        $subject->set('BackendMemcacheTest1', $data, ['UnitTestTag%test', 'UnitTestTag%boring']);
        $subject->set('BackendMemcacheTest2', $data, ['UnitTestTag%test', 'UnitTestTag%special']);
        $subject->set('BackendMemcacheTest3', $data, ['UnitTestTag%test']);
        $subject->flushByTag('UnitTestTag%special');
        self::assertTrue($subject->has('BackendMemcacheTest1'));
        self::assertFalse($subject->has('BackendMemcacheTest2'));
        self::assertTrue($subject->has('BackendMemcacheTest3'));
    }
 
    public function ‪flushByTagsRemovesCacheEntriesWithSpecifiedTags()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $data = 'some data' . microtime();
        $subject->set('BackendMemcacheTest1', $data, ['UnitTestTag%test', 'UnitTestTag%boring']);
        $subject->set('BackendMemcacheTest2', $data, ['UnitTestTag%test', 'UnitTestTag%special']);
        $subject->set('BackendMemcacheTest3', $data, ['UnitTestTag%test']);
        $subject->flushByTags(['UnitTestTag%special', 'UnitTestTag%boring']);
        self::assertFalse($subject->has('BackendMemcacheTest1'));
        self::assertFalse($subject->has('BackendMemcacheTest2'));
        self::assertTrue($subject->has('BackendMemcacheTest3'));
    }
 
    public function ‪flushRemovesAllCacheEntries()
    {
        $frontendProphecy = $this->prophesize(FrontendInterface::class);
        $frontendProphecy->getIdentifier()->willReturn('pages');
 
        $subject = $this->‪initializeSubject();
        $subject->setCache($frontendProphecy->reveal());
 
        $data = 'some data' . microtime();
        $subject->set('BackendMemcacheTest1', $data);
        $subject->set('BackendMemcacheTest2', $data);
        $subject->set('BackendMemcacheTest3', $data);
        $subject->flush();
        self::assertFalse($subject->has('BackendMemcacheTest1'));
        self::assertFalse($subject->has('BackendMemcacheTest2'));
        self::assertFalse($subject->has('BackendMemcacheTest3'));
    }
 
    public function ‪flushRemovesOnlyOwnEntries()
    {
        $thisFrontendProphecy = $this->prophesize(FrontendInterface::class);
        $thisFrontendProphecy->getIdentifier()->willReturn('thisCache');
        $thisBackend = $this->‪initializeSubject();
        $thisBackend->setCache($thisFrontendProphecy->reveal());
 
        $thatFrontendProphecy = $this->prophesize(FrontendInterface::class);
        $thatFrontendProphecy->getIdentifier()->willReturn('thatCache');
        $thatBackend = $this->‪initializeSubject();
        $thatBackend->setCache($thatFrontendProphecy->reveal());
 
        $thisBackend->set('thisEntry', 'Hello');
        $thatBackend->set('thatEntry', 'World!');
        $thatBackend->flush();
 
        self::assertEquals('Hello', $thisBackend->get('thisEntry'));
        self::assertFalse($thatBackend->has('thatEntry'));
    }
}