From 8dea4f980758c2c8735bd582730324944d5e2eda Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Thomas=20M=C3=BCller?= <1005065+DeepDiver1975@users.noreply.github.com> Date: Tue, 14 Dec 2021 12:15:31 +0100 Subject: [PATCH] feat: create a seekable stream when reading. Allows http range requests which is necessary for video playback --- lib/s3storage.php | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/lib/s3storage.php b/lib/s3storage.php index 39efc03d..a5846572 100644 --- a/lib/s3storage.php +++ b/lib/s3storage.php @@ -67,7 +67,7 @@ public function __construct($params) { $this->params = $params; } - protected function init() { + protected function init(): void { if ($this->connection) { return; } @@ -178,7 +178,10 @@ public function deleteObject($urn) { public function readObject($urn) { $this->init(); try { - return \fopen($this->getUrl($urn), 'r'); + $context = stream_context_create([ + 'seekable' => true + ]); + return \fopen($this->getUrl($urn), 'rb', false, $context); } catch (AwsException $ex) { throw new ObjectStoreOperationException($ex->getAwsErrorMessage(), $ex->getStatusCode(), $ex); } @@ -275,7 +278,11 @@ public function getVersion($urn, $versionId) { public function getContentOfVersion($urn, $versionId) { $this->init(); try { - return \fopen($this->getUrl($urn, $versionId), 'r'); + $context = stream_context_create([ + 'seekable' => true + ]); + + return \fopen($this->getUrl($urn, $versionId), 'rb', false, $context); } catch (AwsException $ex) { throw new ObjectStoreOperationException($ex->getAwsErrorMessage(), $ex->getStatusCode(), $ex); }