initial commit (All the (core) files are added)

Author: hussainaliweb

Application.php

@@ -0,0 +1,119 @@
+<?php
+
+namespace app\core;
+
+use app\core\database\Database;
+use app\models\User;
+
+class Application
+{
+    /**
+     * @var Router
+     */
+    public $router;
+    /**
+     * @var Request
+     */
+    public $request;
+    /**
+     * @var Response
+     */
+    public $response;
+    /**
+     * @var View
+     */
+    public $view;
+    /**
+     * @var Application
+     */
+    public static $app;
+    /**
+     * @var string
+     */
+    public static $ROOT_PATH;
+
+    /**
+     * @var Database
+     */
+    public $db;
+
+    /**
+     * @var Session
+     */
+    public $session;
+
+    /**
+     * @var Controller
+     */
+    public $controller;
+
+    public $userClassName;
+
+    /**
+     * @param string $root_path
+     * @param array $config
+     */
+    public function __construct(string $root_path, array $config = [])
+    {
+        self::$ROOT_PATH     = $root_path;
+        $this->request       = new Request();
+        $this->router        = new Router($this->request);
+        $this->response      = new Response();
+        $this->view          = new View($config['layout'] ?? '');
+        self::$app           = $this;
+        $this->db            = new Database($config['db'] ?? []);
+        $this->session       = new Session();
+        $this->userClassName = $config['userClassName'] ?? '';
+    }
+
+    /**
+     * @return void
+     */
+    public function run()
+    {
+        try
+        {
+            echo $this->router->resolve();
+        }
+        catch (\Exception $e)
+        {
+            $this->response->setCode($e->getCode());
+            echo $this->view->renderView('_error', [
+                'exception'=> $e
+            ]);
+        }
+    }
+
+    public function login(int $id): bool
+    {
+        $this->session->set('user', $id);
+        return true;
+    }
+
+    public static function isGuest(): bool
+    {
+        return !Application::$app->isLoggedIn();
+    }
+
+    public static function user()
+    {
+        if(($id = Application::$app->isLoggedIn()) === false)
+        {
+            return false;
+        }
+
+        return Application::$app->userClassName::find([
+            Application::$app->userClassName::primaryKey()=> $id
+        ]);
+    }
+
+    public function logout(): bool
+    {
+        return $this->session->remove('user');
+    }
+
+    public function isLoggedIn()
+    {
+        return $this->session->get('user') ?? false;
+    }
+}

Controller.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace app\core;
+
+abstract class Controller
+{
+    protected $middlewares = [];
+    public $action;
+    protected $model = null;
+
+    public function __construct(Model $model = null)
+    {
+        $this->model = $model;
+    }
+
+    public function validate(Request $request): bool
+    {
+        $this->model->load($request->getBody());
+        return $this->model->validate();
+    }
+
+    public function save(): bool
+    {
+        return $this->model->save();
+    }
+
+    /**
+     * @param string $view
+     * @param array $params
+     * @return array|false|string|string[]
+     */
+    public function render(string $view, array $params = [])
+    {
+        return Application::$app->view->renderView($view, $params);
+    }
+
+    /**
+     * @param string $layout
+     * @return void
+     */
+    public function setLayout(string $layout)
+    {
+        Application::$app->view->setLayout($layout);
+    }
+
+    public function registerMiddleware(Middleware $middleware)
+    {
+        $this->middlewares[] = $middleware;
+    }
+
+    /**
+     * @return array
+     */
+    public function getMiddlewares(): array
+    {
+        return $this->middlewares;
+    }
+}

Middleware.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace app\core;
+
+abstract class Middleware
+{
+    abstract public function execute();
+}

Migration.php

