Subversion Repositories oidplus

<?php

/*

 * OIDplus 2.0

 * Copyright 2019 Daniel Marschall, ViaThinkSoft

 *

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 *

 *     http://www.apache.org/licenses/LICENSE-2.0

 *

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 */

class OIDplus {

        private static /*OIDplusPagePlugin[]*/ $pagePlugins = array();

        private static /*OIDplusAuthPlugin[]*/ $authPlugins = array();

        private static /*OIDplusLoggerPlugin[]*/ $loggerPlugins = array();

        private static /*OIDplusObjectTypePlugin[]*/ $objectTypePlugins = array();

        private static /*string[]*/ $enabledObjectTypes = array();

        private static /*string[]*/ $disabledObjectTypes = array();

        private static /*OIDplusDatabasePlugin[]*/ $dbPlugins = array();

        private static /*OIDplusSqlSlangPlugin[]*/ $sqlSlangPlugins = array();

        private static /*OIDplusLanguagePlugin[]*/ $languagePlugins = array();

        protected static $html = true;

        /*public*/ const DEFAULT_LANGUAGE = 'enus';

        private function __construct() {

        }

        # --- Static classes

        private static $baseConfig = null;

        private static $old_config_format = false;

        public static function baseConfig() {

                $first_init = false;

                if ($first_init = is_null(self::$baseConfig)) {

                        self::$baseConfig = new OIDplusBaseConfig();

                }

                if ($first_init) {

                        // Include a file containing various size/depth limitations of OIDs

                        // It is important to include it before userdata/baseconfig/config.inc.php was included,

                        // so we can give userdata/baseconfig/config.inc.php the chance to override the values.

                        include OIDplus::basePath().'/includes/limits.inc.php';

                        // Include config file

                        $config_file = OIDplus::basePath() . '/userdata/baseconfig/config.inc.php';

                        $config_file_old = OIDplus::basePath() . '/includes/config.inc.php'; // backwards compatibility

                        if (!file_exists($config_file) && file_exists($config_file_old)) {

                                $config_file = $config_file_old;

                        }

                        if (file_exists($config_file)) {

                                if (self::$old_config_format) {

                                        // Note: We may only include it once due to backwards compatibility,

                                        //       since in version 2.0, the configuration was defined using define() statements

                                        // Attention: This does mean that a full re-init (e.g. for test cases) is not possible

                                        //            if a version 2.0 config is used!

                                        include_once $config_file;

                                } else {

                                        include $config_file;

                                }

                                if (defined('OIDPLUS_CONFIG_VERSION') && (OIDPLUS_CONFIG_VERSION == 2.0)) {

                                        self::$old_config_format = true;

                                        // Backwards compatibility 2.0 => 2.1

                                        foreach (get_defined_constants(true)['user'] as $name => $value) {

                                                $name = str_replace('OIDPLUS_', '', $name);

                                                if ($name == 'SESSION_SECRET') $name = 'SERVER_SECRET';

                                                if ($name == 'MYSQL_QUERYLOG') $name = 'QUERY_LOGFILE';

                                                if (($name == 'MYSQL_PASSWORD') || ($name == 'ODBC_PASSWORD') || ($name == 'PDO_PASSWORD') || ($name == 'PGSQL_PASSWORD')) {

                                                        self::$baseConfig->setValue($name, base64_decode($value));

                                                } else {

                                                        if ($name == 'CONFIG_VERSION') $value = 2.1;

                                                        self::$baseConfig->setValue($name, $value);

                                                }

                                        }

                                }

                        } else {

                                if (!is_dir(OIDplus::basePath().'/setup')) {

                                        throw new OIDplusConfigInitializationException('File userdata/baseconfig/config.inc.php is missing, but setup can\'t be started because its directory missing.');

                                } else {

                                        if (self::$html) {

                                                if (strpos($_SERVER['REQUEST_URI'], OIDplus::getSystemUrl(true).'setup/') !== 0) {

                                                        header('Location:'.OIDplus::getSystemUrl().'setup/');

                                                        die('Redirecting to setup...');

                                                } else {

                                                        return self::$baseConfig;

                                                }

                                        } else {

                                                // This can be displayed in e.g. ajax.php

                                                throw new OIDplusConfigInitializationException('File userdata/baseconfig/config.inc.php is missing. Please run setup again.');

                                        }

                                }

                        }

                        // Check important config settings

                        if (self::$baseConfig->getValue('CONFIG_VERSION') != 2.1) {

                                throw new OIDplusConfigInitializationException("The information located in $config_file is outdated.");

                        }

                        if (self::$baseConfig->getValue('SERVER_SECRET', '') === '') {

                                throw new OIDplusConfigInitializationException("You must set a value for SERVER_SECRET in $config_file for the system to operate secure.");

                        }

                }

                return self::$baseConfig;

        }

