Enabling empty file creation via Guzzle

pydio · Nov 21, 2016 · 67c037a · 67c037a
1 parent 7e857f4
commit 67c037a
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 6 deletions.
diff --git a/core/src/plugins/core.access/src/Stream/MetadataCachingStream.php b/core/src/plugins/core.access/src/Stream/MetadataCachingStream.php
@@ -134,13 +134,19 @@ public function stat() {
 
                 CacheService::save(AJXP_CACHE_SERVICE_NS_NODES, $id, $stat);
             }
-        } else if (isset($stats)) {
+        } else {
             CacheService::save(AJXP_CACHE_SERVICE_NS_NODES, $this->cacheOptions["id"], $stats, $this->cacheOptions["timelimit"]);
         }
 
         return CacheService::fetch(AJXP_CACHE_SERVICE_NS_NODES, $this->cacheOptions["id"]);
     }
 
+    public function write($string) {
+        CacheService::delete(AJXP_CACHE_SERVICE_NS_NODES, $this->cacheOptions["id"]);
+
+        return $this->stream->write($string);
+    }
+
     public function rename($newNode) {
         $parentNode = $this->node->getParent();
 

diff --git a/core/src/plugins/core.access/src/Stream/StreamWrapper.php b/core/src/plugins/core.access/src/Stream/StreamWrapper.php
@@ -311,8 +311,10 @@ public static function createStream($path, $mode = "r+") {
         if ($useAuthStream) $nodeStream = new AuthStream($nodeStream, $node);
         if ($useOAuthStream) $nodeStream = new OAuthStream($nodeStream, $node);
 
+        if (strpos($mode, 'w') !== false) {
+            $nodeStream = new WriteBufferStream($nodeStream, $node);
+        }
         $nodeStream = new MetadataCachingStream($nodeStream, $node);
-        $nodeStream = new WriteBufferStream($nodeStream, $node);
 
         PydioStreamWrapper::getResource($nodeStream);
 

diff --git a/core/src/plugins/core.access/src/Stream/WriteBufferStream.php b/core/src/plugins/core.access/src/Stream/WriteBufferStream.php
@@ -56,12 +56,10 @@ public function getContents() {
     }
 
     public function close() {
-        if ($this->size > 0) {
-            $this->stream->write($this->bufferStream);
-        }
+        $this->stream->write($this->bufferStream);
 
         $this->size = 0;
-        $this->stream->close();
+        return $this->stream->close();
     }
 
     /**