Add containerExportStream() and containerCopyStream()

Author: clue

src/Client.php

@@ -152,12 +152,29 @@ public function containerChanges($container)
      * @param string $container container ID
      * @return Promise Promise<string> tar stream
      * @link https://docs.docker.com/reference/api/docker_remote_api_v1.15/#export-a-container
+     * @see self::containerExportStream()
      */
     public function containerExport($container)
     {
         return $this->browser->get($this->url('/containers/%s/export', $container))->then(array($this->parser, 'expectPlain'));
     }
 
+    /**
+     * Export the contents of container id
+     *
+     * The resulting stream is a well-behaving readable stream that will emit
+     * the normal stream events.
+     *
+     * @param string $container container ID
+     * @return ReadableStreamInterface tar stream
+     * @link https://docs.docker.com/reference/api/docker_remote_api_v1.15/#export-a-container
+     * @see self::containerExport()
+     */
+    public function containerExportStream($container)
+    {
+        return $this->streamingParser->parsePlainStream($this->browser->get($this->url('/containers/%s/export', $container)));
+    }
+
     /**
      * Resize the TTY of container id
      *
@@ -280,12 +297,31 @@ public function containerRemove($container, $v = false, $force = false)
      * @param string $container container ID
      * @param array  $config    resources to copy `array('Resource' => 'file.txt')` (see link)
      * @return Promise Promise<string> tar stream
+     * @link https://docs.docker.com/reference/api/docker_remote_api_v1.15/#copy-files-or-folders-from-a-container
+     * @see self::containerCopyStream()
      */
     public function containerCopy($container, $config)
     {
         return $this->postJson($this->url('/containers/%s/copy', $container), $config)->then(array($this->parser, 'expectPlain'));
     }
 
+    /**
+     * Copy files or folders of container id
+     *
+     * The resulting stream is a well-behaving readable stream that will emit
+     * the normal stream events.
+     *
+     * @param string $container container ID
+     * @param array  $config    resources to copy `array('Resource' => 'file.txt')` (see link)
+     * @return ReadableStreamInterface tar stream
+     * @link https://docs.docker.com/reference/api/docker_remote_api_v1.15/#copy-files-or-folders-from-a-container
+     * @see self::containerCopy()
+     */
+    public function containerCopyStream($container, $config)
+    {
+        return $this->streamingParser->parsePlainStream($this->postJson($this->url('/containers/%s/copy', $container), $config));
+    }
+
     /**
      * List images
      *

tests/ClientTest.php

@@ -86,6 +86,16 @@ public function testContainerExport()
         $this->expectPromiseResolveWith($data, $this->client->containerExport(123));
     }
 
+    public function testContainerExportStream()
+    {
+        $stream = $this->getMock('React\Stream\ReadableStreamInterface');
+
+        $this->expectRequest('get', '/containers/123/export', $this->createResponse(''));
+        $this->streamingParser->expects($this->once())->method('parsePlainStream')->will($this->returnValue($stream));
+
+        $this->assertSame($stream, $this->client->containerExportStream(123));
+    }
+
     public function testContainerWait()
     {
         $json = array();
@@ -168,12 +178,23 @@ public function testContainerResize()
     public function testContainerCopy()
     {
         $data = 'tar stream';
-        $config = array('Resource' => 'file.txt');
         $this->expectRequestFlow('post', '/containers/123/copy', $this->createResponse($data), 'expectPlain');
 
+        $config = array('Resource' => 'file.txt');
         $this->expectPromiseResolveWith($data, $this->client->containerCopy('123', $config));
     }
 
+    public function testContainerCopyStream()
+    {
+        $stream = $this->getMock('React\Stream\ReadableStreamInterface');
+
+        $this->expectRequest('post', '/containers/123/copy', $this->createResponse(''));
+        $this->streamingParser->expects($this->once())->method('parsePlainStream')->will($this->returnValue($stream));
+
+        $config = array('Resource' => 'file.txt');
+        $this->assertSame($stream, $this->client->containerCopyStream('123', $config));
+    }
+
     public function testImageList()
     {
         $json = array();