Skip to content
Snippets Groups Projects
Verified Commit 49e1e508 authored by Florian Azizian's avatar Florian Azizian
Browse files

FEAT #65 notificationSchedule

parent 26cd343e
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
core/Test/NotificationScheduleControllerTest.php 0 → 100644
+ 219
− 0
View file @ 49e1e508
<?php
/**
* Copyright Maarch since 2008 under licence GPLv3.
* See LICENCE.txt file at the root folder for more details.
* This file is part of Maarch software.
* @brief NotificationsScheduleControllerTest
* @author dev <dev@maarch.org>
* @ingroup core
*/
use PHPUnit\Framework\TestCase;
class NotificationScheduleControllerTest extends TestCase
{
private static $id = null;
public function testCreateScript()
{
$NotificationScheduleController = new \Notification\controllers\NotificationScheduleController();
// CREATE FAIL
$environment = \Slim\Http\Environment::mock(['REQUEST_METHOD' => 'POST']);
$request = \Slim\Http\Request::createFromEnvironment($environment);
$aArgs = [
"notification_sid" => "gaz",
"notification_id" => "",
];
$fullRequest = \httpRequestCustom::addContentInBody($aArgs, $request);
$response = $NotificationScheduleController->createScriptNotification($fullRequest, new \Slim\Http\Response());
$responseBody = json_decode((string)$response->getBody());
$this->assertSame("notification_sid is not a numeric", $responseBody->errors[0]);
$this->assertSame("one of arguments is empty", $responseBody->errors[1]);
// CREATE
$environment = \Slim\Http\Environment::mock(['REQUEST_METHOD' => 'POST']);
$request = \Slim\Http\Request::createFromEnvironment($environment);
$aArgs = [
"notification_sid" => 1,
"notification_id" => "USERS",
];
$fullRequest = \httpRequestCustom::addContentInBody($aArgs, $request);
$response = $NotificationScheduleController->createScriptNotification($fullRequest, new \Slim\Http\Response());
$responseBody = json_decode((string)$response->getBody());
$this->assertSame(true, $responseBody);
}
public function testSaveCrontab()
{
$NotificationScheduleController = new \Notification\controllers\NotificationScheduleController();
$environment = \Slim\Http\Environment::mock(['REQUEST_METHOD' => 'GET']);
$request = \Slim\Http\Request::createFromEnvironment($environment);
$response = $NotificationScheduleController->get($request, new \Slim\Http\Response());
$responseBody = json_decode((string)$response->getBody());
// CREATE FAIL
$aArgs = [];
$aArgs = $responseBody->crontab;
$corePath = dirname(__FILE__, 3) . '/';
$newCrontab = [
"m" => 12,
"h" => 23,
"dom" => "",
"mon" => "*",
"dow" => "*",
"cmd" => $corePath . "modules/notifications/batch/scripts/notification_testtu.sh",
"state" => "new",
];
array_push($aArgs, $newCrontab);
$fullRequest = \httpRequestCustom::addContentInBody($aArgs, $request);
$response = $NotificationScheduleController->saveCrontab($fullRequest, new \Slim\Http\Response());
$responseBodyFail = json_decode((string)$response->getBody());
$this->assertSame("dom is empty", $responseBodyFail->errors[0]);
// CREATE
$environment = \Slim\Http\Environment::mock(['REQUEST_METHOD' => 'POST']);
$request = \Slim\Http\Request::createFromEnvironment($environment);
$aArgs = [];
$aArgs = $responseBody->crontab;
$corePath = dirname(__FILE__, 3) . '/';
$newCrontab = [
"m" => 12,
"h" => 23,
"dom" => "*",
"mon" => "*",
"dow" => "*",
"cmd" => $corePath . "modules/notifications/batch/scripts/notification_testtu.sh",
"state" => "new",
];
array_push($aArgs, $newCrontab);
$fullRequest = \httpRequestCustom::addContentInBody($aArgs, $request);
$response = $NotificationScheduleController->saveCrontab($fullRequest, new \Slim\Http\Response());
$responseBodyCreate = json_decode((string)$response->getBody());
$this->assertSame(true, $responseBodyCreate);
}
public function testReadAll()
{
$environment = \Slim\Http\Environment::mock(['REQUEST_METHOD' => 'GET']);
$request = \Slim\Http\Request::createFromEnvironment($environment);
$NotificationScheduleController = new \Notification\controllers\NotificationScheduleController();
$response = $NotificationScheduleController->get($request, new \Slim\Http\Response());
$responseBody = json_decode((string)$response->getBody());
$this->assertInternalType('array', $responseBody->crontab);
$this->assertInternalType('object', $responseBody->authorizedNotification);
$this->assertNotNull($responseBody->authorizedNotification);
$this->assertNotNull($responseBody->crontab);
}
public function testUpdateCrontab()
{
$NotificationScheduleController = new \Notification\controllers\NotificationScheduleController();
$environment = \Slim\Http\Environment::mock(['REQUEST_METHOD' => 'GET']);
$request = \Slim\Http\Request::createFromEnvironment($environment);
$response = $NotificationScheduleController->get($request, new \Slim\Http\Response());
$responseBody = json_decode((string)$response->getBody());
// UPDATE
$environment = \Slim\Http\Environment::mock(['REQUEST_METHOD' => 'POST']);
$request = \Slim\Http\Request::createFromEnvironment($environment);
$aArgs = [];
$aArgs = $responseBody->crontab;
$corePath = dirname(__FILE__, 3) . '/';
$aArgs[count($aArgs)-1] = [
"m" => 35,
"h" => 22,
"dom" => "*",
"mon" => "*",
"dow" => "*",
"cmd" => $corePath . "modules/notifications/batch/scripts/notification_testtu.sh",
"state" => "normal",
];
$fullRequest = \httpRequestCustom::addContentInBody($aArgs, $request);
$response = $NotificationScheduleController->saveCrontab($fullRequest, new \Slim\Http\Response());
$responseBody = json_decode((string)$response->getBody());
$this->assertSame(true, $responseBody);
$environment = \Slim\Http\Environment::mock(['REQUEST_METHOD' => 'GET']);
$request = \Slim\Http\Request::createFromEnvironment($environment);
$response = $NotificationScheduleController->get($request, new \Slim\Http\Response());
$responseBody = json_decode((string)$response->getBody());
$this->assertSame('35', $responseBody->crontab[count($responseBody->crontab)-1]->m);
$this->assertSame('22', $responseBody->crontab[count($responseBody->crontab)-1]->h);
}
public function testDelete()
{
// DELETE FAIL
$NotificationScheduleController = new \Notification\controllers\NotificationScheduleController();
$environment = \Slim\Http\Environment::mock(['REQUEST_METHOD' => 'GET']);
$request = \Slim\Http\Request::createFromEnvironment($environment);
$response = $NotificationScheduleController->get($request, new \Slim\Http\Response());
$responseBody = json_decode((string)$response->getBody());
$aArgs = [];
$aArgs = $responseBody->crontab;
foreach ($aArgs as $id => $value) {
if ($value->cmd == dirname(__FILE__, 3) . '/' . "modules/notifications/batch/scripts/notification_testtu.sh") {
$aArgs[$id]->state = "hidden";
}
}
$environment = \Slim\Http\Environment::mock(['REQUEST_METHOD' => 'POST']);
$request = \Slim\Http\Request::createFromEnvironment($environment);
$fullRequest = \httpRequestCustom::addContentInBody($aArgs, $request);
$response = $NotificationScheduleController->saveCrontab($fullRequest, new \Slim\Http\Response());
$responseBodyFail = json_decode((string)$response->getBody());
$this->assertSame("Problem with crontab", $responseBodyFail->errors);
// DELETE
$aArgs = [];
$aArgs = $responseBody->crontab;
foreach ($aArgs as $id => $value) {
if ($value->cmd == dirname(__FILE__, 3) . '/' . "modules/notifications/batch/scripts/notification_testtu.sh") {
$aArgs[$id]->state = "deleted";
}
}
$fullRequest = \httpRequestCustom::addContentInBody($aArgs, $request);
$response = $NotificationScheduleController->saveCrontab($fullRequest, new \Slim\Http\Response());
$responseBody = json_decode((string)$response->getBody());
$this->assertSame(true, $responseBody);
}
}
core/Test/StatusControllerTest.php
+ 0
− 2
View file @ 49e1e508
...@@ -7,8 +7,6 @@ ...@@ -7,8 +7,6 @@
* *
*/ */
namespace MaarchTest;
use PHPUnit\Framework\TestCase; use PHPUnit\Framework\TestCase;
class StatusControllerTest extends TestCase class StatusControllerTest extends TestCase
......
phpunit.xml
+ 1
− 0
View file @ 49e1e508
...@@ -6,6 +6,7 @@ ...@@ -6,6 +6,7 @@
<file>core/Test/ActionControllerTest.php</file> <file>core/Test/ActionControllerTest.php</file>
<file>core/Test/BasketControllerTest.php</file> <file>core/Test/BasketControllerTest.php</file>
<file>core/Test/NotificationControllerTest.php</file> <file>core/Test/NotificationControllerTest.php</file>
<file>core/Test/NotificationScheduleControllerTest.php</file>
<file>core/Test/ParameterControllerTest.php</file> <file>core/Test/ParameterControllerTest.php</file>
<file>core/Test/PriorityControllerTest.php</file> <file>core/Test/PriorityControllerTest.php</file>
<file>core/Test/ReportControllerTest.php</file> <file>core/Test/ReportControllerTest.php</file>
......
src/app/notification/controllers/NotificationScheduleController.php 0 → 100644
+ 283
− 0
View file @ 49e1e508
<?php
/**
* Copyright Maarch since 2008 under licence GPLv3.
* See LICENCE.txt file at the root folder for more details.
* This file is part of Maarch software.
*
*/
/**
* @brief Notifications Schedule Controller
* @author dev@maarch.org
* @ingroup notifications
*/
namespace Notification\controllers;
use History\controllers\HistoryController;
use Respect\Validation\Validator;
use Notification\models\NotificationModel;
use Core\Models\ServiceModel;
use Slim\Http\Request;
use Slim\Http\Response;
use SrcCore\models\CoreConfigModel;
class NotificationScheduleController
{
public function get(Request $request, Response $response)
{
if (!ServiceModel::hasService(['id' => 'admin_notif', 'userId' => $GLOBALS['userId'], 'location' => 'notifications', 'type' => 'admin'])) {
return $response->withStatus(403)->withJson(['errors' => 'Service forbidden']);
}
return $response->withJson([
'crontab' => self::getCrontab(),
'authorizedNotification' => self::getAuthorizedNotifications(),
]);
}
public function saveCrontab(Request $request, Response $response)
{
if (!ServiceModel::hasService(['id' => 'admin_notif', 'userId' => $GLOBALS['userId'], 'location' => 'notifications', 'type' => 'admin'])) {
return $response->withStatus(403)->withJson(['errors' => 'Service forbidden']);
}
$data = $request->getParams();
if (!$this->checkCrontab($data)) {
return $response->withStatus(500)->withJson(['errors' => 'Problem with crontab']);
}
foreach ($data as $id => $cronValue) {
foreach ($cronValue as $key => $value) {
if (!Validator::notEmpty()->validate($value)) {
$errors[] = $key." is empty";
}
if ($key != "cmd" && $key != "state" && !Validator::intVal()->validate($value) && $value != "*") {
$errors[] = "wrong format for ".$key;
}
}
}
if (!empty($errors)) {
return $response->withStatus(500)->withJson(['errors' => $errors]);
}
$aCrontab = self::getCrontab(false);
$file = [];
foreach ($data as $id => $cronValue) {
if ($cronValue['state'] == 'hidden') {
$file[$id] = "{$aCrontab[$id]['m']}\t{$aCrontab[$id]['h']}\t{$aCrontab[$id]['dom']}\t{$aCrontab[$id]['mon']}\t{$aCrontab[$id]['dow']}\t{$aCrontab[$id]['cmd']}";
} elseif ($cronValue['state'] != 'deleted') {
$file[$id] = "{$cronValue['m']}\t{$cronValue['h']}\t{$cronValue['dom']}\t{$cronValue['mon']}\t{$cronValue['dow']}\t{$cronValue['cmd']}";
}
}
$output = '';
if (isset($file)) {
foreach ($file as $l) {
$output .= "$l\n";
}
}
$output = preg_replace("!\n+$!", "\n", $output);
file_put_contents('/tmp/crontab.plain', print_r($file, true));
file_put_contents('/tmp/crontab.txt', $output);
exec('crontab /tmp/crontab.txt');
return $response->withJson(true);
}
protected static function getCrontab($getHiddenValue = true)
{
$crontab = shell_exec('crontab -l');
$lines = explode("\n", $crontab);
$data = array();
$customId = CoreConfigModel::getCustomId();
$corePath = dirname(__FILE__, 5) . '/';
foreach ($lines as $cronLine) {
$cronLine = trim($cronLine);
if (strpos($cronLine, '#') !== false) {
$cronLine = substr($cronLine, 0, strpos($cronLine, '#'));
}
if (empty($cronLine)) {
continue;
}
$cronLine = preg_replace('![ \t]+!', ' ', $cronLine);
if ($cronLine[0] == '@') {
list($time, $cmd) = explode(' ', $cronLine, 2);
} else {
list($m, $h, $dom, $mon, $dow, $cmd) = explode(' ', $cronLine, 6);
}
if ($customId <> '') {
$pathToFolow = $corePath . 'custom/'.$customId . '/';
} else {
$pathToFolow = $corePath;
}
$state = "normal";
if (strpos($cmd, $pathToFolow.'modules/notifications/batch/scripts/') !== 0 && $getHiddenValue) {
$cmd = "hidden";
$state = 'hidden';
}
$data[] = array(
'm' => $m,
'h' => $h,
'dom' => $dom,
'mon' => $mon,
'dow' => $dow,
'cmd' => $cmd,
'state' => $state
);
}
return $data;
}
protected static function getAuthorizedNotifications()
{
$aNotification = NotificationModel::getEnableNotifications(['select' => ['notification_sid', 'description']]);
$notificationsArray = array();
$customId = CoreConfigModel::getCustomId();
$corePath = dirname(__FILE__, 5) . '/';
foreach ($aNotification as $result) {
$filename = "notification";
if (isset($customId) && $customId<>"") {
$filename.="_".str_replace(" ", "", $customId);
}
$filename.="_".$result['notification_sid'].".sh";
if ($customId <> '') {
$pathToFolow = $corePath . 'custom/'.$customId . '/';
} else {
$pathToFolow = $corePath;
}
$path = $pathToFolow.'modules/notifications/batch/scripts/'.$filename;
if (file_exists($path)) {
$notificationsArray[$path] = $result['description'];
}
}
return $notificationsArray;
}
protected static function checkCrontab($crontabToSave)
{
$customId = CoreConfigModel::getCustomId();
$crontabBeforeSave = self::getCrontab();
$corePath = dirname(__FILE__, 5) . '/';
foreach ($crontabToSave as $id => $cronValue) {
if ($cronValue['state'] != "hidden" && $crontabBeforeSave[$id]['state'] == "hidden") {
$returnValue = false;
break;
} elseif ($cronValue['state'] == "hidden" && $crontabBeforeSave[$id]['state'] != "hidden") {
$returnValue = false;
break;
} elseif ($cronValue['state'] == "new" || $cronValue['state'] == "normal") {
if ($customId <> '') {
$pathToFolow = $corePath . 'custom/'.$customId . '/';
} else {
$pathToFolow = $corePath;
}
$returnValue = true;
if (strpos($crontabToSave[$id]['cmd'], $pathToFolow.'modules/notifications/batch/scripts/') !== 0) {
$returnValue = false;
break;
}
} else {
$returnValue = true;
}
}
return $returnValue;
}
public function createScriptNotification(Request $request, Response $response)
{
if (!ServiceModel::hasService(['id' => 'admin_notif', 'userId' => $GLOBALS['userId'], 'location' => 'notifications', 'type' => 'admin'])) {
return $response->withStatus(403)->withJson(['errors' => 'Service forbidden']);
}
$errors = [];
$data = $request->getParams();
if (!Validator::intVal()->validate($data['notification_sid'])) {
$errors[] = 'notification_sid is not a numeric';
}
if (!Validator::notEmpty()->validate($data['notification_sid']) ||
!Validator::notEmpty()->validate($data['notification_id'])) {
$errors[] = 'one of arguments is empty';
}
if (!empty($errors)) {
return $response
->withStatus(500)
->withJson(['errors' => $errors]);
}
$notification_sid = $data['notification_sid'];
$notification_id = $data['notification_id'];
//Creer le script sh pour les notifications
$filename = "notification";
$customId = CoreConfigModel::getCustomId();
if (isset($customId) && $customId<>"") {
$filename.="_".str_replace(" ", "", $customId);
}
$filename.="_".$notification_sid.".sh";
$corePath = dirname(__FILE__, 5) . '/';
if (file_exists($corePath. 'custom/'.$customId .'/modules/notifications/batch/config/config.xml')) {
$ConfigNotif = $corePath. 'custom/'. $customId .'/modules/notifications/batch/config/config.xml';
} elseif (file_exists($corePath. 'custom/'. $customId .'/modules/notifications/batch/config/config_'.$customId.'.xml')) {
$ConfigNotif = $corePath. 'custom/'. $customId .'/modules/notifications/batch/config/config_'.$customId.'.xml';
} elseif (file_exists($corePath. 'modules/notifications/batch/config/config_'.$customId.'.xml')) {
$ConfigNotif = $corePath. 'modules/notifications/batch/config/config_'.$customId.'.xml';
} else {
$ConfigNotif = $corePath. 'modules/notifications/batch/config/config.xml';
}
if ($customId <> '') {
$pathToFolow = $corePath . 'custom/'.$customId . '/';
if (!file_exists($pathToFolow.'modules/notifications/batch/scripts/')) {
mkdir($pathToFolow.'modules/notifications/batch/scripts/', 0777, true);
}
$file_open = fopen($pathToFolow.'modules/notifications/batch/scripts/'.$filename, 'w+');
} else {
$pathToFolow = $corePath;
$file_open = fopen($pathToFolow.'modules/notifications/batch/scripts/'.$filename, 'w+');
}
fwrite($file_open, '#!/bin/sh');
fwrite($file_open, "\n");
fwrite($file_open, 'path=\''.$corePath.'modules/notifications/batch/\'');
fwrite($file_open, "\n");
fwrite($file_open, 'cd $path');
fwrite($file_open, "\n");
if ($notification_id == 'BASKETS') {
fwrite($file_open, 'php \'basket_event_stack.php\' -c '.$ConfigNotif.' -n '.$notification_id);
} elseif ($notification_id == 'RELANCE1' || $notification_id == 'RELANCE2' || $notification_id == 'RET1' || $notification_id == 'RET2') {
fwrite($file_open, 'php \'stack_letterbox_alerts.php\' -c '.$ConfigNotif);
fwrite($file_open, "\n");
fwrite($file_open, 'php \'process_event_stack.php\' -c '.$ConfigNotif.' -n '.$notification_id);
} else {
fwrite($file_open, 'php \'process_event_stack.php\' -c '.$ConfigNotif.' -n '.$notification_id);
}
fwrite($file_open, "\n");
fwrite($file_open, 'cd $path');
fwrite($file_open, "\n");
fwrite($file_open, 'php \'process_email_stack.php\' -c '.$ConfigNotif);
fwrite($file_open, "\n");
fclose($file_open);
shell_exec("chmod +x " . escapeshellarg($pathToFolow . "modules/notifications/batch/scripts/" . $filename));
return $response->withJson(true);
}
}
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