feat(iam): support iam conditions

Core/src/Iam/Iam.php

@@ -106,6 +106,10 @@ public function __construct(IamConnectionInterface $connection, $resource, array
      * ```
      *
      * @param  array $options Configuration Options
+     * @param  int   $options['requestedPolicyVersion'] Specify the policy version to
+     *     request from the server. Please see
+     *     [policy versioning](https://cloud.google.com/iam/docs/policies#versions)
+     *     for more information.
      * @return array An array of policy data
      */
     public function policy(array $options = [])

Core/src/Iam/PolicyBuilder.php

@@ -18,6 +18,7 @@
 namespace Google\Cloud\Core\Iam;
 
 use InvalidArgumentException;
+use BadMethodCallException;
 
 /**
  * Helper class for creating valid IAM policies
@@ -51,6 +52,38 @@ class PolicyBuilder
     /**
      * Create a PolicyBuilder.
      *
+     * To use conditions in the bindings, the version of the policy must be set
+     * to 3.
+     *
+     * @see https://cloud.google.com/iam/docs/policies#versions Policy versioning
+     * @see https://cloud-dot-devsite.googleplex.com/storage/docs/access-control/using-iam-permissions#conditions-iam
+     *   Using Cloud IAM Conditions on buckets
+     *
+     * Example:
+     * ```
+     * $policy = [
+     *     'etag' => 'AgIc==',
+     *     'version' => 3,
+     *     'bindings' => [
+     *         [
+     *             'role' => 'roles/admin',
+     *             'members' => [
+     *                 'user:[email protected]',
+     *                 'user2:[email protected]'
+     *             ],
+     *             'condition' => [
+     *                 'title' => 'match-prefix',
+     *                 'description' => 'Applies to objects matching a prefix',
+     *                 'expression' =>
+     *                     'resource.name.startsWith("projects/_/buckets/bucket-name/objects/prefix-a-")'
+     *             ]
+     *         ]
+     *     ],
+     * ];
+     *
+     * $builder = new PolicyBuilder($policy);
+     * ```
+     *
      * @param  array $policy A policy array
      * @throws InvalidArgumentException
      */
@@ -81,6 +114,10 @@ public function __construct(array $policy = [])
      *         'role' => 'roles/admin',
      *         'members' => [
      *             'user:[email protected]'
+     *         ],
+     *         'condition' => [
+     *             'expression' =>
+     *                 'request.time < timestamp("2020-07-01T00:00:00.000Z")'
      *         ]
      *     ]
      * ]);
@@ -92,17 +129,20 @@ public function __construct(array $policy = [])
      */
     public function setBindings(array $bindings = [])
     {
-        $this->bindings = [];
-        foreach ($bindings as $binding) {
-            $this->addBinding($binding['role'], $binding['members']);
-        }
-
+        $this->bindings = $bindings;
         return $this;
     }
 
     /**
      * Add a new binding to the policy.
      *
+     * This method will fail with an InvalidOpereationException if it is
+     * called on a Policy with a version greater than 1 as that indicates
+     * a more complicated policy than this method is prepared to handle.
+     * Changes to such policies must be made manually by the setBindings()
+     * method.
+     *
+     *
      * Example:
      * ```
      * $builder->addBinding('roles/admin', [ 'user:[email protected]' ]);
@@ -112,9 +152,13 @@ public function setBindings(array $bindings = [])
      * @param  array  $members An array of members to assign to the binding
      * @return PolicyBuilder
      * @throws InvalidArgumentException
+     * @throws BadMethodCallException if the policy's version is greater than 1.
+     * @deprecated
      */
     public function addBinding($role, array $members)
     {
+        $this->validatePolicyVersion();
+
         $this->bindings[] = [
             'role' => $role,
             'members' => $members
@@ -126,6 +170,12 @@ public function addBinding($role, array $members)
     /**
      * Remove a binding from the policy.
      *
+     * This method will fail with an InvalidOpereationException if it is
+     * called on a Policy with a version greater than 1 as that indicates
+     * a more complicated policy than this method is prepared to handle.
+     * Changes to such policies must be made manually by the setBindings()
+     * method.
+     *
      * Example:
      * ```
      * $builder->setBindings([
@@ -144,9 +194,13 @@ public function addBinding($role, array $members)
      * @param  array  $members An array of members to remove from the role
      * @return PolicyBuilder
      * @throws InvalidArgumentException
+     * @throws BadMethodCallException if the policy's version is greater than 1.
+     * @deprecated
      */
     public function removeBinding($role, array $members)
     {
+        $this->validatePolicyVersion();
+
         $bindings = $this->bindings;
         foreach ((array) $bindings as $i => $binding) {
             if ($binding['role'] == $role) {
@@ -226,4 +280,28 @@ public function result()
             'version' => $this->version
         ]);
     }
+
+    private function validatePolicyVersion()
+    {
+        if (isset($this->version) && $this->version > 1) {
+            throw new BadMethodCallException("Helper methods cannot be " .
+                "invoked on policies with version {$this->version}.");
+        }
+
+        $this->validateConditions();
+    }
+
+    private function validateConditions()
+    {
+        if (!$this->bindings) {
+            return;
+        }
+
+        foreach ($this->bindings as $binding) {
+            if (isset($binding['condition'])) {
+                throw new BadMethodCallException("Helper methods cannot " .
+                    "be invoked on policies containing conditions.");
+            }
+        }
+    }
 }

Core/tests/Unit/Iam/PolicyBuilderTest.php

@@ -42,7 +42,7 @@ public function testBuilder()
 
         $builder = new PolicyBuilder;
         $builder->setEtag($etag);
-        $builder->setVersion(2);
+        $builder->setVersion(1);
         $builder->addBinding($role, $members);
 
         $result = $builder->result();
@@ -55,7 +55,7 @@ public function testBuilder()
                 ]
             ],
             'etag' => $etag,
