TenantAtlas/apps/platform/app/Jobs/BulkPolicySyncJob.php

<?php

namespace App\Jobs;

use App\Models\OperationRun;
use App\Services\Intune\PolicySyncService;
use App\Services\OperationRunService;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

class BulkPolicySyncJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public function __construct(public int $bulkRunId) {}

    public function handle(PolicySyncService $syncService, OperationRunService $runs): void
    {
        $run = OperationRun::query()->find($this->bulkRunId);

        if (! $run instanceof OperationRun) {
            return;
        }
        $policyIds = data_get($run->context ?? [], 'policy_ids');

        if (! is_array($policyIds)) {
            return;
        }

        (new SyncPoliciesJob(
            tenantId: (int) $run->managed_environment_id,
            types: null,
            policyIds: $policyIds,
            operationRun: $run,
        ))->handle($syncService, $runs);
    }
}