feat: support updatePolicies method

Author: basakest

src/Adapter.php

@@ -274,18 +274,18 @@ public function removeFilteredPolicy(string $sec, string $ptype, int $fieldIndex
      */
     public function updatePolicy(string $sec, string $ptype, array $oldRule, array $newPolicy): void
     {
-        $where = ['ptype' => $ptype,];
+        $where = ['ptype' => $ptype];
 
         foreach ($oldRule as $k => $v) {
             $where['v' . strval($k)] = $v;
         }
 
         $columns = [];
         foreach ($newPolicy as $k => $v) {
-            $columns['v' . strval($k)][$where['v' . strval($k)]] = $v;
+            $columns['v' . strval($k)] = $v;
         }
 
-        $this->database->replace($this->casbinRuleTableName, $columns, $where);
+        $this->database->update($this->casbinRuleTableName, $columns, $where);
     }
 
     /**
@@ -299,7 +299,11 @@ public function updatePolicy(string $sec, string $ptype, array $oldRule, array $
      */
     public function updatePolicies(string $sec, string $ptype, array $oldRules, array $newRules): void
     {
-        throw new CasbinException('not implemented');
+        $this->database->action(function () use ($sec, $ptype, $oldRules, $newRules) {
+            foreach ($oldRules as $i => $oldRule) {
+                $this->updatePolicy($sec, $ptype, $oldRule, $newRules[$i]);
+            }
+        });
     }
 
     /**

tests/AdapterTest.php

@@ -200,6 +200,34 @@ public function testUpdatePolicy()
         ], $e->getPolicy());
     }
 
+    public function testUpdatePolicies()
+    {
+        $e = $this->getEnforcer();
+        $this->assertEquals([
+            ['alice', 'data1', 'read'],
+            ['bob', 'data2', 'write'],
+            ['data2_admin', 'data2', 'read'],
+            ['data2_admin', 'data2', 'write'],
+        ], $e->getPolicy());
+
+        $oldRules = [
+            ['alice', 'data1', 'read'],
+            ['bob', 'data2', 'write']
+        ];
+        $newRules = [
+            ['alice', 'data1', 'write'],
+            ['bob', 'data2', 'read']
+        ];
+        $e->updatePolicies($oldRules, $newRules);
+
+        $this->assertEquals([
+            ['alice', 'data1', 'write'],
+            ['bob', 'data2', 'read'],
+            ['data2_admin', 'data2', 'read'],
+            ['data2_admin', 'data2', 'write'],
+        ], $e->getPolicy());
+    }
+
     public function testLoadFilteredPolicy()
     {
         $e = $this->getEnforcer();