feat(Bigtable): add bigtable-attempt header

Bigtable/src/Exception/BigtableDataOperationException.php

@@ -41,7 +41,7 @@ public function __construct(
     ) {
         $this->metadata = $metadata;
 
-        parent::__construct($message, $code);
+        parent::__construct($message, $code ?? 0);
     }
 
     /**

Bigtable/src/ResumableStream.php

@@ -126,19 +126,22 @@ public function __construct(
      */
     public function readAll()
     {
-        $tries = 0;
-        $argumentFunction = $this->argumentFunction;
-        $retryFunction = $this->retryFunction;
+        $attempt = 0;
         do {
             $ex = null;
-            list($this->request, $this->callOptions) = $argumentFunction($this->request, $this->callOptions);
+            list($this->request, $this->callOptions) =
+                ($this->argumentFunction)($this->request, $this->callOptions);
 
             $completed = $this->pluck('requestCompleted', $this->callOptions, false);
 
             if ($completed !== true) {
+                // Send in "bigtable-attempt" header on each request
+                $headers = $this->callOptions['headers'] ?? [];
+                $headers['bigtable-attempt'] = [(string) ++$attempt];
+
                 $stream = call_user_func_array(
                     [$this->gapicClient, $this->method],
-                    [$this->request, $this->callOptions]
+                    [$this->request, ['headers' => $headers] + $this->callOptions]
                 );
 
                 try {
@@ -148,8 +151,7 @@ public function readAll()
                 } catch (\Exception $ex) {
                 }
             }
-            $tries++;
-        } while ((!$this->retryFunction || $retryFunction($ex)) && $tries <= $this->retries);
+        } while ((!$this->retryFunction || ($this->retryFunction)($ex)) && $attempt <= $this->retries);
         if ($ex !== null) {
             throw $ex;
         }

Bigtable/tests/Unit/SmartRetriesTest.php

@@ -136,6 +136,33 @@ public function testReadRowsShouldRetryForProvidedAttempts()
         $iterator->getIterator()->current();
     }
 
+    public function testReadRowsContainsAttemptHeader()
+    {
+        $attempt = 1;
+        $expectedArgs = $this->options;
+        $retryingApiException = $this->retryingApiException;
+        $phpunit = $this;
+        $this->serverStream->readAll()
+            ->shouldBeCalledTimes(2)
+            ->will(function () use (&$attempt, $retryingApiException) {
+                // throw a retriable exception on the first call
+                return 1 === $attempt++ ? throw $retryingApiException : [];
+            });
+        $this->bigtableClient->readRows(
+            Argument::type(ReadRowsRequest::class),
+            Argument::that(function ($callOptions) use (&$attempt) {
+                $this->assertSame((string) $attempt, $callOptions['headers']['bigtable-attempt'][0] ?? null);
+                return true;
+            })
+        )->shouldBeCalledTimes(2)
+            ->willReturn(
+                $this->serverStream->reveal()
+            );
+
+        $iterator = $this->table->readRows();
+        $iterator->getIterator()->current();
+    }
+
     public function testReadRowsPartialSuccess()
     {
         $expectedArgs = $this->options;
@@ -186,7 +213,7 @@ public function testReadRowsWithRowsLimit()
                     $this->generateRowsResponse(3, 4)
                 )
             );
-        
+
         $allowedRowsLimit = ['5' => 1, '3' => 1];
         $this->bigtableClient->readRows(
             Argument::that(function ($request) use (&$allowedRowsLimit) {