        private static $config = null;

        public static function config() {

                if ($first_init = is_null(self::$config)) {

                        self::$config = new OIDplusConfig();

                }

                if ($first_init) {

                        // These are important settings for base functionalities and therefore are not inside plugins

                        self::$config->prepareConfigKey('system_title', 'What is the name of your RA?', 'OIDplus 2.0', OIDplusConfig::PROTECTION_EDITABLE, function($value) {

                                if (empty($value)) {

                                        throw new OIDplusException("Please enter a value for the system title.");

                                }

                        });

                        self::$config->prepareConfigKey('admin_email', 'E-Mail address of the system administrator', '', OIDplusConfig::PROTECTION_EDITABLE, function($value) {

                                if (!empty($value) && !OIDplus::mailUtils()->validMailAddress($value)) {

                                        throw new OIDplusException("This is not a correct email address");

                                }

                        });

                        self::$config->prepareConfigKey('global_cc', 'Global CC for all outgoing emails?', '', OIDplusConfig::PROTECTION_EDITABLE, function($value) {

                                if (!empty($value) && !OIDplus::mailUtils()->validMailAddress($value)) {

                                        throw new OIDplusException("This is not a correct email address");

                                }

                        });

                        self::$config->prepareConfigKey('objecttypes_initialized', 'List of object type plugins that were initialized once', '', OIDplusConfig::PROTECTION_READONLY, function($value) {

                                // Nothing here yet

                        });

                        self::$config->prepareConfigKey('objecttypes_enabled', 'Enabled object types and their order, separated with a semicolon (please reload the page so that the change is applied)', '', OIDplusConfig::PROTECTION_EDITABLE, function($value) {

                                # TODO: when objecttypes_enabled is changed at the admin control panel, we need to do a reload of the page, so that jsTree will be updated. Is there anything we can do?

                                $ary = explode(';',$value);

                                $uniq_ary = array_unique($ary);

                                if (count($ary) != count($uniq_ary)) {

                                        throw new OIDplusException("Please check your input. Some object types are double.");

                                }

                                foreach ($ary as $ot_check) {

                                        $ns_found = false;

                                        foreach (OIDplus::getEnabledObjectTypes() as $ot) {

                                                if ($ot::ns() == $ot_check) {

                                                        $ns_found = true;

                                                        break;

                                                }

                                        }

                                        foreach (OIDplus::getDisabledObjectTypes() as $ot) {

                                                if ($ot::ns() == $ot_check) {

                                                        $ns_found = true;

                                                        break;

                                                }

                                        }

                                        if (!$ns_found) {

                                                throw new OIDplusException("Please check your input. Namespace \"$ot_check\" is not found");

                                        }

                                }

                        });

                        self::$config->prepareConfigKey('oidplus_private_key', 'Private key for this system', '', OIDplusConfig::PROTECTION_HIDDEN, function($value) {

                                // Nothing here yet

                        });

                        self::$config->prepareConfigKey('oidplus_public_key', 'Public key for this system. If you "clone" your system, you must delete this key (e.g. using phpMyAdmin), so that a new one is created.', '', OIDplusConfig::PROTECTION_READONLY, function($value) {

                                // Nothing here yet

                        });

                        self::$config->prepareConfigKey('last_known_system_url', 'Last known System URL', '', OIDplusConfig::PROTECTION_HIDDEN, function($value) {

                                // Nothing here yet

                        });

                }

                return self::$config;

        }

