prehistoric-systems/mytinytodo
1
0
Fork 0
mirror of https://github.com/maxpozdeev/mytinytodo.git synced 2026-03-11 08:55:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

implement special notification didFinishRequest (useful for some post-processing in php-fpm)

Browse source
This commit is contained in:
maxpozdeev 2022-09-05 22:28:59 +03:00
parent bb23883e5b
commit b226c00e42
2 changed files with 19 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
src/includes/notifications.php
View file

@ -7,11 +7,6 @@ class MTTNotificationCenter
*/
private static $observers = [];
/**
* @var array<array>
*/
private static $notificationStore = [];
/**
* @param string $notification
* @param MTTNotificationObserverInterface $observer
@ -22,7 +17,10 @@ class MTTNotificationCenter
if (!isset(self::$observers[$notification])) {
self::$observers[$notification] = [];
}
self::$observers[$notification][] = $observer;
if (!in_array($observer, self::$observers[$notification])) {
// do not duplicate same observer
self::$observers[$notification][] = $observer;
}
}
/**
@ -40,35 +38,30 @@ class MTTNotificationCenter
public static function postNotification(string $notification, $object)
{
self::$notificationStore[] = [
'notification' => $notification,
'object' => $object
];
if (!isset(self::$observers[$notification])) {
return; // No observers for this notification
}
foreach (self::$observers[$notification] as $observer) {
$observer->notification($notification, $object);
}
}
/**
* Run this near exit()
* @return void
*/
public static function notifyDelayedObservers()
public static function postDidFinishRequestNotification()
{
if (count(self::$notificationStore) == 0) {
return; // No notifications
}
if (session_status() == PHP_SESSION_ACTIVE) {
session_write_close(); // Close active session
if ( ! isset(self::$observers[MTTNotification::didFinishRequest]) ) {
return; // No observers for didFinishRequest
}
if (function_exists('fastcgi_finish_request')) {
if (session_status() == PHP_SESSION_ACTIVE) {
session_write_close(); // Close active session
}
fastcgi_finish_request();
}
foreach (self::$notificationStore as $notificationItem) {
$notification = $notificationItem['notification'];
$object = $notificationItem['object'];
$observers = self::$observers[$notification] ?? [];
foreach ($observers as $observer) {
$observer->notification($notification, $object);
}
}
self::postNotification(MTTNotification::didFinishRequest, null);
}
}
@ -80,6 +73,7 @@ interface MTTNotificationObserverInterface
// Enum
abstract class MTTNotification
{
const didFinishRequest = 'didFinishRequest';
const didCreateTask = 'didCreateTask';
const didCreateList = 'didCreateList';
}

2
src/init.php
View file

@ -323,7 +323,7 @@ function jsonExit($data)
header('Pragma: no-cache'); // for old HTTP/1.0 intermediate caches
header_remove('Expires');
echo json_encode($data, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
MTTNotificationCenter::notifyDelayedObservers();
MTTNotificationCenter::postDidFinishRequestNotification();
exit;
}