NotifyEtaWorkflow_v0.php

<?php

use Zenaton\Interfaces\WorkflowInterface;
use Zenaton\Traits\Zenatonable;
use Zenaton\Tasks\Wait;

class NotifyEtaWorkflow implements WorkflowInterface
{
    use Zenatonable;
    // inform user # seconds before ETA
    const BEFORE = 3600;
    // trip id
    protected $tripId;
    // user to notify
    protected $user;

    public function __construct($tripId, $user)
    {
        $this->tripId = $tripId;
        $this->user = $user;
    }

    public function handle()
    {
        // calulate current duration & ETA
        [$duration, $eta] = (new CalculateTimeToArrivalTask($this->tripId))->execute();
        // wait until ETA - 1hour
        (new Wait())->timestamp($eta - self::BEFORE)->execute();
        // notify user
        (new NotifyUserOfEtaTask($this->user, $eta))->execute();
    }
}