Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]

<?php

/**
 * @package koko-analytics
 * @license GPL-3.0+
 * @author Danny van Kooten
 */

namespace KokoAnalytics;

use Exception;

class Migrations
{
    protected $option_name;
    protected $version_from;
    protected $version_to;
    protected $current_version;
    protected $migrations_dir;

    public function __construct(string $option_name, string $version_to, string $migrations_dir)
    {
        $this->option_name = $option_name;
        $this->version_from = get_option($this->option_name, '0.0.0');
        $this->version_to = $version_to;
        $this->migrations_dir = $migrations_dir;
    }

    public function maybe_run(): void
    {
        if (\version_compare($this->version_from, $this->version_to, '>=')) {
            return;
        }

        // check if migrations not already running
        if (get_transient('koko_analytics_migrations_running')) {
            return;
        }

        set_transient('koko_analytics_migrations_running', true, 120);
        $this->run();
        delete_transient('koko_analytics_migrations_running');
    }

    /**
     * Run the various migration files, all the way up to the latest version
     */
    protected function run(): void
    {
        $files = glob(rtrim($this->migrations_dir, '/') . '/*.php');
        if (! is_array($files)) {
            return;
        }

        // run each migration file
        foreach ($files as $file) {
            $this->handle_file($file);
        }

        // update database version to current code version
        update_option($this->option_name, $this->version_to, true);
    }

    /**
     * @param string Absolute path to migration file
     */
    protected function handle_file(string $file): void
    {
        $migration = basename($file);
        $parts     = explode('-', $migration);
        $migraton_version   = $parts[0];

        // check if migration file is not for an even higher version
        if (version_compare($migraton_version, $this->version_to, '>')) {
            return;
        }

        // check if we ran migration file before.
        if (version_compare($this->version_from, $migraton_version, '>=')) {
            return;
        }

        // run migration file
        include $file;

        // update option so later runs start after this migration
        $this->version_from = $migraton_version;
        update_option($this->option_name, $migraton_version, true);
    }
}