diff options
Diffstat (limited to 'lib/private/Files/ObjectStore/S3.php')
-rw-r--r-- | lib/private/Files/ObjectStore/S3.php | 68 |
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 - ]); - } - } |