Add new classes for User reading

Author: pH-7

src/Action/User/ListUsersAction.php

@@ -1,4 +1,5 @@
 <?php
+
 declare(strict_types=1);
 
 namespace App\Action\User;

src/Action/User/UserAction.php

@@ -1,4 +1,5 @@
 <?php
+
 declare(strict_types=1);
 
 namespace App\Action\User;

src/Action/User/UserReadAction.php

@@ -0,0 +1,54 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Action\User;
+
+use App\Domain\User\Service\UserReader;
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\ServerRequestInterface;
+
+final class UserReadAction
+{
+    private UserReader $userReader;
+
+    public function __construct(UserReader $userReader)
+    {
+        $this->userReader = $userReader;
+    }
+
+    /**
+     * Invoke.
+     *
+     * @param ServerRequestInterface $request The request
+     * @param ResponseInterface $response The response
+     * @param array<mixed> $args The route arguments
+     *
+     * @return ResponseInterface The response
+     */
+    public function __invoke(
+        ServerRequestInterface $request,
+        ResponseInterface $response,
+        array $args = []
+    ): ResponseInterface {
+        // Collect input from the HTTP request
+        $userId = (int)$args['id'];
+
+        // Invoke the Domain (application service) with inputs and keep the result
+        $user = $this->userReader->getUserDetails($userId);
+
+        // Transform the result into the JSON representation
+        $result = [
+            'user_id' => $user->id,
+            'username' => $user->username,
+            'first_name' => $user->firstName,
+            'last_name' => $user->lastName,
+            'email' => $user->email,
+        ];
+
+        // Build the HTTP response
+        $response->getBody()->write((string)json_encode($result));
+
+        return $response->withHeader('Content-Type', 'application/json')->withStatus(200);
+    }
+}

src/Action/User/ViewUserAction.php

@@ -1,4 +1,5 @@
 <?php
+
 declare(strict_types=1);
 
 namespace App\Action\User;

src/Domain/User/Data/UserReaderResult.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\User\Data;
+
+final class UserReaderResult
+{
+    public int $id;
+
+    public string $username;
+
+    public string $firstName;
+
+    public string $lastName;
+
+    public string $email;
+}

src/Domain/User/Repository/UserReaderRepository.php

@@ -0,0 +1,46 @@
+<?php
+
+namespace App\Domain\User\Repository;
+
+use App\Domain\User\Data\UserReaderResult;
+use DomainException;
+use PDO;
+
+class UserReaderRepository
+{
+    private PDO $connection;
+
+    /**
+     * Constructor.
+     *
+     * @param PDO $connection The database connection
+     */
+    public function __construct(PDO $connection)
+    {
+        $this->connection = $connection;
+    }
+
+    /**
+     * Get user by the given user id.
+     *
+     * @param int $userId The user id
+     *
+     * @throws DomainException
+     *
+     * @return array The user row
+     */
+    public function getUserById(int $userId): array
+    {
+        $sql = "SELECT id, username, first_name, last_name, email FROM users WHERE id = :id;";
+        $statement = $this->connection->prepare($sql);
+        $statement->execute(['id' => $userId]);
+
+        $row = $statement->fetch();
+
+        if (!$row) {
+            throw new DomainException(sprintf('User not found: %s', $userId));
+        }
+
+        return $row;
+    }
+}

src/Domain/User/Service/UserReader.php

@@ -0,0 +1,50 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\User\Service;
+
+use App\Domain\User\Data\UserReaderResult;
+use App\Domain\User\Repository\UserReaderRepository;
+use App\Exception\ValidationException;
+
+final class UserReader
+{
+    private UserReaderRepository $repository;
+
+    public function __construct(UserReaderRepository $repository)
+    {
+        $this->repository = $repository;
+    }
+
+    /**
+     * Read a user by the given user id.
+     *
+     * @param int $userId The user id
+     *
+     * @throws ValidationException
+     *
+     * @return UserReaderResult The user data
+     */
+    public function getUserDetails(int $userId): UserReaderResult
+    {
+        // Input validation
+        if (empty($userId)) {
+            throw new ValidationException('User ID required');
+        }
+
+        $userRow = $this->repository->getUserById($userId);
+
+        // Optional: Do something complex here...
+
+        // Map array to data object
+        $user = new UserReaderResult();
+        $user->id = (int)$userRow['id'];
+        $user->username = (string)$userRow['username'];
+        $user->firstName = (string)$userRow['first_name'];
+        $user->lastName = (string)$userRow['last_name'];
+        $user->email = (string)$userRow['email'];
+
+        return $user;
+    }
+}