. * * @author Daniil Gentili * @copyright 2016-2025 Daniil Gentili * @license https://opensource.org/licenses/AGPL-3.0 AGPLv3 * @link https://docs.madelineproto.xyz MadelineProto documentation */ namespace danog\MadelineProto; use function Amp\ByteStream\getStdin; /** * Class that controls script shutdown. */ final class Shutdown { /** * Callbacks to call on shutdown. * * @var array */ private static array $callbacks = []; /** * Whether the main shutdown was registered. * */ private static bool $registered = false; /** * Incremental ID for new callback. * */ private static int $id = 0; /** * Function to be called on shutdown. */ private static function shutdown(): void { foreach (self::$callbacks as $callback) { $callback(); } self::$callbacks = []; if (\defined('STDIN')) { getStdin()->unreference(); } API::finalize(); MTProto::serializeAll(); Logger::finalize(); if (class_exists(Installer::class)) { Installer::unlock(); } } /** * Register shutdown function. */ public static function init(): void { if (!self::$registered) { register_shutdown_function(static fn () => self::shutdown()); self::$registered = true; } } /** * Add a callback for script shutdown. * * @param callable $callback The callback to set * @param null|string $id The optional callback ID * @return int|string The callback ID */ public static function addCallback(callable $callback, ?string $id = null): int|string { if (!$id) { $id = self::$id++; } self::$callbacks[$id] = $callback; self::init(); return $id; } /** * Remove a callback from the script shutdown callable list. * * @param null|string|int $id The optional callback ID * @return bool true if the callback was removed correctly, false otherwise */ public static function removeCallback(string|int|null $id): bool { if (isset(self::$callbacks[$id])) { unset(self::$callbacks[$id]); return true; } return false; } }