revert & fix again

Makefile

@@ -95,6 +95,10 @@ docs-inject-php:
 .PHONY: docs-format
 docs-format: docs-phpcs docs-inject-php
 
+.PHONY: docs-php-lint
+docs-php-lint: docs-extract-php
+	php -l docs_php/*.php | grep 'Parse error: '
+
 .PHONY: docs-phpcs
 docs-phpcs: docs-extract-php
 	vendor/bin/phpcbf docs_php --exclude=SlevomatCodingStandard.TypeHints.DeclareStrictTypes || true

docs/pages/cli.md

@@ -62,10 +62,11 @@ use Patchlevel\EventSourcing\Console\DoctrineHelper;
 use Patchlevel\EventSourcing\Schema\DoctrineSchemaManager;
 use Symfony\Component\Console\Application;
 
-$store;
 /* define your doctrine store */
-$projectionist;
+$store;
+
 /* create projectionist */
+$projectionist;
 
 $cli = new Application('Event-Sourcing CLI');
 $cli->setCatchExceptions(true);
@@ -103,15 +104,18 @@ use Doctrine\Migrations\Tools\Console\Command;
 use Patchlevel\EventSourcing\Schema\DoctrineMigrationSchemaProvider;
 use Patchlevel\EventSourcing\Schema\DoctrineSchemaDirector;
 
-$connection; /* create connection */
-$store; /* define your doctrine store */
+/* create connection */
+$connection;
+/* define your doctrine store */
+$store;
 
 $schemaDirector = new DoctrineSchemaDirector(
     $store,
     $connection,
 );
 
