-
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Using custom database adapter for casbin
- Loading branch information
Showing
8 changed files
with
405 additions
and
70 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,178 @@ | ||
| <?php declare(strict_types = 1); | ||
|
|
||
| /** | ||
| * Adapter.php | ||
| * | ||
| * @license More in LICENSE.md | ||
| * @copyright https://www.fastybird.com | ||
| * @author Adam Kadlec <[email protected]> | ||
| * @package FastyBird:SimpleAuth! | ||
| * @subpackage Models | ||
| * @since 0.1.0 | ||
| * | ||
| * @date 09.07.20 | ||
| */ | ||
|
|
||
| namespace FastyBird\SimpleAuth\Models\Casbin; | ||
|
|
||
| use Casbin\Model as CasbinModel; | ||
| use Casbin\Persist as CasbinPersist; | ||
| use FastyBird\SimpleAuth\Exceptions; | ||
| use FastyBird\SimpleAuth\Models; | ||
| use FastyBird\SimpleAuth\Queries; | ||
| use FastyBird\SimpleAuth\Types\PolicyType; | ||
| use IPub\DoctrineCrud\Exceptions as DoctrineCrudExceptions; | ||
| use Nette\Utils\ArrayHash; | ||
| use TypeError; | ||
| use ValueError; | ||
| use function array_filter; | ||
| use function count; | ||
| use function implode; | ||
| use function intval; | ||
| use function range; | ||
| use function strval; | ||
| use function trim; | ||
| use function var_dump; | ||
|
|
||
| /** | ||
| * Casbin database adapter | ||
| * | ||
| * @package FastyBird:SimpleAuth! | ||
| * @subpackage Models | ||
| * @author Adam Kadlec <[email protected]> | ||
| */ | ||
| class Adapter implements CasbinPersist\Adapter | ||
| { | ||
|
|
||
| use CasbinPersist\AdapterHelper; | ||
|
|
||
| public function __construct( | ||
| private readonly Models\Policies\Repository $policiesRepository, | ||
| private readonly Models\Policies\Manager $policiesManager, | ||
| ) | ||
| { | ||
| } | ||
|
|
||
| /** | ||
| * @param array<string, string|null> $rule | ||
| * | ||
| * @throws TypeError | ||
| * @throws ValueError | ||
| */ | ||
| public function savePolicyLine(string $ptype, array $rule): void | ||
| { | ||
| $data = [ | ||
| 'type' => PolicyType::from($ptype), | ||
| ]; | ||
|
|
||
| foreach ($rule as $key => $value) { | ||
| $data['v' . strval($key)] = $value; | ||
| } | ||
|
|
||
| $this->policiesManager->create(ArrayHash::from($data)); | ||
| } | ||
|
|
||
| /** | ||
| * @throws Exceptions\InvalidState | ||
| */ | ||
| public function loadPolicy(CasbinModel\Model $model): void | ||
| { | ||
| $findPoliciesQuery = new Queries\FindPolicies(); | ||
|
|
||
| $policies = $this->policiesRepository->findAllBy($findPoliciesQuery); | ||
|
|
||
| foreach ($policies as $policy) { | ||
| $data = [ | ||
| $policy->getType()->value, | ||
| $policy->getV0(), | ||
| $policy->getV1(), | ||
| $policy->getV2(), | ||
| $policy->getV3(), | ||
| $policy->getV4(), | ||
| $policy->getV5(), | ||
| ]; | ||
|
|
||
| $line = implode(', ', array_filter($data, static fn ($val) => $val != '' && $val !== null)); | ||
|
|
||
| $this->loadPolicyLine(trim($line), $model); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * @throws TypeError | ||
| * @throws ValueError | ||
| */ | ||
| public function savePolicy(CasbinModel\Model $model): void | ||
| { | ||
| foreach ($model['p'] ?? [] as $type => $ast) { | ||
| foreach ($ast->policy as $rule) { | ||
| $this->savePolicyLine($type, $rule); | ||
| } | ||
| } | ||
|
|
||
| foreach ($model['g'] ?? [] as $type => $ast) { | ||
| foreach ($ast->policy as $rule) { | ||
| $this->savePolicyLine($type, $rule); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * @throws TypeError | ||
| * @throws ValueError | ||
| */ | ||
| public function addPolicy(string $sec, string $ptype, array $rule): void | ||
| { | ||
| $this->savePolicyLine($ptype, $rule); | ||
| } | ||
|
|
||
| /** | ||
| * @throws DoctrineCrudExceptions\InvalidArgumentException | ||
| * @throws Exceptions\InvalidState | ||
| * @throws TypeError | ||
| * @throws ValueError | ||
| */ | ||
| public function removePolicy(string $sec, string $ptype, array $rule): void | ||
| { | ||
| $findPoliciesQuery = new Queries\FindPolicies(); | ||
| $findPoliciesQuery->byType(PolicyType::from($ptype)); | ||
|
|
||
| foreach ($rule as $key => $value) { | ||
| $findPoliciesQuery->byValue(intval($key), $value); | ||
| } | ||
|
|
||
| $policies = $this->policiesRepository->findAllBy($findPoliciesQuery); | ||
|
|
||
| foreach ($policies as $policy) { | ||
| $this->policiesManager->delete($policy); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * @throws DoctrineCrudExceptions\InvalidArgumentException | ||
| * @throws Exceptions\InvalidState | ||
| * @throws TypeError | ||
| * @throws ValueError | ||
| */ | ||
| public function removeFilteredPolicy(string $sec, string $ptype, int $fieldIndex, string ...$fieldValues): void | ||
| { | ||
| var_dump('REMOVE 2'); | ||
| $findPoliciesQuery = new Queries\FindPolicies(); | ||
| $findPoliciesQuery->byType(PolicyType::from($ptype)); | ||
|
|
||
| foreach (range(0, 5) as $value) { | ||
| if ($fieldIndex <= $value && $value < $fieldIndex + count($fieldValues)) { | ||
| if ($fieldValues[$value - $fieldIndex] != '') { | ||
| $findPoliciesQuery->byValue(intval($value), $fieldValues[$value - $fieldIndex]); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| $policies = $this->policiesRepository->findAllBy($findPoliciesQuery); | ||
|
|
||
| foreach ($policies as $policy) { | ||
| $this->policiesManager->delete($policy); | ||
| } | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.