The event handler for sending

This commit is contained in:
Valentin Popov 2017-10-26 06:45:53 +04:00
parent 28632834af
commit 8651e6a157

View File

@ -59,13 +59,29 @@ class events {
if ($callbacks->valid()) { if ($callbacks->valid()) {
foreach ($callbacks as $callback) { foreach ($callbacks as $callback) {
self::send($data, $callback); self::handlerCallback($data, $callback);
} }
} }
$callbacks->close(); $callbacks->close();
} }
/**
* Processes each callback.
*
* @param array $data
* @param object $callback
*/
private static function handlerCallback($data, $callback) {
if ($callback->enable) {
$events = unserialize(gzuncompress(base64_decode($callback->events)));
if (boolval($events[$data["eventname"]])) {
self::send($data, $callback);
}
}
}
/** /**
* Sending data to the node. * Sending data to the node.
* *
@ -73,11 +89,9 @@ class events {
* @param object $callback * @param object $callback
*/ */
private static function send($data, $callback) { private static function send($data, $callback) {
if ($callback->enable) { $curl = new curl();
$curl = new curl(); $package = self::packup($data);
$package = self::packup($data); $curl::request($callback->url, $package);
$curl::request($callback->url, $package);
}
} }
/** /**