add event payload cryptographer for personal data

[DavidBadura]

I took this blog post as inspiration and built a prototype:

https://www.eventstore.com/blog/protecting-sensitive-data-in-event-sourced-systems-with-crypto-shredding-1

This is what an event looks like when you use personal data:

<?php
use Patchlevel\EventSourcing\Attribute\DataSubjectId;
use Patchlevel\EventSourcing\Attribute\Event;
use Patchlevel\EventSourcing\Attribute\PersonalData;
use Patchlevel\EventSourcing\Serializer\Normalizer\IdNormalizer;

#[Event('profile.created')]
final class ProfileCreated
{
    public function __construct(
        #[IdNormalizer]
        #[DataSubjectId]
        public ProfileId $profileId,
        #[PersonalData(fallback: 'unknown')]
        public string $name,
    ) {
    }
}

And you can use a processor to remove personal data:

use Patchlevel\EventSourcing\Attribute\Processor;
use Patchlevel\EventSourcing\Attribute\Subscribe;
use Patchlevel\EventSourcing\Cryptography\Store\CipherKeyStore;
use Patchlevel\EventSourcing\Message\Message;

#[Processor('delete_personal_data')]
final class DeletePersonalDataProcessor
{
    public function __construct(
        private readonly CipherKeyStore $cipherKeyStore,
    ) {
    }

    #[Subscribe(UserHasRequestedDeletion::class)]
    public function handleUserHasRequestedDeletion(Message $message): void
    {
        $event = $message->event();

        $this->cipherKeyStore->remove($event->profileId->toString());
    }
}

[github-actions]

Hello 👋

here is the most recent benchmark result:

SubscriptionEngineBench
=======================

+---------------------------+-----------------+-----------------+-----------------+------------+
|                           | time (kde mode)                   | memory                       |
+---------------------------+-----------------+-----------------+-----------------+------------+
| subject                   | Tag: <current>  | Tag: base       | Tag: <current>  | Tag: base  |
+---------------------------+-----------------+-----------------+-----------------+------------+
| benchHandle10000Events () | 3.253s (±0.00%) | 3.231s (±0.00%) | 37.782mb        | 37.764mb   |
+---------------------------+-----------------+-----------------+-----------------+------------+

PersonalDataBench
=================

+----------------------------------------+--------------------+-----------------+
|                                        | time (kde mode)    | memory          |
+----------------------------------------+--------------------+-----------------+
| subject                                | Tag: <current>     | Tag: <current>  |
+----------------------------------------+--------------------+-----------------+
| benchLoad10000Events ()                | 231.896ms (±0.00%) | 39.980mb        |
| benchSave1Event ()                     | 1.455ms (±0.00%)   | 39.980mb        |
| benchSave10000Events ()                | 481.688ms (±0.00%) | 39.983mb        |
| benchSave10000Aggregates ()            | 14.107s (±0.00%)   | 39.980mb        |
| benchSave10000AggregatesTransaction () | 11.807s (±0.00%)   | 40.482mb        |
+----------------------------------------+--------------------+-----------------+

SplitStreamBench
================

+-------------------------+--------------------+--------------------+-----------------+------------+
|                         | time (kde mode)                         | memory                       |
+-------------------------+--------------------+--------------------+-----------------+------------+
| subject                 | Tag: <current>     | Tag: base          | Tag: <current>  | Tag: base  |
+-------------------------+--------------------+--------------------+-----------------+------------+
| benchLoad10000Events () | 5.475ms (±0.00%)   | 5.498ms (±0.00%)   | 41.234mb        | 41.203mb   |
| benchSave10000Events () | 556.626ms (±0.00%) | 568.987ms (±0.00%) | 41.244mb        | 41.222mb   |
+-------------------------+--------------------+--------------------+-----------------+------------+

SimpleSetupBench
================

+----------------------------------------+--------------------+--------------------+-----------------+------------+
|                                        | time (kde mode)                         | memory                       |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| subject                                | Tag: <current>     | Tag: base          | Tag: <current>  | Tag: base  |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| benchLoad10000Events ()                | 154.010ms (±0.00%) | 152.617ms (±0.00%) | 37.343mb        | 37.324mb   |
| benchSave1Event ()                     | 949.500μs (±0.00%) | 969.600μs (±0.00%) | 37.343mb        | 37.324mb   |
| benchSave10000Events ()                | 440.978ms (±0.00%) | 394.101ms (±0.00%) | 37.343mb        | 37.333mb   |
| benchSave10000Aggregates ()            | 9.689s (±0.00%)    | 9.879s (±0.00%)    | 37.343mb        | 37.324mb   |
| benchSave10000AggregatesTransaction () | 7.429s (±0.00%)    | 7.455s (±0.00%)    | 37.343mb        | 37.324mb   |
+----------------------------------------+--------------------+--------------------+-----------------+------------+

SnapshotsBench
==============

+----------------------------------------+--------------------+--------------------+-----------------+------------+
|                                        | time (kde mode)                         | memory                       |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| subject                                | Tag: <current>     | Tag: base          | Tag: <current>  | Tag: base  |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| benchLoad10000EventsMissingSnapshot () | 153.172ms (±0.00%) | 154.625ms (±0.00%) | 37.361mb        | 37.343mb   |
| benchLoad10000Events ()                | 514.500μs (±0.00%) | 513.900μs (±0.00%) | 37.361mb        | 37.343mb   |
+----------------------------------------+--------------------+--------------------+-----------------+------------+

This comment gets update everytime a new commit comes in!