        private static $gui = null;

        public static function gui() {

                if (is_null(self::$gui)) {

                        self::$gui = new OIDplusGui();

                }

                return self::$gui;

        }

        private static $authUtils = null;

        public static function authUtils() {

                if (is_null(self::$authUtils)) {

                        self::$authUtils = new OIDplusAuthUtils();

                }

                return self::$authUtils;

        }

        private static $mailUtils = null;

        public static function mailUtils() {

                if (is_null(self::$mailUtils)) {

                        self::$mailUtils = new OIDplusMailUtils();

                }

                return self::$mailUtils;

        }

        private static $menuUtils = null;

        public static function menuUtils() {

                if (is_null(self::$menuUtils)) {

                        self::$menuUtils = new OIDplusMenuUtils();

                }

                return self::$menuUtils;

        }

        private static $logger = null;

        public static function logger() {

                if (is_null(self::$logger)) {

                        self::$logger = new OIDplusLogger();

                }

                return self::$logger;

        }

        private static $sesHandler = null;

        public static function sesHandler() {

                if (is_null(self::$sesHandler)) {

                        self::$sesHandler = new OIDplusSessionHandler();

                }

                return self::$sesHandler;

        }

        # --- SQL slang plugin

        private static function registerSqlSlangPlugin(OIDplusSqlSlangPlugin $plugin) {

                $name = $plugin::id();

                if ($name === false) return false;

                self::$sqlSlangPlugins[$name] = $plugin;

                return true;

        }

        public static function getSqlSlangPlugins() {

                return self::$sqlSlangPlugins;

        }

        public static function getSqlSlangPlugin($id)/*: ?OIDplusSqlSlangPlugin*/ {

                if (isset(self::$sqlSlangPlugins[$id])) {

                        return self::$sqlSlangPlugins[$id];

                } else {

                        return null;

                }

        }

        # --- Database plugin

        private static function registerDatabasePlugin(OIDplusDatabasePlugin $plugin) {

                $name = $plugin::id();

                if ($name === false) return false;

                self::$dbPlugins[$name] = $plugin;

                return true;

        }

        public static function getDatabasePlugins() {

                return self::$dbPlugins;

        }

        public static function getActiveDatabasePlugin() {

                if (OIDplus::baseConfig()->getValue('DATABASE_PLUGIN', '') === '') {

                        throw new OIDplusConfigInitializationException("No database plugin selected in config file");

                }

                if (!isset(self::$dbPlugins[OIDplus::baseConfig()->getValue('DATABASE_PLUGIN')])) {

                        throw new OIDplusConfigInitializationException("Database plugin '".OIDplus::baseConfig()->getValue('DATABASE_PLUGIN')."' not found");

                }

                return self::$dbPlugins[OIDplus::baseConfig()->getValue('DATABASE_PLUGIN')];

        }

        private static $dbMainSession = null;

        public static function db() {

                if (is_null(self::$dbMainSession)) {

                        self::$dbMainSession = self::getActiveDatabasePlugin()->newConnection();

                }

                if (!self::$dbMainSession->isConnected()) self::$dbMainSession->connect();

                return self::$dbMainSession;

        }

        private static $dbIsolatedSession = null;

        public static function dbIsolated() {

                if (is_null(self::$dbIsolatedSession)) {

                        self::$dbIsolatedSession = self::getActiveDatabasePlugin()->newConnection();

                }

                if (!self::$dbIsolatedSession->isConnected()) self::$dbIsolatedSession->connect();

                return self::$dbIsolatedSession;

        }

        # --- Page plugin

        private static function registerPagePlugin(OIDplusPagePlugin $plugin) {

                self::$pagePlugins[] = $plugin;

                return true;

        }

