Post.php

<?php

class PostAggregateRoot
{
    public function applyPostPublished(PostPublished $event) {
        $this->status = 'future';
        $this->publishDate = $event->publishDate;
    }

    public function timeElapsed(DateTime $now) {
        if ($this->status == 'future' && $now->greaterThan($this->publishDate)) {
            $this->recordThat(new PostPublished());
        }

        // other time events to execute..

        return $this;
    }
}

class PublishPostsConsole
{
    public function run() {
        $posts = StoredEvents::postUuids(); // get all posts

        foreach ($posts as $post) {
            PostAggregateRoot::retrieve($post->id)
                ->timeElapsed(now())
                ->persist();
        }
    }
}