use in objectstore copy

Signed-off-by: Robin Appelman <robin@icewind.nl>

lib/private/Files/ObjectStore/Azure.php

@@ -130,4 +130,8 @@ public function objectExists($urn) {
 			}
 		}
 	}
+
+	public function copyObject($from, $to) {
+		$this->getBlobClient()->copyBlob($this->containerName, $to, $this->containerName, $from);
+	}
 }

lib/private/Files/ObjectStore/ObjectStoreStorage.php

@@ -523,4 +523,19 @@ public function writeStream(string $path, $stream, int $size = null): int {
 	public function getObjectStore(): IObjectStore {
 		return $this->objectStore;
 	}
+
+	public function copy($from, $to) {
+		$from = $this->normalizePath($from);
+		$to = $this->normalizePath($to);
+
+		$cache = $this->getCache();
+		$sourceEntry = $cache->get($from);
+		if (!$sourceEntry) {
+			throw new NotFoundException('Source object not found');
+		}
+
+		$this->objectStore->copyObject($from, $to);;
+
+		$cache->copyFromCache($cache, $sourceEntry, $to);
+	}
 }

lib/private/Files/ObjectStore/S3ObjectTrait.php

@@ -124,4 +124,8 @@ public function deleteObject($urn) {
 	public function objectExists($urn) {
 		return $this->getConnection()->doesObjectExist($this->bucket, $urn);
 	}
+
+	public function copyObject($from, $to) {
+		$this->getConnection()->copy($this->getBucket(), $from, $this->getBucket(), $to);
+	}
 }

lib/private/Files/ObjectStore/StorageObjectStore.php

@@ -93,4 +93,8 @@ public function deleteObject($urn) {
 	public function objectExists($urn) {
 		return $this->storage->file_exists($urn);
 	}
+
+	public function copyObject($from, $to) {
+		$this->storage->copy($from, $to);
+	}
 }

lib/private/Files/ObjectStore/Swift.php

@@ -87,13 +87,13 @@ public function writeObject($urn, $stream) {
 		if (filesize($tmpFile) < SWIFT_SEGMENT_SIZE) {
 			$this->getContainer()->createObject([
 				'name' => $urn,
-				'stream' => stream_for($handle)
+				'stream' => stream_for($handle),
 			]);
 		} else {
 			$this->getContainer()->createLargeObject([
 				'name' => $urn,
 				'stream' => stream_for($handle),
-				'segmentSize' => SWIFT_SEGMENT_SIZE
+				'segmentSize' => SWIFT_SEGMENT_SIZE,
 			]);
 		}
 	}
@@ -114,7 +114,7 @@ public function readObject($urn) {
 					'stream' => true,
 					'headers' => [
 						'X-Auth-Token' => $tokenId,
-						'Cache-Control' => 'no-cache'
+						'Cache-Control' => 'no-cache',
 					],
 				]
 			);
@@ -149,4 +149,10 @@ public function deleteContainer() {
 	public function objectExists($urn) {
 		return $this->getContainer()->objectExists($urn);
 	}
+
+	public function copyObject($from, $to) {
+		$this->getContainer()->getObject($from)->copy([
+			'destination' => $this->getContainer()->name . '/' . $to
+		]);
+	}
 }

lib/public/Files/ObjectStore/IObjectStore.php

@@ -73,4 +73,12 @@ public function deleteObject($urn);
 	 * @since 16.0.0
 	 */
 	public function objectExists($urn);
+
+	/**
+	 * @param string $from the unified resource name used to identify the source object
+	 * @param string $to the unified resource name used to identify the target object
+	 * @return void
+	 * @since 21.0.0
+	 */
+	public function copyObject($from, $to);
 }

tests/lib/Files/ObjectStore/FailDeleteObjectStore.php

@@ -51,4 +51,8 @@ public function deleteObject($urn) {
 	public function objectExists($urn) {
 		return $this->objectStore->objectExists($urn);
 	}
+
+	public function copyObject($from, $to) {
+		$this->objectStore->copyObject($from, $to);
+	}
 }

tests/lib/Files/ObjectStore/FailWriteObjectStore.php

@@ -52,4 +52,8 @@ public function deleteObject($urn) {
 	public function objectExists($urn) {
 		return $this->objectStore->objectExists($urn);
 	}
+
+	public function copyObject($from, $to) {
+		$this->objectStore->copyObject($from, $to);
+	}
 }

tests/lib/Files/ObjectStore/ObjectStoreTest.php

@@ -108,4 +108,20 @@ public function testExists() {
 
 		$this->assertFalse($instance->objectExists('2'));
 	}
+
+	public function testCopy() {
+		$stream = $this->stringToStream('foobar');
+
+		$instance = $this->getInstance();
+
+		$instance->writeObject('source', $stream);
+
+		$this->assertFalse($instance->objectExists('target'));
+
+		$instance->copyObject('source', 'target');
+
+		$this->assertTrue($instance->objectExists('target'));
+
+		$this->assertEquals('foobar', stream_get_contents($instance->readObject('target')));
+	}
 }