feat: Adapter - getUsersGroupsOnSp, getGroupsWhereMemberIsActive

Author: BaranekD

lib/Adapter.php

@@ -84,6 +84,14 @@ abstract public function getVoById($id);
      */
     abstract public function getMemberGroups($user, $vo);
 
+    /**
+     * @param User $user perun user
+     * @param Vo   $vo   vo we are working with
+     *
+     * @return Group[] groups from vo where user is valid.
+     */
+    abstract public function getGroupsWhereMemberIsActive($user, $vo);
+
     /**
      * @param string $spEntityId entity id of the sp
      *
@@ -170,7 +178,15 @@ abstract public function getFacilityByClientId($clientId, $clientIdAttr);
      *
      * @return Group[] from vo which are assigned to all facilities with spEntityId for this userId
      */
-    abstract public function getUsersGroupsOnFacility($spEntityId, $userId);
+    abstract public function getUsersGroupsOnSp($spEntityId, $userId);
+
+    /**
+     * @param Facility $facility entity id of the sp
+     * @param int    $userId
+     *
+     * @return Group[] from vo which are assigned to all facilities with spEntityId for this userId
+     */
+    abstract public function getUsersGroupsOnFacility($facility, $userId);
 
     /**
      * @param <String, String> map $attribute

lib/AdapterLdap.php

@@ -152,6 +152,43 @@ public function getMemberGroups($user, $vo)
         return $groups;
     }
 
+    public function getGroupsWhereMemberIsActive($user, $vo)
+    {
+        $userId = $user->getId();
+        $userWithMembership = $this->connector->searchForEntity(
+            'perunUserId=' . $userId . ',ou=People,' . $this->ldapBase,
+            '(objectClass=perunUser)',
+            ['perunUserId', 'memberOf']
+        );
+
+        $groups = [];
+        foreach ($userWithMembership['memberOf'] as $groupDn) {
+            $voId = explode('=', explode(',', $groupDn)[1], 2)[1];
+            if ($voId !== $vo->getId()) {
+                continue;
+            }
+
+            $group = $this->connector->searchForEntity(
+                $groupDn,
+                '(objectClass=perunGroup)',
+                ['perunGroupId', 'cn', 'perunUniqueGroupName', 'perunVoId', 'uuid', 'description']
+            );
+            array_push(
+                $groups,
+                new Group(
+                    $group['perunGroupId'][0],
+                    $group['perunVoId'][0],
+                    $group['uuid'][0],
+                    $group['cn'][0],
+                    $group['perunUniqueGroupName'][0],
+                    $group['description'][0] ?? ''
+                )
+            );
+        }
+
+        return $groups;
+    }
+
     public function getSpGroups(string $spEntityId): array
     {
         $facility = $this->getFacilityByEntityId($spEntityId);
@@ -424,14 +461,17 @@ public function setUserExtSourceAttributes($userExtSourceId, $attributes)
         $this->fallbackAdapter->setUserExtSourceAttributes($userExtSourceId, $attributes);
     }
 
-    public function getUsersGroupsOnFacility($spEntityId, $userId)
+    public function getUsersGroupsOnSp($spEntityId, $userId)
     {
         $facility = $this->getFacilityByEntityId($spEntityId);
+        return self::getUsersGroupsOnFacility($facility, $userId);
+    }
 
+    public function getUsersGroupsOnFacility($facility, $userId)
+    {
         if (null === $facility) {
             return [];
         }
-
         $id = $facility->getId();
 
         $resources = $this->connector->searchForEntities(
@@ -442,7 +482,7 @@ public function getUsersGroupsOnFacility($spEntityId, $userId)
         Logger::debug('Resources - ' . json_encode($resources));
 
         if (null === $resources) {
-            throw new Exception('Service with spEntityId: ' . $spEntityId . ' hasn\'t assigned any resource.');
+            throw new Exception('Service with ID: ' . $id . ' hasn\'t assigned any resource.');
         }
         $resourcesString = '(|';
         foreach ($resources as $resource) {
@@ -470,10 +510,7 @@ public function getUsersGroupsOnFacility($spEntityId, $userId)
                 )
             );
         }
-        $resultGroups = $this->removeDuplicateEntities($resultGroups);
-        Logger::debug('Groups - ' . json_encode($resultGroups));
-
-        return $resultGroups;
+        return $this->removeDuplicateEntities($resultGroups);
     }
 
     public function getMemberStatusByUserAndVo($user, $vo)

lib/AdapterRpc.php

@@ -154,6 +154,48 @@ public function getMemberGroups($user, $vo)
         return $convertedGroups;
     }
 
+    public function getGroupsWhereMemberIsActive($user, $vo)
+    {
+        try {
+            $member = $this->connector->get('membersManager', 'getMemberByUser', [
+                'vo' => $vo->getId(),
+                'user' => $user->getId(),
+            ]);
+
+            $memberGroups = $this->connector->get('groupsManager', 'getGroupsWhereMemberIsActive', [
+                'member' => $member['id'],
+            ]);
+        } catch (PerunException $e) {
+            return [];
+        }
+
+        $convertedGroups = [];
+        foreach ($memberGroups as $group) {
+            try {
+                $attr = $this->connector->get('attributesManager', 'getAttribute', [
+                    'group' => $group['id'],
+                    'attributeName' => 'urn:perun:group:attribute-def:virt:voShortName',
+                ]);
+                $uniqueName = $attr['value'] . ':' . $group['name'];
+                array_push(
+                    $convertedGroups,
+                    new Group(
+                        $group['id'],
+                        $group['voId'],
+                        $group['uuid'],
+                        $group['name'],
+                        $uniqueName,
+                        $group['description']
+                    )
+                );
+            } catch (PerunException $e) {
+                continue;
+            }
+        }
+
+        return $convertedGroups;
+    }
+
     public function getSpGroups(string $spEntityId): array
     {
         $facility = $this->getFacilityByEntityId($spEntityId);
@@ -338,13 +380,16 @@ public function getFacilityAttribute($facility, $attrName)
         return $perunAttr['value'];
     }
 
-    public function getUsersGroupsOnFacility($spEntityId, $userId)
+    public function getUsersGroupsOnSp($spEntityId, $userId)
     {
         $facility = $this->getFacilityByEntityId($spEntityId);
-        $groups = [];
+        return self::getUsersGroupsOnFacility($facility, $userId);
+    }
 
+    public function getUsersGroupsOnFacility($facility, $userId)
+    {
         if (null === $facility) {
-            return $groups;
+            return [];
         }
 
         $usersGroupsOnFacility = $this->connector->get(
@@ -357,6 +402,8 @@ public function getUsersGroupsOnFacility($spEntityId, $userId)
             ]
         );
 
+        $groups = [];
+
         foreach ($usersGroupsOnFacility as $usersGroupOnFacility) {
             if (isset($usersGroupOnFacility['attributes'][0]['friendlyName']) &&
                 'voShortName' === $usersGroupOnFacility['attributes'][0]['friendlyName']) {