Add created and updated on the users events

config/mapping/orm/projections/User.Query.Projections.UserView.orm.xml

@@ -5,5 +5,7 @@
     <entity name="App\Infrastructure\User\Query\Projections\UserView" table="users">
         <id name="uuid" type="uuid_binary" column="uuid"/>
         <embedded name="credentials" class="App\Domain\User\ValueObject\Auth\Credentials"/>
+        <field name="createdAt" column="created_at" type="datetime_immutable" />
+        <field name="updatedAt" column="updated_at" nullable="true" type="datetime_immutable" />
     </entity>
 </doctrine-mapping>

config/packages/doctrine.yaml

@@ -17,6 +17,7 @@ doctrine:
         server_version: '5.7'
         types:
           uuid_binary: Ramsey\Uuid\Doctrine\UuidBinaryType
+          datetime_immutable: App\Infrastructure\Share\Doctrine\DateTimeType
         mapping_types:
           uuid_binary: binary
     orm:

src/Domain/Shared/Exception/DateTimeException.php

@@ -0,0 +1,13 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\Shared\Exception;
+
+class DateTimeException extends \Exception
+{
+    public function __construct(\Exception $e)
+    {
+        parent::__construct('Datetime Malformed or not valid', 500, $e);
+    }
+}

src/Domain/Shared/ValueObject/DateTime.php

@@ -0,0 +1,59 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\Shared\ValueObject;
+
+use App\Domain\Shared\Exception\DateTimeException;
+
+class DateTime
+{
+    const FORMAT = 'Y-m-d\TH:i:s.uP';
+
+    /**
+     * @throws DateTimeException
+     */
+    public static function now(): self
+    {
+        return self::create();
+    }
+
+    /**
+     * @throws DateTimeException
+     */
+    public static function fromString(string $dateTime): self
+    {
+        return self::create($dateTime);
+    }
+
+    /**
+     * @throws DateTimeException
+     */
+    private static function create(string $dateTime = ''): self
+    {
+        $self = new self();
+
+        try {
+            $self->dateTime = new \DateTimeImmutable($dateTime);
+        } catch (\Exception $e) {
+            throw new DateTimeException($e);
+        }
+
+        return $self;
+    }
+
+    public function toString(): string
+    {
+        return $this->dateTime->format(self::FORMAT);
+    }
+
+    public function toNative(): \DateTimeImmutable
+    {
+        return $this->dateTime;
+    }
+
+    /**
+     * @var \DateTimeImmutable
+     */
+    private $dateTime;
+}

src/Domain/User/Event/UserEmailChanged.php

@@ -4,6 +4,7 @@
 
 namespace App\Domain\User\Event;
 
+use App\Domain\Shared\ValueObject\DateTime;
 use App\Domain\User\ValueObject\Email;
 use Assert\Assertion;
 use Broadway\Serializer\Serializable;
@@ -22,22 +23,25 @@ public static function deserialize(array $data): self
 
         return new self(
             Uuid::fromString($data['uuid']),
-            Email::fromString($data['email'])
+            Email::fromString($data['email']),
+            DateTime::fromString($data['updated_at'])
         );
     }
 
     public function serialize(): array
     {
         return [
-            'uuid'  => $this->uuid->toString(),
-            'email' => $this->email->toString(),
+            'uuid'       => $this->uuid->toString(),
+            'email'      => $this->email->toString(),
+            'updated_at' => $this->updatedAt->toString(),
         ];
     }
 
-    public function __construct(UuidInterface $uuid, Email $email)
+    public function __construct(UuidInterface $uuid, Email $email, DateTime $updatedAt)
     {
         $this->email = $email;
         $this->uuid = $uuid;
+        $this->updatedAt = $updatedAt;
     }
 
     /**
@@ -49,4 +53,9 @@ public function __construct(UuidInterface $uuid, Email $email)
      * @var Email
      */
     public $email;
+
+    /**
+     * @var DateTime
+     */
+    public $updatedAt;
 }

src/Domain/User/Event/UserSignedIn.php

@@ -12,16 +12,6 @@
 
 final class UserSignedIn implements Serializable
 {
-    public static function create(UuidInterface $uuid, Email $email): self
-    {
-        $instance = new self();
-
-        $instance->uuid = $uuid;
-        $instance->email = $email;
-
-        return $instance;
-    }
-
     /**
      * @throws \Assert\AssertionFailedException
      */
@@ -30,7 +20,7 @@ public static function deserialize(array $data): self
         Assertion::keyExists($data, 'uuid');
         Assertion::keyExists($data, 'email');
 
-        return self::create(
+        return new self(
             Uuid::fromString($data['uuid']),
             Email::fromString($data['email'])
         );
@@ -44,6 +34,12 @@ public function serialize(): array
         ];
     }
 
+    public function __construct(UuidInterface $uuid, Email $email)
+    {
+        $this->uuid = $uuid;
+        $this->email = $email;
+    }
+
     /** @var Email */
     public $email;
 

src/Domain/User/Event/UserWasCreated.php

