save

Author: wedreamer

.gitignore

@@ -4,5 +4,5 @@ vendor
 .phpunit.result.cache
 # test.php
 # test*.php
-tests/config/test.yaml
+# tests/config/test.yaml
 # tmp

composer.lock

@@ -16,8 +16,7 @@ abstract class BaseClient
     protected $userPoolId;
     protected $appId;
 
-    // private $host = 'https://core.authing.cn';
-    private $host = 'http://authing-server.natapp1.cc';
+    private $host = 'https://core.authing.cn';
 
 
     private $_type = "SDK";

src/BaseClient.php

@@ -1,29 +1,27 @@
 <?php
 
-
 namespace Authing\Mgmt;
 
 use Authing\Types\AllowParam;
+use Authing\Types\AuthorizedResourcesParam;
 use Authing\Types\CommonMessage;
 use Authing\Types\IsActionAllowedParam;
-use Authing\Types\PolicyAssignmentTargetType;
-use Authing\Types\AuthorizedResourcesParam;
-
 use Exception;
 use stdClass;
 
-function formatAuthorizedResources($obj) {
+function formatAuthorizedResources($obj)
+{
     // $authorizedResources = $obj->authorizedResources;
     $list = $obj->list;
     $total = $obj->totalCount;
-    array_map(function($_){
-        foreach($_ as $key => $value) {
-            if(!$_->$key) {
+    array_map(function ($_) {
+        foreach ($_ as $key => $value) {
+            if (!$_->$key) {
                 unset($_->$key);
             }
         }
         return $_;
-    }, (array)$list);
+    }, (array) $list);
     $res = new stdClass;
     $res->list = $list;
     $res->totalCount = $total;
@@ -56,7 +54,8 @@ public function __construct($client)
      * @return CommonMessage
      * @throws Exception
      */
-    public function allow($resource, $action, $userId=null, $role=null) {
+    public function allow($resource, $action, $userId = null, $role = null)
+    {
         $param = (new AllowParam($resource, $action))->withUserId($userId)->withRoleCode($role);
         return $this->client->request($param->createRequest());
     }
@@ -70,22 +69,64 @@ public function allow($resource, $action, $userId=null, $role=null) {
      * @return bool
      * @throws Exception
      */
-    public function isAllowed($userId, $action, $resource) {
+    public function isAllowed($userId, $action, $resource)
+    {
         $param = new IsActionAllowedParam($resource, $action, $userId);
         return $this->client->request($param->createRequest());
     }
 
     // targetType: PolicyAssignmentTargetType,
     // targetIdentifier: string,
     // namespace: string,
-    function listAuthorizedResources($targetType, string $targetIdentifier, string $namespace, $ops = []) {
+    public function listAuthorizedResources($targetType, string $targetIdentifier, string $namespace, $ops = [])
+    {
         $resourceType = null;
-        if(count($ops) > 0) {
+        if (count($ops) > 0) {
             $resourceType = $ops['resourceType'];
         }
         $param = (new AuthorizedResourcesParam())->withTargetType($targetType)->withTargetIdentifier($targetIdentifier)->withNamespace($namespace)->withResourceType($resourceType);
         $data = formatAuthorizedResources($this->client->request($param->createRequest()));
         return $data;
     }
 
+    public function getResources(array $options)
+    {
+        extract($options, EXTR_OVERWRITE);
+        $array = [
+            'namespaceCode' => $namespaceCode,
+            'type' => $type,
+            'limit' => $limit ?? 10,
+            'page' => $page ?? 1,
+        ];
+        $params = http_build_query($array);
+        $data = $this->client->httpGet("/api/v2/resources?$params");
+    }
+
+    public function createResource(array $options)
+    {
+        if (!isset($options['code'])) {
+            throw new Error('请为资源设定一个资源标识符');
+        }
+        if (!isset($options['actions']) || count($options['actions']) === 0) {
+            throw new Error('请至少定义一个资源操作');
+        }
+        if (!isset($options['namespace'])) {
+            throw new Error('请传入权限分组标识符');
+        }
+        $data = $this->client->httpPost('/api/v2/resources', $options);
+
+        return $data;
+    }
+
+    public function updateResource(string $code, array $options)
+    {
+        $data = $this->client->httpPost("/api/v2/resources/$code", $options);
+        return $data;
+    }
+
+    public function deleteResource(string $code, string $namespaceCode)
+    {
+        $data = $this->client->httpDelete("/api/v2/resources/$code?namespace=$namespaceCode");
+        return true;
+    }
 }

src/Mgmt/AclManagementClient.php

@@ -1,6 +1,5 @@
 <?php
 
-
 namespace Authing\Mgmt;
 
 use Authing\Types\ChildrenNodesParam;
@@ -9,15 +8,21 @@
 use Authing\Types\DeleteNodeParam;
 use Authing\Types\DeleteOrgParam;
 use Authing\Types\IsRootNodeParam;
+use Authing\Types\ListNodeByIdAuthorizedResourcesParam;
 use Authing\Types\MoveNodeParam;
 use Authing\Types\Node;
+use Authing\Types\NodeByIdParam;
 use Authing\Types\NodeByIdWithMembersParam;
 use Authing\Types\Org;
 use Authing\Types\OrgParam;
 use Authing\Types\OrgsParam;
 use Authing\Types\PaginatedOrgs;
 use Authing\Types\PaginatedUsers;
 use Authing\Types\RootNodeParam;
+use Authing\Types\SetMainDepartmentParam;
+use Authing\Types\ListNodeByCodeAuthorizedResourcesParam;
+
+
 use Exception;
 use stdClass;
 
@@ -46,7 +51,8 @@ public function __construct($client)
      * @return Org
      * @throws Exception
      */
-    public function create($name, $description = null, $code = null) {
+    public function create($name, $description = null, $code = null)
+    {
         $param = (new CreateOrgParam($name))->withCode($code)->withDescription($description);
         return $this->client->request($param->createRequest());
     }
@@ -58,7 +64,8 @@ public function create($name, $description = null, $code = null) {
      * @return CommonMessage
      * @throws Exception
      */
-    public function deleteById($id) {
+    public function deleteById($id)
+    {
         $param = new DeleteOrgParam($id);
         return $this->client->request($param->createRequest());
     }
@@ -77,13 +84,14 @@ private function buildTree($org)
      * @return PaginatedOrgs
      * @throws Exception
      */
-    public function paginate($page = 1, $limit = 10) {
+    public function paginate($page = 1, $limit = 10)
+    {
         $param = (new OrgsParam())->withPage($page)->withLimit($limit);
         // TODO: buildTree
         $data = $this->client->request($param->createRequest());
         $orgs = $data->orgs;
         $list = $orgs->list;
-        array_map(function($org) {
+        array_map(function ($org) {
             $this->buildTree($org);
         }, $list);
         $totalCount = $orgs->totalCount;
@@ -93,11 +101,13 @@ public function paginate($page = 1, $limit = 10) {
         return $_;
     }
 
-    public function addNode($orgId, $parentNodeId, $data) {
+    public function addNode($orgId, $parentNodeId, $data)
+    {
 
     }
 
-    public function updateNode($id, $updates) {
+    public function updateNode($id, $updates)
+    {
 
     }
 
@@ -108,7 +118,8 @@ public function updateNode($id, $updates) {
      * @return Org
      * @throws Exception
      */
-    public function findById($id) {
+    public function findById($id)
+    {
         $param = new OrgParam($id);
         // TODO: buildTree
         return $this->client->request($param->createRequest());
@@ -122,7 +133,8 @@ public function findById($id) {
      * @return CommonMessage
      * @throws Exception
      */
-    public function deleteNode($orgId, $nodeId) {
+    public function deleteNode($orgId, $nodeId)
+    {
         $param = new DeleteNodeParam($orgId, $nodeId);
         return $this->client->request($param->createRequest());
     }
@@ -136,7 +148,8 @@ public function deleteNode($orgId, $nodeId) {
      * @return Org
      * @throws Exception
      */
-    public function moveNode($orgId, $nodeId, $targetParentId) {
+    public function moveNode($orgId, $nodeId, $targetParentId)
+    {
         $param = new MoveNodeParam($orgId, $nodeId, $targetParentId);
         // TODO: buildTree
         return $this->client->request($param->createRequest());
@@ -150,7 +163,8 @@ public function moveNode($orgId, $nodeId, $targetParentId) {
      * @return boolean
      * @throws Exception
      */
-    public function isRootNode($orgId, $nodeId) {
+    public function isRootNode($orgId, $nodeId)
+    {
         $param = new IsRootNodeParam($orgId, $nodeId);
         return $this->client->request($param->createRequest());
     }
@@ -163,7 +177,8 @@ public function isRootNode($orgId, $nodeId) {
      * @return Node[]
      * @throws Exception
      */
-    public function listChildren($orgId, $nodeId) {
+    public function listChildren($orgId, $nodeId)
+    {
         $param = new ChildrenNodesParam($orgId, $nodeId);
         return $this->client->request($param->createRequest());
     }
@@ -175,16 +190,19 @@ public function listChildren($orgId, $nodeId) {
      * @return Node[]
      * @throws Exception
      */
-    public function rootNode($orgId) {
+    public function rootNode($orgId)
+    {
         $param = new RootNodeParam($orgId);
         return $this->client->request($param->createRequest());
     }
 
-    public function importByJson($json) {
+    public function importByJson($json)
+    {
 
     }
 
-    public function addMembers($nodeId, $userIds) {
+    public function addMembers($nodeId, $userIds)
+    {
 
     }
 
@@ -195,11 +213,75 @@ public function addMembers($nodeId, $userIds) {
      * @return PaginatedUsers
      * @throws Exception
      */
-    public function listMembers($param) {
+    public function listMembers($param)
+    {
         return $this->client->request($param->createRequest())->users;
     }
 
-    public function removeMembers($nodeId, $userIds) {
+    public function removeMembers($nodeId, $userIds)
+    {
+
+    }
+
+    public function getNodeById(string $nodeId)
+    {
+        $param = new NodeByIdParam($nodeId);
+        $node = $this->client->request($param->createRequest())->nodeById;
+        return $node;
+    }
+
+    public function exportAll()
+    {
+        $data = $this->client->httpGet('/api/v2/orgs/export');
+        return $data;
+    }
+
+    public function setMainDepartment(string $userId, string $departmentId)
+    {
+        $param = (new SetMainDepartmentParam($userId))->withDepartmentId($departmentId);
+        $data = $this->client->request($param->createRequest())->setMainDepartment;
+        return $data;
+    }
+
+    public function exportByOrgId(string $orgId)
+    {
+        $data = $this->client->httpGet("/api/v2/orgs/export?org_id=$orgId");
+        return $data;
+    }
+
+    public function listAuthorizedResourcesByNodeId(string $nodeId, string $namespace, array $options = [])
+    {
+        $resourceType = $options['resourceType'] ?? new stdClass;
+        $param = (new ListNodeByIdAuthorizedResourcesParam($nodeId))->withNamespace($namespace)->withResourceType($resourceType);
+        $node = $this->client->request($param->createRequest())->nodeById;
+        if (!$node) {
+            throw new Error('组织机构节点不存在');
+        }
+        $list = $node->authorizedResources->list;
+        $totalCount = $node->authorizedResources->totalCount;
 
+        $list = formatAuthorizedResources($list);
+        $_ = new stdClass;
+        $_->list = $list;
+        $_->totalCount = $totalCount;
+        return $_;
+    }
+
+    public function listAuthorizedResourcesByNodeCode(string $orgId, string $code, string $namespace, array $options = [])
+    {
+        $resourceType = $options['resourceType'] ?? new stdClass;
+        $param = (new ListNodeByCodeAuthorizedResourcesParam($orgId, $code))->withNamespace($namespace)->withResourceType($resourceType);
+        $node = $this->client->request($param->createRequest())->nodeById;
+        if (!$node) {
+            throw new Error('组织机构节点不存在');
+        }
+        $list = $node->authorizedResources->list;
+        $totalCount = $node->authorizedResources->totalCount;
+
+        $list = formatAuthorizedResources($list);
+        $_ = new stdClass;
+        $_->list = $list;
+        $_->totalCount = $totalCount;
+        return $_;
     }
-}
+}