[S3] Add option to specify an SSE-C customer provided key

Signed-off-by: Julius Härtl <jus@bitgrid.net>

Author: juliusknorr

lib/private/Files/ObjectStore/S3ConnectionTrait.php

@@ -225,4 +225,26 @@ protected function getCertificateBundlePath(): ?string {
 			return null;
 		}
 	}
+
+	protected function getSSECKey(): ?string {
+		if (isset($this->params['sse_c_key'])) {
+			return $this->params['sse_c_key'];
+		}
+
+		return null;
+	}
+
+	protected function getSSECParameters(): array {
+		$key = $this->getSSECKey();
+
+		if ($key === null) {
+			return [];
+		}
+
+		return [
+			'SSECustomerAlgorithm' => 'AES256',
+			'SSECustomerKey' => $key,
+			'SSECustomerKeyMD5' => md5($key, true)
+		];
+	}
 }

lib/private/Files/ObjectStore/S3ObjectTrait.php

@@ -44,6 +44,7 @@ trait S3ObjectTrait {
 	abstract protected function getConnection();
 
 	abstract protected function getCertificateBundlePath(): ?string;
+	abstract protected function getSSECParameters(): array;
 
 	/**
 	 * @param string $urn the unified resource name used to identify the object
@@ -57,7 +58,7 @@ public function readObject($urn) {
 				'Bucket' => $this->bucket,
 				'Key' => $urn,
 				'Range' => 'bytes=' . $range,
-			]);
+			] + $this->getSSECParameters());
 			$request = \Aws\serialize($command);
 			$headers = [];
 			foreach ($request->getHeaders() as $key => $values) {
@@ -100,7 +101,7 @@ protected function writeSingle(string $urn, StreamInterface $stream, string $mim
 			'Body' => $stream,
 			'ACL' => 'private',
 			'ContentType' => $mimetype,
-		]);
+		] + $this->getSSECParameters());
 	}
 
 
@@ -119,7 +120,7 @@ protected function writeMultiPart(string $urn, StreamInterface $stream, string $
 			'part_size' => $this->uploadPartSize,
 			'params' => [
 				'ContentType' => $mimetype
-			],
+			] + $this->getSSECParameters(),
 		]);
 
 		try {
@@ -174,10 +175,10 @@ public function deleteObject($urn) {
 	}
 
 	public function objectExists($urn) {
-		return $this->getConnection()->doesObjectExist($this->bucket, $urn);
+		return $this->getConnection()->doesObjectExist($this->bucket, $urn, $this->getSSECParameters());
 	}
 
 	public function copyObject($from, $to) {
-		$this->getConnection()->copy($this->getBucket(), $from, $this->getBucket(), $to);
+		$this->getConnection()->copy($this->getBucket(), $from, $this->getBucket(), $to, 'private', $this->getSSECParameters());
 	}
 }