        public static function getPagePlugins() {

                return self::$pagePlugins;

        }

        # --- Auth plugin

        private static function registerAuthPlugin(OIDplusAuthPlugin $plugin) {

                self::$authPlugins[] = $plugin;

                return true;

        }

        public static function getAuthPlugins() {

                return self::$authPlugins;

        }

        # --- Language plugin

        private static function registerLanguagePlugin(OIDplusLanguagePlugin $plugin) {

                self::$languagePlugins[] = $plugin;

                return true;

        }

        public static function getLanguagePlugins() {

                return self::$languagePlugins;

        }

        # --- Logger plugin

        private static function registerLoggerPlugin(OIDplusLoggerPlugin $plugin) {

                self::$loggerPlugins[] = $plugin;

                return true;

        }

        public static function getLoggerPlugins() {

                return self::$loggerPlugins;

        }

        # --- Object type plugin

        private static function registerObjectTypePlugin(OIDplusObjectTypePlugin $plugin) {

                self::$objectTypePlugins[] = $plugin;

                $ot = $plugin::getObjectTypeClassName();

                self::registerObjectType($ot);

                return true;

        }

        private static function registerObjectType($ot) {

                $ns = $ot::ns();

                if (empty($ns)) throw new OIDplusException("Attention: Empty NS at $ot\n");

                $ns_found = false;

                foreach (array_merge(OIDplus::getEnabledObjectTypes(), OIDplus::getDisabledObjectTypes()) as $test_ot) {

                        if ($test_ot::ns() == $ns) {

                                $ns_found = true;

                                break;

                        }

                }

                if ($ns_found) {

                        throw new OIDplusException("Attention: Two objectType plugins use the same namespace \"$ns\"!");

                }

                $init = OIDplus::config()->getValue("objecttypes_initialized");

                $init_ary = empty($init) ? array() : explode(';', $init);

                $init_ary = array_map('trim', $init_ary);

                $enabled = OIDplus::config()->getValue("objecttypes_enabled");

                $enabled_ary = empty($enabled) ? array() : explode(';', $enabled);

                $enabled_ary = array_map('trim', $enabled_ary);

                $do_enable = false;

                if (in_array($ns, $enabled_ary)) {

                        $do_enable = true;

                } else {

                        if (!OIDplus::config()->getValue('registration_done')) {

                                $do_enable = $ns == 'oid';

                        } else {

                                $do_enable = !in_array($ns, $init_ary);

                        }

                }

                if ($do_enable) {

                        self::$enabledObjectTypes[] = $ot;

                        usort(self::$enabledObjectTypes, function($a, $b) {

                                $enabled = OIDplus::config()->getValue("objecttypes_enabled");

                                $enabled_ary = explode(';', $enabled);

                                $idx_a = array_search($a::ns(), $enabled_ary);

                                $idx_b = array_search($b::ns(), $enabled_ary);

                                if ($idx_a == $idx_b) {

                                    return 0;

                                }

                                return ($idx_a > $idx_b) ? +1 : -1;

                        });

                } else {

                        self::$disabledObjectTypes[] = $ot;

                }

                if (!in_array($ns, $init_ary)) {

                        // Was never initialized before, so we add it to the list of enabled object types once

                        if ($do_enable) {

                                $enabled_ary[] = $ns;

                                OIDplus::config()->setValue("objecttypes_enabled", implode(';', $enabled_ary));

                        }

                        $init_ary[] = $ns;

                        OIDplus::config()->setValue("objecttypes_initialized", implode(';', $init_ary));

                }

        }

        public static function getObjectTypePlugins() {

                return self::$objectTypePlugins;

        }

        public static function getObjectTypePluginsEnabled() {

                $res = array();

                foreach (self::$objectTypePlugins as $plugin) {

                        $ot = $plugin::getObjectTypeClassName();

                        if (in_array($ot, self::$enabledObjectTypes)) $res[] = $plugin;

                }

                return $res;

        }

