| <?php␊ |
| ␊ |
| /*include "system/engine/hf_controller.php";␊ |
| include "system/engine/smtp.php";␊ |
| include "system/engine/exceptions.php";␊ |
| include "system/engine/hf_model.php";*/␊ |
| ␊ |
| namespace system\engine;␊ |
| ␊ |
| use vendor\DB\DB;␊ |
| ␊ |
| include "exceptions.php";␊ |
| ␊ |
| ␊ |
| class HF_Core␊ |
| {␊ |
| ␉private $class;␊ |
| ␉private $method;␊ |
| ␉private $classname;␊ |
| ␉private $args = array();␊ |
| ␉private $config = array();␊ |
| ␉private $tpl;␊ |
| ␉␊ |
| ␉public function __construct($migrations=false)␊ |
| ␉{␊ |
| ␉␉$config = include("system/engine/config-default.php");␊ |
| ␉␉if (is_file("application/config.php"))␊ |
| ␉␉{␊ |
| ␉␉␉$newconfig = include("application/config.php");␊ |
| ␉␉}␊ |
| ␉␉$this->config = array_merge($config, $newconfig);␊ |
| ␉␉\vendor\DB\DB::$type = $config["DATABASE_TYPE"];␊ |
| ␉␉if ($this->config["USE_H20_TPL"])␊ |
| ␉␉␉$this->tpl = new \H2o(null, array(␊ |
| ␉␉␉␉"searchpath" => getcwd() . "/application/views/",␊ |
| ␉␉␉␉"cache_dir" => "application/tmp/",␊ |
| ␉␉␉␉'cache' => 'file'␊ |
| ␉␉␉));␊ |
| ␉␉set_error_handler("\\system\\engine\\HF_Core::error_handler");␊ |
| ␉␉//set_exception_handler("\\system\\engine\\HF_Core::exception_handler");␊ |
| ␉␉if (!$migrations)␊ |
| ␉␉␉$this->findController();␊ |
| ␉}␊ |
| ␊ |
| ␉public static function exception_handler($e) {␊ |
| ␉␉echo "Hello";␊ |
| ␉}␊ |
| ␊ |
| ␉public function siteURL()␊ |
| ␉{␊ |
| ␉␉if (isvarset($this->config["SITE_URL"]))␊ |
| ␉␉{␊ |
| ␉␉␉return $this->config["SITE_URL"];␊ |
| ␉␉}␊ |
| ␉␉$path = explode("/", $_SERVER["REQUEST_URI"]);␊ |
| ␉␉$path = array_filter($path, 'strlen');␊ |
| ␉␉if (count($path) == 0)␊ |
| ␉␉{␊ |
| ␉␉␉return $_SERVER["HTTP_HOST"] . "/";␊ |
| ␉␉} else {␊ |
| ␉␉␉if (in_array($this->classname, $path))␊ |
| ␉␉␉{␊ |
| ␉␉␉␉$newpath = implode("/", array_splice($path, 0, -2));␊ |
| ␉␉␉␉return $_SERVER["HTTP_HOST"] . "/" . $newpath . "/";␊ |
| ␉␉␉} else {␊ |
| ␉␉␉␉$newpath = implode("/", $path);␊ |
| ␉␉␉␉return $_SERVER["HTTP_HOST"] . "/" . $newpath . "/";␊ |
| ␉␉␉}␊ |
| ␉␉}␊ |
| ␉}␊ |
| ␉␊ |
| ␉private function findController()␊ |
| ␉{␊ |
| ␉␉try␊ |
| ␉␉{␊ |
| ␉␉␉if (isvarset($_SERVER["PATH_INFO"]))␊ |
| ␉␉␉{␊ |
| ␉␉␉␉$request = $_SERVER["PATH_INFO"];␊ |
| ␉␉␉␉//$request = $_SERVER["PHP_SELF"];␊ |
| ␉␉␉␉$splitreq = explode("/", $request);␊ |
| ␉␉␉␉/*$request = "";␊ |
| ␉␉␉␉for($i = 0; $i < count($splitreq); $i++)␊ |
| ␉␉␉␉{␊ |
| ␉␉␉␉␉if ($splitreq[$i] == "index.php")␊ |
| ␉␉␉␉␉{␊ |
| ␉␉␉␉␉␉$request = implode("/", array_splice($splitreq, $i+1));␊ |
| ␉␉␉␉␉}␊ |
| ␉␉␉␉}*/␊ |
| ␉␉␉␉//print $request;␊ |
| ␉␉␉␉//$request = substr($request, 1);␊ |
| ␉␉␉␉//$request = substr($request, 0, -1);␊ |
| ␉␉␉} else {␊ |
| ␉␉␉␉$request = "";␊ |
| ␉␉␉}␊ |
| ␉␉␉if ($request == "" || $request == "/")␊ |
| ␉␉␉{␊ |
| ␉␉␉␉require_once("application/controllers/" . $this->config["DEFAULT_ROUTE"] . ".php");␊ |
| ␉␉␉␉$this->loadController(new $this->config["DEFAULT_ROUTE"]($this->config, $this, $this->tpl), $this->config["DEFAULT_ROUTE"], "index");␊ |
| ␉␉␉␉return;␊ |
| ␉␉␉}␊ |
| ␉␉␉if ($request[strlen($request)-1] == "/")␊ |
| ␉␉␉␉$request = substr($request, 0, -1);␊ |
| ␉␉␉$arr = explode("/", $request);␊ |
| ␉␉␉$path = "application/controllers/";␊ |
| ␉␉␉for($i = 0; $i < count($arr); $i++)␊ |
| ␉␉␉{␊ |
| ␉␉␉␉if (is_file($path . $arr[$i] . ".php")) // found the controller␊ |
| ␉␉␉␉{␊ |
| ␉␉␉␉␉include_once($path . $arr[$i] . ".php");␊ |
| ␉␉␉␉␉if ($i + 1 < count($arr)) // if there is a define after the controller name - this would be the method name␊ |
| ␉␉␉␉␉{␊ |
| ␉␉␉␉␉␉$this->loadController(new $arr[$i]($this->config, $this, $this->tpl), $arr[$i], $arr[$i+1], array_slice ($arr, 3));␊ |
| ␉␉␉␉␉} else { // call index␊ |
| ␉␉␉␉␉␉$this->loadController(new $arr[$i]($this->config, $this, $this->tpl), $arr[$i], "index");␊ |
| ␉␉␉␉␉}␊ |
| ␉␉␉␉␉return;␊ |
| ␉␉␉␉}␊ |
| ␊ |
| ␉␉␉␉if (is_dir($path . $arr[$i])) // controller is hidden deeper␊ |
| ␉␉␉␉{␊ |
| ␉␉␉␉␉$path = $path . $arr[$i] . "/";␊ |
| ␉␉␉␉␉continue;␊ |
| ␉␉␉␉}␊ |
| ␊ |
| ␉␉␉␉include_once($path . $this->config["DEFAULT_ROUTE"] . ".php");␊ |
| ␉␉␉␉$this->loadController(new $this->config["DEFAULT_ROUTE"]($this->config, $this, $this->tpl), $this->config["DEFAULT_ROUTE"], "index");␊ |
| ␉␉␉␉//$this->load404Controller();␊ |
| ␉␉␉␉break;␊ |
| ␉␉␉␉// throw exception controller not found␊ |
| ␉␉␉}␊ |
| ␉␉} catch (\Exception $e) {␊ |
| ␉␉␉if ($this->config["DEBUG"])␊ |
| ␉␉␉␉echo vdump($e, $this);␊ |
| ␉␉␉else␊ |
| ␉␉␉␉$this->mail_admins("[Exception - " . $this->config["SITE_NAME"] . "]", vdump($e, $this), true);␊ |
| ␉␉}␊ |
| ␉}␊ |
| ␊ |
| ␉private function load404Controller()␊ |
| ␉{␊ |
| ␉␉if (is_file(getcwd() . "/application/status.php"))␊ |
| ␉␉{␊ |
| ␉␉␉include_once (getcwd() . "/application/status.php");␊ |
| ␉␉␉$this->loadController(new HF_Status($this->config, $this, $this->tpl), "\\system\\engine\\HF_Status", "Status404");␊ |
| ␉␉} else {␊ |
| ␉␉␉include_once(getcwd() . "/system/engine/status.php");␊ |
| ␉␉␉$this->loadController(new HF_Status($this->config, $this, $this->tpl), "\\system\\engine\\HF_Status", "Status404");␊ |
| ␊ |
| ␉␉}␊ |
| ␉}␊ |
| ␊ |
| ␉private function load500Controller()␊ |
| ␉{␊ |
| ␉␉if (is_file(getcwd() . "/application/status.php"))␊ |
| ␉␉{␊ |
| ␉␉␉include_once (getcwd() . "/application/status.php");␊ |
| ␉␉␉$this->loadController(new HF_Status($this->config, $this, $this->tpl), "\\system\\engine\\HF_Status", "Status500");␊ |
| ␉␉} else {␊ |
| ␉␉␉include_once (getcwd() . "/system/engine/status.php");␊ |
| ␉␉␉$this->loadController(new HF_Status($this->config, $this, $this->tpl), "\\system\\engine\\HF_Status", "Status500");␊ |
| ␊ |
| ␉␉}␊ |
| ␉}␊ |
| ␊ |
| ␉private function loadController($class, $classname, $method, $args = array())␊ |
| ␉{␊ |
| ␉␉$this->class = $class;␊ |
| ␉␉$this->classname = $classname;␊ |
| ␉␉$this->method = $method;␊ |
| ␉␉$this->args = $args;␊ |
| ␉}␊ |
| ␉␊ |
| ␉public function run($err=false)␊ |
| ␉{␊ |
| ␉␉try␊ |
| ␉␉{␊ |
| ␉␉␉$call = new \ReflectionMethod($this->classname, $this->method);␊ |
| ␉␉␉if ($err)␊ |
| ␉␉␉{␊ |
| ␉␉␉␉$call->invokeArgs($this->class, $this->args);␊ |
| ␉␉␉␉return;␊ |
| ␉␉␉}␊ |
| ␊ |
| ␉␉␉$numOfReqPara = $call->getNumberOfRequiredParameters();␊ |
| ␉␉␉$numOfOptPara = $call->getNumberOfParameters() - $numOfReqPara;␊ |
| ␉␉␉$remainparas = count($this->args) - $numOfReqPara;␊ |
| ␉␉␉if ($numOfReqPara == 0 || ($remainparas >= 0 && $remainparas <= $numOfOptPara))␊ |
| ␉␉␉{␊ |
| ␉␉␉␉$call->invokeArgs($this->class, $this->args);␊ |
| ␉␉␉}␊ |
| ␉␉␉else␊ |
| ␉␉␉{␊ |
| ␉␉␉␉$this->load404Controller();␊ |
| ␉␉␉␉$this->run(true);␊ |
| ␉␉␉}␊ |
| ␊ |
| ␉␉}␊ |
| ␉␉catch (\ReflectionException $e)␊ |
| ␉␉{␊ |
| ␉␉␉if (strstr($e->getMessage(), "does not exist") !== false)␊ |
| ␉␉␉{␊ |
| ␉␉␉␉$this->load404Controller();␊ |
| ␉␉␉} else {␊ |
| ␉␉␉␉$this->load500Controller();␊ |
| ␉␉␉}␊ |
| ␉␉␉$this->run(true);␊ |
| ␉␉␉if ($this->config["DEBUG"])␊ |
| ␉␉␉␉echo vdump($e, $this);␊ |
| ␉␉␉else␊ |
| ␉␉␉␉$this->mail_admins("[Exception - " . $this->config["SITE_NAME"] . "]", vdump($e, $this), true);␊ |
| ␊ |
| ␊ |
| ␉␉} catch (\Exception $e) {␊ |
| ␉␉␉$this->load500Controller();␊ |
| ␉␉␉$this->run(true);␊ |
| ␉␉␉if ($this->config["DEBUG"])␊ |
| ␉␉␉␉echo vdump($e, $this);␊ |
| ␉␉␉else␊ |
| ␉␉␉␉$this->mail_admins("[Exception - " . $this->config["SITE_NAME"] . "]", vdump($e, $this), true);␊ |
| ␉␉}␊ |
| ␉}␊ |
| ␊ |
| ␉public function mail_admins($subject, $msg, $html = false)␊ |
| ␉{␊ |
| ␉␉if (array_key_exists("ADMINS", $this->config))␊ |
| ␉␉{␊ |
| ␉␉␉foreach($this->config["ADMINS"] as $email)␊ |
| ␉␉␉{␊ |
| ␉␉␉␉$this->mail_user($email, $subject, $msg, $html);␊ |
| ␉␉␉}␊ |
| ␉␉}␊ |
| ␉}␊ |
| ␊ |
| ␉public function mail_user($to, $subject, $msg, $html = false)␊ |
| ␉{␊ |
| ␉␉if ($this->config["USE_HF_SMTP"])␊ |
| ␉␉{␊ |
| ␉␉␉$smtp = new HF_SMTP($this->config["SMTP_FROM"], $to, $subject, $msg, $this->config["SMTP_SERVER"], $this->config["SMTP_USER"], $this->config["SMTP_PASS"], $this->config["SMTP_PORT"]);␊ |
| ␉␉␉$smtp->send($html);␊ |
| ␉␉} else {␊ |
| ␉␉␉require_once "Mail.php";␊ |
| ␉␉␉$smtp = null;␊ |
| ␉␉␉if ($this->$this->config["SMTP_USER"] && $this->config["SMTP_PASS"])␊ |
| ␉␉␉␉$smtp = Mail::factory('smtp', array(␊ |
| ␉␉␉␉␉"host" => $this->config["SMTP_SERVER"],␊ |
| ␉␉␉␉␉"port" => $this->config["SMTP_PORT"],␊ |
| ␉␉␉␉␉"auth" => true,␊ |
| ␉␉␉␉␉'username' => $this->config["SMTP_USER"],␊ |
| ␉␉␉␉␉'password' => $this->config["SMTP_PASS"]␊ |
| ␉␉␉␉));␊ |
| ␉␉␉else␊ |
| ␉␉␉␉$smtp = Mail::factory('smtp', array(␊ |
| ␉␉␉␉␉"host" => $this->config["SMTP_SERVER"],␊ |
| ␉␉␉␉␉"port" => $this->config["SMTP_PORT"]␊ |
| ␉␉␉␉));␊ |
| ␉␉␉$headers = array ('From' => $this->config["SMTP_FROM"],␊ |
| ␉␉␉␉'To' => $to,␊ |
| ␉␉␉␉'Subject' => $subject);␊ |
| ␉␉␉$smtp->send($to, $headers, $msg);␊ |
| ␉␉}␊ |
| ␉}␊ |
| ␊ |
| ␉public static function error_handler($err_severity, $err_msg, $err_file, $err_line, array $err_context)␊ |
| ␉{␊ |
| ␉␉if (0 === error_reporting()) { return false;}␊ |
| ␉␉switch($err_severity)␊ |
| ␉␉{␊ |
| ␉␉␉case E_ERROR: throw new \ErrorException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_WARNING: throw new WarningException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_PARSE: throw new ParseException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_NOTICE: throw new NoticeException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_CORE_ERROR: throw new CoreErrorException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_CORE_WARNING: throw new CoreWarningException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_COMPILE_ERROR: throw new CompileErrorException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_COMPILE_WARNING: throw new CoreWarningException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_USER_ERROR: throw new UserErrorException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_USER_WARNING: throw new UserWarningException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_USER_NOTICE: throw new UserNoticeException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_STRICT: throw new StrictException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_RECOVERABLE_ERROR: throw new RecoverableErrorException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_DEPRECATED: throw new DeprecatedException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉␉case E_USER_DEPRECATED: throw new UserDeprecatedException ($err_msg, 0, $err_severity, $err_file, $err_line);␊ |
| ␉␉}␊ |
| ␉}␊ |
| ␊ |
| ␉public function setupDatabaseConnection() {␊ |
| ␉␉switch($this->config["DATABASE_TYPE"]) {␊ |
| ␉␉␉case "SQLITE":␊ |
| ␉␉␉␉DB::$c = new \PDO("sqlite:" . $this->config["DATABASE_FILE"]);␊ |
| ␉␉␉␉break;␊ |
| ␉␉␉case "MySQL":␊ |
| ␉␉␉␉DB::$c = new \PDO(␊ |
| ␉␉␉␉␉␉"mysql:dbname={$this->config['MYSQL_DBNAME']};host={$this->config['MYSQL_HOST']}",␊ |
| ␉␉␉␉␉␉$this->config['MYSQL_USER'],␊ |
| ␉␉␉␉␉␉$this->config['MYSQL_PASS'],␊ |
| ␉␉␉␉␉␉array(␊ |
| ␉␉␉␉␉␉␉␉\PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8",␊ |
| ␉␉␉␉␉␉␉␉\PDO::ATTR_DEFAULT_FETCH_MODE => \PDO::FETCH_OBJ,␊ |
| ␉␉␉␉␉␉␉␉\PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION␊ |
| ␉␉␉␉␉␉)␊ |
| ␉␉␉␉);␊ |
| ␉␉␉␉break;␊ |
| ␉␉}␊ |
| ␉␉DB::$c->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);␊ |
| ␉}␊ |
| ␊ |
| ␉public function runMigrations() {␊ |
| global $argv;␊ |
| ␉␉$this->setupDatabaseConnection();␊ |
| DB::query("CREATE TABLE IF NOT EXISTS migrations (␊ |
| ␉␉␉␉␉␉␉ id INTEGER PRIMARY KEY AUTOINCREMENT,␊ |
| ␉␉␉␉␉␉␉ migration INTEGER,␊ |
| ␉␉␉␉␉␉␉ ran_at DATETIME␊ |
| ␉␉␉␉)");␊ |
| switch ($argv[1]) {␊ |
| case "show":␊ |
| foreach(DB::fetch("SELECT migration, ran_at FROM migrations") as $migration) {␊ |
| echo $migration["migration"] . " => " . $migration["ran_at"] . PHP_EOL;␊ |
| }␊ |
| break;␊ |
| case "count":␊ |
| echo DB::column("SELECT COUNT(id) FROM migrations");␊ |
| break;␊ |
| case "run":␊ |
| $migrations = DB::fetch("SELECT migration FROM migrations");␊ |
| $migrationArray = [];␊ |
| foreach($migrations as $migration) {␊ |
| $migrationArray[] = $migration["migration"];␊ |
| }␊ |
| ␊ |
| foreach (glob("application/migrations/*.php") as $filename)␊ |
| {␊ |
| if (!in_array($filename, $migrationArray)) {␊ |
| ␉␉␉␉␉␉try {␊ |
| ␉␉␉␉␉␉␉include $filename;␊ |
| ␉␉␉␉␉␉␉DB::insert("migrations", ["migration" => $filename, "ran_at" => (new \DateTime())->format("Y-m-d")]);␊ |
| ␉␉␉␉␉␉} catch (\Exception $e) {␊ |
| ␉␉␉␉␉␉␉echo "[HF_Core] - Migration error - $e";␊ |
| ␉␉␉␉␉␉␉exit(1);␊ |
| ␉␉␉␉␉␉}␊ |
| }␊ |
| ␊ |
| ␊ |
| }␊ |
| break;␊ |
| case "clear":␊ |
| DB::query("DELETE FROM migrations");␊ |
| break;␊ |
| case "reset":␊ |
| switch($this->config["DATABASE_TYPE"]) {␊ |
| case "SQLITE":␊ |
| DB::$c = null;␊ |
| unlink($this->config["DATABASE_FILE"]);␊ |
| break;␊ |
| case "MYSQL":␊ |
| DB::query("DROP DATABASE " . $this->config['MYSQL_DBNAME']);␊ |
| DB::query("CREATE DATABASE " . $this->config['MYSQL_DBNAME']);␊ |
| break;␊ |
| }␊ |
| break;␊ |
| }␊ |
| ␊ |
| ␊ |
| ␉}␊ |
| } |
accountmanagementengine