Skip to content
GitLab
Verified Commit 5adb0ccd authored by dockx thibault's avatar dockx thibault
Browse files

:art: refactor(archive) - improve method structure and enhance supann status... 

:art: refactor(archive) - improve method structure and enhance supann status handling in archiving process
parent 08af123a
dev revert-55863b23
1 merge request!82Resolve "[Orchestrator] - Automatic Archiving Based on SupAnn Resource States"
Pipeline #32445 failed with stages
in 18 seconds
Hide whitespace changes
Inline Side-by-side
Showing
with 133 additions and 117 deletions
+133 -117
plugins/tasks/Archive.php
+ 133
− 117
View file @ 5adb0ccd
...@@ -4,134 +4,150 @@ use FusionDirectory\Rest\WebServiceCall; ...@@ -4,134 +4,150 @@ use FusionDirectory\Rest\WebServiceCall;
class Archive implements EndpointInterface class Archive implements EndpointInterface
{ {
private TaskGateway $gateway; private TaskGateway $gateway;
public function __construct (TaskGateway $gateway)
{
$this->gateway = $gateway;
}
/**
* @return array
* Part of the interface of orchestrator plugin to treat GET method
*/
public function processEndPointGet (): array
{
// Retrieve tasks of type 'archive'
return $this->gateway->getObjectTypeTask('archive');
}
/**
* @param array|null $data
* @return array
* @throws Exception
* Note: Part of the interface of orchestrator plugin to treat PATCH method
*/
public function processEndPointPatch (array $data = NULL): array
{
$result = [];
$archiveTasks = $this->gateway->getObjectTypeTask('archive');
// Initialize the WebServiceCall object for login
$webServiceCall = new WebServiceCall($_ENV['FUSION_DIRECTORY_API_URL'] . '/login', 'POST');
$webServiceCall->setCurlSettings(); // Perform login and set the token
foreach ($archiveTasks as $task) {
try {
if (!$this->gateway->statusAndScheduleCheck($task)) {
// Skip this task if it does not meet the status and schedule criteria
continue;
}
// Receive null or 'toBeArchived' public function __construct(TaskGateway $gateway)
$supannState = $this->getUserSupannAccountStatus($task['fdtasksgranulardn'][0]); {
$this->gateway = $gateway;
}
if ($supannState !== 'toBeArchived') { /**
// The task does not meet the criteria for archiving and can therefore be suppressed * @return array
$result[$task['dn']]['result'] = "User does not meet the criteria for archiving."; * Part of the interface of orchestrator plugin to treat GET method
$this->gateway->removeSubTask($task['dn']); */
continue; public function processEndPointGet(): array
} {
// Retrieve tasks of type 'archive'
return $this->gateway->getObjectTypeTask('archive');
}
// Set the archive endpoint and method using the same WebServiceCall object /**
$archiveUrl = $_ENV['FUSION_DIRECTORY_API_URL'] . '/archive/user/' . rawurlencode($task['fdtasksgranulardn'][0]); * @param array|null $data
$webServiceCall->setCurlSettings($archiveUrl, NULL, 'POST'); // Update settings for the archive request * @return array
$response = $webServiceCall->execute(); * @throws Exception
* Note: Part of the interface of orchestrator plugin to treat PATCH method
// Check if the HTTP status code is 204 */
if ($webServiceCall->getHttpStatusCode() === 204) { public function processEndPointPatch(array $data = null): array
$result[$task['dn']]['result'] = "User successfully archived."; {
$this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], '2'); $result = [];
} else { $archiveTasks = $this->gateway->getObjectTypeTask('archive');
throw new Exception("Unexpected HTTP status code: " . $webServiceCall->getHttpStatusCode());
// Initialize the WebServiceCall object for login
$webServiceCall = new WebServiceCall($_ENV['FUSION_DIRECTORY_API_URL'] . '/login', 'POST');
$webServiceCall->setCurlSettings(); // Perform login and set the token
foreach ($archiveTasks as $task) {
try {
if (!$this->gateway->statusAndScheduleCheck($task)) {
// Skip this task if it does not meet the status and schedule criteria
continue;
}
// Retrieve the desired supann status from the main task
$desiredSupannStatus = $this->getArchiveTaskBehaviorFromMainTask($task['fdtasksgranularmaster'][0]);
// Retrieve the current supann status of the user
$currentSupannStatus = $this->getUserSupannAccountStatus($task['fdtasksgranulardn'][0]);
// Check if the current supann status matches the desired status
if (!$this->isSupannStatusMatching($desiredSupannStatus, $currentSupannStatus)) {
// The task does not meet the criteria for archiving and can therefore be suppressed
$result[$task['dn']]['result'] = "User does not meet the criteria for archiving.";
$this->gateway->removeSubTask($task['dn']);
continue;
}
// Set the archive endpoint and method using the same WebServiceCall object
$archiveUrl = $_ENV['FUSION_DIRECTORY_API_URL'] . '/archive/user/' . rawurlencode($task['fdtasksgranulardn'][0]);
$webServiceCall->setCurlSettings($archiveUrl, null, 'POST'); // Update settings for the archive request
$response = $webServiceCall->execute();
// Check if the HTTP status code is 204
if ($webServiceCall->getHttpStatusCode() === 204) {
$result[$task['dn']]['result'] = "User successfully archived.";
$this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], '2');
} else {
throw new Exception("Unexpected HTTP status code: " . $webServiceCall->getHttpStatusCode());
}
} catch (Exception $e) {
$result[$task['dn']]['result'] = "Error archiving user: " . $e->getMessage();
$this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], $e->getMessage());
}
} }
} catch (Exception $e) {
$result[$task['dn']]['result'] = "Error archiving user: " . $e->getMessage();
$this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], $e->getMessage());
}
}
return $result; return $result;
}
/**
* @param array|null $data
* @return array
* Note: Part of the interface of orchestrator plugin to treat POST method
*/
public function processEndPointPost (array $data = NULL): array
{
return [];
}
/**
* @param array|null $data
* @return array
* Note: Part of the interface of orchestrator plugin to treat DELETE method
*/
public function processEndPointDelete (array $data = NULL): array
{
return [];
}
/**
* Retrieve the supannAccountStatus of a user
* @param string $userDn
* @return string|null
*/
private function getUserSupannAccountStatus (string $userDn): ?string
{
$supannState = $this->gateway->getLdapTasks(
'(objectClass=supannPerson)',
['supannRessourceEtatDate'],
'',
$userDn
);
if ($this->hasToBeArchived($supannState)) {
return 'toBeArchived';
} }
return NULL; /**
} * @param array|null $data
* @return array
* Note: Part of the interface of orchestrator plugin to treat POST method
*/
public function processEndPointPost(array $data = null): array
{
return [];
}
private function hasToBeArchived (array $supannState): bool /**
{ * @param array|null $data
if (!isset($supannState[0]['supannressourceetatdate']) || !is_array($supannState[0]['supannressourceetatdate'])) { * @return array
return FALSE; * Note: Part of the interface of orchestrator plugin to treat DELETE method
*/
public function processEndPointDelete(array $data = null): array
{
return [];
} }
foreach ($supannState[0]['supannressourceetatdate'] as $key => $value) { /**
// Skip non-numeric keys (e.g., 'count') * Retrieve the supannAccountStatus of a user
if (!is_numeric($key)) { * @param string $userDn
continue; * @return array|null
} */
private function getUserSupannAccountStatus(string $userDn): ?array
{
return $this->gateway->getLdapTasks(
'(objectClass=supannPerson)',
['supannRessourceEtatDate'],
'',
$userDn
);
}
if (strpos($value, '{COMPTE}I:toBeArchived') !== FALSE) { /**
return TRUE; * @param string $taskDN
} * @return array
* Note: Retrieve the desired supann status from the main task attributes.
*/
private function getArchiveTaskBehaviorFromMainTask(string $taskDN): array
{
return $this->gateway->getLdapTasks(
'(objectClass=*)',
['fdArchiveTaskResource', 'fdArchiveTaskState', 'fdArchiveTaskSubState'],
'',
$taskDN
);
} }
return FALSE; /**
} * @param array $desiredStatus
* @param array $currentStatus
* @return bool
* Note: Compare the desired supann status with the current status to determine if they match.
*/
private function isSupannStatusMatching(array $desiredStatus, array $currentStatus): bool
{
if (empty($currentStatus[0]['supannressourceetatdate'])) {
return false;
}
foreach ($currentStatus[0]['supannressourceetatdate'] as $resource) {
if (strpos($resource, '{' . $desiredStatus[0]['fdarchivetaskresource'][0] . '}') !== false &&
strpos($resource, ':' . $desiredStatus[0]['fdarchivetaskstate'][0]) !== false &&
(empty($desiredStatus[0]['fdarchivetasksubstate'][0]) || strpos($resource, ':' . $desiredStatus[0]['fdarchivetasksubstate'][0]) !== false)) {
return true;
}
}
return false;
}
} }
\ No newline at end of file
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment