forceOptimization = $forceOptimization;
$this->queueService = $queueService;
$this->generateQueue = $generateQueue;
$this->jobManagerFactory = $jobManagerFactory;
$this->configProvider = $configProvider;
$this->imageProcessor = $imageProcessor;
$this->collectionFactory = $collectionFactory;
}
/**
* @inheritdoc
*/
public function execute(
\Symfony\Component\Console\Input\InputInterface $input,
\Symfony\Component\Console\Output\OutputInterface $output
) :?int {
$output->writeln('Generating Images Queue.');
$imageSettingCollection = $this->collectionFactory->create();
$imageSettingCollection->addFilter(ImageSetting::IS_ENABLED, true);
if ($imageSettingId = (int)$input->getOption(OptimizeCommand::IMAGE_SETTING_ID)) {
$imageSettingCollection->addFilter(ImageSetting::IMAGE_SETTING_ID, $imageSettingId);
}
$queueSize = $this->generateQueue->generateQueue($imageSettingCollection->getItems());
$counter = 0;
$maxJobs = $input->getOption(OptimizeCommand::JOBS_AMOUNT) ?: $this->configProvider->getMaxJobsCount();
$maxJobs = (int)$maxJobs;
if ($maxJobs > 1) {
if (!function_exists('pcntl_fork')) {
$output->writeln(__('Warning: \'pcntl\' php extension is required for parallel image optimization.'));
$maxJobs = 1;
}
}
$multiProcessMode = $maxJobs > 1;
/** @var \Symfony\Component\Console\Helper\ProgressBar $progressBar */
$progressBar = ObjectManager::getInstance()->create(
\Symfony\Component\Console\Helper\ProgressBar::class,
[
'output' => $output,
'max' => ceil($queueSize/100)
]
);
$progressBar->setFormat(
'%message% %current%/%max% [%bar%]'
);
$output->writeln('Optimization Process Started.');
$progressBar->start();
$progressBar->display();
if ($multiProcessMode) {
/** @var \Amasty\PageSpeedTools\Model\JobManager $jobManager */
$jobManager = $this->jobManagerFactory->create(['maxJobs' => $maxJobs]);
while (!$this->queueService->isQueueEmpty()) {
$this->batches[] = $this->queueService->shuffleQueues(100);
}
while (!empty($this->batches)) {
if ($jobManager->waitForFreeSlot()) {
$progressBar->advance();
}
$imagesQueue = array_shift($this->batches);
$counter += count($imagesQueue);
$progressBar->setMessage('Process Images ' . ($counter) . ' from ' . $queueSize . '...');
$progressBar->display();
if (!$jobManager->fork()) { // Child process
foreach ($imagesQueue as $queue) {
$this->imageProcessor->process($queue);
}
return 0;
}
}
$jobManager->waitForAllJobs();
} else {
while (!$this->queueService->isQueueEmpty()) {
$progressBar->setMessage('Process Images ' . (($counter++) * 100) . ' from ' . $queueSize . '...');
$progressBar->display();
$this->forceOptimization->execute(100);
$progressBar->advance();
}
}
$progressBar->setMessage('Process Images ' . $queueSize . ' from ' . $queueSize . '...');
$progressBar->display();
$progressBar->finish();
$output->writeln('');
$output->writeln('Images were optimized successfully.');
return 0;
}
}