moodle/local_webhooks
0
Fork 0
Code Issues Releases Activity

Added worked a class observer

Browse Source 
Signed-off-by: Valentin Popov <info@valentineus.link>
This commit is contained in:
Valentin Popov
2019-05-06 05:45:35 +04:00
parent bde135499d
commit eb4b9b69f8
4 changed files with 110 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
classes/event_observer.php → classes/event/observer.php
View File

@@ -14,35 +14,31 @@
// You should have received a copy of the GNU General Public License
// along with Moodle. If not, see <http://www.gnu.org/licenses/>.
/**
* Handlers of observers for events.
*
* @copyright 2018 'Valentin Popov' <info@valentineus.link>
* @license http://www.gnu.org/copyleft/gpl.html GNU GPL v3 or later
* @package local_webhooks
*/
namespace local_webhooks;
namespace local_webhooks\event;
defined('MOODLE_INTERNAL') || die();
use core\event\base as event;
use core\task\manager;
use local_webhooks\task\notify;
use function defined;
/**
* Defines event handlers.
* Class observer.
*
* @copyright 2018 'Valentin Popov' <info@valentineus.link>
* @copyright 2019 'Valentin Popov' <info@valentineus.link>
* @license http://www.gnu.org/copyleft/gpl.html GNU GPL v3 or later
* @package local_webhooks
* @package local_webhooks\event
*/
class event_observer {
final class observer {
/**
* Handler of all the events.
* Each event is put into the job queue.
* Main handler for events.
*
* @param object $event
* @param \core\event\base $event
*/
public static function observe_all($event) {
$task = new \local_webhooks\task\process_events_task();
public static function handler(event $event) {
$task = new notify();
$task->set_custom_data($event->get_data());
\core\task\manager::queue_adhoc_task($task);
manager::queue_adhoc_task($task);
}
}

2
classes/task/notify.php
View File

@@ -79,7 +79,7 @@ final class notify extends adhoc_task {
public function post(record $service, array $data) {
$curl = new curl();
$curl->setHeader(['Content-Type: ' . $service->header]);
$curl->post($service->point, $data);
$curl->post($service->point, json_encode($data));
if (defined('PHPUNIT_TEST') && PHPUNIT_TEST) {
$this->debug = array_merge($this->debug ?? [], [

13
db/events.php
View File

@@ -17,16 +17,15 @@
/**
* Registration of observers for events.
*
* @copyright 2018 'Valentin Popov' <info@valentineus.link>
* @copyright 2019 'Valentin Popov' <info@valentineus.link>
* @license http://www.gnu.org/copyleft/gpl.html GNU GPL v3 or later
* @package local_webhooks
*/
defined('MOODLE_INTERNAL') || die();
$observers = array(
array(
'callback' => '\local_webhooks\event_observer::observe_all',
$observers = [
[
'callback' => '\local_webhooks\event\observer::handler',
'eventname' => '*',
),
);
],
];

89
tests/task_test.php
View File

@@ -64,7 +64,7 @@ final class local_webhooks_task_testcase extends advanced_testcase {
$record->status = false;
$record->token = '967b2286-0874-4938-b088-efdbcf8a79bc';
$record->id = api::create_service($record);
api::create_service($record);
$task = new notify();
$task->set_custom_data(['eventname' => '\core\event\course_viewed']);
@@ -108,4 +108,91 @@ final class local_webhooks_task_testcase extends advanced_testcase {
self::assertEquals($record->id, $element['service']->id);
self::assertEquals($record->token, $element['data']['token']);
}
/**
* Testing count creating tasks.
*
* @throws \coding_exception
* @throws \dml_exception
*/
public function test_observer_multiple() {
$generator = self::getDataGenerator();
curl::mock_response('{}');
$this->resetAfterTest();
$record = new record();
$record->events = ['\core\event\course_created'];
$record->header = 'application/json';
$record->name = 'Example name';
$record->point = 'http://example.org/';
$record->status = true;
$record->token = '967b2286-0874-4938-b088-efdbcf8a79bc';
api::create_service($record);
$total = random_int(5, 20);
for ($i = 0; $i < $total; $i++) {
$generator->create_course();
}
$debug = [];
foreach (manager::get_adhoc_tasks(notify::class) as $event) {
if (!is_object($event)) {
continue;
}
/** @var \local_webhooks\task\notify $event */
$event->execute();
if (isset($event->debug) && is_array($event->debug)) {
$debug[] = array_merge(...$event->debug);
}
}
self::assertCount($total, $debug);
}
/**
* Testing structure a creating task.
*
* @throws \coding_exception
* @throws \dml_exception
*/
public function test_observer_single() {
$generator = self::getDataGenerator();
curl::mock_response('{}');
$this->resetAfterTest();
$record = new record();
$record->events = ['\core\event\course_created'];
$record->header = 'application/json';
$record->name = 'Example name';
$record->point = 'http://example.org/';
$record->status = true;
$record->token = '967b2286-0874-4938-b088-efdbcf8a79bc';
api::create_service($record);
$course = $generator->create_course();
$debug = [];
foreach (manager::get_adhoc_tasks(notify::class) as $event) {
if (!is_object($event)) {
continue;
}
/** @var \local_webhooks\task\notify $event */
$event->execute();
if (isset($event->debug) && is_array($event->debug)) {
$debug[] = array_merge(...$event->debug);
}
}
self::assertCount(1, $debug);
$element = array_shift($debug);
self::assertInternalType('array', $element['data']);
self::assertEquals($course->id, $element['data']['courseid']);
}
}