Repeated refactoring of the event handler
This commit is contained in:
parent
91754489b0
commit
05512c5440
@ -26,6 +26,8 @@ namespace local_webhooks;
|
|||||||
|
|
||||||
defined("MOODLE_INTERNAL") || die();
|
defined("MOODLE_INTERNAL") || die();
|
||||||
|
|
||||||
|
require_once(__DIR__ . "/../lib.php");
|
||||||
|
|
||||||
require_once($CFG->libdir . "/filelib.php");
|
require_once($CFG->libdir . "/filelib.php");
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -42,16 +44,6 @@ class handler {
|
|||||||
*/
|
*/
|
||||||
public static function events($event) {
|
public static function events($event) {
|
||||||
$data = $event->get_data();
|
$data = $event->get_data();
|
||||||
self::transmitter($data);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Transmitter, processing event and services.
|
|
||||||
*
|
|
||||||
* @param array $data
|
|
||||||
*/
|
|
||||||
private static function transmitter($data) {
|
|
||||||
global $DB;
|
|
||||||
|
|
||||||
if ($callbacks = local_webhooks_get_list_records()) {
|
if ($callbacks = local_webhooks_get_list_records()) {
|
||||||
foreach ($callbacks as $callback) {
|
foreach ($callbacks as $callback) {
|
||||||
@ -70,17 +62,12 @@ class handler {
|
|||||||
global $CFG;
|
global $CFG;
|
||||||
|
|
||||||
if (boolval($callback->enable)) {
|
if (boolval($callback->enable)) {
|
||||||
if (!empty($events[$data["eventname"]])) {
|
if (!empty($data["eventname"])) {
|
||||||
$urlparse = parse_url($CFG->wwwroot);
|
$urlparse = parse_url($CFG->wwwroot);
|
||||||
$data["host"] = $urlparse['host'];
|
|
||||||
|
|
||||||
if (!empty($callback->token)) {
|
$data["host"] = $urlparse['host'];
|
||||||
$data["token"] = $callback->token;
|
$data["token"] = $callback->token;
|
||||||
}
|
$data["extra"] = $callback->other;
|
||||||
|
|
||||||
if (!empty($callback->other)) {
|
|
||||||
$data["extra"] = $callback->other;
|
|
||||||
}
|
|
||||||
|
|
||||||
self::send($data, $callback);
|
self::send($data, $callback);
|
||||||
}
|
}
|
||||||
@ -95,7 +82,7 @@ class handler {
|
|||||||
*/
|
*/
|
||||||
private static function send($data, $callback) {
|
private static function send($data, $callback) {
|
||||||
$curl = new \curl();
|
$curl = new \curl();
|
||||||
$curl->setHeader(array("Content-Type: application/$callback->type"));
|
$curl->setHeader(array("Content-Type: application/" . $callback->type));
|
||||||
$curl->post($callback->url, json_encode($data));
|
$curl->post($callback->url, json_encode($data));
|
||||||
|
|
||||||
$response = $curl->getResponse();
|
$response = $curl->getResponse();
|
||||||
|
Loading…
x
Reference in New Issue
Block a user