Compilé au build. Exécuté en worker.

use Plerino\Http\ArrayOf;
use Plerino\Http\From;
use Plerino\Http\Input;
use Plerino\Http\Source;

final readonly class CreateTicket extends Input
{
    public function __construct(
        #[From(Source::Route)]
        public int $project,
        #[From(Source::Body)]
        public string $title,
        #[ArrayOf('int')]
        public array $labels = [],
        #[From(Source::Query)]
        public bool $notify = false,
        #[From(Source::Header, 'X-Request-Id')]
        public string $requestId = '',
    ) {}
}

<l-props>string $heading, array $products</l-props>
<Layout :title="$heading">
<h1>{{ $heading }}</h1>
<ul l-if="$products !== []">
<li l-each="$products as $name => $price">{{ $name }}: {{ $price }}</li>
</ul>
<p l-else>No products.</p>
</Layout>

use Plerino\Tessera\Attributes\Column;
use Plerino\Tessera\Attributes\ColumnType;
use Plerino\Tessera\Attributes\Entity;
use Plerino\Tessera\Attributes\HasMany;
use Plerino\Tessera\Attributes\Id;
use Plerino\Tessera\Attributes\IdStrategy;
use Plerino\Tessera\Attributes\Unique;

#[Entity('authors')]
#[Unique(['name'])]
final class Author
{
    #[HasMany(Post::class)]
    public array $posts = [];

    public function __construct(
        #[Column(ColumnType::String)]
        public string $name = '',
        #[Id(IdStrategy::Ulid)]
        public string $id = '',
    ) {}
}

use Plerino\Flux\Attributes\Job;
use Plerino\Flux\Attributes\Retry;
use Plerino\Flux\Attributes\Unique;
use Plerino\Flux\Job\Backoff;
use Plerino\Flux\Job\BackoffKind;

#[Job(queue: 'mail', timeout: 30)]
#[Retry(times: 4, backoff: new Backoff(BackoffKind::Exponential, seconds: 5, maxSeconds: 300, jitter: true))]
#[Unique(by: ['invoiceId'], for: 600)]
final readonly class SendInvoice
{
    public function __construct(public int $invoiceId, public string $locale = 'en') {}

    public function __invoke(InvoiceMailer $mailer): void
    {
        $mailer->send($this->invoiceId, $this->locale);
    }
}

use Plerino\Clock\Duration;
use Plerino\Flux\Workflow\WorkflowDefinition;

$definition = WorkflowDefinition::named('order-fulfilment')
    ->step('reserve-stock', new ReserveStock())
    ->approval('manager-review', approvers: 2)
    ->timer('cooling-off', Duration::hours(24))
    ->step('charge-card', new ChargeCard());

import { createClient } from '@plerino/comet';

const client = createClient({ url: 'wss://example.test/comet' });
const orders = client.channel('orders.42');

const stop = orders.on('paid', (payload, meta) => {
  console.log(meta.id, payload);
});

await orders.publish('note', { text: 'shipped' });

stop();
orders.leave();