        public static function getObjectTypePluginsDisabled() {

                $res = array();

                foreach (self::$objectTypePlugins as $plugin) {

                        $ot = $plugin::getObjectTypeClassName();

                        if (in_array($ot, self::$disabledObjectTypes)) $res[] = $plugin;

                }

                return $res;

        }

        public static function getEnabledObjectTypes() {

                return self::$enabledObjectTypes;

        }

        public static function getDisabledObjectTypes() {

                return self::$disabledObjectTypes;

        }

        # --- Plugin handling functions

        public static function getAllPlugins()/*: array*/ {

                $res = array();

                $res = array_merge($res, self::$pagePlugins);

                $res = array_merge($res, self::$authPlugins);

                $res = array_merge($res, self::$loggerPlugins);

                $res = array_merge($res, self::$objectTypePlugins);

                $res = array_merge($res, self::$dbPlugins);

                $res = array_merge($res, self::$sqlSlangPlugins);

                $res = array_merge($res, self::$languagePlugins);

                return $res;

        }

        public static function getPluginByOid($oid)/*: ?OIDplusPlugin*/ {

                $plugins = self::getAllPlugins();

                foreach ($plugins as $plugin) {

                        if (oid_dotnotation_equal($plugin->getManifest()->getOid(), $oid)) {

                                return $plugin;

                        }

                }

                return null;

        }

        public static function getPluginManifest($class_name)/*: ?OIDplusPluginManifest*/ {

                $reflector = new ReflectionClass($class_name);

                $ini = dirname($reflector->getFileName()).'/manifest.xml';

                $manifest = new OIDplusPluginManifest();

                return $manifest->loadManifest($ini) ? $manifest : null;

        }

        public static function getAllPluginManifests($pluginFolderMask='*', $flat=true): array {

                $out = array();

                // Note: glob() will sort by default, so we do not need a page priority attribute.

                //       So you just need to use a numeric plugin directory prefix (padded).

                $ary = glob(OIDplus::basePath().'/plugins/'.$pluginFolderMask.'/'.'*'.'/manifest.xml');

                foreach ($ary as $ini) {

                        if (!file_exists($ini)) continue;

                        $manifest = new OIDplusPluginManifest();

                        $manifest->loadManifest($ini);

                        if ($flat) {

                                $out[] = $manifest;

                        } else {

                                $plugintype_folder = basename(dirname(dirname($ini)));

                                $pluginname_folder = basename(dirname($ini));

                                if (!isset($out[$plugintype_folder])) $out[$plugintype_folder] = array();

                                if (!isset($out[$plugintype_folder][$pluginname_folder])) $out[$plugintype_folder][$pluginname_folder] = array();

                                $out[$plugintype_folder][$pluginname_folder] = $manifest;

                        }

                }

                return $out;

        }

