|
|
@ -60,14 +60,9 @@ class FixityCheckWorker extends QueueWorkerBase implements ContainerFactoryPlugi |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
public function processItem($data) { |
|
|
|
public function processItem($data) { |
|
|
|
if ($data instanceof FixityCheckInterface) { |
|
|
|
if ($data instanceof FixityCheckInterface) { |
|
|
|
if (empty($data->getFile())) { |
|
|
|
|
|
|
|
$data->delete(); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
else { |
|
|
|
|
|
|
|
/** @var \Drupal\dgi_fixity\FixityCheckInterface $data */ |
|
|
|
/** @var \Drupal\dgi_fixity\FixityCheckInterface $data */ |
|
|
|
$this->fixity->check($data->getFile()); |
|
|
|
$this->fixity->check($data->getFile()); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|