flack / openpsa

lib/midcom/cron/purgedeleted.php

<?php
/**
 * @package midcom.services
 * @author The Midgard Project, http://www.midgard-project.org
 * @copyright The Midgard Project, http://www.midgard-project.org
 * @license http://www.gnu.org/licenses/lgpl.html GNU Lesser General Public License
 */

/**
 * @package midcom.services
 */
class midcom_cron_purgedeleted extends midcom_baseclasses_components_cron_handler
{
    private int $_cutoff;

    public function set_cutoff(int $days)
    {
        $this->_cutoff = strtotime($days . ' days ago');
    }

    public function get_cutoff() : int
    {
        if (empty($this->_cutoff)) {
            $this->set_cutoff(midcom::get()->config->get('cron_purge_deleted_after'));

It seems like midcom::get()->config->get('cron_purge_deleted_after') can also be of type null; however, parameter $days of midcom_cron_purgedeleted::set_cutoff() does only seem to accept integer, maybe add an additional type check?

        }
        return $this->_cutoff;
    }

    public function get_classes() : array
    {
        return array_filter(midcom_connection::get_schema_types(), function($mgdschema) {
            return midgard_reflector_object::has_metadata_class($mgdschema);
        });
    }

    public function execute()
    {
        $cut_off = $this->get_cutoff();
        debug_add('Purging entries deleted before ' . gmdate('Y-m-d H:i:s', $cut_off) . "\n");
        foreach ($this->get_classes() as $mgdschema) {
            debug_add("Processing class {$mgdschema}");
            $stats = $this->process_class($mgdschema);

            foreach ($stats['errors'] as $error) {
                debug_add($error, MIDCOM_LOG_ERROR);
            }
            if ($stats['found'] > 0) {
                debug_add("  Found {$stats['found']} deleted {$mgdschema} objects, purged {$stats['purged']}\n", MIDCOM_LOG_INFO);
            } else {
                debug_add("  No {$mgdschema} objects deleted before cutoff date found\n");
            }
        }
    }

    public function process_class(string $mgdschema) : array
    {
        $cut_off = $this->get_cutoff();
        $qb = new midgard_query_builder($mgdschema);
        $qb->add_constraint('metadata.deleted', '<>', 0);
        $qb->add_constraint('metadata.revised', '<', gmdate('Y-m-d H:i:s', $cut_off));
        $qb->include_deleted();

        $stats = [
            'found' => 0,
            'purged' => 0,
            'errors' => []
        ];

        foreach ($qb->iterate() as $obj) {
            $stats['found']++;
            if (!$obj->purge()) {
                $stats['errors'][] = "Failed to purge {$obj->guid}, deleted: {$obj->metadata->deleted}, revised: {$obj->metadata->revised}. errstr: " . midcom_connection::get_error_string();
                debug_print_r('Purge failed for object', $obj);
                continue;
            }
            $stats['purged']++;
        }
        return $stats;
    }
}