feat: Upgrade Guzzlehttp/psr7 version

BigQuery/src/Bytes.php

@@ -17,7 +17,7 @@
 
 namespace Google\Cloud\BigQuery;
 
-use GuzzleHttp\Psr7;
+use GuzzleHttp\Psr7\Utils;
 use Psr\Http\Message\StreamInterface;
 
 /**
@@ -45,7 +45,7 @@ class Bytes implements ValueInterface
      */
     public function __construct($value)
     {
-        $this->value = Psr7\stream_for($value);
+        $this->value = Utils::streamFor($value);
     }
 
     /**

BigQuery/src/Connection/Rest.php

@@ -25,7 +25,7 @@
 use Google\Cloud\Core\Upload\AbstractUploader;
 use Google\Cloud\Core\Upload\MultipartUploader;
 use Google\Cloud\Core\UriTrait;
-use GuzzleHttp\Psr7;
+use GuzzleHttp\Psr7\Utils;
 
 /**
  * Implementation of the
@@ -280,7 +280,7 @@ private function resolveUploadOptions(array $args)
             'jobReference' => []
         ];
 
-        $args['data'] = Psr7\stream_for($args['data']);
+        $args['data'] = Utils::streamFor($args['data']);
         $args['metadata'] = $this->pluckArray([
             'labels',
             'dryRun',

BigQuery/tests/System/LoadDataAndQueryTest.php

@@ -21,7 +21,7 @@
 use Google\Cloud\BigQuery\Geography;
 use Google\Cloud\BigQuery\Numeric;
 use Google\Cloud\Core\ExponentialBackoff;
-use GuzzleHttp\Psr7;
+use GuzzleHttp\Psr7\Utils;
 
 /**
  * @group bigquery
@@ -408,7 +408,7 @@ public function rowProvider()
         return [
             [$data],
             [fopen(__DIR__ . '/data/table-data.json', 'r')],
-            [Psr7\stream_for($data)]
+            [Utils::streamFor($data)]
         ];
     }
 

BigQuery/tests/Unit/BytesTest.php

@@ -18,7 +18,7 @@
 namespace Google\Cloud\BigQuery\Tests\Unit;
 
 use Google\Cloud\BigQuery\Bytes;
-use GuzzleHttp\Psr7;
+use GuzzleHttp\Psr7\Utils;
 use PHPUnit\Framework\TestCase;
 
 /**
@@ -47,7 +47,7 @@ public function valueProvider()
         return [
             [$this->value],
             [$fh],
-            [Psr7\stream_for($this->value)]
+            [Utils::streamFor($this->value)]
         ];
     }
 

BigQuery/tests/Unit/Connection/RestTest.php

@@ -22,7 +22,6 @@
 use Google\Cloud\Core\RequestWrapper;
 use Google\Cloud\Core\Testing\TestHelpers;
 use Google\Cloud\Core\Upload\AbstractUploader;
-use GuzzleHttp\Psr7;
 use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Response;
 use PHPUnit\Framework\TestCase;

Core/composer.json

@@ -9,7 +9,7 @@
         "google/auth": "^1.12",
         "guzzlehttp/guzzle": "^5.3|^6.0|^7.0",
         "guzzlehttp/promises": "^1.3",
-        "guzzlehttp/psr7": "^1.2",
+        "guzzlehttp/psr7": "^1.7|^2.0",
         "monolog/monolog": "^1.1|^2.0",
         "psr/http-message": "1.0.*"
     },

Core/src/Blob.php

@@ -17,7 +17,7 @@
 
 namespace Google\Cloud\Core;
 
-use GuzzleHttp\Psr7;
+use GuzzleHttp\Psr7\Utils;
 use Psr\Http\Message\StreamInterface;
 
 /**
@@ -52,7 +52,7 @@ class Blob
      */
     public function __construct($value)
     {
-        $this->value = Psr7\stream_for($value);
+        $this->value = Utils::streamFor($value);
     }
 
     /**

Core/src/RequestBuilder.php

@@ -17,7 +17,6 @@
 
 namespace Google\Cloud\Core;
 
-use GuzzleHttp\Psr7;
 use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Uri;
 use Psr\Http\Message\RequestInterface;

Core/src/RequestWrapper.php

@@ -25,7 +25,7 @@
 use Google\Cloud\Core\RequestWrapperTrait;
 use GuzzleHttp\Exception\RequestException;
 use GuzzleHttp\Promise\PromiseInterface;
-use GuzzleHttp\Psr7;
+use GuzzleHttp\Psr7\Utils;
 use Psr\Http\Message\RequestInterface;
 use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\StreamInterface;
@@ -304,7 +304,7 @@ private function applyHeaders(RequestInterface $request)
             }
         }
 
-        return Psr7\modify_request($request, ['set_headers' => $headers]);
+        return Utils::modifyRequest($request, ['set_headers' => $headers]);
     }
 
     /**

Core/src/Upload/AbstractUploader.php

@@ -19,7 +19,7 @@
 
 use Google\Cloud\Core\RequestWrapper;
 use Google\Cloud\Core\UriTrait;
-use GuzzleHttp\Psr7;
+use GuzzleHttp\Psr7\Utils;
 use Psr\Http\Message\StreamInterface;
 
 /**
@@ -96,7 +96,7 @@ public function __construct(
         array $options = []
     ) {
         $this->requestWrapper = $requestWrapper;
-        $this->data = Psr7\stream_for($data);
+        $this->data = Utils::streamFor($data);
         $this->uri = $uri;
         $this->metadata = isset($options['metadata']) ? $options['metadata'] : [];
         $this->chunkSize = isset($options['chunkSize']) ? $options['chunkSize'] : null;

Core/src/Upload/ResumableUploader.php

@@ -23,7 +23,6 @@
 use Google\Cloud\Core\JsonTrait;
 use Google\Cloud\Core\RequestWrapper;
 use GuzzleHttp\Promise\PromiseInterface;
-use GuzzleHttp\Psr7;
 use GuzzleHttp\Psr7\LimitStream;
 use GuzzleHttp\Psr7\Request;
 use Psr\Http\Message\ResponseInterface;

Core/src/UriTrait.php

@@ -17,7 +17,8 @@
 
 namespace Google\Cloud\Core;
 
-use GuzzleHttp\Psr7;
+use GuzzleHttp\Psr7\Query;
+use GuzzleHttp\Psr7\Utils;
 use Psr\Http\Message\UriInterface;
 use Rize\UriTemplate;
 
@@ -59,6 +60,6 @@ public function buildUriWithQuery($uri, array $query)
             }
         }
 
-        return Psr7\uri_for($uri)->withQuery(Psr7\build_query($query));
+        return Utils::uriFor($uri)->withQuery(Query::build($query));
     }
 }

Core/tests/Unit/Upload/MultipartUploaderTest.php

@@ -20,14 +20,13 @@
 use Google\Cloud\Core\RequestWrapper;
 use Google\Cloud\Core\Upload\MultipartUploader;
 use GuzzleHttp\Psr7;
-use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Response;
 use GuzzleHttp\Promise;
 use GuzzleHttp\Promise\PromiseInterface;
+use GuzzleHttp\Psr7\Utils;
 use Prophecy\Argument;
 use Psr\Http\Message\RequestInterface;
 use PHPUnit\Framework\TestCase;
-use Psr\Http\Message\StreamInterface;
 
 /**
  * @group core
@@ -38,7 +37,7 @@ class MultipartUploaderTest extends TestCase
     public function testUploadsData()
     {
         $requestWrapper = $this->prophesize(RequestWrapper::class);
-        $stream = Psr7\stream_for('abcd');
+        $stream = Utils::streamFor('abcd');
         $successBody = '{"canI":"kickIt"}';
         $response = new Response(200, [], $successBody);
 
@@ -59,7 +58,7 @@ public function testUploadsData()
     public function testUploadsAsyncData()
     {
         $requestWrapper = $this->prophesize(RequestWrapper::class);
-        $stream = Psr7\stream_for('abcd');
+        $stream = Utils::streamFor('abcd');
         $successBody = '{"canI":"kickIt"}';
         $response = new Response(200, [], $successBody);
         $promise = Promise\promise_for($response);

Core/tests/Unit/Upload/ResumableUploaderTest.php

@@ -20,9 +20,8 @@
 use Google\Cloud\Core\Exception\GoogleException;
 use Google\Cloud\Core\RequestWrapper;
 use Google\Cloud\Core\Upload\ResumableUploader;
-use GuzzleHttp\Psr7;
-use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Response;
+use GuzzleHttp\Psr7\Utils;
 use Prophecy\Argument;
 use Psr\Http\Message\RequestInterface;
 use Psr\Http\Message\StreamInterface;
@@ -41,7 +40,7 @@ class ResumableUploaderTest extends TestCase
     public function setUp()
     {
         $this->requestWrapper = $this->prophesize(RequestWrapper::class);
-        $this->stream = Psr7\stream_for('abcd');
+        $this->stream = Utils::streamFor('abcd');
         $this->successBody = '{"canI":"kickIt"}';
     }
 

Core/tests/Unit/Upload/SignedUrlUploaderTest.php

@@ -20,12 +20,11 @@
 use Google\Cloud\Core\Exception\GoogleException;
 use Google\Cloud\Core\RequestWrapper;
 use Google\Cloud\Core\Upload\SignedUrlUploader;
-use GuzzleHttp\Psr7;
 use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Response;
+use GuzzleHttp\Psr7\Utils;
 use Prophecy\Argument;
 use Psr\Http\Message\RequestInterface;
-use Psr\Http\Message\StreamInterface;
 use PHPUnit\Framework\TestCase;
 
 /**
@@ -41,7 +40,7 @@ class SignedUrlUploaderTest extends TestCase
     public function setUp()
     {
         $this->requestWrapper = $this->prophesize(RequestWrapper::class);
-        $this->stream = Psr7\stream_for('abcd');
+        $this->stream = Utils::streamFor('abcd');
         $this->successBody = '{"canI":"kickIt"}';
     }
 

Datastore/src/Blob.php

@@ -18,8 +18,6 @@
 namespace Google\Cloud\Datastore;
 
 use Google\Cloud\Core\Blob as CoreBlob;
-use GuzzleHttp\Psr7;
-use Psr\Http\Message\StreamInterface;
 
 /**
  * Represents a Blob value.

Datastore/tests/Unit/BlobTest.php

@@ -18,7 +18,7 @@
 namespace Google\Cloud\Datastore\Tests\Unit;
 
 use Google\Cloud\Datastore\Blob;
-use GuzzleHttp\Psr7;
+use GuzzleHttp\Psr7\Utils;
 use PHPUnit\Framework\TestCase;
 
 /**
@@ -45,7 +45,7 @@ public function testBlobResource()
 
     public function testBlobStreamInterface()
     {
-        $blob = new Blob(Psr7\stream_for('hello world'));
+        $blob = new Blob(Utils::streamFor('hello world'));
         $this->assertEquals('hello world', (string) $blob);
     }
 

Datastore/tests/Unit/Connection/RestTest.php

@@ -21,7 +21,6 @@
 use Google\Cloud\Core\RequestWrapper;
 use Google\Cloud\Core\Testing\TestHelpers;
 use Google\Cloud\Datastore\Connection\Rest;
-use GuzzleHttp\Psr7;
 use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Response;
 use PHPUnit\Framework\TestCase;

Datastore/tests/Unit/EntityTest.php

@@ -20,7 +20,6 @@
 use Google\Cloud\Datastore\Entity;
 use Google\Cloud\Datastore\EntityMapper;
 use Google\Cloud\Datastore\Key;
-use GuzzleHttp\Psr7\Stream;
 use PHPUnit\Framework\TestCase;
 
 /**

Language/tests/Unit/Connection/RestTest.php

@@ -21,7 +21,6 @@
 use Google\Cloud\Core\RequestWrapper;
 use Google\Cloud\Core\Testing\TestHelpers;
 use Google\Cloud\Language\Connection\Rest;
-use GuzzleHttp\Psr7;
 use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Response;
 use PHPUnit\Framework\TestCase;

Logging/tests/Unit/Connection/RestTest.php

@@ -21,7 +21,6 @@
 use Google\Cloud\Core\RequestWrapper;
 use Google\Cloud\Core\Testing\TestHelpers;
 use Google\Cloud\Logging\Connection\Rest;
-use GuzzleHttp\Psr7;
 use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Response;
 use PHPUnit\Framework\TestCase;

PubSub/tests/Unit/Connection/RestTest.php

@@ -21,7 +21,6 @@
 use Google\Cloud\Core\RequestWrapper;
 use Google\Cloud\Core\Testing\TestHelpers;
 use Google\Cloud\PubSub\Connection\Rest;
-use GuzzleHttp\Psr7;
 use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Response;
 use PHPUnit\Framework\TestCase;

Spanner/src/Bytes.php

@@ -17,7 +17,7 @@
 
 namespace Google\Cloud\Spanner;
 
-use GuzzleHttp\Psr7;
+use GuzzleHttp\Psr7\Utils;
 use Psr\Http\Message\StreamInterface;
 
 /**
@@ -50,7 +50,7 @@ class Bytes implements ValueInterface
      */
     public function __construct($value)
     {
-        $this->value = Psr7\stream_for($value);
+        $this->value = Utils::streamFor($value);
     }
 
     /**

Speech/tests/Unit/Connection/RestTest.php

@@ -21,7 +21,6 @@
 use Google\Cloud\Core\RequestWrapper;
 use Google\Cloud\Core\Testing\TestHelpers;
 use Google\Cloud\Speech\Connection\Rest;
-use GuzzleHttp\Psr7;
 use GuzzleHttp\Psr7\Request;
 use GuzzleHttp\Psr7\Response;
 use PHPUnit\Framework\TestCase;

Storage/src/Bucket.php

@@ -32,7 +32,8 @@
 use Google\Cloud\Storage\Connection\IamBucket;
 use Google\Cloud\Storage\SigningHelper;
 use GuzzleHttp\Promise\PromiseInterface;
-use GuzzleHttp\Psr7;
+use GuzzleHttp\Psr7\MimeType;
+use GuzzleHttp\Psr7\Utils;
 use Psr\Http\Message\StreamInterface;
 
 /**
@@ -1070,7 +1071,7 @@ public function compose(array $sourceObjects, $name, array $options = [])
         ];
 
         if (!isset($options['destination']['contentType'])) {
-            $options['destination']['contentType'] = Psr7\mimetype_from_filename($name);
+            $options['destination']['contentType'] = MimeType::fromFilename($name);
         }
 
         if ($options['destination']['contentType'] === null) {
@@ -1266,7 +1267,7 @@ public function isWritable($file = null)
     {
         $file = $file ?: '__tempfile';
         $uploader = $this->getResumableUploader(
-            Psr7\stream_for(''),
+            Utils::streamFor(''),
             ['name' => $file]
         );
         try {