@@ -4,6 +4,7 @@
 
 namespace App\Domain\User\Event;
 
+use App\Domain\Shared\ValueObject\DateTime;
 use App\Domain\User\ValueObject\Auth\Credentials;
 use App\Domain\User\ValueObject\Auth\HashedPassword;
 use App\Domain\User\ValueObject\Email;
@@ -15,6 +16,7 @@
 final class UserWasCreated implements Serializable
 {
     /**
+     * @throws \App\Domain\Shared\Exception\DateTimeException
      * @throws \Assert\AssertionFailedException
      */
     public static function deserialize(array $data): self
@@ -27,7 +29,8 @@ public static function deserialize(array $data): self
             new Credentials(
                 Email::fromString($data['credentials']['email']),
                 HashedPassword::fromHash($data['credentials']['password'])
-            )
+            ),
+            DateTime::fromString($data['created_at'])
         );
     }
 
@@ -39,13 +42,15 @@ public function serialize(): array
                 'email'    => $this->credentials->email->toString(),
                 'password' => $this->credentials->password->toString(),
             ],
+            'created_at' => $this->createdAt->toString(),
         ];
     }
 
-    public function __construct(UuidInterface $uuid, Credentials $credentials)
+    public function __construct(UuidInterface $uuid, Credentials $credentials, DateTime $createdAt)
     {
         $this->uuid = $uuid;
         $this->credentials = $credentials;
+        $this->createdAt = $createdAt;
     }
 
     /**
@@ -57,4 +62,9 @@ public function __construct(UuidInterface $uuid, Credentials $credentials)
      * @var Credentials
      */
     public $credentials;
+
+    /**
+     * @var DateTime
+     */
+    public $createdAt;
 }

src/Domain/User/User.php

@@ -4,6 +4,7 @@
 
 namespace App\Domain\User;
 
+use App\Domain\Shared\ValueObject\DateTime;
 use App\Domain\User\Event\UserEmailChanged;
 use App\Domain\User\Event\UserSignedIn;
 use App\Domain\User\Event\UserWasCreated;
@@ -18,6 +19,9 @@
 
 class User extends EventSourcedAggregateRoot
 {
+    /**
+     * @throws \App\Domain\Shared\Exception\DateTimeException
+     */
     public static function create(
         UuidInterface $uuid,
         Credentials $credentials,
@@ -27,17 +31,20 @@ public static function create(
 
         $user = new self();
 
-        $user->apply(new UserWasCreated($uuid, $credentials));
+        $user->apply(new UserWasCreated($uuid, $credentials, DateTime::now()));
 
         return $user;
     }
 
+    /**
+     * @throws \App\Domain\Shared\Exception\DateTimeException
+     */
     public function changeEmail(
         Email $email,
         UniqueEmailSpecificationInterface $uniqueEmailSpecification
     ): void {
         $uniqueEmailSpecification->isUnique($email);
-        $this->apply(new UserEmailChanged($this->uuid, $email));
+        $this->apply(new UserEmailChanged($this->uuid, $email, DateTime::now()));
     }
 
     /**
@@ -51,7 +58,7 @@ public function signIn(string $plainPassword): void
             throw new InvalidCredentialsException('Invalid credentials entered.');
         }
 
-        $this->apply(UserSignedIn::create($this->uuid, $this->email));
+        $this->apply(new UserSignedIn($this->uuid, $this->email));
     }
 
     protected function applyUserWasCreated(UserWasCreated $event): void
@@ -60,6 +67,7 @@ protected function applyUserWasCreated(UserWasCreated $event): void
 
         $this->setEmail($event->credentials->email);
         $this->setHashedPassword($event->credentials->password);
+        $this->setCreatedAt($event->createdAt);
     }
 
     /**
@@ -70,6 +78,7 @@ protected function applyUserEmailChanged(UserEmailChanged $event): void
         Assertion::notEq($this->email->toString(), $event->email->toString(), 'New email should be different');
 
         $this->setEmail($event->email);
+        $this->setUpdatedAt($event->updatedAt);
     }
 
     private function setEmail(Email $email): void
@@ -82,6 +91,26 @@ private function setHashedPassword(HashedPassword $hashedPassword): void
         $this->hashedPassword = $hashedPassword;
     }
 
+    private function setCreatedAt(DateTime $createdAt): void
+    {
+        $this->createdAt = $createdAt;
+    }
+
+    private function setUpdatedAt(DateTime $updatedAt): void
+    {
+        $this->updatedAt = $updatedAt;
+    }
+
+    public function createdAt(): string
+    {
+        return $this->createdAt->toString();
+    }
+
+    public function updatedAt(): ?string
+    {
+        return isset($this->updatedAt) ? $this->updatedAt->toString() : null;
+    }
+
     public function email(): string
     {
         return $this->email->toString();
@@ -105,4 +134,10 @@ public function getAggregateRootId(): string
 
     /** @var HashedPassword */
     private $hashedPassword;
+
+    /** @var DateTime */
+    private $createdAt;
+
+    /** @var DateTime|null */
+    private $updatedAt;
 }