-            'version' => 2
+            'version' => 1
         ];
 
         $this->assertEquals($policy, $result);
@@ -139,6 +139,43 @@ public function testConstructWithExistingPolicy()
         $this->assertEquals($policy, $result);
     }
 
+    /**
+     * @expectedException BadMethodCallException
+     * @expectedExceptionMessage Helper methods cannot be invoked on policies with version 3.
+     */
+    public function testAddBindingVersionThrowsException()
+    {
+        $builder = new PolicyBuilder();
+        $builder->setVersion(3);
+
+        $builder->addBinding('test', ['user:[email protected]']);
+    }
+
+    /**
+     * @expectedException BadMethodCallException
+     * @expectedExceptionMessage Helper methods cannot be invoked on policies containing conditions.
+     */
+    public function testAddBindingWithConditionsThrowsException()
+    {
+        $policy = [
+            'bindings' => [
+                [
+                    'role' => 'test',
+                    'members' => [
+                        'user:[email protected]',
+                    ],
+                    'condition' => [
+                        'expression' => 'true',
+                    ]
+                ],
+            ],
+        ];
+        $builder = new PolicyBuilder($policy);
+        $builder->setVersion(1);
+
+        $builder->addBinding('test2', ['user:[email protected]']);
+    }
+
     public function testRemoveBinding()
     {
         $policy = [
@@ -225,4 +262,51 @@ public function testRemoveBindingInvalidRoleThrowsException()
         $builder = new PolicyBuilder($policy);
         $builder->removeBinding('test2', ['user:[email protected]']);
     }
+
+    /**
+     * @expectedException BadMethodCallException
+     * @expectedExceptionMessage Helper methods cannot be invoked on policies with version 3.
+     */
+    public function testRemoveBindingVersionThrowsException()
+    {
+        $policy = [
+            'version' => 3,
+            'bindings' => [
+                [
+                    'role' => 'test',
+                    'members' => [
+                        'user:[email protected]',
+                    ]
+                ],
+            ]
+        ];
+
+        $builder = new PolicyBuilder($policy);
+        $builder->removeBinding('test', ['user:[email protected]']);
+    }
+
+    /**
+     * @expectedException BadMethodCallException
+     * @expectedExceptionMessage Helper methods cannot be invoked on policies containing conditions.
+     */
+    public function testRemoveBindingWithConditionsThrowsException()
+    {
+        $policy = [
+            'bindings' => [
+                [
+                    'role' => 'test',
+                    'members' => [
+                        'user:[email protected]',
+                    ],
+                    'condition' => [
+                        'expression' => 'true',
+                    ]
+                ],
+            ],
+        ];
+
+        $builder = new PolicyBuilder($policy);
+        $builder->setVersion(1);
+        $builder->removeBinding('test', ['user:[email protected]']);
+    }
 }

Storage/src/Bucket.php

@@ -1165,18 +1165,27 @@ public function isWritable($file = null)
     /**
      * Manage the IAM policy for the current Bucket.
      *
-     * Please note that this method may not yet be available in your project.
+     * To request a policy with conditions, pass an array with
+     * '[requestedPolicyVersion => 3]' as argument to the policy() and
+     * reload() methods.
      *
      * Example:
      * ```
      * $iam = $bucket->iam();
+     *
+     * // Returns the stored policy, or fetches the policy if none exists.
+     * $policy = $iam->policy(['requestedPolicyVersion' => 3]);
+     *
+     * // Fetches a policy from the server.
+     * $policy = $iam->reload(['requestedPolicyVersion' => 3]);
      * ```
      *
      * @codingStandardsIgnoreStart
      * @see https://cloud.google.com/storage/docs/access-control/iam-with-json-and-xml Storage Access Control Documentation
      * @see https://cloud.google.com/storage/docs/json_api/v1/buckets/getIamPolicy Get Bucket IAM Policy
      * @see https://cloud.google.com/storage/docs/json_api/v1/buckets/setIamPolicy Set Bucket IAM Policy
      * @see https://cloud.google.com/storage/docs/json_api/v1/buckets/testIamPermissions Test Bucket Permissions
+     * @see https://cloud.google.com/iam/docs/policies#versions policy versioning.
      * @codingStandardsIgnoreEnd
      *
      * @return Iam

Storage/src/Connection/IamBucket.php

@@ -42,6 +42,11 @@ public function __construct(ConnectionInterface $connection)
      */
     public function getPolicy(array $args)
     {
+        if (isset($args['requestedPolicyVersion'])) {
+            $args['optionsRequestedPolicyVersion'] = $args['requestedPolicyVersion'];
+            unset($args['requestedPolicyVersion']);
+        }
+
         return $this->connection->getBucketIamPolicy($args);
     }
 

Storage/tests/Snippet/BucketTest.php

@@ -592,7 +592,10 @@ public function testIam()
     {
         $snippet = $this->snippetFromMethod(Bucket::class, 'iam');
         $snippet->addLocal('bucket', $this->bucket);
+        $this->connection->getBucketIamPolicy(Argument::withEntry('optionsRequestedPolicyVersion', 3))
+            ->shouldBeCalled();
 
+        $this->bucket->___setProperty('connection', $this->connection->reveal());
         $res = $snippet->invoke('iam');
         $this->assertInstanceOf(Iam::class, $res->returnVal());
     }