kritbit

kritbit Git Source Tree


Root/web/system/engine/hf_core.php

<?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 NOT NULL AUTO_INCREMENT,
                              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;
        }
 
 
    }
}

Archive Download this file

Branches

Number of commits:
Page rendered in 0.08971s using 11 queries.