diff options
author | Joas Schilling <nickvergessen@owncloud.com> | 2016-05-13 11:56:47 +0200 |
---|---|---|
committer | Joas Schilling <nickvergessen@owncloud.com> | 2016-05-24 08:41:22 +0200 |
commit | f14dff680d5e1e0fe10065ed25c524d9b5078cae (patch) | |
tree | f86d6466629f4d0f5d1a6de7fcd111ca27d3f52f /apps/files_external/tests/AmazonS3MigrationTest.php | |
parent | 4576891f10aa41cc146dc6ed421384269eca283a (diff) | |
download | nextcloud-server-f14dff680d5e1e0fe10065ed25c524d9b5078cae.tar.gz nextcloud-server-f14dff680d5e1e0fe10065ed25c524d9b5078cae.zip |
Move remaining classes to PSR-4
Diffstat (limited to 'apps/files_external/tests/AmazonS3MigrationTest.php')
-rw-r--r-- | apps/files_external/tests/AmazonS3MigrationTest.php | 145 |
1 files changed, 145 insertions, 0 deletions
diff --git a/apps/files_external/tests/AmazonS3MigrationTest.php b/apps/files_external/tests/AmazonS3MigrationTest.php new file mode 100644 index 00000000000..132d907ab14 --- /dev/null +++ b/apps/files_external/tests/AmazonS3MigrationTest.php @@ -0,0 +1,145 @@ +<?php +/** + * @author Joas Schilling <nickvergessen@owncloud.com> + * @author Jörn Friedrich Dreyer <jfd@butonic.de> + * @author Morris Jobke <hey@morrisjobke.de> + * @author Robin McCorkell <robin@mccorkell.me.uk> + * @author Thomas Müller <thomas.mueller@tmit.eu> + * + * @copyright Copyright (c) 2016, ownCloud, Inc. + * @license AGPL-3.0 + * + * This code is free software: you can redistribute it and/or modify + * it under the terms of the GNU Affero General Public License, version 3, + * as published by the Free Software Foundation. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Affero General Public License for more details. + * + * You should have received a copy of the GNU Affero General Public License, version 3, + * along with this program. If not, see <http://www.gnu.org/licenses/> + * + */ + + +namespace OCA\Files_External\Tests; + +use OCA\Files_External\Lib\Storage\AmazonS3; + +/** + * Class AmazonS3Migration + * + * @group DB + * + * @package OCA\Files_External\Tests + */ +class AmazonS3MigrationTest extends \Test\TestCase { + + /** + * @var \OC\Files\Storage\Storage instance + */ + protected $instance; + + /** @var array */ + protected $params; + + /** @var string */ + protected $oldId; + + /** @var string */ + protected $newId; + + protected function setUp() { + parent::setUp(); + + $uuid = $this->getUniqueID(); + + $this->params['key'] = 'key'.$uuid; + $this->params['secret'] = 'secret'.$uuid; + $this->params['bucket'] = 'bucket'.$uuid; + + $this->oldId = 'amazon::' . $this->params['key'] . md5($this->params['secret']); + $this->newId = 'amazon::' . $this->params['bucket']; + } + + protected function tearDown() { + $this->deleteStorage($this->oldId); + $this->deleteStorage($this->newId); + + parent::tearDown(); + } + + public function testUpdateLegacyOnlyId () { + // add storage ids + $oldCache = new \OC\Files\Cache\Cache($this->oldId); + + // add file to old cache + $fileId = $oldCache->put('foobar', array('size' => 0, 'mtime' => time(), 'mimetype' => 'httpd/directory')); + + try { + $this->instance = new AmazonS3($this->params); + } catch (\Exception $e) { + //ignore + } + $storages = $this->getStorages(); + + $this->assertTrue(isset($storages[$this->newId])); + $this->assertFalse(isset($storages[$this->oldId])); + $this->assertSame((int)$oldCache->getNumericStorageId(), (int)$storages[$this->newId]); + + list($storageId, $path) = \OC\Files\Cache\Cache::getById($fileId); + + $this->assertSame($this->newId, $storageId); + $this->assertSame('foobar', $path); + } + + public function testUpdateLegacyAndNewId () { + // add storage ids + + $oldCache = new \OC\Files\Cache\Cache($this->oldId); + new \OC\Files\Cache\Cache($this->newId); + + // add file to old cache + $fileId = $oldCache->put('/', array('size' => 0, 'mtime' => time(), 'mimetype' => 'httpd/directory')); + + try { + $this->instance = new AmazonS3($this->params); + } catch (\Exception $e) { + //ignore + } + $storages = $this->getStorages(); + + $this->assertTrue(isset($storages[$this->newId])); + $this->assertFalse(isset($storages[$this->oldId])); + + $this->assertNull(\OC\Files\Cache\Cache::getById($fileId), 'old filecache has not been cleared'); + } + + /** + * @param $storages + * @return array + */ + public function getStorages() { + $storages = array(); + $stmt = \OC::$server->getDatabaseConnection()->prepare( + 'SELECT `numeric_id`, `id` FROM `*PREFIX*storages` WHERE `id` IN (?, ?)' + ); + $stmt->execute(array($this->oldId, $this->newId)); + while ($row = $stmt->fetch()) { + $storages[$row['id']] = $row['numeric_id']; + } + return $storages; + } + + /** + * @param string $id + */ + public function deleteStorage($id) { + $stmt = \OC::$server->getDatabaseConnection()->prepare( + 'DELETE FROM `*PREFIX*storages` WHERE `id` = ?' + ); + $stmt->execute(array($id)); + } +} |