Ego_Process.php

gehe zur Dokumentation dieser Datei

<?php
class Ego_Process {
    private $id;
    private $pid = 0;
    private $path;
    private $ttl;
    private $format = 'Y-m-d H:i:s';
    private $destruct = true;
 
    public function __construct(string $id = '', int $ttl = 3600) {
        $this->id = $id ?: md5(microtime());
        $this->path = $GLOBALS['egotec_conf']['tmp_dir'] . "pid_{$this->id}";
        $this->ttl = $ttl;
 
        if ($id == '') {
            // Aktuelle Prozess-ID verwenden
            $this->pid = getmypid();
 
            // Neuen Prozess-Stempel anlegen
            Ego_System::file_put_contents($this->path, json_encode([
                'created' => date($this->format),
                'pid' => $this->pid
            ], JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT));
 
            // ...und am Ende des Prozesses löschen
            register_shutdown_function([$this, 'remove']);
        } else {
            $value = $this->read();
            if (!empty($value)) {
                $this->pid = $value['pid'];
                $this->destruct = false;
            }
        }
    }
 
    public function __destruct() {
        if ($this->destruct) {
            $this->remove();
        }
    }
 
    public function id() : string {
        return $this->id;
    }
 
    public function pid() : int {
        return $this->pid;
    }
 
    private function read() : array {
        if (Ego_System::file_exists($this->path)) {
            $value = Ego_System::file_get_contents($this->path);
            if (!empty($value)) {
                $value = json_decode($value, true);
                if (!empty($value)) {
                    return $value;
                }
            }
        }
        return [];
    }
 
    public function exists() : bool {
        $value = $this->read();
        if (!empty($value)) {
            if (function_exists('posix_getpgid') && !posix_getpgid($value['pid'])) {
                return false;
            }
            return date($this->format, strtotime($value['created']) + $this->ttl) > date($this->format);
        }
        return false;
    }
 
    public function remove() : void {
        // Prozess-Stempel löschen
        @unlink($this->path);
    }
}