message_cli.php

<?php

require_once "vendor/autoload.php";

use App\Storage\RedisStorage;

try {
    $options = getopt("m:d:");
    $config = require "./config/config.php";

    $message = $options['m'] ?? null;
    $delay = $options['d'] ?? 0;

    if ($delay < 0) {
        throw new InvalidArgumentException("delay must be a positive number");
    }

    if (is_null($message)) {
        throw new InvalidArgumentException("Missing message argument -m");
    }

    $storage = new RedisStorage($config['queue']['name'], $config['redis']['host'], $config['redis']['port']);

    $time = (new DateTime())->add(new DateInterval("PT{$delay}S"));

    $storage->push($message, $time);

    echo 'Success!' . PHP_EOL;

    return 0;
} catch (\Throwable $e) {
    var_dump($e);
    echo $e->getMessage();
    echo PHP_EOL;
    return 1;
}