hub-loader.php

<?php

namespace SmartCloud\WPSuite\Hub;

if (!defined('ABSPATH')) {
    exit; // Exit if accessed directly.
}

use SmartCloud\WPSuite\Flow\Logger;

const SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION = '2.3.0';

final class FlowHubLoader
{
    private static ?FlowHubLoader $instance = null;

    private string $plugin;

    private string $text_domain;

    /** Hub admin instance */
    private HubAdmin $admin;

    private function __construct($plugin, $text_domain)
    {
        $this->plugin = $plugin;
        $this->text_domain = $text_domain;
        $this->includes();
    }

    /**
     * Access the singleton instance.
     */
    public static function instance($plugin, $text_domain): FlowHubLoader
    {
        if (self::$instance === null) {
            Logger::info('Initializing Flow Hub Loader singleton', [
                'plugin' => $plugin,
                'version' => SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION
            ]);
        }

        return self::$instance ?? (self::$instance = new self($plugin, $text_domain));
    }

    /**
     * Hub init callback
     */
    public function init(): void
    {
        if (!isset($this->admin)) {
            Logger::debug('Hub init skipped - admin not initialized', [
                'plugin' => $this->plugin
            ]);
            return;
        }

        Logger::info('Hub initializing', ['plugin' => $this->plugin]);

        // Hooks.
        add_action('admin_menu', array($this, 'createAdminMenu'), 10);

        $this->admin->init();
    }

    public function createAdminMenu(): void
    {
        if (!isset($this->admin)) {
            Logger::debug('Hub menu creation skipped - admin not initialized', [
                'plugin' => $this->plugin
            ]);
            return;
        }

        Logger::debug('Creating Hub admin menu', ['plugin' => $this->plugin]);
        $icon_url = $this->admin->getIconUrl();
        add_menu_page(
            __('SmartCloud', 'smartcloud-flow'),
            __('SmartCloud', 'smartcloud-flow'),
            'manage_options',
            SMARTCLOUD_WPSUITE_SLUG,
            null,
            $icon_url,
            58,
        );

        $connect_suffix = add_submenu_page(
            SMARTCLOUD_WPSUITE_SLUG,
            __('Connect your Site to WPSuite', 'smartcloud-flow'),
            __('Connect your Site', 'smartcloud-flow'),
            'manage_options',
            SMARTCLOUD_WPSUITE_SLUG,
            array($this->admin, 'renderAdminPage'),
        );

        $settings_suffix = add_submenu_page(
            SMARTCLOUD_WPSUITE_SLUG,
            __('WPSuite General Settings', 'smartcloud-flow'),
            __('Global Settings', 'smartcloud-flow'),
            'manage_options',
            SMARTCLOUD_WPSUITE_SLUG . '-settings',
            array($this->admin, 'renderAdminPage'),
        );

        $this->admin->enqueueAdminScripts($connect_suffix, $settings_suffix);
    }

    /**
     * Check configuration and license.
     */
    public function check(): void
    {
        if (!isset($this->admin)) {
            return;
        }
        $this->admin->check();
    }

