sapiet/processor

There is no license information available for the latest version (0.2.1) of this package.

0.2.1 2020-12-21 15:21 UTC

Requires

• ext-json: *

Requires (Dev)

• symfony/var-dumper: ^5.1

Unknown License

• Xavier QUIÈVRE

README

This package allows you to handle state modifications.

For example, when you have a cron job that is executed every minute, and you want to alert someone if your script does not work, but once, not every minute !

Installation

composer require sapiet/processor

Usage

This example simulates a script that start throwing exceptions every second.

This configuration allows you to do something every 4 seconds.

If the Processor::ERROR_CALLBACK_DELAY_OPTION option is ommited, the callback will be called once.

In this example, the last call is executed without throwing an exception, so the success callback is called

<?php

require 'vendor/autoload.php';

use Sapiet\Processor\Processor;
use Sapiet\Processor\Resolvers\ExceptionResolver;
use Sapiet\Processor\Storage\FileStorage;

$processor = (new Processor())
    ->withProcess(function (bool $success, int $sleep = 1) {
        sleep($sleep);

        if (false === $success) {
            throw new \Exception('Failed!');
        }
    })
    ->withResolver(new ExceptionResolver())
    ->withStorage(new FileStorage('processor.txt'))
    ->withOption(Processor::ERROR_CALLBACK_DELAY_OPTION, 4)
    ->onSuccess(function() {
        echo 'Yeah!'.PHP_EOL;
    })
    ->onError(function (array $bag) {
        echo sprintf('Oh noooo (%s)', $bag['exception']->getMessage()).PHP_EOL;
    })
;

$values = array_merge(
    [true],
    array_fill(0, 10, false),
    [true]
);

foreach ($values as $value) {
    $processor->process($value);
}

Ouput:

Oh noooo (failed!)
Oh noooo (failed!)
Oh noooo (failed!)
Yeah!

You can also use the BooleanResolver or simply create yours if your script has a different behavior by implementing the ResolverInterface and extending the BaseResolver

There is only one available storage class, FileStorage, but you can easily create yours by implementing StorageInterface