Refresh gapics

src/PubSub/Connection/ConnectionInterface.php

@@ -73,6 +73,11 @@ public function testTopicIamPermissions(array $args);
      */
     public function createSubscription(array $args);
 
+    /**
+     * @param array $args
+     */
+    public function updateSubscription(array $args);
+
     /**
      * @param array $args
      */

src/PubSub/Connection/Grpc.php

@@ -180,6 +180,28 @@ public function createSubscription(array $args)
         ]);
     }
 
+    /**
+     * @param array $args
+     */
+    public function updateSubscription(array $args)
+    {
+        // Get a list of keys used before building subscription, which modifies $args
+        $mask = array_keys($args);
+
+        // Remove immutable properties.
+        $mask = array_values(array_diff($mask, ['name', 'topic']));
+
+        $fieldMask = $this->serializer->decodeMessage(new FieldMask(), ['paths' => $mask]);
+
+        $subscriptionObject = $this->buildSubscription($args);
+
+        return $this->send([$this->subscriberClient, 'updateSubscription'], [
+            $subscriptionObject,
+            $fieldMask,
+            $args
+        ]);
+    }
+
     /**
      * @param array $args
      */

src/PubSub/Connection/Rest.php

@@ -145,6 +145,14 @@ public function createSubscription(array $args)
         return $this->send('subscriptions', 'create', $args);
     }
 
+    /**
+     * @param array $args
+     */
+    public function updateSubscription(array $args)
+    {
+        return $this->send('subscriptions', 'patch', $args);
+    }
+
     /**
      * @param array $args
      */

src/PubSub/Subscription.php

@@ -222,6 +222,52 @@ public function create(array $options = [])
         return $this->info;
     }
 
+    /**
+     * Update the subscription.
+     *
+     * Note that subscription name and topic are immutable properties and may
+     * not be modified.
+     *
+     * Example:
+     * ```
+     * $subscription->update([
+     *     'retainAckedMessages' => true
+     * ]);
+     * ```
+     *
+     * @param array $subscription {
+     *     The Subscription data.
+     *
+     *     For information regarding the push configuration settings, see
+     *     [PushConfig](https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions#PushConfig).
+     *
+     *     @type string $pushConfig.pushEndpoint A URL locating the endpoint to which
+     *           messages should be pushed. For example, a Webhook endpoint
+     *           might use "https://example.com/push".
+     *     @type array $pushConfig.attributes Endpoint configuration attributes.
+     *     @type int $ackDeadlineSeconds The maximum time after a subscriber
+     *           receives a message before the subscriber should acknowledge the
+     *           message.
+     *     @type bool $retainAckedMessages Indicates whether to retain
+     *           acknowledged messages.
+     *     @type Duration $messageRetentionDuration How long to retain
+     *           unacknowledged messages in the subscription's backlog, from the
+     *           moment a message is published. If `$retainAckedMessages` is
+     *           true, then this also configures the retention of acknowledged
+     *           messages, and thus configures how far back in time a `Seek`
+     *           can be done. Cannot be more than 7 days or less than 10 minutes.
+     *           **Defaults to** 7 days.
+     * }
+     * @param array $options [optional] Configuration options.
+     * @return array The subscription info.
+     */
+    public function update(array $subscription, array $options = [])
+    {
+        return $this->info = $this->connection->updateSubscription([
+            'name' => $this->name
+        ] + $options + $subscription);
+    }
+
     /**
      * Delete a subscription
      *

tests/snippets/PubSub/SubscriptionTest.php

@@ -95,6 +95,19 @@ public function testCreate()
         $this->assertEquals($return, $res->returnVal());
     }
 
+    public function testUpdate()
+    {
+        $snippet = $this->snippetFromMethod(Subscription::class, 'update');
+        $snippet->addLocal('subscription', $this->subscription);
+
+        $this->connection->updateSubscription(Argument::any())
+            ->shouldBeCalled();
+
+        $this->subscription->___setProperty('connection', $this->connection->reveal());
+
+        $snippet->invoke();
+    }
+
     public function testDelete()
     {
         $snippet = $this->snippetFromMethod(Subscription::class, 'delete');