<?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;␊ |
}␊ |
␊ |
␊ |
␉}␊ |
} |