Retrieve, Retrieve All and Remove user from database

Author: pH-7

src/Dal/UserDal.php

@@ -28,4 +28,28 @@ public static function create(UserEntity $userEntity): int|string
 
         return $id;
     }
+
+    public static function get(string $userUuid): ?array
+    {
+        $bindings = ['userUuid' => $userUuid];
+        $userBean = R::findOne(self::TABLE_NAME, 'user_uuid = :userUuid ', $bindings);
+
+       return $userBean?->export();
+    }
+
+    public static function getAll(): array
+    {
+        return R::findAll(self::TABLE_NAME);
+    }
+
+    public static function remove(string $userUuid): bool
+    {
+        $userBean = R::findOne(self::TABLE_NAME, 'user_uuid = :userUuid', ['userUuid' => $userUuid]);
+
+        if ($userBean) {
+            return (bool)R::trash($userBean);
+        }
+
+        return false;
+    }
 }

src/Service/User.php

@@ -17,7 +17,6 @@ class User
 
     public function create(mixed $data): object
     {
-        // validate data
         $userValidation = new UserValidation($data);
         if ($userValidation->isCreationSchemaValid()) {
             $userUuid = Uuid::uuid4(); // assigning a UUID to the user
@@ -49,23 +48,33 @@ public function create(mixed $data): object
 
     public function retrieveAll(): array
     {
-        return [];
+        $users = UserDal::getAll();
+
+        return array_map(function (object $user): object {
+            // Remove unnecessary "id" field
+            unset($user['id']);
+            return $user;
+        }, $users);
     }
 
-    public function retrieve(string $userId): self
+    public function retrieve(string $userUuid): array
     {
-        if (v::uuid()->validate($userId)) {
-            // TODO To be implemented
+        if (v::uuid()->validate($userUuid)) {
+            if ($user = UserDal::get($userUuid)) {
+                // Removing fields we don't want to expose
+                unset($user['id']);
+
+                return $user;
+            }
 
-            return $this;
+            return [];
         }
 
         throw new InvalidValidationException("Invalid user UUID");
     }
 
     public function update(mixed $postBody): object
     {
-        // validation schema
         $userValidation = new UserValidation($postBody);
         if ($userValidation->isUpdateSchemaValid()) {
             return $postBody;
@@ -74,16 +83,13 @@ public function update(mixed $postBody): object
         throw new InvalidValidationException("Invalid user payload");
     }
 
-    public function remove(string $userId): bool
+    public function remove(object $data): bool
     {
-        if (v::uuid()->validate($userId)) {
-            // TODO To be implemented
-        } else {
-            throw new InvalidValidationException("Invalid user UUID");
+        $userValidation = new UserValidation($data);
+        if ($userValidation->isRemoveSchemaValid()) {
+            return UserDal::remove($data->userUuid);
         }
 
-
-        // TODO Lookup the the DB user row with this userId
-        return true; // default value
+        throw new InvalidValidationException("Invalid user UUID");
     }
 }

src/Validation/UserValidation.php

@@ -10,11 +10,10 @@ class UserValidation
     private const MINIMUM_NAME_LENGTH = 2;
     private const MAXIMUM_NAME_LENGTH = 40;
 
-    public function __construct(private mixed $data) {}
+    public function __construct(private readonly mixed $data) {}
 
     public function isCreationSchemaValid(): bool
     {
-        // validation schema
         $schemaValidation =
             v::attribute('first', v::stringType()->length(self::MINIMUM_NAME_LENGTH, self::MAXIMUM_NAME_LENGTH))
             ->attribute('last', v::stringType()->length(self::MINIMUM_NAME_LENGTH, self::MAXIMUM_NAME_LENGTH))
@@ -24,6 +23,11 @@ public function isCreationSchemaValid(): bool
         return $schemaValidation->validate($this->data);
     }
 
+    public function isRemoveSchemaValid(): bool
+    {
+        return v::attribute('userUuid', v::uuid())->validate($this->data);
+    }
+
     public function isUpdateSchemaValid(): bool
     {
         // same schema for both creation and update

src/routes/user.routes.php

@@ -27,18 +27,18 @@ public function getResponse(): string
         try {
             $response = match ($this) {
                 self::CREATE => $user->create($postBody),
-                    self::RETRIEVE_ALL => $user->retrieveAll(),
-                    self::RETRIEVE => $user->retrieve($userId),
-                    self::REMOVE => $user->remove($userId),
-                    self::UPDATE => $user->update($postBody),
-                };
-            } catch (InvalidValidationException $e) {
-                // Send 400 http status code
-                Http::setHeadersByCode(StatusCode::BAD_REQUEST);
+                self::RETRIEVE_ALL => $user->retrieveAll(),
+                self::RETRIEVE => $user->retrieve($userId),
+                self::REMOVE => $user->remove($postBody),
+                self::UPDATE => $user->update($postBody),
+            };
+        } catch (InvalidValidationException $e) {
+            // Send 400 http status code
+            Http::setHeadersByCode(StatusCode::BAD_REQUEST);
 
-                $response = [
-                    'errors' => [
-                        'message' => $e->getMessage(),
+            $response = [
+                'errors' => [
+                    'message' => $e->getMessage(),
                     'code' => $e->getCode()
                 ]
             ];
@@ -55,6 +55,7 @@ public function getResponse(): string
 $userAction = match ($action) {
     'create' => UserAction::CREATE, // send 201
     'retrieve' => UserAction::RETRIEVE, // send 200
+    'retrieveall' => UserAction::RETRIEVE_ALL,
     'remove' => UserAction::REMOVE, // send 204 status code
     'update' => UserAction::UPDATE, //
     default => UserAction::RETRIEVE_ALL, // send 200