Merge pull request #1 from hexlet-components/db

add work with database

Author: fey

.gitignore

@@ -1,3 +1,4 @@
 vendor/
 users.json
 .vscode
+database.sqlite

composer.json

@@ -1,6 +1,6 @@
 {   "autoload": {
         "psr-4": {
-            "App\\": "src"
+            "App\\": "src/"
         }
     },
     "require": {

init.sql

@@ -0,0 +1,5 @@
+CREATE TABLE IF NOT EXISTS cars (
+    id INTEGER PRIMARY KEY AUTOINCREMENT,
+    make VARCHAR(255) NOT NULL,
+    model VARCHAR(255) NOT NULL
+);

public/index.php

@@ -4,15 +4,18 @@
 require __DIR__ . '/../vendor/autoload.php';
 
 // Контейнеры в этом курсе не рассматриваются (это тема связанная с самим ООП), но если вам интересно, то посмотрите DI Container
+
+use App\Car;
+use App\CarRepository;
+use App\CarValidator;
 use Slim\Factory\AppFactory;
 use Slim\Middleware\MethodOverrideMiddleware;
 use DI\Container;
-use App\Validator;
+use App\UserValidator;
 
 // Старт PHP сессии
 session_start();
 
-const FILE_PATH = __DIR__ . '/../users.json';
 const ADMIN_EMAIL = '[email protected]';
 
 function getUsers($request)
@@ -26,13 +29,26 @@ function filterUsersByName($users, $term)
 }
 
 $container = new Container();
+
 $container->set('renderer', function () {
     // Параметром передается базовая директория, в которой будут храниться шаблоны
     return new \Slim\Views\PhpRenderer(__DIR__ . '/../templates');
 });
+
 $container->set('flash', function () {
     return new \Slim\Flash\Messages();
 });
+
+$container->set(\PDO::class, function () {
+    $conn = new \PDO('sqlite:database.sqlite');
+    $conn->setAttribute(\PDO::ATTR_DEFAULT_FETCH_MODE, \PDO::FETCH_ASSOC);
+    return $conn;
+});
+
+$initFilePath = implode('/', [dirname(__DIR__), 'init.sql']);
+$initSql = file_get_contents($initFilePath);
+$container->get(\PDO::class)->exec($initSql);
+
 $app = AppFactory::createFromContainer($container);
 
 $router = $app->getRouteCollector()->getRouteParser();
@@ -74,7 +90,7 @@ function filterUsersByName($users, $term)
         return $response->withRedirect($router->urlFor('home'));
 });
 
