21220108336

Committed 21 Jan 2026 05:55PM UTC coverage: 38.99% (-6.1%) from 45.13%

Build # 21220108336

Build Type

Pull #185

github

Committed by

web-flow

Commit Message

Merge 7fa0e283e into 35f9e968a

Pull Request Pull Request #185: EventHub command protection and restyling

Run Details

0 of 189 new or added lines in 8 files covered. (0.0%)

6 existing lines in 5 files now uncovered.

278 of 713 relevant lines covered (38.99%)

12.51 hits per line

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

0.0

/src/Console/Commands/EventHub/WebhookToggle.php

<?php

namespace Northwestern\SysDev\SOA\Console\Commands\EventHub;

use Illuminate\Console\Command;
use Illuminate\Console\ConfirmableTrait;
use Northwestern\SysDev\SOA\Console\Commands\Concerns\ConfirmsEventHubChanges;
use Northwestern\SysDev\SOA\EventHub;

use function Laravel\Prompts\multiselect;
use function Laravel\Prompts\spin;

class WebhookToggle extends Command
{
    use ConfirmableTrait, ConfirmsEventHubChanges;

    protected $signature = 'eventhub:webhook:toggle {status : pause or unpause} {queues?* : one or more queues to toggle. if unspecified, all queues will be updated.}';

    protected $description = 'Pause or unpause webhook deliveries.';

    public function __construct(
        protected EventHub\Webhook $webhook_api
    ) {
        parent::__construct();
    }

    public function handle(): int
    {
        if (! $this->confirmWebhookToggle()) {
            $this->components->error('Command aborted.');

            return self::FAILURE;
        }

        $queues = [];

        $status = strtolower($this->argument('status'));
        if (in_array($status, ['pause', 'unpause']) === false) {
            $this->components->error('Invalid status. Please specify pause or unpause.');

            return self::FAILURE;
        }

        $specific_queues = $this->argument('queues');
        if (count($specific_queues) > 0) {
            $queues = $specific_queues;
        } else {
            $hooks = spin(
                fn () => $this->webhook_api->listAll(),
                'Fetching webhooks...'
            );

            $queues = collect($hooks['webhooks'])->pluck('topicName')->all();

            if (empty($queues)) {
                $this->components->warn('No webhooks found.');

                return self::SUCCESS;
            }
        }

        foreach ($queues as $queue) {
            try {
                spin(
                    fn () => $this->webhook_api->$status($queue),
                    ucfirst($status)."ing {$queue}..."
                );

                $this->components->info(ucfirst($status)."d <bg=magenta;fg=white;options=bold> {$queue} </>");
            } catch (EventHub\Exception\EventHubError $e) {
                $this->components->error("Unable to change status of <bg=magenta;fg=white;options=bold> {$queue} </>: {$e->getMessage()}");
                $this->newLine();
            }
        }

        // Display status after the changes are made.
        $this->call('eventhub:webhook:status');

        return self::SUCCESS;
    }
}

1	<?php
2
3	namespace Northwestern\SysDev\SOA\Console\Commands\EventHub;
4
5	use Illuminate\Console\Command;
6	use Illuminate\Console\ConfirmableTrait;
7	use Northwestern\SysDev\SOA\Console\Commands\Concerns\ConfirmsEventHubChanges;
8	use Northwestern\SysDev\SOA\EventHub;
9
10	use function Laravel\Prompts\multiselect;
11	use function Laravel\Prompts\spin;
12
13	class WebhookToggle extends Command
14	{
15	use ConfirmableTrait, ConfirmsEventHubChanges;
16
17	protected $signature = 'eventhub:webhook:toggle {status : pause or unpause} {queues?* : one or more queues to toggle. if unspecified, all queues will be updated.}';
18
19	protected $description = 'Pause or unpause webhook deliveries.';
20
21	public function __construct(
22	protected EventHub\Webhook $webhook_api
23	) {
NEW 24	parent::__construct();	×
25	}
26
27	public function handle(): int
28	{
NEW 29	if (! $this->confirmWebhookToggle()) {	×
NEW 30	$this->components->error('Command aborted.');	×
31
NEW 32	return self::FAILURE;	×
33	}
34
UNCOV 35	$queues = [];	×
36
37	$status = strtolower($this->argument('status'));	×
38	if (in_array($status, ['pause', 'unpause']) === false) {	×
NEW 39	$this->components->error('Invalid status. Please specify pause or unpause.');	×
40
NEW 41	return self::FAILURE;	×
42	}
43
44	$specific_queues = $this->argument('queues');	×
45	if (count($specific_queues) > 0) {	×
46	$queues = $specific_queues;	×
47	} else {
NEW 48	$hooks = spin(	×
NEW 49	fn () => $this->webhook_api->listAll(),	×
NEW 50	'Fetching webhooks...'	×
NEW 51	);	×
52
NEW 53	$queues = collect($hooks['webhooks'])->pluck('topicName')->all();	×
54
NEW 55	if (empty($queues)) {	×
NEW 56	$this->components->warn('No webhooks found.');	×
57
NEW 58	return self::SUCCESS;	×
59	}
60	}
61
62	foreach ($queues as $queue) {	×
63	try {
NEW 64	spin(	×
NEW 65	fn () => $this->webhook_api->$status($queue),	×
NEW 66	ucfirst($status)."ing {$queue}..."	×
NEW 67	);	×
68
NEW 69	$this->components->info(ucfirst($status)."d <bg=magenta;fg=white;options=bold> {$queue} </>");	×
NEW 70	} catch (EventHub\Exception\EventHubError $e) {	×
NEW 71	$this->components->error("Unable to change status of <bg=magenta;fg=white;options=bold> {$queue} </>: {$e->getMessage()}");	×
NEW 72	$this->newLine();	×
73	}
74	}
75
76	// Display status after the changes are made.
77	$this->call('eventhub:webhook:status');	×
78
NEW 79	return self::SUCCESS;	×
80	}
81	}

NIT-Administrative-Systems / SysDev-laravel-soa / 21220108336

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