From c547d0c6eb3dbfdd5e51a0fa511dbfce3e02cec7 Mon Sep 17 00:00:00 2001 From: JoeWang1127 Date: Mon, 24 Aug 2026 15:39:30 +0000 Subject: [PATCH] chore: format bigtable --- Bigtable/owlbot.py | 13 + .../V2/Client/BigtableInstanceAdminClient.php | 41 +- .../V2/Client/BigtableTableAdminClient.php | 66 +- Bigtable/src/V2/Client/BigtableClient.php | 32 +- .../BigtableInstanceAdminClientTest.php | 649 ++++++++-------- .../Client/BigtableTableAdminClientTest.php | 735 +++++++++--------- .../Unit/V2/Client/BigtableClientTest.php | 300 +++---- 7 files changed, 984 insertions(+), 852 deletions(-) diff --git a/Bigtable/owlbot.py b/Bigtable/owlbot.py index 00fd9d596e64..19e68ca76234 100644 --- a/Bigtable/owlbot.py +++ b/Bigtable/owlbot.py @@ -54,3 +54,16 @@ s.move(admin_library / f'proto/src/Google/Cloud/Bigtable', f'src/', merge=preserve_copyright_year) s.move(admin_library / f'proto/src/GPBMetadata/Google/Bigtable', f'metadata/', merge=preserve_copyright_year) +# format generated clients +subprocess.run([ + 'npm', + 'exec', + '--yes', + '--package=@prettier/plugin-php@^0.19', + '--', + 'prettier', + '**/Client/*', + '--write', + '--parser=php', + '--single-quote', + '--print-width=120']) diff --git a/Bigtable/src/Admin/V2/Client/BigtableInstanceAdminClient.php b/Bigtable/src/Admin/V2/Client/BigtableInstanceAdminClient.php index cb812a4d13af..b25269907f8b 100644 --- a/Bigtable/src/Admin/V2/Client/BigtableInstanceAdminClient.php +++ b/Bigtable/src/Admin/V2/Client/BigtableInstanceAdminClient.php @@ -208,7 +208,10 @@ public function getOperationsClient() */ public function resumeOperation($operationName, $methodName = null) { - $options = $methodName && isset($this->descriptors[$methodName]['longRunning']) ? $this->descriptors[$methodName]['longRunning'] : []; + $options = + $methodName && isset($this->descriptors[$methodName]['longRunning']) + ? $this->descriptors[$methodName]['longRunning'] + : []; $operation = new OperationResponse($operationName, $this->getOperationsClient(), $options); $operation->reload(); return $operation; @@ -641,8 +644,10 @@ public function createLogicalView(CreateLogicalViewRequest $request, array $call * * @throws ApiException Thrown if the API call fails. */ - public function createMaterializedView(CreateMaterializedViewRequest $request, array $callOptions = []): OperationResponse - { + public function createMaterializedView( + CreateMaterializedViewRequest $request, + array $callOptions = [] + ): OperationResponse { return $this->startApiCall('CreateMaterializedView', $request, $callOptions)->wait(); } @@ -1082,8 +1087,10 @@ public function listLogicalViews(ListLogicalViewsRequest $request, array $callOp * * @throws ApiException Thrown if the API call fails. */ - public function listMaterializedViews(ListMaterializedViewsRequest $request, array $callOptions = []): PagedListResponse - { + public function listMaterializedViews( + ListMaterializedViewsRequest $request, + array $callOptions = [] + ): PagedListResponse { return $this->startApiCall('ListMaterializedViews', $request, $callOptions); } @@ -1120,8 +1127,10 @@ public function listMaterializedViews(ListMaterializedViewsRequest $request, arr * * @throws ApiException Thrown if the API call fails. */ - public function partialUpdateCluster(PartialUpdateClusterRequest $request, array $callOptions = []): OperationResponse - { + public function partialUpdateCluster( + PartialUpdateClusterRequest $request, + array $callOptions = [] + ): OperationResponse { return $this->startApiCall('PartialUpdateCluster', $request, $callOptions)->wait(); } @@ -1148,8 +1157,10 @@ public function partialUpdateCluster(PartialUpdateClusterRequest $request, array * * @throws ApiException Thrown if the API call fails. */ - public function partialUpdateInstance(PartialUpdateInstanceRequest $request, array $callOptions = []): OperationResponse - { + public function partialUpdateInstance( + PartialUpdateInstanceRequest $request, + array $callOptions = [] + ): OperationResponse { return $this->startApiCall('PartialUpdateInstance', $request, $callOptions)->wait(); } @@ -1202,8 +1213,10 @@ public function setIamPolicy(SetIamPolicyRequest $request, array $callOptions = * * @throws ApiException Thrown if the API call fails. */ - public function testIamPermissions(TestIamPermissionsRequest $request, array $callOptions = []): TestIamPermissionsResponse - { + public function testIamPermissions( + TestIamPermissionsRequest $request, + array $callOptions = [] + ): TestIamPermissionsResponse { return $this->startApiCall('TestIamPermissions', $request, $callOptions)->wait(); } @@ -1341,8 +1354,10 @@ public function updateLogicalView(UpdateLogicalViewRequest $request, array $call * * @throws ApiException Thrown if the API call fails. */ - public function updateMaterializedView(UpdateMaterializedViewRequest $request, array $callOptions = []): OperationResponse - { + public function updateMaterializedView( + UpdateMaterializedViewRequest $request, + array $callOptions = [] + ): OperationResponse { return $this->startApiCall('UpdateMaterializedView', $request, $callOptions)->wait(); } diff --git a/Bigtable/src/Admin/V2/Client/BigtableTableAdminClient.php b/Bigtable/src/Admin/V2/Client/BigtableTableAdminClient.php index f3f5db0b68fe..7b627630af99 100644 --- a/Bigtable/src/Admin/V2/Client/BigtableTableAdminClient.php +++ b/Bigtable/src/Admin/V2/Client/BigtableTableAdminClient.php @@ -221,7 +221,10 @@ public function getOperationsClient() */ public function resumeOperation($operationName, $methodName = null) { - $options = $methodName && isset($this->descriptors[$methodName]['longRunning']) ? $this->descriptors[$methodName]['longRunning'] : []; + $options = + $methodName && isset($this->descriptors[$methodName]['longRunning']) + ? $this->descriptors[$methodName]['longRunning'] + : []; $operation = new OperationResponse($operationName, $this->getOperationsClient(), $options); $operation->reload(); return $operation; @@ -257,8 +260,12 @@ private function createOperationsClient(array $options) * * @return string The formatted authorized_view resource. */ - public static function authorizedViewName(string $project, string $instance, string $table, string $authorizedView): string - { + public static function authorizedViewName( + string $project, + string $instance, + string $table, + string $authorizedView + ): string { return self::getPathTemplate('authorizedView')->render([ 'project' => $project, 'instance' => $instance, @@ -319,8 +326,13 @@ public static function clusterName(string $project, string $instance, string $cl * * @return string The formatted crypto_key_version resource. */ - public static function cryptoKeyVersionName(string $project, string $location, string $keyRing, string $cryptoKey, string $cryptoKeyVersion): string - { + public static function cryptoKeyVersionName( + string $project, + string $location, + string $keyRing, + string $cryptoKey, + string $cryptoKeyVersion + ): string { return self::getPathTemplate('cryptoKeyVersion')->render([ 'project' => $project, 'location' => $location, @@ -375,8 +387,12 @@ public static function locationName(string $project, string $location): string * * @return string The formatted schema_bundle resource. */ - public static function schemaBundleName(string $project, string $instance, string $table, string $schemaBundle): string - { + public static function schemaBundleName( + string $project, + string $instance, + string $table, + string $schemaBundle + ): string { return self::getPathTemplate('schemaBundle')->render([ 'project' => $project, 'instance' => $instance, @@ -571,8 +587,10 @@ public function __call($method, $args) * * @throws ApiException Thrown if the API call fails. */ - public function checkConsistency(CheckConsistencyRequest $request, array $callOptions = []): CheckConsistencyResponse - { + public function checkConsistency( + CheckConsistencyRequest $request, + array $callOptions = [] + ): CheckConsistencyResponse { return $this->startApiCall('CheckConsistency', $request, $callOptions)->wait(); } @@ -625,8 +643,10 @@ public function copyBackup(CopyBackupRequest $request, array $callOptions = []): * * @throws ApiException Thrown if the API call fails. */ - public function createAuthorizedView(CreateAuthorizedViewRequest $request, array $callOptions = []): OperationResponse - { + public function createAuthorizedView( + CreateAuthorizedViewRequest $request, + array $callOptions = [] + ): OperationResponse { return $this->startApiCall('CreateAuthorizedView', $request, $callOptions)->wait(); } @@ -747,8 +767,10 @@ public function createTable(CreateTableRequest $request, array $callOptions = [] * * @throws ApiException Thrown if the API call fails. */ - public function createTableFromSnapshot(CreateTableFromSnapshotRequest $request, array $callOptions = []): OperationResponse - { + public function createTableFromSnapshot( + CreateTableFromSnapshotRequest $request, + array $callOptions = [] + ): OperationResponse { return $this->startApiCall('CreateTableFromSnapshot', $request, $callOptions)->wait(); } @@ -931,8 +953,10 @@ public function dropRowRange(DropRowRangeRequest $request, array $callOptions = * * @throws ApiException Thrown if the API call fails. */ - public function generateConsistencyToken(GenerateConsistencyTokenRequest $request, array $callOptions = []): GenerateConsistencyTokenResponse - { + public function generateConsistencyToken( + GenerateConsistencyTokenRequest $request, + array $callOptions = [] + ): GenerateConsistencyTokenResponse { return $this->startApiCall('GenerateConsistencyToken', $request, $callOptions)->wait(); } @@ -1383,8 +1407,10 @@ public function snapshotTable(SnapshotTableRequest $request, array $callOptions * * @throws ApiException Thrown if the API call fails. */ - public function testIamPermissions(TestIamPermissionsRequest $request, array $callOptions = []): TestIamPermissionsResponse - { + public function testIamPermissions( + TestIamPermissionsRequest $request, + array $callOptions = [] + ): TestIamPermissionsResponse { return $this->startApiCall('TestIamPermissions', $request, $callOptions)->wait(); } @@ -1436,8 +1462,10 @@ public function undeleteTable(UndeleteTableRequest $request, array $callOptions * * @throws ApiException Thrown if the API call fails. */ - public function updateAuthorizedView(UpdateAuthorizedViewRequest $request, array $callOptions = []): OperationResponse - { + public function updateAuthorizedView( + UpdateAuthorizedViewRequest $request, + array $callOptions = [] + ): OperationResponse { return $this->startApiCall('UpdateAuthorizedView', $request, $callOptions)->wait(); } diff --git a/Bigtable/src/V2/Client/BigtableClient.php b/Bigtable/src/V2/Client/BigtableClient.php index 405f7f8fd3a1..45ec3f1c5f32 100644 --- a/Bigtable/src/V2/Client/BigtableClient.php +++ b/Bigtable/src/V2/Client/BigtableClient.php @@ -152,8 +152,12 @@ private static function getClientDefaults() * * @return string The formatted authorized_view resource. */ - public static function authorizedViewName(string $project, string $instance, string $table, string $authorizedView): string - { + public static function authorizedViewName( + string $project, + string $instance, + string $table, + string $authorizedView + ): string { return self::getPathTemplate('authorizedView')->render([ 'project' => $project, 'instance' => $instance, @@ -355,8 +359,10 @@ public function __call($method, $args) * * @throws ApiException Thrown if the API call fails. */ - public function checkAndMutateRow(CheckAndMutateRowRequest $request, array $callOptions = []): CheckAndMutateRowResponse - { + public function checkAndMutateRow( + CheckAndMutateRowRequest $request, + array $callOptions = [] + ): CheckAndMutateRowResponse { return $this->startApiCall('CheckAndMutateRow', $request, $callOptions)->wait(); } @@ -402,8 +408,10 @@ public function executeQuery(ExecuteQueryRequest $request, array $callOptions = * * @throws ApiException Thrown if the API call fails. */ - public function generateInitialChangeStreamPartitions(GenerateInitialChangeStreamPartitionsRequest $request, array $callOptions = []): ServerStream - { + public function generateInitialChangeStreamPartitions( + GenerateInitialChangeStreamPartitionsRequest $request, + array $callOptions = [] + ): ServerStream { return $this->startApiCall('GenerateInitialChangeStreamPartitions', $request, $callOptions); } @@ -430,8 +438,10 @@ public function generateInitialChangeStreamPartitions(GenerateInitialChangeStrea * * @throws ApiException Thrown if the API call fails. */ - public function getClientConfiguration(GetClientConfigurationRequest $request, array $callOptions = []): ClientConfiguration - { + public function getClientConfiguration( + GetClientConfigurationRequest $request, + array $callOptions = [] + ): ClientConfiguration { return $this->startApiCall('GetClientConfiguration', $request, $callOptions)->wait(); } @@ -658,8 +668,10 @@ public function readChangeStream(ReadChangeStreamRequest $request, array $callOp * * @throws ApiException Thrown if the API call fails. */ - public function readModifyWriteRow(ReadModifyWriteRowRequest $request, array $callOptions = []): ReadModifyWriteRowResponse - { + public function readModifyWriteRow( + ReadModifyWriteRowRequest $request, + array $callOptions = [] + ): ReadModifyWriteRowResponse { return $this->startApiCall('ReadModifyWriteRow', $request, $callOptions)->wait(); } diff --git a/Bigtable/tests/Unit/Admin/V2/Client/BigtableInstanceAdminClientTest.php b/Bigtable/tests/Unit/Admin/V2/Client/BigtableInstanceAdminClientTest.php index 9408fe83731c..aef275f247e5 100644 --- a/Bigtable/tests/Unit/Admin/V2/Client/BigtableInstanceAdminClientTest.php +++ b/Bigtable/tests/Unit/Admin/V2/Client/BigtableInstanceAdminClientTest.php @@ -96,7 +96,9 @@ private function createTransport($deserialize = null) /** @return CredentialsWrapper */ private function createCredentials() { - return $this->getMockBuilder(CredentialsWrapper::class)->disableOriginalConstructor()->getMock(); + return $this->getMockBuilder(CredentialsWrapper::class) + ->disableOriginalConstructor() + ->getMock(); } /** @return BigtableInstanceAdminClient */ @@ -160,12 +162,15 @@ public function createAppProfileExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); @@ -294,12 +299,15 @@ public function createClusterExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); @@ -461,12 +469,15 @@ public function createInstanceExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->projectName('[PROJECT]'); @@ -624,12 +635,15 @@ public function createLogicalViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); @@ -769,12 +783,15 @@ public function createMaterializedViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); @@ -822,9 +839,7 @@ public function deleteAppProfileTest() // Mock request $formattedName = $gapicClient->appProfileName('[PROJECT]', '[INSTANCE]', '[APP_PROFILE]'); $ignoreWarnings = true; - $request = (new DeleteAppProfileRequest()) - ->setName($formattedName) - ->setIgnoreWarnings($ignoreWarnings); + $request = (new DeleteAppProfileRequest())->setName($formattedName)->setIgnoreWarnings($ignoreWarnings); $gapicClient->deleteAppProfile($request); $actualRequests = $transport->popReceivedCalls(); $this->assertSame(1, count($actualRequests)); @@ -849,19 +864,20 @@ public function deleteAppProfileExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->appProfileName('[PROJECT]', '[INSTANCE]', '[APP_PROFILE]'); $ignoreWarnings = true; - $request = (new DeleteAppProfileRequest()) - ->setName($formattedName) - ->setIgnoreWarnings($ignoreWarnings); + $request = (new DeleteAppProfileRequest())->setName($formattedName)->setIgnoreWarnings($ignoreWarnings); try { $gapicClient->deleteAppProfile($request); // If the $gapicClient method call did not throw, fail the test @@ -888,8 +904,7 @@ public function deleteClusterTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); - $request = (new DeleteClusterRequest()) - ->setName($formattedName); + $request = (new DeleteClusterRequest())->setName($formattedName); $gapicClient->deleteCluster($request); $actualRequests = $transport->popReceivedCalls(); $this->assertSame(1, count($actualRequests)); @@ -912,17 +927,19 @@ public function deleteClusterExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); - $request = (new DeleteClusterRequest()) - ->setName($formattedName); + $request = (new DeleteClusterRequest())->setName($formattedName); try { $gapicClient->deleteCluster($request); // If the $gapicClient method call did not throw, fail the test @@ -949,8 +966,7 @@ public function deleteInstanceTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new DeleteInstanceRequest()) - ->setName($formattedName); + $request = (new DeleteInstanceRequest())->setName($formattedName); $gapicClient->deleteInstance($request); $actualRequests = $transport->popReceivedCalls(); $this->assertSame(1, count($actualRequests)); @@ -973,17 +989,19 @@ public function deleteInstanceExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new DeleteInstanceRequest()) - ->setName($formattedName); + $request = (new DeleteInstanceRequest())->setName($formattedName); try { $gapicClient->deleteInstance($request); // If the $gapicClient method call did not throw, fail the test @@ -1010,8 +1028,7 @@ public function deleteLogicalViewTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->logicalViewName('[PROJECT]', '[INSTANCE]', '[LOGICAL_VIEW]'); - $request = (new DeleteLogicalViewRequest()) - ->setName($formattedName); + $request = (new DeleteLogicalViewRequest())->setName($formattedName); $gapicClient->deleteLogicalView($request); $actualRequests = $transport->popReceivedCalls(); $this->assertSame(1, count($actualRequests)); @@ -1034,17 +1051,19 @@ public function deleteLogicalViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->logicalViewName('[PROJECT]', '[INSTANCE]', '[LOGICAL_VIEW]'); - $request = (new DeleteLogicalViewRequest()) - ->setName($formattedName); + $request = (new DeleteLogicalViewRequest())->setName($formattedName); try { $gapicClient->deleteLogicalView($request); // If the $gapicClient method call did not throw, fail the test @@ -1071,8 +1090,7 @@ public function deleteMaterializedViewTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->materializedViewName('[PROJECT]', '[INSTANCE]', '[MATERIALIZED_VIEW]'); - $request = (new DeleteMaterializedViewRequest()) - ->setName($formattedName); + $request = (new DeleteMaterializedViewRequest())->setName($formattedName); $gapicClient->deleteMaterializedView($request); $actualRequests = $transport->popReceivedCalls(); $this->assertSame(1, count($actualRequests)); @@ -1095,17 +1113,19 @@ public function deleteMaterializedViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->materializedViewName('[PROJECT]', '[INSTANCE]', '[MATERIALIZED_VIEW]'); - $request = (new DeleteMaterializedViewRequest()) - ->setName($formattedName); + $request = (new DeleteMaterializedViewRequest())->setName($formattedName); try { $gapicClient->deleteMaterializedView($request); // If the $gapicClient method call did not throw, fail the test @@ -1138,8 +1158,7 @@ public function getAppProfileTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->appProfileName('[PROJECT]', '[INSTANCE]', '[APP_PROFILE]'); - $request = (new GetAppProfileRequest()) - ->setName($formattedName); + $request = (new GetAppProfileRequest())->setName($formattedName); $response = $gapicClient->getAppProfile($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1163,17 +1182,19 @@ public function getAppProfileExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->appProfileName('[PROJECT]', '[INSTANCE]', '[APP_PROFILE]'); - $request = (new GetAppProfileRequest()) - ->setName($formattedName); + $request = (new GetAppProfileRequest())->setName($formattedName); try { $gapicClient->getAppProfile($request); // If the $gapicClient method call did not throw, fail the test @@ -1206,8 +1227,7 @@ public function getClusterTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); - $request = (new GetClusterRequest()) - ->setName($formattedName); + $request = (new GetClusterRequest())->setName($formattedName); $response = $gapicClient->getCluster($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1231,17 +1251,19 @@ public function getClusterExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); - $request = (new GetClusterRequest()) - ->setName($formattedName); + $request = (new GetClusterRequest())->setName($formattedName); try { $gapicClient->getCluster($request); // If the $gapicClient method call did not throw, fail the test @@ -1272,8 +1294,7 @@ public function getIamPolicyTest() $transport->addResponse($expectedResponse); // Mock request $resource = 'resource-341064690'; - $request = (new GetIamPolicyRequest()) - ->setResource($resource); + $request = (new GetIamPolicyRequest())->setResource($resource); $response = $gapicClient->getIamPolicy($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1297,17 +1318,19 @@ public function getIamPolicyExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $resource = 'resource-341064690'; - $request = (new GetIamPolicyRequest()) - ->setResource($resource); + $request = (new GetIamPolicyRequest())->setResource($resource); try { $gapicClient->getIamPolicy($request); // If the $gapicClient method call did not throw, fail the test @@ -1342,8 +1365,7 @@ public function getInstanceTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new GetInstanceRequest()) - ->setName($formattedName); + $request = (new GetInstanceRequest())->setName($formattedName); $response = $gapicClient->getInstance($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1367,17 +1389,19 @@ public function getInstanceExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new GetInstanceRequest()) - ->setName($formattedName); + $request = (new GetInstanceRequest())->setName($formattedName); try { $gapicClient->getInstance($request); // If the $gapicClient method call did not throw, fail the test @@ -1412,8 +1436,7 @@ public function getLogicalViewTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->logicalViewName('[PROJECT]', '[INSTANCE]', '[LOGICAL_VIEW]'); - $request = (new GetLogicalViewRequest()) - ->setName($formattedName); + $request = (new GetLogicalViewRequest())->setName($formattedName); $response = $gapicClient->getLogicalView($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1437,17 +1460,19 @@ public function getLogicalViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->logicalViewName('[PROJECT]', '[INSTANCE]', '[LOGICAL_VIEW]'); - $request = (new GetLogicalViewRequest()) - ->setName($formattedName); + $request = (new GetLogicalViewRequest())->setName($formattedName); try { $gapicClient->getLogicalView($request); // If the $gapicClient method call did not throw, fail the test @@ -1482,8 +1507,7 @@ public function getMaterializedViewTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->materializedViewName('[PROJECT]', '[INSTANCE]', '[MATERIALIZED_VIEW]'); - $request = (new GetMaterializedViewRequest()) - ->setName($formattedName); + $request = (new GetMaterializedViewRequest())->setName($formattedName); $response = $gapicClient->getMaterializedView($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1507,17 +1531,19 @@ public function getMaterializedViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->materializedViewName('[PROJECT]', '[INSTANCE]', '[MATERIALIZED_VIEW]'); - $request = (new GetMaterializedViewRequest()) - ->setName($formattedName); + $request = (new GetMaterializedViewRequest())->setName($formattedName); try { $gapicClient->getMaterializedView($request); // If the $gapicClient method call did not throw, fail the test @@ -1542,17 +1568,14 @@ public function listAppProfilesTest() // Mock response $nextPageToken = ''; $appProfilesElement = new AppProfile(); - $appProfiles = [ - $appProfilesElement, - ]; + $appProfiles = [$appProfilesElement]; $expectedResponse = new ListAppProfilesResponse(); $expectedResponse->setNextPageToken($nextPageToken); $expectedResponse->setAppProfiles($appProfiles); $transport->addResponse($expectedResponse); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new ListAppProfilesRequest()) - ->setParent($formattedParent); + $request = (new ListAppProfilesRequest())->setParent($formattedParent); $response = $gapicClient->listAppProfiles($request); $this->assertEquals($expectedResponse, $response->getPage()->getResponseObject()); $resources = iterator_to_array($response->iterateAllElements()); @@ -1579,17 +1602,19 @@ public function listAppProfilesExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new ListAppProfilesRequest()) - ->setParent($formattedParent); + $request = (new ListAppProfilesRequest())->setParent($formattedParent); try { $gapicClient->listAppProfiles($request); // If the $gapicClient method call did not throw, fail the test @@ -1618,8 +1643,7 @@ public function listClustersTest() $transport->addResponse($expectedResponse); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new ListClustersRequest()) - ->setParent($formattedParent); + $request = (new ListClustersRequest())->setParent($formattedParent); $response = $gapicClient->listClusters($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1643,17 +1667,19 @@ public function listClustersExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new ListClustersRequest()) - ->setParent($formattedParent); + $request = (new ListClustersRequest())->setParent($formattedParent); try { $gapicClient->listClusters($request); // If the $gapicClient method call did not throw, fail the test @@ -1678,17 +1704,14 @@ public function listHotTabletsTest() // Mock response $nextPageToken = ''; $hotTabletsElement = new HotTablet(); - $hotTablets = [ - $hotTabletsElement, - ]; + $hotTablets = [$hotTabletsElement]; $expectedResponse = new ListHotTabletsResponse(); $expectedResponse->setNextPageToken($nextPageToken); $expectedResponse->setHotTablets($hotTablets); $transport->addResponse($expectedResponse); // Mock request $formattedParent = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); - $request = (new ListHotTabletsRequest()) - ->setParent($formattedParent); + $request = (new ListHotTabletsRequest())->setParent($formattedParent); $response = $gapicClient->listHotTablets($request); $this->assertEquals($expectedResponse, $response->getPage()->getResponseObject()); $resources = iterator_to_array($response->iterateAllElements()); @@ -1715,17 +1738,19 @@ public function listHotTabletsExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); - $request = (new ListHotTabletsRequest()) - ->setParent($formattedParent); + $request = (new ListHotTabletsRequest())->setParent($formattedParent); try { $gapicClient->listHotTablets($request); // If the $gapicClient method call did not throw, fail the test @@ -1754,8 +1779,7 @@ public function listInstancesTest() $transport->addResponse($expectedResponse); // Mock request $formattedParent = $gapicClient->projectName('[PROJECT]'); - $request = (new ListInstancesRequest()) - ->setParent($formattedParent); + $request = (new ListInstancesRequest())->setParent($formattedParent); $response = $gapicClient->listInstances($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1779,17 +1803,19 @@ public function listInstancesExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->projectName('[PROJECT]'); - $request = (new ListInstancesRequest()) - ->setParent($formattedParent); + $request = (new ListInstancesRequest())->setParent($formattedParent); try { $gapicClient->listInstances($request); // If the $gapicClient method call did not throw, fail the test @@ -1814,17 +1840,14 @@ public function listLogicalViewsTest() // Mock response $nextPageToken = ''; $logicalViewsElement = new LogicalView(); - $logicalViews = [ - $logicalViewsElement, - ]; + $logicalViews = [$logicalViewsElement]; $expectedResponse = new ListLogicalViewsResponse(); $expectedResponse->setNextPageToken($nextPageToken); $expectedResponse->setLogicalViews($logicalViews); $transport->addResponse($expectedResponse); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new ListLogicalViewsRequest()) - ->setParent($formattedParent); + $request = (new ListLogicalViewsRequest())->setParent($formattedParent); $response = $gapicClient->listLogicalViews($request); $this->assertEquals($expectedResponse, $response->getPage()->getResponseObject()); $resources = iterator_to_array($response->iterateAllElements()); @@ -1851,17 +1874,19 @@ public function listLogicalViewsExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new ListLogicalViewsRequest()) - ->setParent($formattedParent); + $request = (new ListLogicalViewsRequest())->setParent($formattedParent); try { $gapicClient->listLogicalViews($request); // If the $gapicClient method call did not throw, fail the test @@ -1886,17 +1911,14 @@ public function listMaterializedViewsTest() // Mock response $nextPageToken = ''; $materializedViewsElement = new MaterializedView(); - $materializedViews = [ - $materializedViewsElement, - ]; + $materializedViews = [$materializedViewsElement]; $expectedResponse = new ListMaterializedViewsResponse(); $expectedResponse->setNextPageToken($nextPageToken); $expectedResponse->setMaterializedViews($materializedViews); $transport->addResponse($expectedResponse); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new ListMaterializedViewsRequest()) - ->setParent($formattedParent); + $request = (new ListMaterializedViewsRequest())->setParent($formattedParent); $response = $gapicClient->listMaterializedViews($request); $this->assertEquals($expectedResponse, $response->getPage()->getResponseObject()); $resources = iterator_to_array($response->iterateAllElements()); @@ -1923,17 +1945,19 @@ public function listMaterializedViewsExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new ListMaterializedViewsRequest()) - ->setParent($formattedParent); + $request = (new ListMaterializedViewsRequest())->setParent($formattedParent); try { $gapicClient->listMaterializedViews($request); // If the $gapicClient method call did not throw, fail the test @@ -1989,9 +2013,7 @@ public function partialUpdateClusterTest() $clusterServeNodes = 1434304124; $cluster->setServeNodes($clusterServeNodes); $updateMask = new FieldMask(); - $request = (new PartialUpdateClusterRequest()) - ->setCluster($cluster) - ->setUpdateMask($updateMask); + $request = (new PartialUpdateClusterRequest())->setCluster($cluster)->setUpdateMask($updateMask); $response = $gapicClient->partialUpdateCluster($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2049,12 +2071,15 @@ public function partialUpdateClusterExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $cluster = new Cluster(); @@ -2063,9 +2088,7 @@ public function partialUpdateClusterExceptionTest() $clusterServeNodes = 1434304124; $cluster->setServeNodes($clusterServeNodes); $updateMask = new FieldMask(); - $request = (new PartialUpdateClusterRequest()) - ->setCluster($cluster) - ->setUpdateMask($updateMask); + $request = (new PartialUpdateClusterRequest())->setCluster($cluster)->setUpdateMask($updateMask); $response = $gapicClient->partialUpdateCluster($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2139,9 +2162,7 @@ public function partialUpdateInstanceTest() ]; $instance->setLabels($instanceLabels); $updateMask = new FieldMask(); - $request = (new PartialUpdateInstanceRequest()) - ->setInstance($instance) - ->setUpdateMask($updateMask); + $request = (new PartialUpdateInstanceRequest())->setInstance($instance)->setUpdateMask($updateMask); $response = $gapicClient->partialUpdateInstance($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2199,12 +2220,15 @@ public function partialUpdateInstanceExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $instance = new Instance(); @@ -2220,9 +2244,7 @@ public function partialUpdateInstanceExceptionTest() ]; $instance->setLabels($instanceLabels); $updateMask = new FieldMask(); - $request = (new PartialUpdateInstanceRequest()) - ->setInstance($instance) - ->setUpdateMask($updateMask); + $request = (new PartialUpdateInstanceRequest())->setInstance($instance)->setUpdateMask($updateMask); $response = $gapicClient->partialUpdateInstance($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2263,9 +2285,7 @@ public function setIamPolicyTest() // Mock request $resource = 'resource-341064690'; $policy = new Policy(); - $request = (new SetIamPolicyRequest()) - ->setResource($resource) - ->setPolicy($policy); + $request = (new SetIamPolicyRequest())->setResource($resource)->setPolicy($policy); $response = $gapicClient->setIamPolicy($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -2291,19 +2311,20 @@ public function setIamPolicyExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $resource = 'resource-341064690'; $policy = new Policy(); - $request = (new SetIamPolicyRequest()) - ->setResource($resource) - ->setPolicy($policy); + $request = (new SetIamPolicyRequest())->setResource($resource)->setPolicy($policy); try { $gapicClient->setIamPolicy($request); // If the $gapicClient method call did not throw, fail the test @@ -2331,9 +2352,7 @@ public function testIamPermissionsTest() // Mock request $resource = 'resource-341064690'; $permissions = []; - $request = (new TestIamPermissionsRequest()) - ->setResource($resource) - ->setPermissions($permissions); + $request = (new TestIamPermissionsRequest())->setResource($resource)->setPermissions($permissions); $response = $gapicClient->testIamPermissions($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -2359,19 +2378,20 @@ public function testIamPermissionsExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $resource = 'resource-341064690'; $permissions = []; - $request = (new TestIamPermissionsRequest()) - ->setResource($resource) - ->setPermissions($permissions); + $request = (new TestIamPermissionsRequest())->setResource($resource)->setPermissions($permissions); try { $gapicClient->testIamPermissions($request); // If the $gapicClient method call did not throw, fail the test @@ -2423,9 +2443,7 @@ public function updateAppProfileTest() // Mock request $appProfile = new AppProfile(); $updateMask = new FieldMask(); - $request = (new UpdateAppProfileRequest()) - ->setAppProfile($appProfile) - ->setUpdateMask($updateMask); + $request = (new UpdateAppProfileRequest())->setAppProfile($appProfile)->setUpdateMask($updateMask); $response = $gapicClient->updateAppProfile($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2483,19 +2501,20 @@ public function updateAppProfileExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $appProfile = new AppProfile(); $updateMask = new FieldMask(); - $request = (new UpdateAppProfileRequest()) - ->setAppProfile($appProfile) - ->setUpdateMask($updateMask); + $request = (new UpdateAppProfileRequest())->setAppProfile($appProfile)->setUpdateMask($updateMask); $response = $gapicClient->updateAppProfile($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2556,9 +2575,7 @@ public function updateClusterTest() // Mock request $name = 'name3373707'; $serveNodes = 1288838783; - $request = (new Cluster()) - ->setName($name) - ->setServeNodes($serveNodes); + $request = (new Cluster())->setName($name)->setServeNodes($serveNodes); $response = $gapicClient->updateCluster($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2616,19 +2633,20 @@ public function updateClusterExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $name = 'name3373707'; $serveNodes = 1288838783; - $request = (new Cluster()) - ->setName($name) - ->setServeNodes($serveNodes); + $request = (new Cluster())->setName($name)->setServeNodes($serveNodes); $response = $gapicClient->updateCluster($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2712,12 +2730,15 @@ public function updateInstanceExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $name = 'name3373707'; @@ -2786,8 +2807,7 @@ public function updateLogicalViewTest() $logicalView = new LogicalView(); $logicalViewQuery = 'logicalViewQuery1609026330'; $logicalView->setQuery($logicalViewQuery); - $request = (new UpdateLogicalViewRequest()) - ->setLogicalView($logicalView); + $request = (new UpdateLogicalViewRequest())->setLogicalView($logicalView); $response = $gapicClient->updateLogicalView($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2843,19 +2863,21 @@ public function updateLogicalViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $logicalView = new LogicalView(); $logicalViewQuery = 'logicalViewQuery1609026330'; $logicalView->setQuery($logicalViewQuery); - $request = (new UpdateLogicalViewRequest()) - ->setLogicalView($logicalView); + $request = (new UpdateLogicalViewRequest())->setLogicalView($logicalView); $response = $gapicClient->updateLogicalView($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2919,8 +2941,7 @@ public function updateMaterializedViewTest() $materializedView = new MaterializedView(); $materializedViewQuery = 'materializedViewQuery1755221932'; $materializedView->setQuery($materializedViewQuery); - $request = (new UpdateMaterializedViewRequest()) - ->setMaterializedView($materializedView); + $request = (new UpdateMaterializedViewRequest())->setMaterializedView($materializedView); $response = $gapicClient->updateMaterializedView($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2976,19 +2997,21 @@ public function updateMaterializedViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $materializedView = new MaterializedView(); $materializedViewQuery = 'materializedViewQuery1755221932'; $materializedView->setQuery($materializedViewQuery); - $request = (new UpdateMaterializedViewRequest()) - ->setMaterializedView($materializedView); + $request = (new UpdateMaterializedViewRequest())->setMaterializedView($materializedView); $response = $gapicClient->updateMaterializedView($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); diff --git a/Bigtable/tests/Unit/Admin/V2/Client/BigtableTableAdminClientTest.php b/Bigtable/tests/Unit/Admin/V2/Client/BigtableTableAdminClientTest.php index 9422e6821985..352041089eda 100644 --- a/Bigtable/tests/Unit/Admin/V2/Client/BigtableTableAdminClientTest.php +++ b/Bigtable/tests/Unit/Admin/V2/Client/BigtableTableAdminClientTest.php @@ -102,7 +102,9 @@ private function createTransport($deserialize = null) /** @return CredentialsWrapper */ private function createCredentials() { - return $this->getMockBuilder(CredentialsWrapper::class)->disableOriginalConstructor()->getMock(); + return $this->getMockBuilder(CredentialsWrapper::class) + ->disableOriginalConstructor() + ->getMock(); } /** @return BigtableTableAdminClient */ @@ -130,9 +132,7 @@ public function checkConsistencyTest() // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); $consistencyToken = 'consistencyToken-1090516718'; - $request = (new CheckConsistencyRequest()) - ->setName($formattedName) - ->setConsistencyToken($consistencyToken); + $request = (new CheckConsistencyRequest())->setName($formattedName)->setConsistencyToken($consistencyToken); $response = $gapicClient->checkConsistency($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -158,19 +158,20 @@ public function checkConsistencyExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); $consistencyToken = 'consistencyToken-1090516718'; - $request = (new CheckConsistencyRequest()) - ->setName($formattedName) - ->setConsistencyToken($consistencyToken); + $request = (new CheckConsistencyRequest())->setName($formattedName)->setConsistencyToken($consistencyToken); try { $gapicClient->checkConsistency($request); // If the $gapicClient method call did not throw, fail the test @@ -292,12 +293,15 @@ public function copyBackupExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); @@ -433,12 +437,15 @@ public function createAuthorizedViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); @@ -578,12 +585,15 @@ public function createBackupExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); @@ -719,12 +729,15 @@ public function createSchemaBundleExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); @@ -806,12 +819,15 @@ public function createTableExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); @@ -934,12 +950,15 @@ public function createTableFromSnapshotExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); @@ -984,8 +1003,7 @@ public function deleteAuthorizedViewTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->authorizedViewName('[PROJECT]', '[INSTANCE]', '[TABLE]', '[AUTHORIZED_VIEW]'); - $request = (new DeleteAuthorizedViewRequest()) - ->setName($formattedName); + $request = (new DeleteAuthorizedViewRequest())->setName($formattedName); $gapicClient->deleteAuthorizedView($request); $actualRequests = $transport->popReceivedCalls(); $this->assertSame(1, count($actualRequests)); @@ -1008,17 +1026,19 @@ public function deleteAuthorizedViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->authorizedViewName('[PROJECT]', '[INSTANCE]', '[TABLE]', '[AUTHORIZED_VIEW]'); - $request = (new DeleteAuthorizedViewRequest()) - ->setName($formattedName); + $request = (new DeleteAuthorizedViewRequest())->setName($formattedName); try { $gapicClient->deleteAuthorizedView($request); // If the $gapicClient method call did not throw, fail the test @@ -1045,8 +1065,7 @@ public function deleteBackupTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->backupName('[PROJECT]', '[INSTANCE]', '[CLUSTER]', '[BACKUP]'); - $request = (new DeleteBackupRequest()) - ->setName($formattedName); + $request = (new DeleteBackupRequest())->setName($formattedName); $gapicClient->deleteBackup($request); $actualRequests = $transport->popReceivedCalls(); $this->assertSame(1, count($actualRequests)); @@ -1069,17 +1088,19 @@ public function deleteBackupExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->backupName('[PROJECT]', '[INSTANCE]', '[CLUSTER]', '[BACKUP]'); - $request = (new DeleteBackupRequest()) - ->setName($formattedName); + $request = (new DeleteBackupRequest())->setName($formattedName); try { $gapicClient->deleteBackup($request); // If the $gapicClient method call did not throw, fail the test @@ -1106,8 +1127,7 @@ public function deleteSchemaBundleTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->schemaBundleName('[PROJECT]', '[INSTANCE]', '[TABLE]', '[SCHEMA_BUNDLE]'); - $request = (new DeleteSchemaBundleRequest()) - ->setName($formattedName); + $request = (new DeleteSchemaBundleRequest())->setName($formattedName); $gapicClient->deleteSchemaBundle($request); $actualRequests = $transport->popReceivedCalls(); $this->assertSame(1, count($actualRequests)); @@ -1130,17 +1150,19 @@ public function deleteSchemaBundleExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->schemaBundleName('[PROJECT]', '[INSTANCE]', '[TABLE]', '[SCHEMA_BUNDLE]'); - $request = (new DeleteSchemaBundleRequest()) - ->setName($formattedName); + $request = (new DeleteSchemaBundleRequest())->setName($formattedName); try { $gapicClient->deleteSchemaBundle($request); // If the $gapicClient method call did not throw, fail the test @@ -1167,8 +1189,7 @@ public function deleteSnapshotTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->snapshotName('[PROJECT]', '[INSTANCE]', '[CLUSTER]', '[SNAPSHOT]'); - $request = (new DeleteSnapshotRequest()) - ->setName($formattedName); + $request = (new DeleteSnapshotRequest())->setName($formattedName); $gapicClient->deleteSnapshot($request); $actualRequests = $transport->popReceivedCalls(); $this->assertSame(1, count($actualRequests)); @@ -1191,17 +1212,19 @@ public function deleteSnapshotExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->snapshotName('[PROJECT]', '[INSTANCE]', '[CLUSTER]', '[SNAPSHOT]'); - $request = (new DeleteSnapshotRequest()) - ->setName($formattedName); + $request = (new DeleteSnapshotRequest())->setName($formattedName); try { $gapicClient->deleteSnapshot($request); // If the $gapicClient method call did not throw, fail the test @@ -1228,8 +1251,7 @@ public function deleteTableTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new DeleteTableRequest()) - ->setName($formattedName); + $request = (new DeleteTableRequest())->setName($formattedName); $gapicClient->deleteTable($request); $actualRequests = $transport->popReceivedCalls(); $this->assertSame(1, count($actualRequests)); @@ -1252,17 +1274,19 @@ public function deleteTableExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new DeleteTableRequest()) - ->setName($formattedName); + $request = (new DeleteTableRequest())->setName($formattedName); try { $gapicClient->deleteTable($request); // If the $gapicClient method call did not throw, fail the test @@ -1289,8 +1313,7 @@ public function dropRowRangeTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new DropRowRangeRequest()) - ->setName($formattedName); + $request = (new DropRowRangeRequest())->setName($formattedName); $gapicClient->dropRowRange($request); $actualRequests = $transport->popReceivedCalls(); $this->assertSame(1, count($actualRequests)); @@ -1313,17 +1336,19 @@ public function dropRowRangeExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new DropRowRangeRequest()) - ->setName($formattedName); + $request = (new DropRowRangeRequest())->setName($formattedName); try { $gapicClient->dropRowRange($request); // If the $gapicClient method call did not throw, fail the test @@ -1352,8 +1377,7 @@ public function generateConsistencyTokenTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new GenerateConsistencyTokenRequest()) - ->setName($formattedName); + $request = (new GenerateConsistencyTokenRequest())->setName($formattedName); $response = $gapicClient->generateConsistencyToken($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1377,17 +1401,19 @@ public function generateConsistencyTokenExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new GenerateConsistencyTokenRequest()) - ->setName($formattedName); + $request = (new GenerateConsistencyTokenRequest())->setName($formattedName); try { $gapicClient->generateConsistencyToken($request); // If the $gapicClient method call did not throw, fail the test @@ -1420,8 +1446,7 @@ public function getAuthorizedViewTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->authorizedViewName('[PROJECT]', '[INSTANCE]', '[TABLE]', '[AUTHORIZED_VIEW]'); - $request = (new GetAuthorizedViewRequest()) - ->setName($formattedName); + $request = (new GetAuthorizedViewRequest())->setName($formattedName); $response = $gapicClient->getAuthorizedView($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1445,17 +1470,19 @@ public function getAuthorizedViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->authorizedViewName('[PROJECT]', '[INSTANCE]', '[TABLE]', '[AUTHORIZED_VIEW]'); - $request = (new GetAuthorizedViewRequest()) - ->setName($formattedName); + $request = (new GetAuthorizedViewRequest())->setName($formattedName); try { $gapicClient->getAuthorizedView($request); // If the $gapicClient method call did not throw, fail the test @@ -1490,8 +1517,7 @@ public function getBackupTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->backupName('[PROJECT]', '[INSTANCE]', '[CLUSTER]', '[BACKUP]'); - $request = (new GetBackupRequest()) - ->setName($formattedName); + $request = (new GetBackupRequest())->setName($formattedName); $response = $gapicClient->getBackup($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1515,17 +1541,19 @@ public function getBackupExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->backupName('[PROJECT]', '[INSTANCE]', '[CLUSTER]', '[BACKUP]'); - $request = (new GetBackupRequest()) - ->setName($formattedName); + $request = (new GetBackupRequest())->setName($formattedName); try { $gapicClient->getBackup($request); // If the $gapicClient method call did not throw, fail the test @@ -1556,8 +1584,7 @@ public function getIamPolicyTest() $transport->addResponse($expectedResponse); // Mock request $resource = 'resource-341064690'; - $request = (new GetIamPolicyRequest()) - ->setResource($resource); + $request = (new GetIamPolicyRequest())->setResource($resource); $response = $gapicClient->getIamPolicy($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1581,17 +1608,19 @@ public function getIamPolicyExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $resource = 'resource-341064690'; - $request = (new GetIamPolicyRequest()) - ->setResource($resource); + $request = (new GetIamPolicyRequest())->setResource($resource); try { $gapicClient->getIamPolicy($request); // If the $gapicClient method call did not throw, fail the test @@ -1622,8 +1651,7 @@ public function getSchemaBundleTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->schemaBundleName('[PROJECT]', '[INSTANCE]', '[TABLE]', '[SCHEMA_BUNDLE]'); - $request = (new GetSchemaBundleRequest()) - ->setName($formattedName); + $request = (new GetSchemaBundleRequest())->setName($formattedName); $response = $gapicClient->getSchemaBundle($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1647,17 +1675,19 @@ public function getSchemaBundleExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->schemaBundleName('[PROJECT]', '[INSTANCE]', '[TABLE]', '[SCHEMA_BUNDLE]'); - $request = (new GetSchemaBundleRequest()) - ->setName($formattedName); + $request = (new GetSchemaBundleRequest())->setName($formattedName); try { $gapicClient->getSchemaBundle($request); // If the $gapicClient method call did not throw, fail the test @@ -1690,8 +1720,7 @@ public function getSnapshotTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->snapshotName('[PROJECT]', '[INSTANCE]', '[CLUSTER]', '[SNAPSHOT]'); - $request = (new GetSnapshotRequest()) - ->setName($formattedName); + $request = (new GetSnapshotRequest())->setName($formattedName); $response = $gapicClient->getSnapshot($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1715,17 +1744,19 @@ public function getSnapshotExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->snapshotName('[PROJECT]', '[INSTANCE]', '[CLUSTER]', '[SNAPSHOT]'); - $request = (new GetSnapshotRequest()) - ->setName($formattedName); + $request = (new GetSnapshotRequest())->setName($formattedName); try { $gapicClient->getSnapshot($request); // If the $gapicClient method call did not throw, fail the test @@ -1756,8 +1787,7 @@ public function getTableTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new GetTableRequest()) - ->setName($formattedName); + $request = (new GetTableRequest())->setName($formattedName); $response = $gapicClient->getTable($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -1781,17 +1811,19 @@ public function getTableExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new GetTableRequest()) - ->setName($formattedName); + $request = (new GetTableRequest())->setName($formattedName); try { $gapicClient->getTable($request); // If the $gapicClient method call did not throw, fail the test @@ -1816,17 +1848,14 @@ public function listAuthorizedViewsTest() // Mock response $nextPageToken = ''; $authorizedViewsElement = new AuthorizedView(); - $authorizedViews = [ - $authorizedViewsElement, - ]; + $authorizedViews = [$authorizedViewsElement]; $expectedResponse = new ListAuthorizedViewsResponse(); $expectedResponse->setNextPageToken($nextPageToken); $expectedResponse->setAuthorizedViews($authorizedViews); $transport->addResponse($expectedResponse); // Mock request $formattedParent = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new ListAuthorizedViewsRequest()) - ->setParent($formattedParent); + $request = (new ListAuthorizedViewsRequest())->setParent($formattedParent); $response = $gapicClient->listAuthorizedViews($request); $this->assertEquals($expectedResponse, $response->getPage()->getResponseObject()); $resources = iterator_to_array($response->iterateAllElements()); @@ -1853,17 +1882,19 @@ public function listAuthorizedViewsExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new ListAuthorizedViewsRequest()) - ->setParent($formattedParent); + $request = (new ListAuthorizedViewsRequest())->setParent($formattedParent); try { $gapicClient->listAuthorizedViews($request); // If the $gapicClient method call did not throw, fail the test @@ -1888,17 +1919,14 @@ public function listBackupsTest() // Mock response $nextPageToken = ''; $backupsElement = new Backup(); - $backups = [ - $backupsElement, - ]; + $backups = [$backupsElement]; $expectedResponse = new ListBackupsResponse(); $expectedResponse->setNextPageToken($nextPageToken); $expectedResponse->setBackups($backups); $transport->addResponse($expectedResponse); // Mock request $formattedParent = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); - $request = (new ListBackupsRequest()) - ->setParent($formattedParent); + $request = (new ListBackupsRequest())->setParent($formattedParent); $response = $gapicClient->listBackups($request); $this->assertEquals($expectedResponse, $response->getPage()->getResponseObject()); $resources = iterator_to_array($response->iterateAllElements()); @@ -1925,17 +1953,19 @@ public function listBackupsExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); - $request = (new ListBackupsRequest()) - ->setParent($formattedParent); + $request = (new ListBackupsRequest())->setParent($formattedParent); try { $gapicClient->listBackups($request); // If the $gapicClient method call did not throw, fail the test @@ -1960,17 +1990,14 @@ public function listSchemaBundlesTest() // Mock response $nextPageToken = ''; $schemaBundlesElement = new SchemaBundle(); - $schemaBundles = [ - $schemaBundlesElement, - ]; + $schemaBundles = [$schemaBundlesElement]; $expectedResponse = new ListSchemaBundlesResponse(); $expectedResponse->setNextPageToken($nextPageToken); $expectedResponse->setSchemaBundles($schemaBundles); $transport->addResponse($expectedResponse); // Mock request $formattedParent = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new ListSchemaBundlesRequest()) - ->setParent($formattedParent); + $request = (new ListSchemaBundlesRequest())->setParent($formattedParent); $response = $gapicClient->listSchemaBundles($request); $this->assertEquals($expectedResponse, $response->getPage()->getResponseObject()); $resources = iterator_to_array($response->iterateAllElements()); @@ -1997,17 +2024,19 @@ public function listSchemaBundlesExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new ListSchemaBundlesRequest()) - ->setParent($formattedParent); + $request = (new ListSchemaBundlesRequest())->setParent($formattedParent); try { $gapicClient->listSchemaBundles($request); // If the $gapicClient method call did not throw, fail the test @@ -2032,17 +2061,14 @@ public function listSnapshotsTest() // Mock response $nextPageToken = ''; $snapshotsElement = new Snapshot(); - $snapshots = [ - $snapshotsElement, - ]; + $snapshots = [$snapshotsElement]; $expectedResponse = new ListSnapshotsResponse(); $expectedResponse->setNextPageToken($nextPageToken); $expectedResponse->setSnapshots($snapshots); $transport->addResponse($expectedResponse); // Mock request $formattedParent = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); - $request = (new ListSnapshotsRequest()) - ->setParent($formattedParent); + $request = (new ListSnapshotsRequest())->setParent($formattedParent); $response = $gapicClient->listSnapshots($request); $this->assertEquals($expectedResponse, $response->getPage()->getResponseObject()); $resources = iterator_to_array($response->iterateAllElements()); @@ -2069,17 +2095,19 @@ public function listSnapshotsExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->clusterName('[PROJECT]', '[INSTANCE]', '[CLUSTER]'); - $request = (new ListSnapshotsRequest()) - ->setParent($formattedParent); + $request = (new ListSnapshotsRequest())->setParent($formattedParent); try { $gapicClient->listSnapshots($request); // If the $gapicClient method call did not throw, fail the test @@ -2104,17 +2132,14 @@ public function listTablesTest() // Mock response $nextPageToken = ''; $tablesElement = new Table(); - $tables = [ - $tablesElement, - ]; + $tables = [$tablesElement]; $expectedResponse = new ListTablesResponse(); $expectedResponse->setNextPageToken($nextPageToken); $expectedResponse->setTables($tables); $transport->addResponse($expectedResponse); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new ListTablesRequest()) - ->setParent($formattedParent); + $request = (new ListTablesRequest())->setParent($formattedParent); $response = $gapicClient->listTables($request); $this->assertEquals($expectedResponse, $response->getPage()->getResponseObject()); $resources = iterator_to_array($response->iterateAllElements()); @@ -2141,17 +2166,19 @@ public function listTablesExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new ListTablesRequest()) - ->setParent($formattedParent); + $request = (new ListTablesRequest())->setParent($formattedParent); try { $gapicClient->listTables($request); // If the $gapicClient method call did not throw, fail the test @@ -2183,9 +2210,7 @@ public function modifyColumnFamiliesTest() // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); $modifications = []; - $request = (new ModifyColumnFamiliesRequest()) - ->setName($formattedName) - ->setModifications($modifications); + $request = (new ModifyColumnFamiliesRequest())->setName($formattedName)->setModifications($modifications); $response = $gapicClient->modifyColumnFamilies($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -2211,19 +2236,20 @@ public function modifyColumnFamiliesExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); $modifications = []; - $request = (new ModifyColumnFamiliesRequest()) - ->setName($formattedName) - ->setModifications($modifications); + $request = (new ModifyColumnFamiliesRequest())->setName($formattedName)->setModifications($modifications); try { $gapicClient->modifyColumnFamilies($request); // If the $gapicClient method call did not throw, fail the test @@ -2273,9 +2299,7 @@ public function restoreTableTest() // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); $tableId = 'tableId-895419604'; - $request = (new RestoreTableRequest()) - ->setParent($formattedParent) - ->setTableId($tableId); + $request = (new RestoreTableRequest())->setParent($formattedParent)->setTableId($tableId); $response = $gapicClient->restoreTable($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2333,19 +2357,20 @@ public function restoreTableExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedParent = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); $tableId = 'tableId-895419604'; - $request = (new RestoreTableRequest()) - ->setParent($formattedParent) - ->setTableId($tableId); + $request = (new RestoreTableRequest())->setParent($formattedParent)->setTableId($tableId); $response = $gapicClient->restoreTable($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2386,9 +2411,7 @@ public function setIamPolicyTest() // Mock request $resource = 'resource-341064690'; $policy = new Policy(); - $request = (new SetIamPolicyRequest()) - ->setResource($resource) - ->setPolicy($policy); + $request = (new SetIamPolicyRequest())->setResource($resource)->setPolicy($policy); $response = $gapicClient->setIamPolicy($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -2414,19 +2437,20 @@ public function setIamPolicyExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $resource = 'resource-341064690'; $policy = new Policy(); - $request = (new SetIamPolicyRequest()) - ->setResource($resource) - ->setPolicy($policy); + $request = (new SetIamPolicyRequest())->setResource($resource)->setPolicy($policy); try { $gapicClient->setIamPolicy($request); // If the $gapicClient method call did not throw, fail the test @@ -2542,12 +2566,15 @@ public function snapshotTableExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); @@ -2593,9 +2620,7 @@ public function testIamPermissionsTest() // Mock request $resource = 'resource-341064690'; $permissions = []; - $request = (new TestIamPermissionsRequest()) - ->setResource($resource) - ->setPermissions($permissions); + $request = (new TestIamPermissionsRequest())->setResource($resource)->setPermissions($permissions); $response = $gapicClient->testIamPermissions($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -2621,19 +2646,20 @@ public function testIamPermissionsExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $resource = 'resource-341064690'; $permissions = []; - $request = (new TestIamPermissionsRequest()) - ->setResource($resource) - ->setPermissions($permissions); + $request = (new TestIamPermissionsRequest())->setResource($resource)->setPermissions($permissions); try { $gapicClient->testIamPermissions($request); // If the $gapicClient method call did not throw, fail the test @@ -2682,8 +2708,7 @@ public function undeleteTableTest() $operationsTransport->addResponse($completeOperation); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new UndeleteTableRequest()) - ->setName($formattedName); + $request = (new UndeleteTableRequest())->setName($formattedName); $response = $gapicClient->undeleteTable($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2739,17 +2764,19 @@ public function undeleteTableExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new UndeleteTableRequest()) - ->setName($formattedName); + $request = (new UndeleteTableRequest())->setName($formattedName); $response = $gapicClient->undeleteTable($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2809,8 +2836,7 @@ public function updateAuthorizedViewTest() $operationsTransport->addResponse($completeOperation); // Mock request $authorizedView = new AuthorizedView(); - $request = (new UpdateAuthorizedViewRequest()) - ->setAuthorizedView($authorizedView); + $request = (new UpdateAuthorizedViewRequest())->setAuthorizedView($authorizedView); $response = $gapicClient->updateAuthorizedView($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2866,17 +2892,19 @@ public function updateAuthorizedViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $authorizedView = new AuthorizedView(); - $request = (new UpdateAuthorizedViewRequest()) - ->setAuthorizedView($authorizedView); + $request = (new UpdateAuthorizedViewRequest())->setAuthorizedView($authorizedView); $response = $gapicClient->updateAuthorizedView($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -2925,9 +2953,7 @@ public function updateBackupTest() $backupExpireTime = new Timestamp(); $backup->setExpireTime($backupExpireTime); $updateMask = new FieldMask(); - $request = (new UpdateBackupRequest()) - ->setBackup($backup) - ->setUpdateMask($updateMask); + $request = (new UpdateBackupRequest())->setBackup($backup)->setUpdateMask($updateMask); $response = $gapicClient->updateBackup($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -2953,12 +2979,15 @@ public function updateBackupExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $backup = new Backup(); @@ -2967,9 +2996,7 @@ public function updateBackupExceptionTest() $backupExpireTime = new Timestamp(); $backup->setExpireTime($backupExpireTime); $updateMask = new FieldMask(); - $request = (new UpdateBackupRequest()) - ->setBackup($backup) - ->setUpdateMask($updateMask); + $request = (new UpdateBackupRequest())->setBackup($backup)->setUpdateMask($updateMask); try { $gapicClient->updateBackup($request); // If the $gapicClient method call did not throw, fail the test @@ -3018,8 +3045,7 @@ public function updateSchemaBundleTest() $operationsTransport->addResponse($completeOperation); // Mock request $schemaBundle = new SchemaBundle(); - $request = (new UpdateSchemaBundleRequest()) - ->setSchemaBundle($schemaBundle); + $request = (new UpdateSchemaBundleRequest())->setSchemaBundle($schemaBundle); $response = $gapicClient->updateSchemaBundle($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -3075,17 +3101,19 @@ public function updateSchemaBundleExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $schemaBundle = new SchemaBundle(); - $request = (new UpdateSchemaBundleRequest()) - ->setSchemaBundle($schemaBundle); + $request = (new UpdateSchemaBundleRequest())->setSchemaBundle($schemaBundle); $response = $gapicClient->updateSchemaBundle($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -3144,9 +3172,7 @@ public function updateTableTest() // Mock request $table = new Table(); $updateMask = new FieldMask(); - $request = (new UpdateTableRequest()) - ->setTable($table) - ->setUpdateMask($updateMask); + $request = (new UpdateTableRequest())->setTable($table)->setUpdateMask($updateMask); $response = $gapicClient->updateTable($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -3204,19 +3230,20 @@ public function updateTableExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $operationsTransport->addResponse(null, $status); // Mock request $table = new Table(); $updateMask = new FieldMask(); - $request = (new UpdateTableRequest()) - ->setTable($table) - ->setUpdateMask($updateMask); + $request = (new UpdateTableRequest())->setTable($table)->setUpdateMask($updateMask); $response = $gapicClient->updateTable($request); $this->assertFalse($response->isDone()); $this->assertNull($response->getResult()); @@ -3255,9 +3282,7 @@ public function checkConsistencyAsyncTest() // Mock request $formattedName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); $consistencyToken = 'consistencyToken-1090516718'; - $request = (new CheckConsistencyRequest()) - ->setName($formattedName) - ->setConsistencyToken($consistencyToken); + $request = (new CheckConsistencyRequest())->setName($formattedName)->setConsistencyToken($consistencyToken); $response = $gapicClient->checkConsistencyAsync($request)->wait(); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); diff --git a/Bigtable/tests/Unit/V2/Client/BigtableClientTest.php b/Bigtable/tests/Unit/V2/Client/BigtableClientTest.php index ab9a89d987ee..8d120bc5ae21 100644 --- a/Bigtable/tests/Unit/V2/Client/BigtableClientTest.php +++ b/Bigtable/tests/Unit/V2/Client/BigtableClientTest.php @@ -76,7 +76,9 @@ private function createTransport($deserialize = null) /** @return CredentialsWrapper */ private function createCredentials() { - return $this->getMockBuilder(CredentialsWrapper::class)->disableOriginalConstructor()->getMock(); + return $this->getMockBuilder(CredentialsWrapper::class) + ->disableOriginalConstructor() + ->getMock(); } /** @return BigtableClient */ @@ -104,9 +106,7 @@ public function checkAndMutateRowTest() // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); $rowKey = '122'; - $request = (new CheckAndMutateRowRequest()) - ->setTableName($formattedTableName) - ->setRowKey($rowKey); + $request = (new CheckAndMutateRowRequest())->setTableName($formattedTableName)->setRowKey($rowKey); $response = $gapicClient->checkAndMutateRow($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -132,19 +132,20 @@ public function checkAndMutateRowExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); $rowKey = '122'; - $request = (new CheckAndMutateRowRequest()) - ->setTableName($formattedTableName) - ->setRowKey($rowKey); + $request = (new CheckAndMutateRowRequest())->setTableName($formattedTableName)->setRowKey($rowKey); try { $gapicClient->checkAndMutateRow($request); // If the $gapicClient method call did not throw, fail the test @@ -216,12 +217,15 @@ public function executeQueryExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->setStreamingStatus($status); $this->assertTrue($transport->isExhausted()); // Mock request @@ -267,8 +271,7 @@ public function generateInitialChangeStreamPartitionsTest() $transport->addResponse($expectedResponse3); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new GenerateInitialChangeStreamPartitionsRequest()) - ->setTableName($formattedTableName); + $request = (new GenerateInitialChangeStreamPartitionsRequest())->setTableName($formattedTableName); $serverStream = $gapicClient->generateInitialChangeStreamPartitions($request); $this->assertInstanceOf(ServerStream::class, $serverStream); $responses = iterator_to_array($serverStream->readAll()); @@ -297,18 +300,20 @@ public function generateInitialChangeStreamPartitionsExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->setStreamingStatus($status); $this->assertTrue($transport->isExhausted()); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new GenerateInitialChangeStreamPartitionsRequest()) - ->setTableName($formattedTableName); + $request = (new GenerateInitialChangeStreamPartitionsRequest())->setTableName($formattedTableName); $serverStream = $gapicClient->generateInitialChangeStreamPartitions($request); $results = $serverStream->readAll(); try { @@ -339,8 +344,7 @@ public function getClientConfigurationTest() $transport->addResponse($expectedResponse); // Mock request $formattedInstanceName = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new GetClientConfigurationRequest()) - ->setInstanceName($formattedInstanceName); + $request = (new GetClientConfigurationRequest())->setInstanceName($formattedInstanceName); $response = $gapicClient->getClientConfiguration($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -364,17 +368,19 @@ public function getClientConfigurationExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedInstanceName = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new GetClientConfigurationRequest()) - ->setInstanceName($formattedInstanceName); + $request = (new GetClientConfigurationRequest())->setInstanceName($formattedInstanceName); try { $gapicClient->getClientConfiguration($request); // If the $gapicClient method call did not throw, fail the test @@ -434,12 +440,15 @@ public function mutateRowExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); @@ -480,9 +489,7 @@ public function mutateRowsTest() // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); $entries = []; - $request = (new MutateRowsRequest()) - ->setTableName($formattedTableName) - ->setEntries($entries); + $request = (new MutateRowsRequest())->setTableName($formattedTableName)->setEntries($entries); $serverStream = $gapicClient->mutateRows($request); $this->assertInstanceOf(ServerStream::class, $serverStream); $responses = iterator_to_array($serverStream->readAll()); @@ -513,20 +520,21 @@ public function mutateRowsExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->setStreamingStatus($status); $this->assertTrue($transport->isExhausted()); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); $entries = []; - $request = (new MutateRowsRequest()) - ->setTableName($formattedTableName) - ->setEntries($entries); + $request = (new MutateRowsRequest())->setTableName($formattedTableName)->setEntries($entries); $serverStream = $gapicClient->mutateRows($request); $results = $serverStream->readAll(); try { @@ -566,10 +574,7 @@ public function openAuthorizedViewTest() $bidi->write($request); $responses = []; $responses[] = $bidi->read(); - $bidi->writeAll([ - $request2, - $request3, - ]); + $bidi->writeAll([$request2, $request3]); foreach ($bidi->closeWriteAndReadAll() as $response) { $responses[] = $response; } @@ -607,12 +612,15 @@ public function openAuthorizedViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->setStreamingStatus($status); $this->assertTrue($transport->isExhausted()); $bidi = $gapicClient->openAuthorizedView(); @@ -654,10 +662,7 @@ public function openMaterializedViewTest() $bidi->write($request); $responses = []; $responses[] = $bidi->read(); - $bidi->writeAll([ - $request2, - $request3, - ]); + $bidi->writeAll([$request2, $request3]); foreach ($bidi->closeWriteAndReadAll() as $response) { $responses[] = $response; } @@ -695,12 +700,15 @@ public function openMaterializedViewExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->setStreamingStatus($status); $this->assertTrue($transport->isExhausted()); $bidi = $gapicClient->openMaterializedView(); @@ -742,10 +750,7 @@ public function openTableTest() $bidi->write($request); $responses = []; $responses[] = $bidi->read(); - $bidi->writeAll([ - $request2, - $request3, - ]); + $bidi->writeAll([$request2, $request3]); foreach ($bidi->closeWriteAndReadAll() as $response) { $responses[] = $response; } @@ -783,12 +788,15 @@ public function openTableExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->setStreamingStatus($status); $this->assertTrue($transport->isExhausted()); $bidi = $gapicClient->openTable(); @@ -819,8 +827,7 @@ public function pingAndWarmTest() $transport->addResponse($expectedResponse); // Mock request $formattedName = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new PingAndWarmRequest()) - ->setName($formattedName); + $request = (new PingAndWarmRequest())->setName($formattedName); $response = $gapicClient->pingAndWarm($request); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls(); @@ -844,17 +851,19 @@ public function pingAndWarmExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedName = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); - $request = (new PingAndWarmRequest()) - ->setName($formattedName); + $request = (new PingAndWarmRequest())->setName($formattedName); try { $gapicClient->pingAndWarm($request); // If the $gapicClient method call did not throw, fail the test @@ -919,12 +928,15 @@ public function prepareQueryExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedInstanceName = $gapicClient->instanceName('[PROJECT]', '[INSTANCE]'); @@ -967,8 +979,7 @@ public function readChangeStreamTest() $transport->addResponse($expectedResponse3); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new ReadChangeStreamRequest()) - ->setTableName($formattedTableName); + $request = (new ReadChangeStreamRequest())->setTableName($formattedTableName); $serverStream = $gapicClient->readChangeStream($request); $this->assertInstanceOf(ServerStream::class, $serverStream); $responses = iterator_to_array($serverStream->readAll()); @@ -997,18 +1008,20 @@ public function readChangeStreamExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->setStreamingStatus($status); $this->assertTrue($transport->isExhausted()); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new ReadChangeStreamRequest()) - ->setTableName($formattedTableName); + $request = (new ReadChangeStreamRequest())->setTableName($formattedTableName); $serverStream = $gapicClient->readChangeStream($request); $results = $serverStream->readAll(); try { @@ -1070,12 +1083,15 @@ public function readModifyWriteRowExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->addResponse(null, $status); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); @@ -1121,8 +1137,7 @@ public function readRowsTest() $transport->addResponse($expectedResponse3); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new ReadRowsRequest()) - ->setTableName($formattedTableName); + $request = (new ReadRowsRequest())->setTableName($formattedTableName); $serverStream = $gapicClient->readRows($request); $this->assertInstanceOf(ServerStream::class, $serverStream); $responses = iterator_to_array($serverStream->readAll()); @@ -1151,18 +1166,20 @@ public function readRowsExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->setStreamingStatus($status); $this->assertTrue($transport->isExhausted()); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new ReadRowsRequest()) - ->setTableName($formattedTableName); + $request = (new ReadRowsRequest())->setTableName($formattedTableName); $serverStream = $gapicClient->readRows($request); $results = $serverStream->readAll(); try { @@ -1207,8 +1224,7 @@ public function sampleRowKeysTest() $transport->addResponse($expectedResponse3); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new SampleRowKeysRequest()) - ->setTableName($formattedTableName); + $request = (new SampleRowKeysRequest())->setTableName($formattedTableName); $serverStream = $gapicClient->sampleRowKeys($request); $this->assertInstanceOf(ServerStream::class, $serverStream); $responses = iterator_to_array($serverStream->readAll()); @@ -1237,18 +1253,20 @@ public function sampleRowKeysExceptionTest() $status = new stdClass(); $status->code = Code::DATA_LOSS; $status->details = 'internal error'; - $expectedExceptionMessage = json_encode([ - 'message' => 'internal error', - 'code' => Code::DATA_LOSS, - 'status' => 'DATA_LOSS', - 'details' => [], - ], JSON_PRETTY_PRINT); + $expectedExceptionMessage = json_encode( + [ + 'message' => 'internal error', + 'code' => Code::DATA_LOSS, + 'status' => 'DATA_LOSS', + 'details' => [], + ], + JSON_PRETTY_PRINT + ); $transport->setStreamingStatus($status); $this->assertTrue($transport->isExhausted()); // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); - $request = (new SampleRowKeysRequest()) - ->setTableName($formattedTableName); + $request = (new SampleRowKeysRequest())->setTableName($formattedTableName); $serverStream = $gapicClient->sampleRowKeys($request); $results = $serverStream->readAll(); try { @@ -1280,9 +1298,7 @@ public function checkAndMutateRowAsyncTest() // Mock request $formattedTableName = $gapicClient->tableName('[PROJECT]', '[INSTANCE]', '[TABLE]'); $rowKey = '122'; - $request = (new CheckAndMutateRowRequest()) - ->setTableName($formattedTableName) - ->setRowKey($rowKey); + $request = (new CheckAndMutateRowRequest())->setTableName($formattedTableName)->setRowKey($rowKey); $response = $gapicClient->checkAndMutateRowAsync($request)->wait(); $this->assertEquals($expectedResponse, $response); $actualRequests = $transport->popReceivedCalls();