submissionIds = $submissionIds; } /** * Execute the job. * */ public function handle(): void { $successful = 0; $submissionSearchIndex = Application::getSubmissionSearchIndex(); foreach ($this->submissionIds as $currentSubmissionId) { $submission = Repo::submission()->get($currentSubmissionId); if (!$submission) { continue; } $submissionSearchIndex->submissionMetadataChanged($submission); $submissionSearchIndex->submissionFilesChanged($submission); $successful++; } if (!$successful) { throw new JobException(JobException::INVALID_PAYLOAD); } $submissionSearchIndex->submissionChangesFinished(); } }