nextcloud / server

lib/private/Files/ObjectStore/S3ObjectTrait.php

Unused Use Statements -3 removed lines

@@ -23,10 +23,7 @@
 
 namespace OC\Files\ObjectStore;
 
-use Aws\Exception\MultipartUploadException;
-use Aws\S3\MultipartUploader;
 use Aws\S3\S3Client;
-use Psr\Http\Message\StreamInterface;
 
 const S3_UPLOAD_PART_SIZE = 524288000; // 500MB
 

Indentation +58 added lines, -58 removed lines

@@ -31,66 +31,66 @@
 const S3_UPLOAD_PART_SIZE = 524288000; // 500MB
 
 trait S3ObjectTrait {
-	/**
-	 * Returns the connection
-	 *
-	 * @return S3Client connected client
-	 * @throws \Exception if connection could not be made
-	 */
-	abstract protected function getConnection();
+    /**
+     * Returns the connection
+     *
+     * @return S3Client connected client
+     * @throws \Exception if connection could not be made
+     */
+    abstract protected function getConnection();
 
-	/**
-	 * @param string $urn the unified resource name used to identify the object
-	 * @return resource stream with the read data
-	 * @throws \Exception when something goes wrong, message will be logged
-	 * @since 7.0.0
-	 */
-	function readObject($urn) {
-		$client = $this->getConnection();
-		$command = $client->getCommand('GetObject', [
-			'Bucket' => $this->bucket,
-			'Key' => $urn
-		]);
-		$request = \Aws\serialize($command);
-		$headers = [];
-		foreach ($request->getHeaders() as $key => $values) {
-			foreach ($values as $value) {
-				$headers[] = "$key: $value";
-			}
-		}
-		$opts = [
-			'http' => [
-				'header' => $headers
-			]
-		];
+    /**
+     * @param string $urn the unified resource name used to identify the object
+     * @return resource stream with the read data
+     * @throws \Exception when something goes wrong, message will be logged
+     * @since 7.0.0
+     */
+    function readObject($urn) {
+        $client = $this->getConnection();
+        $command = $client->getCommand('GetObject', [
+            'Bucket' => $this->bucket,
+            'Key' => $urn
+        ]);
+        $request = \Aws\serialize($command);
+        $headers = [];
+        foreach ($request->getHeaders() as $key => $values) {
+            foreach ($values as $value) {
+                $headers[] = "$key: $value";
+            }
+        }
+        $opts = [
+            'http' => [
+                'header' => $headers
+            ]
+        ];
 
-		$context = stream_context_create($opts);
-		return fopen($request->getUri(), 'r', false, $context);
-	}
+        $context = stream_context_create($opts);
+        return fopen($request->getUri(), 'r', false, $context);
+    }
 
-	/**
-	 * @param string $urn the unified resource name used to identify the object
-	 * @param resource $stream stream with the data to write
-	 * @throws \Exception when something goes wrong, message will be logged
-	 * @since 7.0.0
-	 */
-	function writeObject($urn, $stream) {
-		$this->getConnection()->upload($this->bucket, $urn, $stream, 'private', [
-			'mup_threshold' => S3_UPLOAD_PART_SIZE,
-			'part_size' => S3_UPLOAD_PART_SIZE
-		]);
-	}
+    /**
+     * @param string $urn the unified resource name used to identify the object
+     * @param resource $stream stream with the data to write
+     * @throws \Exception when something goes wrong, message will be logged
+     * @since 7.0.0
+     */
+    function writeObject($urn, $stream) {
+        $this->getConnection()->upload($this->bucket, $urn, $stream, 'private', [
+            'mup_threshold' => S3_UPLOAD_PART_SIZE,
+            'part_size' => S3_UPLOAD_PART_SIZE
+        ]);
+    }
 
-	/**
-	 * @param string $urn the unified resource name used to identify the object
-	 * @return void
-	 * @throws \Exception when something goes wrong, message will be logged
-	 * @since 7.0.0
-	 */
-	function deleteObject($urn) {
-		$this->getConnection()->deleteObject([
-			'Bucket' => $this->bucket,
-			'Key' => $urn
-		]);
-	}
+    /**
+     * @param string $urn the unified resource name used to identify the object
+     * @return void
+     * @throws \Exception when something goes wrong, message will be logged
+     * @since 7.0.0
+     */
+    function deleteObject($urn) {
+        $this->getConnection()->deleteObject([
+            'Bucket' => $this->bucket,
+            'Key' => $urn
+        ]);
+    }
 }