@@ -0,0 +1,170 @@
+<?php
+
+namespace app\core;
+
+use app\core\database\Database;
+
+class Migration
+{
+    public static $migrationTableName = 'migration';
+    /**
+     * @var array
+     */
+    protected $migrations;
+
+    /**
+     * @var Database
+     */
+    public static $db;
+
+    /**
+     * @var string
+     */
+    public static $ROOT_PATH;
+
+    /**
+     * @var string
+     */
+    public static $MIGRATION_PATH;
+
+    /**
+     * @var bool
+     */
+    public static $saveMigrationInDb = true;
+
+    /**
+     * @var int
+     */
+    protected $batch         = 1;
+    protected $batchMigrated = 0;
+
+    /**
+     * @param string $root_path
+     * @param string $migration_path
+     * @param array $config
+     * @return void
+     */
+    public function setup(string $root_path, string $migration_path, array $config = [])
+    {
+        static::$db           = new Database($config ?? []);
+        self::$ROOT_PATH      = $root_path;
+        self::$MIGRATION_PATH = $migration_path;
+    }
+
+    /**
+     * @return string
+     */
+    public function getMigrationsPath(): string
+    {
+        return self::$ROOT_PATH . '/' . self::$MIGRATION_PATH;
+    }
+
+    /**
+     * @return array
+     */
+    public function getMigrationFiles(): array
+    {
+        $this->migrations = array_filter(scandir($this->getMigrationsPath()), function ($migration) {
+            return !($migration === '.' || $migration === '..');
+        });
+
+        return $this->migrations;
+    }
+
+    /**
+     * @param $message
+     * @return void
+     */
+    public function message($message)
+    {
+        echo $message, ' ', static::class, PHP_EOL;
+    }
+
+    /**
+     * @return void
+     */
+    public function migrate()
+    {
+        $migrationPath = $this->getMigrationsPath();
+        $this->batch   = $this->getNextBatchNumber();
+
+        foreach ($this->getMigrationFiles() as $migration)
+        {
+            if(!$this->isMigrated($migration))
+            {
+                $this->batchMigrated++;
+                $this->migrateSingleFile($migrationPath, $migration);
+            }
+        }
+
+        $this->showIfNothingIsMigrated();
+    }
+
+    public function showIfNothingIsMigrated()
+    {
+        if(!$this->batchMigrated)
+        {
+            echo 'Nothing to migrate!', PHP_EOL;
+        }
+    }
+
+    public function getNextBatchNumber(): int
+    {
+        try {
+            $sql       = 'SELECT batch FROM ' . self::$migrationTableName . ' ORDER BY batch DESC LIMIT 1';
+            $statement = self::$db->pdo->prepare($sql);
+            $statement->execute();
+            $batch     = $statement->fetch(\PDO::FETCH_OBJ);
+
+            return ++$batch->batch;
+        } catch (\PDOException $e)
+        {
+            return 1;
+        }
+    }
+
+    /**
+     * @param string $migration
+     * @return bool
+     */
+    public function isMigrated(string $migration): bool
+    {
+        try {
+            $sql  = "SELECT * FROM " . self::$migrationTableName. " WHERE migration = '{$migration}' LIMIT 1";
+            $stmt = self::$db->pdo->prepare($sql);
+            $stmt->execute();
+        }
+        catch (\PDOException $e) {
+            return false;
+        }
+
+        return $stmt->rowCount() > 0;
+    }
+
+    /**
+     * @param string $migrationPath
+     * @param string $migration
+     * @return void
+     */
+    public function migrateSingleFile(string $migrationPath, string $migration)
+    {
+        require $migrationPath . '/' . $migration;
+        $class  = 'app\\migrations\\' . pathinfo($migration, PATHINFO_FILENAME);
+        $object = new $class();
+        $object->up();
+
+        if($class::$saveMigrationInDb)
+        {
+            $this->saveMigration($migration);
+        }
+    }
+
+    public function saveMigration(string $migration)
+    {
+        $sql  = "INSERT INTO " . self::$migrationTableName . "(migration, batch) VALUES (:migration, :batch)";
+        $stmt = self::$db->pdo->prepare($sql);
+        $stmt->bindValue(':migration', $migration);
+        $stmt->bindValue(':batch', $this->batch);
+        $stmt->execute();
+    }
+}