26886467550

Committed 03 Jun 2026 01:01PM UTC coverage: 88.948% (+14.0%) from 74.974%

Build # 26886467550

Build Type

push

github

Committed by

web-flow

Commit Message

v3.0: single clean architecture (remove V1, lease-based queues, secure-by-default)

Complete v3.0 rewrite into a single, clean architecture. The v1 API and the V2\ scaffolding
are removed (no facade, no dual code); the package passes PHPStan level 6 + strict-rules +
codeigniter with NO baseline.

- Definition: Jobs::define()->...->dispatch() fluent builder -> immutable JobDefinition.
- Handlers decoupled from the god-object (JobHandlerInterface / AbstractJobHandler / TypedJobHandler + JobContext).
- One QueueBackend contract (enqueue/fetch(lease)/ack/nack(delay)/abandon/reapExpired) with 5 backends:
  Sync, Database, Redis, Beanstalk, ServiceBus.
- Runtime: one attempt per fetch; real interrupting Timeout; opt-in idempotency; single-instance lock.
- Worker/Cron: jobs:queue:work, jobs:queue:reap, jobs:cronjob:run, jobs:queue:purge.
- Secure-by-default: HMAC-signed envelopes, per-queue handler allowlist, ShellHandler deny-by-default,
  EventHandler allowlist, UrlHandler anti-SSRF.

Resolves audit findings #1,#2,#3,#4,#5,#6,#7,#8,#10,#12,#13,#17,#18,#19,#20,#22.
Tests: 359 (Beanstalk live); line coverage 88.9%; PHPStan/Psalm/Rector/cs green on PHP 8.2-8.5.

BREAKING CHANGE: v1 API removed. See docs/MIGRATION-v1-to-v3.md.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Coverage Stats

983 of 1103 new or added lines in 43 files covered. (89.12%)

15 existing lines in 3 files now uncovered.

1497 of 1683 relevant lines covered (88.95%)

7.55 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/Queues/Backends/CurlServiceBusTransport.php

<?php

declare(strict_types=1);

/**
 * This file is part of Daycry Queues.
 *
 * (c) Daycry <daycry9@proton.me>
 *
 * For the full copyright and license information, please view
 * the LICENSE file that was distributed with this source code.
 */

namespace Daycry\Jobs\Queues\Backends;

/**
 * Default {@see ServiceBusTransport} forwarding to CodeIgniter's curlrequest service. The HTTP
 * response it returns already exposes getStatusCode()/getBody()/getHeader(), matching the shape
 * {@see ServiceBusBackend} expects.
 */
final class CurlServiceBusTransport implements ServiceBusTransport
{
    public function post(string $url, array $headers, ?string $body = null): object
    {
        $options = ['headers' => $headers];
        if ($body !== null) {
            $options['body'] = $body;
        }

        return service('curlrequest')->post($url, $options);
    }

    public function delete(string $url, array $headers): object
    {
        return service('curlrequest')->delete($url, ['headers' => $headers]);
    }
}

1	<?php
2
3	declare(strict_types=1);
4
5	/**
6	* This file is part of Daycry Queues.
7	*
8	* (c) Daycry <daycry9@proton.me>
9	*
10	* For the full copyright and license information, please view
11	* the LICENSE file that was distributed with this source code.
12	*/
13
14	namespace Daycry\Jobs\Queues\Backends;
15
16	/**
17	* Default {@see ServiceBusTransport} forwarding to CodeIgniter's curlrequest service. The HTTP
18	* response it returns already exposes getStatusCode()/getBody()/getHeader(), matching the shape
19	* {@see ServiceBusBackend} expects.
20	*/
21	final class CurlServiceBusTransport implements ServiceBusTransport
22	{
23	public function post(string $url, array $headers, ?string $body = null): object
24	{
NEW 25	$options = ['headers' => $headers];	×
NEW 26	if ($body !== null) {	×
NEW 27	$options['body'] = $body;	×
28	}
29
NEW 30	return service('curlrequest')->post($url, $options);	×
31	}
32
33	public function delete(string $url, array $headers): object
34	{
NEW 35	return service('curlrequest')->delete($url, ['headers' => $headers]);	×
36	}
37	}

daycry / jobs / 26886467550

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous