108 lines
3.2 KiB
PHP
108 lines
3.2 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs;
|
|
|
|
use App\Models\BulkOperationRun;
|
|
use App\Models\Policy;
|
|
use App\Notifications\RunStatusChangedNotification;
|
|
use App\Services\BulkOperationService;
|
|
use App\Services\Intune\VersionService;
|
|
use Illuminate\Bus\Queueable;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|
use Illuminate\Queue\InteractsWithQueue;
|
|
use Illuminate\Queue\SerializesModels;
|
|
use Throwable;
|
|
|
|
class CapturePolicySnapshotJob implements ShouldQueue
|
|
{
|
|
use Dispatchable;
|
|
use InteractsWithQueue;
|
|
use Queueable;
|
|
use SerializesModels;
|
|
|
|
public function __construct(
|
|
public int $bulkOperationRunId,
|
|
public int $policyId,
|
|
public bool $includeAssignments = true,
|
|
public bool $includeScopeTags = true,
|
|
public ?string $createdBy = null,
|
|
) {}
|
|
|
|
public function handle(BulkOperationService $bulkOperationService, VersionService $versionService): void
|
|
{
|
|
$run = BulkOperationRun::query()->with(['tenant', 'user'])->find($this->bulkOperationRunId);
|
|
|
|
if (! $run) {
|
|
return;
|
|
}
|
|
|
|
$policy = Policy::query()->with('tenant')->find($this->policyId);
|
|
|
|
if (! $policy || ! $policy->tenant) {
|
|
$bulkOperationService->abort($run, 'policy_not_found');
|
|
$this->notifyStatus($run, 'failed');
|
|
|
|
return;
|
|
}
|
|
|
|
$this->notifyStatus($run, 'queued');
|
|
$bulkOperationService->start($run);
|
|
$this->notifyStatus($run, 'running');
|
|
|
|
try {
|
|
$versionService->captureFromGraph(
|
|
tenant: $policy->tenant,
|
|
policy: $policy,
|
|
createdBy: $this->createdBy,
|
|
includeAssignments: $this->includeAssignments,
|
|
includeScopeTags: $this->includeScopeTags,
|
|
);
|
|
|
|
$bulkOperationService->recordSuccess($run);
|
|
$bulkOperationService->complete($run);
|
|
|
|
$this->notifyStatus($run, $run->refresh()->status);
|
|
} catch (Throwable $e) {
|
|
$bulkOperationService->recordFailure(
|
|
run: $run,
|
|
itemId: (string) $policy->getKey(),
|
|
reason: $bulkOperationService->sanitizeFailureReason($e->getMessage())
|
|
);
|
|
|
|
$bulkOperationService->complete($run);
|
|
|
|
$this->notifyStatus($run->refresh(), $run->status);
|
|
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
private function notifyStatus(BulkOperationRun $run, string $status): void
|
|
{
|
|
if (! $run->relationLoaded('user')) {
|
|
$run->loadMissing('user');
|
|
}
|
|
|
|
if (! $run->user) {
|
|
return;
|
|
}
|
|
|
|
$normalizedStatus = $status === 'pending' ? 'queued' : $status;
|
|
|
|
$run->user->notify(new RunStatusChangedNotification([
|
|
'tenant_id' => (int) $run->tenant_id,
|
|
'run_type' => 'bulk_operation',
|
|
'run_id' => (int) $run->getKey(),
|
|
'status' => (string) $normalizedStatus,
|
|
'counts' => [
|
|
'total' => (int) $run->total_items,
|
|
'processed' => (int) $run->processed_items,
|
|
'succeeded' => (int) $run->succeeded,
|
|
'failed' => (int) $run->failed,
|
|
'skipped' => (int) $run->skipped,
|
|
],
|
|
]));
|
|
}
|
|
}
|