    private function includes()
    {
        Logger::debug('Hub includes() started', [
            'plugin' => $this->plugin,
            'version' => SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION
        ]);

        if (!function_exists('is_plugin_active')) {
            require_once ABSPATH . 'wp-admin/includes/plugin.php';
        }

        if (!empty($GLOBALS['smartcloud_wpsuite_menu_parent'])) {
            Logger::debug('Hub includes() skipped - menu parent already exists', [
                'plugin' => $this->plugin,
                'existing_parent' => $GLOBALS['smartcloud_wpsuite_menu_parent']
            ]);
            return false;
        }

        // If Hub is not present, try to create a single common top-level menu
        // Mutex: first writer wins on the option
        if (!defined('SMARTCLOUD_WPSUITE_SLUG')) {
            define('SMARTCLOUD_WPSUITE_SLUG', 'hub-for-wpsuiteio');
        }
        $fallback_parent = SMARTCLOUD_WPSUITE_SLUG; // common top-level slug
        $owner_option = SMARTCLOUD_WPSUITE_SLUG . '/top-menu-owner';

        $owner = get_option($owner_option); // may be string or false/null
        $owner_version = get_option($owner_option . '/version') ?? "1.0.0";
        $owner_missing = empty($owner);
        $owner_is_me = ($owner === $this->plugin);

        Logger::debug('Hub ownership check', [
            'current_plugin' => $this->plugin,
            'current_owner' => $owner ?: 'none',
            'owner_version' => $owner_version,
            'this_version' => SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION,
            'owner_missing' => $owner_missing,
            'owner_is_me' => $owner_is_me
        ]);

        $owner_is_active = $owner && is_plugin_active($owner);
        $owner_exists = file_exists(WP_PLUGIN_DIR . '/' . $owner);
        $owner_is_valid = in_array(WP_PLUGIN_DIR . '/' . $owner, wp_get_active_and_valid_plugins(), true);
        $owner_inactive = !$owner_is_active || !$owner_is_valid || !$owner_exists;

        if ($owner && $owner_inactive) {
            Logger::warning('Current hub owner is inactive', [
                'owner' => $owner,
                'is_active' => $owner_is_active,
                'exists' => $owner_exists,
                'is_valid' => $owner_is_valid
            ]);
        }

        $owner_version_is_smaller = version_compare($owner_version, SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION) === -1;
        $owner_version_equals = version_compare($owner_version, SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION) === 0;

        // If there is no owner yet, try to claim it
        if ($owner_missing || $owner_is_me || $owner_inactive || $owner_version_is_smaller) {
            Logger::debug('Hub ownership claim attempt', [
                'plugin' => $this->plugin,
                'reason' => $owner_missing ? 'owner_missing' :
                    ($owner_is_me ? 'owner_is_me' :
                        ($owner_inactive ? 'owner_inactive' :
                            ($owner_version_is_smaller ? 'version_upgrade' : 'unknown'))),
                'current_owner' => $owner ?: 'none',
                'current_version' => $owner_version,
                'new_version' => SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION
            ]);

            $result = false;
            // add_option atomic: only one can win in case of multiple concurrent requests
            if (empty($GLOBALS['smartcloud_wpsuite_fallback_parent_added'])) {
                $GLOBALS['smartcloud_wpsuite_fallback_parent_added'] = true;
                $result = true;

                Logger::info('Hub ownership claimed successfully', [
                    'plugin' => $this->plugin,
                    'version' => SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION,
                    'previous_owner' => $owner ?: 'none'
                ]);

                define('SMARTCLOUD_WPSUITE_VERSION', SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION);
                define('SMARTCLOUD_WPSUITE_PATH', plugin_dir_path(__FILE__) . SMARTCLOUD_WPSUITE_SLUG . '/');
                define('SMARTCLOUD_WPSUITE_URL', plugin_dir_url(__FILE__) . SMARTCLOUD_WPSUITE_SLUG . '/');
                define('SMARTCLOUD_WPSUITE_READY_HOOK', SMARTCLOUD_WPSUITE_SLUG . '/ready');

                if (file_exists(SMARTCLOUD_WPSUITE_PATH . 'index.php')) {
                    require_once SMARTCLOUD_WPSUITE_PATH . 'index.php';
                }
                if (class_exists('\SmartCloud\WPSuite\Hub\HubAdmin')) {
                    $this->admin = new HubAdmin();
                }
                if (!$owner_is_me || !$owner_version_equals) {
                    update_option($owner_option, $this->plugin, false);
                    update_option($owner_option . '/version', SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION, false);

                    Logger::info('Hub ownership registered in database', [
                        'plugin' => $this->plugin,
                        'version' => SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION
                    ]);
                }
            } else {
                Logger::debug('Hub ownership race lost - another plugin already claimed', [
                    'plugin' => $this->plugin,
                    'winner' => $GLOBALS['smartcloud_wpsuite_fallback_parent_added'] ?? 'unknown'
                ]);
            }
            if (!$owner_is_me && $owner_version_is_smaller) {
                update_option($owner_option, $this->plugin, false);
                update_option($owner_option . '/version', SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION, false);

                Logger::info('Hub ownership updated due to version upgrade', [
                    'plugin' => $this->plugin,
                    'from_version' => $owner_version,
                    'to_version' => SMARTCLOUD_WPSUITE_FLOW_HUB_VERSION,
                    'previous_owner' => $owner
                ]);
            }
            return $result;
        }

        Logger::debug('Hub ownership check - no claim needed', [
            'plugin' => $this->plugin,
            'owner' => $owner,
            'owner_version' => $owner_version
        ]);

        return false;
    }

}