-$migrationConfig; /* define your migration config */
+/* define your migration config */
+$migrationConfig;
 
 
 $dependencyFactory = DependencyFactory::fromConnection(

docs/pages/clock.md

@@ -16,8 +16,8 @@ $clock = new SystemClock();
 $date = $clock->now(); // get the actual datetime
 $date2 = $clock->now();
 
-$date === $date2; // false
-$date === $date2; // false
+// $date == $date2 => false
+// $date === $date2 => false
 ```
 ## FrozenClock
 
@@ -32,8 +32,8 @@ $date = new DateTimeImmutable();
 $clock = new FrozenClock($date);
 $frozenDate = $clock->now(); // gets the date provided before
 
-$date === $frozenDate; // true
-$date === $frozenDate; // false
+// $date == $frozenDate => true
+// $date === $frozenDate => false
 ```
 The `FrozenClock` can also be updated with a new date, so you can test a jump in time.
 
@@ -48,8 +48,8 @@ $clock->update($secondDate);
 
 $frozenDate = $clock->now();
 
-$firstDate === $frozenDate; // false
-$secondDate === $frozenDate; // true
+// $firstDate == $frozenDate => false
+// $secondDate == $frozenDate => true
 ```
 Or you can use the `sleep` method to simulate a time jump.
 

docs/pages/event_bus.md

@@ -65,8 +65,7 @@ $message->customHeaders(); // ['application-id' => 'app']
 If you want *all* the headers you can also retrieve them.
 
 ```php
-$message->headers();
-
+$headers = $message->headers();
 /*
 [
     'aggregateName' => 'profile',

docs/pages/getting_started.md

@@ -279,6 +279,7 @@ $connection = DriverManager::getConnection(['url' => 'mysql://user:secret@localh
 
 $projectionConnection = DriverManager::getConnection(['url' => 'mysql://user:secret@localhost/projection']);
 
+/* your own mailer */
 $mailer;
 
 $serializer = DefaultEventSerializer::createFromPaths(['src/Domain/Hotel/Event']);

docs/pages/normalizer.md

@@ -288,12 +288,33 @@ You also need to implement a `normalize` and `denormalize` method.
 Finally, you have to allow the normalizer to be used as an attribute.
 
 ```php
-use Patchlevel\Hydrator\Normalizer\DateTimeImmutableNormalizer;
+use Patchlevel\Hydrator\Normalizer\InvalidArgument;
+use Patchlevel\Hydrator\Normalizer\Normalizer;
 
-final class DTO
+#[Attribute(Attribute::TARGET_PROPERTY)]
+class NameNormalizer implements Normalizer
 {
-    #[DateTimeImmutableNormalizer]
-    public DateTimeImmutable $date;
+    public function normalize(mixed $value): string
+    {
+        if (!$value instanceof Name) {
+            throw InvalidArgument::withWrongType(Name::class, $value);
+        }
+
+        return $value->toString();
+    }
+
+    public function denormalize(mixed $value): Name|null
+    {
+        if ($value === null) {
+            return null;
+        }
+
+        if (!is_string($value)) {
+            throw InvalidArgument::withWrongType('string', $value);
+        }
+
+        return new Name($value);
+    }
 }
 ```
 !!! warning

docs/pages/pipeline.md

@@ -245,24 +245,9 @@ $middleware = new FilterEventMiddleware(static function (AggregateChanged $event
 With this middleware you can exclude archived events.
 
 ```php
-use Patchlevel\EventSourcing\Pipeline\Middleware\ExcludeEventMiddleware;
-use Patchlevel\EventSourcing\Pipeline\Middleware\RecalculatePlayheadMiddleware;
-use Patchlevel\EventSourcing\Pipeline\Middleware\ReplaceEventMiddleware;
-use Patchlevel\EventSourcing\Pipeline\Pipeline;
-use Patchlevel\EventSourcing\Pipeline\Source\StoreSource;
-use Patchlevel\EventSourcing\Pipeline\Target\StoreTarget;
+use Patchlevel\EventSourcing\Pipeline\Middleware\ExcludeArchivedEventMiddleware;
 
-$pipeline = new Pipeline(
-    new StoreSource($oldStore),
-    new StoreTarget($newStore),
-    [
-        new ExcludeEventMiddleware([PrivacyAdded::class]),
-        new ReplaceEventMiddleware(OldVisited::class, static function (OldVisited $oldVisited) {
-            return new NewVisited($oldVisited->profileId());
-        }),
-        new RecalculatePlayheadMiddleware(),
-    ],
-);
+$middleware = new ExcludeArchivedEventMiddleware();
 ```
 !!! warning
 

docs/pages/store.md

@@ -275,7 +275,14 @@ There is also the possibility of executing a function in a transaction.
 Then dbal takes care of starting a transaction, committing it and then possibly rollback it again.
 
 ```php
-use Doctrine\DBAL\DriverManager;
+$store->transactional(static function () use ($command, $bankAccountRepository): void {
+    $accountFrom = $bankAccountRepository->get($command->from());
+    $accountTo = $bankAccountRepository->get($command->to());
 
-$connection = DriverManager::getConnection(['url' => 'mysql://user:secret@localhost/app']);
+    $accountFrom->transferMoney($command->to(), $command->amount());
+    $accountTo->receiveMoney($command->from(), $command->amount());
+
+    $bankAccountRepository->save($accountFrom);
+    $bankAccountRepository->save($accountTo);
+});
 ```

docs/pages/subscription.md

@@ -572,13 +572,7 @@ All booting subscriptions will catch up to the current event stream.
 After the boot process, the subscription is set to active or finished.
 
 ```php
-use Patchlevel\EventSourcing\Attribute\Subscriber;
-use Patchlevel\EventSourcing\Subscription\RunMode;
-
-#[Subscriber('do_stuff', RunMode::Once)]
-final class DoStuffSubscriber
-{
-}
+$subscriptionEngine->boot($criteria);
 ```
 ### Run
 

docs/pages/upcasting.md

@@ -104,7 +104,7 @@ final class EventStreamCleanupCommand extends Command
 
         $pipeline->run();
 
-        return 0;
+        return Command::SUCCESS;
     }
 }
 ```