summaryrefslogtreecommitdiffstats
path: root/lib/private/Files/ObjectStore/S3.php
diff options
context:
space:
mode:
Diffstat (limited to 'lib/private/Files/ObjectStore/S3.php')
-rw-r--r--lib/private/Files/ObjectStore/S3.php68
1 files changed, 1 insertions, 67 deletions
diff --git a/lib/private/Files/ObjectStore/S3.php b/lib/private/Files/ObjectStore/S3.php
index 6f37492271c..e4a7b068b65 100644
--- a/lib/private/Files/ObjectStore/S3.php
+++ b/lib/private/Files/ObjectStore/S3.php
@@ -23,13 +23,9 @@ namespace OC\Files\ObjectStore;
use OCP\Files\ObjectStore\IObjectStore;
-// TODO: proper composer
-set_include_path(get_include_path() . PATH_SEPARATOR .
- \OC_App::getAppPath('files_external') . '/3rdparty/aws-sdk-php');
-require_once 'aws-autoloader.php';
-
class S3 implements IObjectStore {
use S3ConnectionTrait;
+ use S3ObjectTrait;
public function __construct($parameters) {
$this->parseParams($parameters);
@@ -42,66 +38,4 @@ class S3 implements IObjectStore {
public function getStorageId() {
return $this->id;
}
-
- /**
- * @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
- */
- public function readObject($urn) {
- // Create the command and serialize the request
- $request = $this->getConnection()->getCommand('GetObject', [
- 'Bucket' => $this->bucket,
- 'Key' => $urn
- ])->prepare();
-
- $request->dispatch('request.before_send', array(
- 'request' => $request
- ));
-
- $headers = $request->getHeaderLines();
- $headers[] = 'Connection: close';
-
- $opts = [
- 'http' => [
- 'method' => "GET",
- 'header' => $headers
- ],
- 'ssl' => [
- 'verify_peer' => true
- ]
- ];
-
- $context = stream_context_create($opts);
- return fopen($request->getUrl(), '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
- */
- public function writeObject($urn, $stream) {
- $this->getConnection()->putObject([
- 'Bucket' => $this->bucket,
- 'Key' => $urn,
- 'Body' => $stream
- ]);
- }
-
- /**
- * @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
- */
- public function deleteObject($urn) {
- $this->getConnection()->deleteObject([
- 'Bucket' => $this->bucket,
- 'Key' => $urn
- ]);
- }
-
}