        public static function registerAllPlugins($pluginDirName, $expectedPluginClass, $registerCallback): array {

                $out = array();

                $ary = self::getAllPluginManifests($pluginDirName, false);

                $known_plugin_oids = array();

                foreach ($ary as $plugintype_folder => $bry) {

                        foreach ($bry as $pluginname_folder => $cry) {

                                $class_name = $cry->getPhpMainClass();

                                if (!$class_name) {

                                        throw new OIDplusException("Plugin '$plugintype_folder/$pluginname_folder' is errornous: Manifest does not declare a PHP main class");

                                }

                                if (OIDplus::baseConfig()->getValue('DISABLE_PLUGIN_'.$class_name, false)) {

                                        continue;

                                }

                                if (!class_exists($class_name)) {

                                        throw new OIDplusException("Plugin '$plugintype_folder/$pluginname_folder' is errornous: Manifest declares PHP main class as '$class_name', but it could not be found");

                                }

                                if (!is_subclass_of($class_name, $expectedPluginClass)) {

                                        throw new OIDplusException("Plugin '$plugintype_folder/$pluginname_folder' is errornous: Plugin main class '$class_name' is expected to be a subclass of '$expectedPluginClass'");

                                }

                                if (($class_name!=$cry->getTypeClass()) && (!is_subclass_of($class_name,$cry->getTypeClass()))) {

                                        throw new OIDplusException("Plugin '$plugintype_folder/$pluginname_folder' is errornous: Plugin main class '$class_name' is expected to be a subclass of '".$cry->getTypeClass()."', according to type declared in manifest");

                                }

                                if (($cry->getTypeClass()!=$expectedPluginClass) && (!is_subclass_of($cry->getTypeClass(),$expectedPluginClass))) {

                                        throw new OIDplusException("Plugin '$plugintype_folder/$pluginname_folder' is errornous: Class declared in manifest is '".$cry->getTypeClasS()."' does not fit expected class for this plugin type '$expectedPluginClass'");

                                }

                                $plugin_oid = $cry->getOid();

                                if (!$plugin_oid) {

                                        throw new OIDplusException("Plugin '$plugintype_folder/$pluginname_folder' is errornous: Does not have an OID");

                                }

                                if (!oid_valid_dotnotation($plugin_oid, false, false, 2)) {

                                        throw new OIDplusException("Plugin '$plugintype_folder/$pluginname_folder' is errornous: Plugin OID '$plugin_oid' is invalid (needs to be valid dot-notation)");

                                }

                                if (isset($known_plugin_oids[$plugin_oid])) {

                                        throw new OIDplusException("Plugin '$plugintype_folder/$pluginname_folder' is errornous: The OID '$plugin_oid' is already used by the plugin '".$known_plugin_oids[$plugin_oid]."'");

                                } else {

                                        $known_plugin_oids[$plugin_oid] = $plugintype_folder.'/'.$pluginname_folder;

                                }

                                $out[] = $class_name;

                                if (!is_null($registerCallback)) {

                                        call_user_func($registerCallback, new $class_name());

                                }

                        }

                }

                return $out;

        }

        # --- Initialization of OIDplus

        public static function init($html=true) {

                self::$html = $html;

                // Reset internal state, so we can re-init verything if required

                if (self::$old_config_format) {

                        // Note: This can only happen in very special cases (e.g. test cases) where you call init() twice

                        throw new OIDplusConfigInitializationException('A full re-initialization is not possible if a version 2.0 config file (containing "defines") is used. Please update to a config 2.1 file by running setup again.');

                }

                self::$config = null;

                self::$baseConfig = null;

                self::$gui = null;

                self::$authUtils = null;

                self::$mailUtils = null;

                self::$menuUtils = null;

                self::$logger = null;

                self::$sesHandler = null;

                self::$dbMainSession = null;

                self::$dbIsolatedSession = null;

                self::$pagePlugins = array();

                self::$authPlugins = array();

                self::$loggerPlugins = array();

                self::$objectTypePlugins = array();

                self::$enabledObjectTypes = array();

                self::$disabledObjectTypes = array();

                self::$dbPlugins = array();

                self::$sqlSlangPlugins = array();

                self::$languagePlugins = array();

                self::$system_id_cache = null;

                self::$sslAvailableCache = null;

                // Continue...

                OIDplus::baseConfig(); // this loads the base configuration located in userdata/baseconfig/config.inc.php (once!)

                                       // You can do changes to the configuration afterwards using OIDplus::baseConfig()->...

                // Register database types (highest priority)

                // SQL slangs

                self::registerAllPlugins('sqlSlang', 'OIDplusSqlSlangPlugin', array('OIDplus','registerSqlSlangPlugin'));

                foreach (OIDplus::getSqlSlangPlugins() as $plugin) {

                        $plugin->init($html);

                }

                // Database providers

                self::registerAllPlugins('database', 'OIDplusDatabasePlugin', array('OIDplus','registerDatabasePlugin'));

                foreach (OIDplus::getDatabasePlugins() as $plugin) {

                        $plugin->init($html);

                }

                // Do redirect stuff etc.

                self::isSslAvailable(); // This function does automatic redirects

                // Construct the configuration manager

                OIDplus::config(); // During the construction, various system settings are prepared if required