From 2b40e69206c18bfcebae1043a3afd28f1b6ed79d Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Mon, 24 Mar 2025 12:57:16 +0100
Subject: [PATCH 01/21] rebase
---
plugins/tasks/Reminder.php | 1 -
1 file changed, 1 deletion(-)
diff --git a/plugins/tasks/Reminder.php b/plugins/tasks/Reminder.php
index 1faeff7..8e525f2 100644
--- a/plugins/tasks/Reminder.php
+++ b/plugins/tasks/Reminder.php
@@ -545,5 +545,4 @@ class Reminder implements EndpointInterface
return $result;
}
-
}
\ No newline at end of file
--
GitLab
From 2e5f0410e555d916595ce6e45f6b2493495e1fca Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Mon, 24 Mar 2025 13:05:43 +0100
Subject: [PATCH 02/21] Add mail utils
---
library/MailUtils.php | 22 ++++++++++++++++++++++
1 file changed, 22 insertions(+)
create mode 100644 library/MailUtils.php
diff --git a/library/MailUtils.php b/library/MailUtils.php
new file mode 100644
index 0000000..44b1f48
--- /dev/null
+++ b/library/MailUtils.php
@@ -0,0 +1,22 @@
+<?php
+
+class MailUtils
+{
+ private function __construct()
+ {
+ }
+
+ public static function sendMail($setFrom, $setBCC, $recipients, $body, $signature, $subject, $receipt, $attachments)
+ {
+ $mail_controller = new \FusionDirectory\Mail\MailLib($setFrom,
+ $setBCC,
+ $recipients,
+ $body,
+ $signature,
+ $subject,
+ $receipt,
+ $attachments);
+
+ return $mail_controller->sendMail();
+ }
+}
\ No newline at end of file
--
GitLab
From b00f33367e77cad40e2504b132676217020999bf Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Mon, 24 Mar 2025 13:08:46 +0100
Subject: [PATCH 03/21] use utils
---
plugins/tasks/Reminder.php | 20 ++++++++------------
1 file changed, 8 insertions(+), 12 deletions(-)
diff --git a/plugins/tasks/Reminder.php b/plugins/tasks/Reminder.php
index 8e525f2..8fdb67c 100644
--- a/plugins/tasks/Reminder.php
+++ b/plugins/tasks/Reminder.php
@@ -480,18 +480,14 @@ class Reminder implements EndpointInterface
}
$numberOfRecipients = count($mailDetails['mail']['recipients']);
- $mail_controller = new \FusionDirectory\Mail\MailLib(
- $mailDetails['mail']['setFrom'],
- NULL,
- $mailDetails['mail']['recipients'],
- $mailDetails['mail']['body'],
- $mailDetails['mail']['signature'],
- $mailDetails['mail']['subject'],
- $mailDetails['mail']['receipt'],
- NULL
- );
-
- $mailSentResult = $mail_controller->sendMail();
+ $setFrom = $mailDetails['mail']['setFrom'];
+ $recipients = $mailDetails['mail']['recipients'];
+ $body = $mailDetails['mail']['body'];
+ $signature = $mailDetails['mail']['signature'];
+ $subject = $mailDetails['mail']['subject'];
+ $receipt = $mailDetails['mail']['receipt'];
+
+ $mailSentResult = MailUtils::sendMail($setFrom, NULL, $recipients, $body, $signature, $subject, $receipt, NULL);
// Here we incremented as well the counter of spam to the backend.
$result[] = $this->processMailResponseAndUpdateTasks($mailSentResult, $reminder, $fdTasksConf);
--
GitLab
From eb36997abf51b64afb0436ad0c2c34d9fec42ddf Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Mon, 24 Mar 2025 13:10:44 +0100
Subject: [PATCH 04/21] add method
---
library/MailUtils.php | 12 ++++++++++++
1 file changed, 12 insertions(+)
diff --git a/library/MailUtils.php b/library/MailUtils.php
index 44b1f48..81eaa33 100644
--- a/library/MailUtils.php
+++ b/library/MailUtils.php
@@ -19,4 +19,16 @@ class MailUtils
return $mail_controller->sendMail();
}
+
+ /**
+ * @return array
+ * Note : A simple retrieval methods of the mail backend configuration set in FusionDirectory
+ */
+ public static function getMailObjectConfiguration (TaskGateway $gateway): array
+ {
+ return $gateway->getLdapTasks(
+ "(objectClass=fdTasksConf)",
+ ["fdTasksConfLastExecTime", "fdTasksConfIntervalEmails", "fdTasksConfMaxEmails"]
+ );
+ }
}
\ No newline at end of file
--
GitLab
From 205afc3c2bff00c5a69e19382051c006948c8bca Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Mon, 24 Mar 2025 13:12:51 +0100
Subject: [PATCH 05/21] use utils
---
plugins/tasks/Reminder.php | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/plugins/tasks/Reminder.php b/plugins/tasks/Reminder.php
index 8fdb67c..3dc0744 100644
--- a/plugins/tasks/Reminder.php
+++ b/plugins/tasks/Reminder.php
@@ -454,10 +454,7 @@ class Reminder implements EndpointInterface
{
$result = [];
// Re-use of the same mail processing template logic
- $fdTasksConf = $this->gateway->getLdapTasks(
- "(objectClass=fdTasksConf)",
- ["fdTasksConfLastExecTime", "fdTasksConfIntervalEmails", "fdTasksConfMaxEmails"]
- );
+ $fdTasksConf = MailUtils::getMailObjectConfiguration($this->gateway);
$maxMailsConfig = $fdTasksConf[0]["fdtasksconfmaxemails"][0] ?? 50;
/*
--
GitLab
From afcb6b5f252fb44ef9d835a0bcd3e4131f1f69cf Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Mon, 24 Mar 2025 13:20:20 +0100
Subject: [PATCH 06/21] use utils
---
plugins/tasks/Reminder.php | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/plugins/tasks/Reminder.php b/plugins/tasks/Reminder.php
index 3dc0744..b326b74 100644
--- a/plugins/tasks/Reminder.php
+++ b/plugins/tasks/Reminder.php
@@ -4,6 +4,7 @@ class Reminder implements EndpointInterface
{
private TaskGateway $gateway;
+ private string $errorMessage = 'No reminder triggers were found, therefore removing the sub-task!';
public function __construct (TaskGateway $gateway)
{
@@ -81,7 +82,7 @@ class Reminder implements EndpointInterface
if ($monitoredResources['resource'][0] === 'NONE' && $monitoredResources['prolongation'] === 'FALSE') {
// Removal subtask
$result[$task['dn']]['Removed'] = $this->gateway->removeSubTask($task['dn']);
- $result[$task['dn']]['Status'] = 'No reminder triggers were found, therefore removing the sub-task!';
+ $result[$task['dn']]['Status'] = $this->errorMessage;
}
// Case where supann is set monitored but no prolongation desired.
@@ -97,7 +98,7 @@ class Reminder implements EndpointInterface
} else {
// Not about to expire, delete subTask
$result[$task['dn']]['Removed'] = $this->gateway->removeSubTask($task['dn']);
- $result[$task['dn']]['Status'] = 'No reminder triggers were found, therefore removing the sub-task!';
+ $result[$task['dn']]['Status'] = $this->errorMessage;
}
}
@@ -123,7 +124,7 @@ class Reminder implements EndpointInterface
} else {
// Not about to expire, delete subTask
$result[$task['dn']]['Removed'] = $this->gateway->removeSubTask($task['dn']);
- $result[$task['dn']]['Status'] = 'No reminder triggers were found, therefore removing the sub-task!';
+ $result[$task['dn']]['Status'] = $this->errorMessage;
}
}
@@ -150,7 +151,7 @@ class Reminder implements EndpointInterface
} else {
// Not about to expire, delete subTask
$result[$task['dn']]['Removed'] = $this->gateway->removeSubTask($task['dn']);
- $result[$task['dn']]['Status'] = 'No reminder triggers were found, therefore removing the sub-task!';
+ $result[$task['dn']]['Status'] = $this->errorMessage;
}
}
}
@@ -340,10 +341,9 @@ class Reminder implements EndpointInterface
$result = '';
//Construct the reminder Supann Resource State as string
+ $monitoredSupannState = '{' . $reminderSupann['resource'][0] . '}' . $reminderSupann['state'][0];
if (!empty($reminderSupann['subState'][0])) {
- $monitoredSupannState = '{' . $reminderSupann['resource'][0] . '}' . $reminderSupann['state'][0] . ':' . $reminderSupann['subState'][0];
- } else {
- $monitoredSupannState = '{' . $reminderSupann['resource'][0] . '}' . $reminderSupann['state'][0];
+ $monitoredSupannState = $monitoredSupannState . ':' . $reminderSupann['subState'][0];
}
if (!empty($dnSupann['supannressourceetat'])) {
--
GitLab
From dcec192d9c088a53fda30b35642b89e1243f38da Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Mon, 24 Mar 2025 13:22:52 +0100
Subject: [PATCH 07/21] fix indent
---
library/MailUtils.php | 52 +++++++++++++++++++++----------------------
1 file changed, 26 insertions(+), 26 deletions(-)
diff --git a/library/MailUtils.php b/library/MailUtils.php
index 81eaa33..8779224 100644
--- a/library/MailUtils.php
+++ b/library/MailUtils.php
@@ -2,33 +2,33 @@
class MailUtils
{
- private function __construct()
- {
- }
+ private function __construct()
+ {
+ }
- public static function sendMail($setFrom, $setBCC, $recipients, $body, $signature, $subject, $receipt, $attachments)
- {
- $mail_controller = new \FusionDirectory\Mail\MailLib($setFrom,
- $setBCC,
- $recipients,
- $body,
- $signature,
- $subject,
- $receipt,
- $attachments);
+ public static function sendMail($setFrom, $setBCC, $recipients, $body, $signature, $subject, $receipt, $attachments)
+ {
+ $mail_controller = new \FusionDirectory\Mail\MailLib($setFrom,
+ $setBCC,
+ $recipients,
+ $body,
+ $signature,
+ $subject,
+ $receipt,
+ $attachments);
- return $mail_controller->sendMail();
- }
+ return $mail_controller->sendMail();
+ }
- /**
- * @return array
- * Note : A simple retrieval methods of the mail backend configuration set in FusionDirectory
- */
- public static function getMailObjectConfiguration (TaskGateway $gateway): array
- {
- return $gateway->getLdapTasks(
- "(objectClass=fdTasksConf)",
- ["fdTasksConfLastExecTime", "fdTasksConfIntervalEmails", "fdTasksConfMaxEmails"]
- );
- }
+ /**
+ * @return array
+ * Note : A simple retrieval methods of the mail backend configuration set in FusionDirectory
+ */
+ public static function getMailObjectConfiguration (TaskGateway $gateway): array
+ {
+ return $gateway->getLdapTasks(
+ "(objectClass=fdTasksConf)",
+ ["fdTasksConfLastExecTime", "fdTasksConfIntervalEmails", "fdTasksConfMaxEmails"]
+ );
+ }
}
\ No newline at end of file
--
GitLab
From a5485aa342e5c9b409ef9e0fd81a605aabc18e28 Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Mon, 24 Mar 2025 13:23:22 +0100
Subject: [PATCH 08/21] fix indent
---
library/MailUtils.php | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/library/MailUtils.php b/library/MailUtils.php
index 8779224..5fc496a 100644
--- a/library/MailUtils.php
+++ b/library/MailUtils.php
@@ -2,11 +2,11 @@
class MailUtils
{
- private function __construct()
+ private function __construct ()
{
}
- public static function sendMail($setFrom, $setBCC, $recipients, $body, $signature, $subject, $receipt, $attachments)
+ public static function sendMail ($setFrom, $setBCC, $recipients, $body, $signature, $subject, $receipt, $attachments)
{
$mail_controller = new \FusionDirectory\Mail\MailLib($setFrom,
$setBCC,
--
GitLab
From e6bb63ea0052a746b0563df8f4acb6196062ec0b Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Mon, 24 Mar 2025 13:27:56 +0100
Subject: [PATCH 09/21] fix indent
---
plugins/tasks/Reminder.php | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/plugins/tasks/Reminder.php b/plugins/tasks/Reminder.php
index b326b74..ac02ffa 100644
--- a/plugins/tasks/Reminder.php
+++ b/plugins/tasks/Reminder.php
@@ -477,12 +477,12 @@ class Reminder implements EndpointInterface
}
$numberOfRecipients = count($mailDetails['mail']['recipients']);
- $setFrom = $mailDetails['mail']['setFrom'];
+ $setFrom = $mailDetails['mail']['setFrom'];
$recipients = $mailDetails['mail']['recipients'];
- $body = $mailDetails['mail']['body'];
- $signature = $mailDetails['mail']['signature'];
- $subject = $mailDetails['mail']['subject'];
- $receipt = $mailDetails['mail']['receipt'];
+ $body = $mailDetails['mail']['body'];
+ $signature = $mailDetails['mail']['signature'];
+ $subject = $mailDetails['mail']['subject'];
+ $receipt = $mailDetails['mail']['receipt'];
$mailSentResult = MailUtils::sendMail($setFrom, NULL, $recipients, $body, $signature, $subject, $receipt, NULL);
// Here we incremented as well the counter of spam to the backend.
--
GitLab
From 6036715e1a1b433614c5c54269992c0c8d735c29 Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Tue, 25 Mar 2025 11:11:09 +0100
Subject: [PATCH 10/21] use maps
---
library/Utils.php | 26 ++++++++------------------
1 file changed, 8 insertions(+), 18 deletions(-)
diff --git a/library/Utils.php b/library/Utils.php
index 1c132ac..24e8309 100644
--- a/library/Utils.php
+++ b/library/Utils.php
@@ -13,20 +13,12 @@ class Utils
*/
public static function recursiveArrayFilter (array $array): array
{
- // First filter the array for non-empty elements
- $filtered = array_filter($array, function ($item) {
- if (is_array($item)) {
- // Recursively filter the sub-array
- $item = self::recursiveArrayFilter($item);
- // Only retain non-empty arrays
- return !empty($item);
- } else {
- // Retain non-empty scalar values
+ return array_filter($array, function ($item) {
+ if (is_array($item)) {
+ $item = self::recursiveArrayFilter($item);
+ }
return !empty($item);
- }
});
-
- return $filtered;
}
/**
@@ -40,12 +32,10 @@ class Utils
{
$matching = [];
- if (!empty($elements)) {
- foreach ($elements as $element) {
- foreach ($keys as $key) {
- if (!empty($element) && array_key_exists($key, $element)) {
- $matching[] = $key;
- }
+ foreach ($elements as $element) {
+ foreach ($keys as $key) {
+ if (!empty($element) && array_key_exists($key, $element)) {
+ $matching[] = $key;
}
}
}
--
GitLab
From 5cac7dc1e9e804eaf88445ae7b2123d96098299b Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Tue, 25 Mar 2025 11:12:26 +0100
Subject: [PATCH 11/21] indent
---
library/Utils.php | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/library/Utils.php b/library/Utils.php
index 24e8309..7e31d9b 100644
--- a/library/Utils.php
+++ b/library/Utils.php
@@ -14,10 +14,10 @@ class Utils
public static function recursiveArrayFilter (array $array): array
{
return array_filter($array, function ($item) {
- if (is_array($item)) {
- $item = self::recursiveArrayFilter($item);
- }
- return !empty($item);
+ if (is_array($item)) {
+ $item = self::recursiveArrayFilter($item);
+ }
+ return !empty($item);
});
}
--
GitLab
From 9850cdc326587e9d5e322afaf33d492514542ccc Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Tue, 25 Mar 2025 11:56:04 +0100
Subject: [PATCH 12/21] make non static
---
library/Utils.php | 75 -------------------
library/{ => plugins}/MailUtils.php | 6 +-
.../ReminderTokenUtils.php} | 40 ++++++----
library/plugins/Utils.php | 59 +++++++++++++++
plugins/tasks/Audit.php | 4 +-
plugins/tasks/Notifications.php | 6 +-
plugins/tasks/Reminder.php | 14 ++--
7 files changed, 102 insertions(+), 102 deletions(-)
delete mode 100644 library/Utils.php
rename library/{ => plugins}/MailUtils.php (70%)
rename library/{TokenUtils.php => plugins/ReminderTokenUtils.php} (77%)
create mode 100644 library/plugins/Utils.php
diff --git a/library/Utils.php b/library/Utils.php
deleted file mode 100644
index 7e31d9b..0000000
--- a/library/Utils.php
+++ /dev/null
@@ -1,75 +0,0 @@
-<?php
-
-class Utils
-{
- private function __construct ()
- {
- }
-
- /**
- * @param array $array
- * @return array
- * Note : Recursively filters out empty values and arrays at any depth.
- */
- public static function recursiveArrayFilter (array $array): array
- {
- return array_filter($array, function ($item) {
- if (is_array($item)) {
- $item = self::recursiveArrayFilter($item);
- }
- return !empty($item);
- });
- }
-
- /**
- * Find matching keys between 2 lists.
- *
- * @param array|null $elements
- * @param array $keys
- * @return array
- */
- public static function findMatchingKeys (?array $elements, array $keys): array
- {
- $matching = [];
-
- foreach ($elements as $element) {
- foreach ($keys as $key) {
- if (!empty($element) && array_key_exists($key, $element)) {
- $matching[] = $key;
- }
- }
- }
-
- return $matching;
- }
-
- /**
- * @param $array
- * @return array
- * Note : simply return all values of a multi-dimensional array.
- */
- public static function getArrayValuesRecursive ($array)
- {
- $values = [];
- foreach ($array as $value) {
- if (is_array($value)) {
- // If value is an array, merge its values recursively
- $values = array_merge($values, self::getArrayValuesRecursive($value));
- } else {
- // If value is not an array, add it to the result
- $values[] = $value;
- }
- }
- return $values;
- }
-
- /**
- * @param string $text
- * @return string
- * Note : This come from jwtToken, as it is completely private - it is cloned here for now.
- */
- public static function base64urlEncode (string $text): string
- {
- return str_replace(["+", "/", "="], ["A", "B", ""], base64_encode($text));
- }
-}
\ No newline at end of file
diff --git a/library/MailUtils.php b/library/plugins/MailUtils.php
similarity index 70%
rename from library/MailUtils.php
rename to library/plugins/MailUtils.php
index 5fc496a..87f4c64 100644
--- a/library/MailUtils.php
+++ b/library/plugins/MailUtils.php
@@ -2,11 +2,11 @@
class MailUtils
{
- private function __construct ()
+ public function __construct ()
{
}
- public static function sendMail ($setFrom, $setBCC, $recipients, $body, $signature, $subject, $receipt, $attachments)
+ public function sendMail ($setFrom, $setBCC, $recipients, $body, $signature, $subject, $receipt, $attachments)
{
$mail_controller = new \FusionDirectory\Mail\MailLib($setFrom,
$setBCC,
@@ -24,7 +24,7 @@ class MailUtils
* @return array
* Note : A simple retrieval methods of the mail backend configuration set in FusionDirectory
*/
- public static function getMailObjectConfiguration (TaskGateway $gateway): array
+ public function getMailObjectConfiguration (TaskGateway $gateway): array
{
return $gateway->getLdapTasks(
"(objectClass=fdTasksConf)",
diff --git a/library/TokenUtils.php b/library/plugins/ReminderTokenUtils.php
similarity index 77%
rename from library/TokenUtils.php
rename to library/plugins/ReminderTokenUtils.php
index 8552514..4ead9b4 100644
--- a/library/TokenUtils.php
+++ b/library/plugins/ReminderTokenUtils.php
@@ -1,8 +1,8 @@
<?php
-class TokenUtils
+class ReminderTokenUtils
{
- private function __construct ()
+ public function __construct ()
{
}
@@ -12,7 +12,7 @@ class TokenUtils
* @return string
* @throws Exception
*/
- public static function generateToken (string $userDN, int $timeStamp, TaskGateway $gateway): string
+ public function generateToken (string $userDN, int $timeStamp, TaskGateway $gateway): string
{
$token = NULL;
// Salt has been generated with APG.
@@ -25,10 +25,10 @@ class TokenUtils
$token_hmac = hash_hmac("sha256", $time . $payload, $_ENV["SECRET_KEY"], TRUE);
// We need to have a token allowed to be used within an URL.
- $token = Utils::base64urlEncode($token_hmac);
+ $token = $this->base64urlEncode($token_hmac);
// Save token within LDAP
- self::saveTokenInLdap($userDN, $token, $timeStamp, $gateway);
+ $this->saveTokenInLdap($userDN, $token, $timeStamp, $gateway);
return $token;
}
@@ -41,7 +41,7 @@ class TokenUtils
* @return bool
* @throws Exception
*/
- public static function saveTokenInLdap (string $userDN, string $token, int $days, TaskGateway $gateway): bool
+ private function saveTokenInLdap (string $userDN, string $token, int $days, TaskGateway $gateway): bool
{
$result = FALSE;
@@ -64,17 +64,17 @@ class TokenUtils
// Verify if token ou branch exists
- if (!self::tokenBranchExist('ou=tokens' . ',' . $_ENV["LDAP_BASE"], $gateway)) {
+ if (!$this->tokenBranchExist('ou=tokens' . ',' . $_ENV["LDAP_BASE"], $gateway)) {
// Create the branch
- self::createBranchToken($gateway);
+ $this->createBranchToken($gateway);
}
// The user token DN creation
$userTokenDN = 'cn=' . $uid . ',ou=tokens' . ',' . $_ENV["LDAP_BASE"];
// Verify if a token already exists for specified user and remove it to create new one correctly.
- if (self::tokenBranchExist($userTokenDN, $gateway)) {
+ if ($this->tokenBranchExist($userTokenDN, $gateway)) {
// Remove the user token
- self::removeUserToken($userTokenDN, $gateway);
+ $this->removeUserToken($userTokenDN, $gateway);
}
// Add token to LDAP for specific UID
@@ -95,7 +95,7 @@ class TokenUtils
* @return int
* Note : Simply return the difference between first and second call. (First call can be null).
*/
- public static function getTokenExpiration (int $subTaskCall, int $firstCall, int $secondCall): int
+ public function getTokenExpiration (int $subTaskCall, int $firstCall, int $secondCall): int
{
// if firstCall is empty, secondCall is the timestamp expiry for the token.
$result = $secondCall;
@@ -115,7 +115,7 @@ class TokenUtils
* @return void
* Note : Simply remove the token for specific user DN
*/
- public static function removeUserToken ($userTokenDN, TaskGateway $gateway): void
+ private function removeUserToken ($userTokenDN, TaskGateway $gateway): void
{
// Add token to LDAP for specific UID
try {
@@ -130,7 +130,7 @@ class TokenUtils
* Create ou=pluginManager LDAP branch
* @throws Exception
*/
- public static function createBranchToken (TaskGateway $gateway): void
+ private function createBranchToken (TaskGateway $gateway): void
{
try {
ldap_add(
@@ -153,7 +153,7 @@ class TokenUtils
* @param string $taskDN
* @return array
*/
- public static function generateTokenUrl (string $token, array $mailTemplateForm, string $taskDN): array
+ public function generateTokenUrl (string $token, array $mailTemplateForm, string $taskDN): array
{
//Only take the cn of the main task name :
preg_match('/cn=([^,]+),ou=/', $taskDN, $matches);
@@ -173,7 +173,7 @@ class TokenUtils
* @return bool
* Note : Simply inspect if the branch for token is existing.
*/
- public static function tokenBranchExist (string $dn, TaskGateway $gateway): bool
+ private function tokenBranchExist (string $dn, TaskGateway $gateway): bool
{
$result = FALSE;
@@ -195,4 +195,14 @@ class TokenUtils
return $result;
}
+
+ /**
+ * @param string $text
+ * @return string
+ * Note : This come from jwtToken, as it is completely private - it is cloned here for now.
+ */
+ private function base64urlEncode (string $text): string
+ {
+ return str_replace(["+", "/", "="], ["A", "B", ""], base64_encode($text));
+ }
}
\ No newline at end of file
diff --git a/library/plugins/Utils.php b/library/plugins/Utils.php
new file mode 100644
index 0000000..10eafe6
--- /dev/null
+++ b/library/plugins/Utils.php
@@ -0,0 +1,59 @@
+<?php
+
+class Utils
+{
+ public function __construct ()
+ {
+ }
+
+ /**
+ * @param array $array
+ * @return array
+ * Note : Recursively filters out empty values and arrays at any depth.
+ */
+ public function recursiveArrayFilter (array $array): array
+ {
+ return array_filter($array, function ($item) {
+ if (is_array($item)) {
+ $item = $this->recursiveArrayFilter($item);
+ }
+ return !empty($item);
+ });
+ }
+
+ /**
+ * Find matching keys between 2 lists.
+ *
+ * @param array|null $elements
+ * @param array $keys
+ * @return array
+ */
+ public function findMatchingKeys (?array $elements, array $keys): array
+ {
+ $matching = [];
+
+ if (!empty($elements)) {
+ foreach ($elements as $element) {
+ foreach ($keys as $key) {
+ if (!empty($element) && array_key_exists($key, $element)) {
+ $matching[] = $key;
+ }
+ }
+ }
+ }
+
+ return $matching;
+ }
+
+ /**
+ * @param $array
+ * @return array
+ * Note : simply return all values of a multi-dimensional array.
+ */
+ public function getArrayValuesRecursive ($array)
+ {
+ return array_reduce($array, function ($carry, $value) {
+ return array_merge($carry, is_array($value) ? $this->getArrayValuesRecursive($value) : [$value]);
+ }, []);
+ }
+}
\ No newline at end of file
diff --git a/plugins/tasks/Audit.php b/plugins/tasks/Audit.php
index c4bbe40..9481831 100644
--- a/plugins/tasks/Audit.php
+++ b/plugins/tasks/Audit.php
@@ -4,10 +4,12 @@ class Audit implements EndpointInterface
{
private TaskGateway $gateway;
+ private Utils $utils;
public function __construct (TaskGateway $gateway)
{
$this->gateway = $gateway;
+ $this->utils = new Utils();
}
/**
@@ -47,7 +49,7 @@ class Audit implements EndpointInterface
$result = $this->processAuditDeletion($this->gateway->getObjectTypeTask('Audit'));
// Recursive function to filter out empty arrays at any depth
- $nonEmptyResults = Utils::recursiveArrayFilter($result);
+ $nonEmptyResults = $this->utils->recursiveArrayFilter($result);
if (!empty($nonEmptyResults)) {
return $nonEmptyResults;
diff --git a/plugins/tasks/Notifications.php b/plugins/tasks/Notifications.php
index e17ffe3..4547b87 100644
--- a/plugins/tasks/Notifications.php
+++ b/plugins/tasks/Notifications.php
@@ -4,10 +4,12 @@ class Notifications implements EndpointInterface
{
private TaskGateway $gateway;
+ private Utils $utils;
public function __construct (TaskGateway $gateway)
{
$this->gateway = $gateway;
+ $this->utils = new Utils();
}
/**
@@ -82,7 +84,7 @@ class Notifications implements EndpointInterface
$this->gateway->unsetCountKeys($monitoredSupannResource);
// Find matching attributes between audited and monitored attributes
- $matchingAttrs = Utils::findMatchingKeys($auditAttributes, $monitoredAttrs);
+ $matchingAttrs = $this->utils->findMatchingKeys($auditAttributes, $monitoredAttrs);
// Verify Supann resource state if applicable
if ($this->shouldVerifySupannResource($monitoredSupannResource, $auditAttributes)) {
@@ -183,7 +185,7 @@ class Notifications implements EndpointInterface
}
// Get all the values only of a multidimensional array.
- $auditedValues = Utils::getArrayValuesRecursive($auditedAttrs);
+ $auditedValues = $this->utils->getArrayValuesRecursive($auditedAttrs);
if (in_array($monitoredSupannState, $auditedValues)) {
$result = TRUE;
diff --git a/plugins/tasks/Reminder.php b/plugins/tasks/Reminder.php
index ac02ffa..50947d9 100644
--- a/plugins/tasks/Reminder.php
+++ b/plugins/tasks/Reminder.php
@@ -4,11 +4,13 @@ class Reminder implements EndpointInterface
{
private TaskGateway $gateway;
+ private ReminderTokenUtils $reminderTokenUtils;
private string $errorMessage = 'No reminder triggers were found, therefore removing the sub-task!';
public function __construct (TaskGateway $gateway)
{
$this->gateway = $gateway;
+ $this->reminderTokenUtils = new ReminderTokenUtils();
}
/**
@@ -110,13 +112,13 @@ class Reminder implements EndpointInterface
$reminders[$remindersMainTaskName]['subTask'][$task['cn'][0]]['uid'] = $task['fdtasksgranulardn'][0];
// Create timeStamp expiration for token
- $tokenExpire = TokenUtils::getTokenExpiration($task['fdtasksgranularhelper'][0],
+ $tokenExpire = $this->reminderTokenUtils->getTokenExpiration($task['fdtasksgranularhelper'][0],
$remindersMainTask[0]['fdtasksreminderfirstcall'][0],
$remindersMainTask[0]['fdtasksremindersecondcall'][0]);
// Create token for SubTask
- $token = TokenUtils::generateToken($task['fdtasksgranulardn'][0], $tokenExpire, $this->gateway);
+ $token = $this->reminderTokenUtils->generateToken($task['fdtasksgranulardn'][0], $tokenExpire, $this->gateway);
// Edit the mailForm with the url link containing the token
- $tokenMailTemplateForm = TokenUtils::generateTokenUrl($token, $mailTemplateForm, $remindersMainTaskName);
+ $tokenMailTemplateForm = $this->reminderTokenUtils->generateTokenUrl($token, $mailTemplateForm, $remindersMainTaskName);
// Recipient email form
$reminders[$remindersMainTaskName]['subTask'][$task['cn'][0]]['mail'] = $tokenMailTemplateForm;
@@ -137,13 +139,13 @@ class Reminder implements EndpointInterface
$reminders[$remindersMainTaskName]['subTask'][$task['cn'][0]]['uid'] = $task['fdtasksgranulardn'][0];
// Create timeStamp expiration for token
- $tokenExpire = TokenUtils::getTokenExpiration($task['fdtasksgranularhelper'][0],
+ $tokenExpire = $this->reminderTokenUtils->getTokenExpiration($task['fdtasksgranularhelper'][0],
$remindersMainTask[0]['fdtasksreminderfirstcall'][0],
$remindersMainTask[0]['fdtasksremindersecondcall'][0]);
// Create token for SubTask
- $token = TokenUtils::generateToken($task['fdtasksgranulardn'][0], $tokenExpire, $this->gateway);
+ $token = $this->reminderTokenUtils->generateToken($task['fdtasksgranulardn'][0], $tokenExpire, $this->gateway);
// Edit the mailForm with the url link containing the token
- $tokenMailTemplateForm = TokenUtils::generateTokenUrl($token, $mailTemplateForm, $remindersMainTaskName);
+ $tokenMailTemplateForm = $this->reminderTokenUtils->generateTokenUrl($token, $mailTemplateForm, $remindersMainTaskName);
// Recipient email form
$reminders[$remindersMainTaskName]['subTask'][$task['cn'][0]]['mail'] = $tokenMailTemplateForm;
--
GitLab
From b5bbe1ef3a47c136880d8f41bb0e09e95cc81092 Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Tue, 25 Mar 2025 11:57:20 +0100
Subject: [PATCH 13/21] fix indent
---
library/plugins/ReminderTokenUtils.php | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
diff --git a/library/plugins/ReminderTokenUtils.php b/library/plugins/ReminderTokenUtils.php
index 4ead9b4..bb08d24 100644
--- a/library/plugins/ReminderTokenUtils.php
+++ b/library/plugins/ReminderTokenUtils.php
@@ -196,13 +196,13 @@ class ReminderTokenUtils
return $result;
}
- /**
- * @param string $text
- * @return string
- * Note : This come from jwtToken, as it is completely private - it is cloned here for now.
- */
- private function base64urlEncode (string $text): string
- {
- return str_replace(["+", "/", "="], ["A", "B", ""], base64_encode($text));
- }
+ /**
+ * @param string $text
+ * @return string
+ * Note : This come from jwtToken, as it is completely private - it is cloned here for now.
+ */
+ private function base64urlEncode (string $text): string
+ {
+ return str_replace(["+", "/", "="], ["A", "B", ""], base64_encode($text));
+ }
}
\ No newline at end of file
--
GitLab
From 83b7d2b9122a95d24115bbed94fcea8e4c85cd82 Mon Sep 17 00:00:00 2001
From: Oana-Eliza Alexa <43857161+alexaeliza@users.noreply.github.com>
Date: Tue, 25 Mar 2025 12:07:51 +0100
Subject: [PATCH 14/21] use mailutils
---
plugins/tasks/Reminder.php | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/plugins/tasks/Reminder.php b/plugins/tasks/Reminder.php
index 50947d9..9742b65 100644
--- a/plugins/tasks/Reminder.php
+++ b/plugins/tasks/Reminder.php
@@ -6,11 +6,13 @@ class Reminder implements EndpointInterface
private TaskGateway $gateway;
private ReminderTokenUtils $reminderTokenUtils;
private string $errorMessage = 'No reminder triggers were found, therefore removing the sub-task!';
+ private MailUtils $mailUtils;
public function __construct (TaskGateway $gateway)
{
$this->gateway = $gateway;
$this->reminderTokenUtils = new ReminderTokenUtils();
+ $this->mailUtils = new MailUtils();
}
/**
@@ -456,7 +458,7 @@ class Reminder implements EndpointInterface
{
$result = [];
// Re-use of the same mail processing template logic
- $fdTasksConf = MailUtils::getMailObjectConfiguration($this->gateway);
+ $fdTasksConf = $this->mailUtils->getMailObjectConfiguration($this->gateway);
$maxMailsConfig = $fdTasksConf[0]["fdtasksconfmaxemails"][0] ?? 50;
/*
@@ -486,7 +488,7 @@ class Reminder implements EndpointInterface
$subject = $mailDetails['mail']['subject'];
$receipt = $mailDetails['mail']['receipt'];
- $mailSentResult = MailUtils::sendMail($setFrom, NULL, $recipients, $body, $signature, $subject, $receipt, NULL);
+ $mailSentResult = $this->mailUtils->sendMail($setFrom, NULL, $recipients, $body, $signature, $subject, $receipt, NULL);
// Here we incremented as well the counter of spam to the backend.
$result[] = $this->processMailResponseAndUpdateTasks($mailSentResult, $reminder, $fdTasksConf);
--
GitLab
From 1ee9c2350b0662cee361e52a20af48f50245efb5 Mon Sep 17 00:00:00 2001
From: Thibault Dockx <thibault.dockx@fusiondirectory.org>
Date: Mon, 24 Mar 2025 10:46:00 +0000
Subject: [PATCH 15/21] :sparkles: Feat(gateway) - simply add gateway to get
methods
---
.gitignore | 7 +++++++
library/TaskController.php | 2 +-
2 files changed, 8 insertions(+), 1 deletion(-)
diff --git a/.gitignore b/.gitignore
index a474600..84558c9 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,2 +1,9 @@
.vendor/
.composer.lock
+filelist
+phpstan.neon
+.idea/fusiondirectory-orchestrator.iml
+.idea/modules.xml
+.idea/php.xml
+.idea/vcs.xml
+.idea/codeStyles/codeStyleConfig.xml
diff --git a/library/TaskController.php b/library/TaskController.php
index 849f5b6..2b4ddf3 100644
--- a/library/TaskController.php
+++ b/library/TaskController.php
@@ -55,7 +55,7 @@ class TaskController
switch ($objectType) {
case $objectType:
if (class_exists($objectType)) {
- $endpoint = new $objectType;
+ $endpoint = new $objectType($this->gateway);
$result = $endpoint->processEndPointGet();
}
break;
--
GitLab
From a22c1a25cf5fa274b68a7f8109e2996527ee947c Mon Sep 17 00:00:00 2001
From: Thibault Dockx <thibault.dockx@fusiondirectory.org>
Date: Mon, 24 Mar 2025 15:21:23 +0000
Subject: [PATCH 16/21] :sparkles: feat(archive) - implement Archive endpoint
with GET, PATCH, POST, and DELETE methods
---
plugins/tasks/Archive.php | 98 +++++++++++++++++++++++++++++++++++++++
1 file changed, 98 insertions(+)
create mode 100644 plugins/tasks/Archive.php
diff --git a/plugins/tasks/Archive.php b/plugins/tasks/Archive.php
new file mode 100644
index 0000000..e7838f8
--- /dev/null
+++ b/plugins/tasks/Archive.php
@@ -0,0 +1,98 @@
+<?php
+
+class Archive implements EndpointInterface
+{
+ 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 webservice object
+ // TODO
+ $webservice = new FusionDirectory\Rest\WebServiceCall($_ENV['FUSION_DIRECTORY_API_URL'] . '/archive', 'POST');
+ $webservice->setCurlSettings();
+
+ foreach ($archiveTasks as $task) {
+ // Verify the task status and schedule
+ if ($this->gateway->statusAndScheduleCheck($task)) {
+ // Retrieve the user's supannAccountStatus
+ $userStatus = $this->getUserSupannAccountStatus($task['fdtasksgranulardn'][0]);
+
+ // Check if the user meets the "toBeArchived" condition
+ // TODO
+ if ($userStatus === 'toBeArchived') {
+ // Trigger the archive method via the webservice
+ $archiveResult = $webservice->triggerArchive($task['fdtasksgranulardn'][0]);
+
+ // Update the task status based on the result
+ if ($archiveResult === TRUE) {
+ $result[$task['dn']]['result'] = "User successfully archived.";
+ $this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], '2'); // Mark task as completed
+ } else {
+ $result[$task['dn']]['result'] = "Error archiving user.";
+ $this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], '3'); // Mark task as failed
+ }
+ } else {
+ $result[$task['dn']]['result'] = "User does not meet the criteria for archiving.";
+ }
+ }
+ }
+
+ 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
+ {
+ // Logic to retrieve the supannAccountStatus attribute of the user
+ $user = $this->gateway->getLdapEntry($userDn, ['supannAccountStatus']);
+ return $user['supannAccountStatus'][0] ?? NULL;
+ }
+}
\ No newline at end of file
--
GitLab
From 36f623e45e95ace8eda2304f0b6fca770d68e975 Mon Sep 17 00:00:00 2001
From: Thibault Dockx <thibault.dockx@fusiondirectory.org>
Date: Mon, 24 Mar 2025 16:44:58 +0000
Subject: [PATCH 17/21] :sparkles: feat(archive) - enhance Archive
functionality with WebServiceCall integration and improved error handling
---
.idea/.gitignore | 8 ++++++++
plugins/tasks/Archive.php | 30 ++++++++++++++++++++----------
2 files changed, 28 insertions(+), 10 deletions(-)
create mode 100755 .idea/.gitignore
diff --git a/.idea/.gitignore b/.idea/.gitignore
new file mode 100755
index 0000000..13566b8
--- /dev/null
+++ b/.idea/.gitignore
@@ -0,0 +1,8 @@
+# Default ignored files
+/shelf/
+/workspace.xml
+# Editor-based HTTP Client requests
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml
diff --git a/plugins/tasks/Archive.php b/plugins/tasks/Archive.php
index e7838f8..77492f8 100644
--- a/plugins/tasks/Archive.php
+++ b/plugins/tasks/Archive.php
@@ -1,5 +1,7 @@
<?php
+use FusionDirectory\Rest\WebServiceCall;
+
class Archive implements EndpointInterface
{
private TaskGateway $gateway;
@@ -30,11 +32,6 @@ class Archive implements EndpointInterface
$result = [];
$archiveTasks = $this->gateway->getObjectTypeTask('archive');
- // Initialize the webservice object
- // TODO
- $webservice = new FusionDirectory\Rest\WebServiceCall($_ENV['FUSION_DIRECTORY_API_URL'] . '/archive', 'POST');
- $webservice->setCurlSettings();
-
foreach ($archiveTasks as $task) {
// Verify the task status and schedule
if ($this->gateway->statusAndScheduleCheck($task)) {
@@ -42,19 +39,32 @@ class Archive implements EndpointInterface
$userStatus = $this->getUserSupannAccountStatus($task['fdtasksgranulardn'][0]);
// Check if the user meets the "toBeArchived" condition
- // TODO
if ($userStatus === 'toBeArchived') {
- // Trigger the archive method via the webservice
- $archiveResult = $webservice->triggerArchive($task['fdtasksgranulardn'][0]);
+ // Construct the archive URL
+ $archiveUrl = $_ENV['FUSION_DIRECTORY_API_URL'] . '/archive/user/' . rawurlencode($task['fdtasksgranulardn'][0]);
+
+ // Initialize the WebServiceCall object
+ $webServiceCall = new WebServiceCall($archiveUrl, 'POST');
+ $webServiceCall->setCurlSettings();
- // Update the task status based on the result
- if ($archiveResult === TRUE) {
+ // Execute the request
+ $response = curl_exec($webServiceCall->ch);
+
+ // Handle any cURL errors
+ $webServiceCall->handleCurlError($webServiceCall->ch);
+
+ // Decode and process the response
+ $responseData = json_decode($response, true);
+ if ($responseData && isset($responseData['success']) && $responseData['success'] === true) {
$result[$task['dn']]['result'] = "User successfully archived.";
$this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], '2'); // Mark task as completed
} else {
$result[$task['dn']]['result'] = "Error archiving user.";
$this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], '3'); // Mark task as failed
}
+
+ // Close the cURL resource
+ curl_close($webServiceCall->ch);
} else {
$result[$task['dn']]['result'] = "User does not meet the criteria for archiving.";
}
--
GitLab
From 2806bf65f7eb8421c067d6953fc7142b360fcb3c Mon Sep 17 00:00:00 2001
From: Thibault Dockx <thibault.dockx@fusiondirectory.org>
Date: Tue, 25 Mar 2025 00:40:12 +0000
Subject: [PATCH 18/21] :sparkles: feat(archive) - refactor archiving logic to
streamline user status checks and enhance error handling (still error from
API)
---
plugins/tasks/Archive.php | 107 ++++++++++++++++++++++++--------------
1 file changed, 69 insertions(+), 38 deletions(-)
diff --git a/plugins/tasks/Archive.php b/plugins/tasks/Archive.php
index 77492f8..f2bd8fb 100644
--- a/plugins/tasks/Archive.php
+++ b/plugins/tasks/Archive.php
@@ -32,43 +32,45 @@ class Archive implements EndpointInterface
$result = [];
$archiveTasks = $this->gateway->getObjectTypeTask('archive');
- foreach ($archiveTasks as $task) {
- // Verify the task status and schedule
- if ($this->gateway->statusAndScheduleCheck($task)) {
- // Retrieve the user's supannAccountStatus
- $userStatus = $this->getUserSupannAccountStatus($task['fdtasksgranulardn'][0]);
-
- // Check if the user meets the "toBeArchived" condition
- if ($userStatus === 'toBeArchived') {
- // Construct the archive URL
- $archiveUrl = $_ENV['FUSION_DIRECTORY_API_URL'] . '/archive/user/' . rawurlencode($task['fdtasksgranulardn'][0]);
-
- // Initialize the WebServiceCall object
- $webServiceCall = new WebServiceCall($archiveUrl, 'POST');
- $webServiceCall->setCurlSettings();
-
- // Execute the request
- $response = curl_exec($webServiceCall->ch);
-
- // Handle any cURL errors
- $webServiceCall->handleCurlError($webServiceCall->ch);
-
- // Decode and process the response
- $responseData = json_decode($response, true);
- if ($responseData && isset($responseData['success']) && $responseData['success'] === true) {
- $result[$task['dn']]['result'] = "User successfully archived.";
- $this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], '2'); // Mark task as completed
- } else {
- $result[$task['dn']]['result'] = "Error archiving user.";
- $this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], '3'); // Mark task as failed
- }
+ // Initialize the WebServiceCall object for login
+ $webServiceCall = new WebServiceCall($_ENV['FUSION_DIRECTORY_API_URL'] . '/login', 'POST');
+ $webServiceCall->setCurlSettings(); // Perform login and set the token
- // Close the cURL resource
- curl_close($webServiceCall->ch);
- } else {
- $result[$task['dn']]['result'] = "User does not meet the criteria for archiving.";
+ 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'
+ $supannState = $this->getUserSupannAccountStatus($task['fdtasksgranulardn'][0]);
+
+ if ($supannState !== 'toBeArchived') {
+ // 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, [], 'POST'); // Update settings for the archive request
+ $response = $webServiceCall->execute();
+
+ print_r([$response]);
+ exit;
+
+ if (isset($response['success']) && $response['success'] === true) {
+ $result[$task['dn']]['result'] = "User successfully archived.";
+ $this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], '2');
+ } else {
+ throw new Exception("Invalid API response format");
+ }
+ } catch (Exception $e) {
+ $result[$task['dn']]['result'] = "Error archiving user: " . $e->getMessage();
+ $this->gateway->updateTaskStatus($task['dn'], $task['cn'][0], $e->getMessage());
}
- }
}
return $result;
@@ -101,8 +103,37 @@ class Archive implements EndpointInterface
*/
private function getUserSupannAccountStatus(string $userDn): ?string
{
- // Logic to retrieve the supannAccountStatus attribute of the user
- $user = $this->gateway->getLdapEntry($userDn, ['supannAccountStatus']);
- return $user['supannAccountStatus'][0] ?? NULL;
+ $supannState = $this->gateway->getLdapTasks(
+ '(objectClass=supannPerson)',
+ ['supannRessourceEtatDate'],
+ '',
+ $userDn
+ );
+
+ if ($this->hasToBeArchived($supannState)) {
+ return 'toBeArchived';
+ }
+
+ return null;
+ }
+
+ private function hasToBeArchived(array $supannState): bool
+ {
+ if (!isset($supannState[0]['supannressourceetatdate']) || !is_array($supannState[0]['supannressourceetatdate'])) {
+ return false;
+ }
+
+ foreach ($supannState[0]['supannressourceetatdate'] as $key => $value) {
+ // Skip non-numeric keys (e.g., 'count')
+ if (!is_numeric($key)) {
+ continue;
+ }
+
+ if (strpos($value, '{COMPTE}I:toBeArchived') !== false) {
+ return true;
+ }
+ }
+
+ return false;
}
}
\ No newline at end of file
--
GitLab
From eff284c0a31c1b726c44c1ecae26a7bc055176b1 Mon Sep 17 00:00:00 2001
From: Thibault Dockx <thibault.dockx@fusiondirectory.org>
Date: Tue, 25 Mar 2025 11:57:08 +0000
Subject: [PATCH 19/21] :sparkles: feat(archive) - update archive request
settings and improve error handling for unexpected HTTP status codes
---
plugins/tasks/Archive.php | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
diff --git a/plugins/tasks/Archive.php b/plugins/tasks/Archive.php
index f2bd8fb..593c99d 100644
--- a/plugins/tasks/Archive.php
+++ b/plugins/tasks/Archive.php
@@ -55,17 +55,15 @@ class Archive implements EndpointInterface
// 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, [], 'POST'); // Update settings for the archive request
+ $webServiceCall->setCurlSettings($archiveUrl, NULL, 'POST'); // Update settings for the archive request
$response = $webServiceCall->execute();
- print_r([$response]);
- exit;
-
- if (isset($response['success']) && $response['success'] === true) {
+ // 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("Invalid API response format");
+ throw new Exception("Unexpected HTTP status code: " . $webServiceCall->getHttpStatusCode());
}
} catch (Exception $e) {
$result[$task['dn']]['result'] = "Error archiving user: " . $e->getMessage();
--
GitLab
From e2970af4740176a64cf189779e4019ecaae91b2e Mon Sep 17 00:00:00 2001
From: Thibault Dockx <thibault.dockx@fusiondirectory.org>
Date: Tue, 25 Mar 2025 15:17:33 +0000
Subject: [PATCH 20/21] :art: style(archive) - apply consistent spacing in
method signatures and improve code readability
---
plugins/tasks/Archive.php | 112 +++++++++++++++++++-------------------
1 file changed, 56 insertions(+), 56 deletions(-)
diff --git a/plugins/tasks/Archive.php b/plugins/tasks/Archive.php
index 593c99d..2ef3e2f 100644
--- a/plugins/tasks/Archive.php
+++ b/plugins/tasks/Archive.php
@@ -6,7 +6,7 @@ class Archive implements EndpointInterface
{
private TaskGateway $gateway;
- public function __construct(TaskGateway $gateway)
+ public function __construct (TaskGateway $gateway)
{
$this->gateway = $gateway;
}
@@ -15,7 +15,7 @@ class Archive implements EndpointInterface
* @return array
* Part of the interface of orchestrator plugin to treat GET method
*/
- public function processEndPointGet(): array
+ public function processEndPointGet (): array
{
// Retrieve tasks of type 'archive'
return $this->gateway->getObjectTypeTask('archive');
@@ -27,7 +27,7 @@ class Archive implements EndpointInterface
* @throws Exception
* Note: Part of the interface of orchestrator plugin to treat PATCH method
*/
- public function processEndPointPatch(array $data = NULL): array
+ public function processEndPointPatch (array $data = NULL): array
{
$result = [];
$archiveTasks = $this->gateway->getObjectTypeTask('archive');
@@ -37,38 +37,38 @@ class Archive implements EndpointInterface
$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'
- $supannState = $this->getUserSupannAccountStatus($task['fdtasksgranulardn'][0]);
-
- if ($supannState !== 'toBeArchived') {
- // 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());
+ try {
+ if (!$this->gateway->statusAndScheduleCheck($task)) {
+ // Skip this task if it does not meet the status and schedule criteria
+ continue;
}
+
+ // Receive null or 'toBeArchived'
+ $supannState = $this->getUserSupannAccountStatus($task['fdtasksgranulardn'][0]);
+
+ if ($supannState !== 'toBeArchived') {
+ // 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());
+ }
}
return $result;
@@ -79,7 +79,7 @@ class Archive implements EndpointInterface
* @return array
* Note: Part of the interface of orchestrator plugin to treat POST method
*/
- public function processEndPointPost(array $data = NULL): array
+ public function processEndPointPost (array $data = NULL): array
{
return [];
}
@@ -89,7 +89,7 @@ class Archive implements EndpointInterface
* @return array
* Note: Part of the interface of orchestrator plugin to treat DELETE method
*/
- public function processEndPointDelete(array $data = NULL): array
+ public function processEndPointDelete (array $data = NULL): array
{
return [];
}
@@ -99,7 +99,7 @@ class Archive implements EndpointInterface
* @param string $userDn
* @return string|null
*/
- private function getUserSupannAccountStatus(string $userDn): ?string
+ private function getUserSupannAccountStatus (string $userDn): ?string
{
$supannState = $this->gateway->getLdapTasks(
'(objectClass=supannPerson)',
@@ -107,31 +107,31 @@ class Archive implements EndpointInterface
'',
$userDn
);
-
- if ($this->hasToBeArchived($supannState)) {
- return 'toBeArchived';
- }
-
- return null;
+
+ if ($this->hasToBeArchived($supannState)) {
+ return 'toBeArchived';
+ }
+
+ return NULL;
}
- private function hasToBeArchived(array $supannState): bool
+ private function hasToBeArchived (array $supannState): bool
{
- if (!isset($supannState[0]['supannressourceetatdate']) || !is_array($supannState[0]['supannressourceetatdate'])) {
- return false;
- }
+ if (!isset($supannState[0]['supannressourceetatdate']) || !is_array($supannState[0]['supannressourceetatdate'])) {
+ return FALSE;
+ }
- foreach ($supannState[0]['supannressourceetatdate'] as $key => $value) {
- // Skip non-numeric keys (e.g., 'count')
- if (!is_numeric($key)) {
- continue;
- }
+ foreach ($supannState[0]['supannressourceetatdate'] as $key => $value) {
+ // Skip non-numeric keys (e.g., 'count')
+ if (!is_numeric($key)) {
+ continue;
+ }
- if (strpos($value, '{COMPTE}I:toBeArchived') !== false) {
- return true;
- }
+ if (strpos($value, '{COMPTE}I:toBeArchived') !== FALSE) {
+ return TRUE;
}
+ }
- return false;
+ return FALSE;
}
}
\ No newline at end of file
--
GitLab
From 4169a2bd21220e19168015713eeda654f11b4e7b Mon Sep 17 00:00:00 2001
From: Benoit Mortier <benoit.mortier@fusiondirectory.org>
Date: Tue, 25 Mar 2025 18:11:35 +0100
Subject: [PATCH 21/21] :ambulance: fix(centos) remove centos from the builds
Signed-off-by: Benoit Mortier <benoit.mortier@fusiondirectory.org>
---
.gitlab-ci.yml | 7 -------
1 file changed, 7 deletions(-)
diff --git a/.gitlab-ci.yml b/.gitlab-ci.yml
index 1e84902..8356ce6 100644
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@@ -93,10 +93,3 @@ trigger-ci-ubuntu-focal:
project: ubuntu/focal-fusiondirectory-orchestrator-dev
branch: "main"
-trigger-ci-centos-7:
- stage: trigger
- only:
- - dev
- trigger:
- project: centos/centos7-fusiondirectory-orchestrator-dev
- branch: "main"
--
GitLab