final readonly class {Name}Command
{
    public function __construct(
        public {ValueObject} $id,
        public string $data
    ) {
        if (empty($data)) {
            throw new \InvalidArgumentException('Data is required');
        }
    }
 
    public static function fromArray(array $data): self
    {
        return new self(
            id: new {ValueObject}($data['id']),
            data: $data['data']
        );
    }
}

final readonly class {Name}Handler
{
    public function __construct(
        private {Repository}Interface $repository,
        private EventDispatcherInterface $events
    ) {}
 
    public function __invoke({Name}Command $command): void
    {
        $aggregate = $this->repository->findById($command->id);
 
        if ($aggregate === null) {
            throw new NotFoundException($command->id);
        }
 
        $aggregate->doSomething($command->data);
 
        $this->repository->save($aggregate);
 
        foreach ($aggregate->releaseEvents() as $event) {
            $this->events->dispatch($event);
        }
    }
}

public function __invoke(CreateCommand $command): AggregateId
{
    $aggregate = Aggregate::create(
        id: $this->repository->nextIdentity(),
        ...
    );
 
    $this->repository->save($aggregate);
 
    foreach ($aggregate->releaseEvents() as $event) {
        $this->events->dispatch($event);
    }
 
    return $aggregate->id();
}