-$app->get('/users', function ($request, $response) {
+$app->get('/users', function ($request, $response) use ($router) {
     if (!isset($_SESSION['isAdmin'])) {
         $this->get('flash')->addMessage('error', 'Access Denied! Please login!');
 
@@ -100,7 +116,7 @@ function filterUsersByName($users, $term)
     $users = getUsers($request);
     $userData = $request->getParsedBodyParam('user');
 
-    $validator = new Validator();
+    $validator = new UserValidator();
     $errors = $validator->validate($userData);
 
     if (count($errors) === 0) {
@@ -123,7 +139,7 @@ function filterUsersByName($users, $term)
     return $this->get('renderer')->render($response->withStatus(422), 'users/new.phtml', $params);
 })->setName('users.store');
 
-$app->get('/users/new', function ($request, $response) {
+$app->get('/users/new', function ($request, $response) use ($router){
     if (!isset($_SESSION['isAdmin'])) {
         $this->get('flash')->addMessage('error', 'Access Denied! Please login!');
 
@@ -143,7 +159,7 @@ function filterUsersByName($users, $term)
     return $response->write("Course id: {$id}");
 })->setName('courses.show');
 
-$app->get('/users/{id}', function ($request, $response, $args) {
+$app->get('/users/{id}', function ($request, $response, $args) use ($router) {
     if (!isset($_SESSION['isAdmin'])) {
         $this->get('flash')->addMessage('error', 'Access Denied! Please login!');
 
@@ -168,7 +184,7 @@ function filterUsersByName($users, $term)
     return $this->get('renderer')->render($response, 'users/show.phtml', $params);
 })->setName('users.show');
 
-$app->get('/users/{id}/edit', function ($request, $response, $args) {
+$app->get('/users/{id}/edit', function ($request, $response, $args) use ($router) {
     if (!isset($_SESSION['isAdmin'])) {
         $this->get('flash')->addMessage('error', 'Access Denied! Please login!');
 
@@ -195,7 +211,7 @@ function filterUsersByName($users, $term)
     $user = $users[$id];
     $userData = $request->getParsedBodyParam('user');
 
-    $validator = new Validator();
+    $validator = new UserValidator();
     $errors = $validator->validate($userData);
 
     if (count($errors) === 0) {
@@ -233,4 +249,113 @@ function filterUsersByName($users, $term)
         ->withRedirect($router->urlFor('users.index'));
 });
 
+$app->get('/cars', function ($request, $response) {
+    $carRepository = $this->get(CarRepository::class);
+    $cars = $carRepository->getEntities();
+
+    $messages = $this->get('flash')->getMessages();
+
+    $params = [
+      'cars' => $cars,
+      'flash' => $messages
+    ];
+
+    return $this->get('renderer')->render($response, 'cars/index.phtml', $params);
+})->setName('cars.index');
+
+$app->post('/cars', function ($request, $response) use ($router) {
+    $carRepository = $this->get(CarRepository::class);
+    $carData = $request->getParsedBodyParam('car');
+
+    $validator = new CarValidator();
+    $errors = $validator->validate($carData);
+
+    if (count($errors) === 0) {
+        $car = Car::fromArray([$carData['make'], $carData['model']]);
+        $carRepository->save($car);
+        $this->get('flash')->addMessage('success', 'Car was added successfully');
+        return $response->withRedirect($router->urlFor('cars.index'));
+    }
+
+    $params = [
+        'car' => $carData,
+        'errors' => $errors
+    ];
+
+    return $this->get('renderer')->render($response->withStatus(422), 'cars/new.phtml', $params);
+})->setName('cars.store');
+
+$app->get('/cars/new', function ($request, $response) {
+    $params = [
+        'car' => new Car(),
+        'errors' => []
+    ];
+
+    return $this->get('renderer')->render($response, 'cars/new.phtml', $params);
+})->setName('cars.create');
+
+$app->get('/cars/{id}', function ($request, $response, $args) {
+    $carRepository = $this->get(CarRepository::class);
+    $id = $args['id'];
+    $car = $carRepository->find($id);
+
+    if (is_null($car)) {
+        return $response->write('Page not found')->withStatus(404);
+    }
+
+    $messages = $this->get('flash')->getMessages();
+
+    $params = [
+        'car' => $car,
+        'flash' => $messages
+    ];
+
+    return $this->get('renderer')->render($response, 'cars/show.phtml', $params);
+})->setName('cars.show');
+
+$app->get('/cars/{id}/edit', function ($request, $response, $args) {
+    $carRepository = $this->get(CarRepository::class);
+    $messages = $this->get('flash')->getMessages();
+    $id = $args['id'];
+    $car = $carRepository->find($id);
+
+    $params = [
+        'car' => $car,
+        'errors' => [],
+        'flash' => $messages
+    ];
+
+    return $this->get('renderer')->render($response, 'cars/edit.phtml', $params);
+})->setName('cars.edit');
+
+$app->patch('/cars/{id}', function ($request, $response, $args) use ($router) {
+    $carRepository = $this->get(CarRepository::class);
+    $id = $args['id'];
+
+    $car = $carRepository->find($id);
+
+    if (is_null($car)) {
+        return $response->write('Page not found')->withStatus(404);
+    }
+
+    $carData = $request->getParsedBodyParam('car');
+    $validator = new CarValidator();
+    $errors = $validator->validate($carData);
+
+    if (count($errors) === 0) {
+        $car->setMake($carData['make']);
+        $car->setModel($carData['model']);
+        $carRepository->save($car);
+        $this->get('flash')->addMessage('success', "Car was updated successfully");
+        return $response->withRedirect($router->urlFor('cars.show', $args));
+    }
+
+    $params = [
+        'car' => $car,
+        'errors' => $errors
+    ];
+
+    return $this->get('renderer')->render($response->withStatus(422), 'cars/edit.phtml', $params);
+});
+
 $app->run();

src/Car.php

@@ -0,0 +1,54 @@
+<?php
+
+namespace App;
+
+class Car
+{
+    private ?int $id = null;
+    private ?string $make = null;
+    private ?string $model = null;
+
+    public static function fromArray(array $carData): Car
+    {
+        [$make, $model] = $carData;
+        $car = new Car();
+        $car->setMake($make);
+        $car->setModel($model);
+        return $car;
+    }
+
+    public function getId(): ?int
+    {
+        return $this->id;
+    }
+
+    public function getMake(): ?string
+    {
+        return $this->make;
+    }
+
+    public function getModel(): ?string
+    {
+        return $this->model;
+    }
+
+    public function setId(int $id): void
+    {
+        $this->id = $id;
+    }
+
+    public function setMake(string $make): void
+    {
+        $this->make = $make;
+    }
+
+    public function setModel(string $model): void
+    {
+        $this->model = $model;
+    }
+
+    public function exists(): bool
+    {
+        return !is_null($this->getId());
+    }
+}

src/CarRepository.php

@@ -0,0 +1,76 @@
+<?php
+
+namespace App;
+
+class CarRepository
+{
+    private \PDO $conn;
+
+    public function __construct(\PDO $conn)
+    {
+        $this->conn = $conn;
+    }
+
+    public function getEntities(): array
+    {
+        $cars = [];
+        $sql = "SELECT * FROM cars";
+        $stmt = $this->conn->query($sql);
+
+        while ($row = $stmt->fetch()) {
+            $car = Car::fromArray([$row['make'], $row['model']]);
+            $car->setId($row['id']);
+            $cars[] = $car;
+        }
+
+        return $cars;
+    }
+
+    public function find(int $id): ?Car
+    {
+        $sql = "SELECT * FROM cars WHERE id = ?";
+        $stmt = $this->conn->prepare($sql);
+        $stmt->execute([$id]);
+        if ($row = $stmt->fetch())  {
+            $car = Car::fromArray([$row['make'], $row['model']]);
+            $car->setId($row['id']);
+            return $car;
+        }
+
+        return null;
+    }
+
+    public function save(Car $car): void {
+        if ($car->exists()) {
+            $this->update($car);
+        } else {
+            $this->create($car);
+        }
+    }
+
+    private function update(Car $car): void
+    {
+        $sql = "UPDATE cars SET make = :make, model = :model WHERE id = :id";
+        $stmt = $this->conn->prepare($sql);
+        $id = $car->getId();
+        $make = $car->getMake();
+        $model = $car->getModel();
+        $stmt->bindParam(':make', $make);
+        $stmt->bindParam(':model', $model);
+        $stmt->bindParam(':id', $id);
+        $stmt->execute();
+    }
+
+    private function create(Car $car): void
+    {
+        $sql = "INSERT INTO cars (make, model) VALUES (:make, :model)";
+        $stmt = $this->conn->prepare($sql);
+        $make = $car->getMake();
+        $model = $car->getModel();
+        $stmt->bindParam(':make', $make);
+        $stmt->bindParam(':model', $model);
+        $stmt->execute();
+        $id = (int) $this->conn->lastInsertId();
+        $car->setId($id);
+    }
+}

src/CarValidator.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace App;
+
+class CarValidator
+{
+    public function validate(array $car): array
+    {
+        $errors = [];
+        if (empty($car['make'])) {
+            $errors['make'] = "Make can not be empty";
+        }
+
+        if (empty($car['model'])) {
+            $errors['model'] = "Model can not be empty";
+        }
+
+        return $errors;
+    }
+}

src/Validator.php renamed to src/UserValidator.php

@@ -2,7 +2,7 @@
 
 namespace App;
 
-class Validator
+class UserValidator
 {
     public function validate(array $user): array
     {