Fix : Imap SSL read issue with parellel CronJob execution

[sreekuttan-m-achari]

Hi , We were having the following issue while running email processing cronjob

`

[Diamante\EmailProcessingBundle\Model\MessageProcessingException]
cannot read - connection closed?

Exception trace:
() at /var/www/html/desk-application/vendor/diamante/email-processing-bundle/Diamante/EmailProcessingBundle/Infrastructure/Message/Zend/ImapMessageProvider.php:85
Diamante\EmailProcessingBundle\Infrastructure\Message\Zend\ImapMessageProvider->fetchMessagesToProcess() at /var/www/html/desk-application/vendor/diamante/email-processing-bundle/Diamante/EmailProcessingBundle/Model/Service/MessageProcessingManager.php:56
Diamante\EmailProcessingBundle\Model\Service\MessageProcessingManager->handle() at /var/www/html/desk-application/vendor/diamante/email-processing-bundle/Diamante/EmailProcessingBundle/Api/Impl/EmailProcessingServiceImpl.php:67
Diamante\EmailProcessingBundle\Api\Impl\EmailProcessingServiceImpl->process() at /var/www/html/desk-application/vendor/diamante/email-processing-bundle/Diamante/EmailProcessingBundle/Command/GeneralEmailProcessingCommand.php:32
Diamante\EmailProcessingBundle\Command\GeneralEmailProcessingCommand->execute() at /var/www/html/desk-application/vendor/symfony/symfony/src/Symfony/Component/Console/Command/Command.php:256
Symfony\Component\Console\Command\Command->run() at /var/www/html/desk-application/vendor/symfony/symfony/src/Symfony/Component/Console/Application.php:846
Symfony\Component\Console\Application->doRunCommand() at /var/www/html/desk-application/vendor/symfony/symfony/src/Symfony/Component/Console/Application.php:189
Symfony\Component\Console\Application->doRun() at /var/www/html/desk-application/vendor/symfony/symfony/src/Symfony/Bundle/FrameworkBundle/Console/Application.php:96
Symfony\Bundle\FrameworkBundle\Console\Application->doRun() at /var/www/html/desk-application/vendor/jms/job-queue-bundle/JMS/JobQueueBundle/Console/Application.php:45
JMS\JobQueueBundle\Console\Application->doRun() at /var/www/html/desk-application/vendor/symfony/symfony/src/Symfony/Component/Console/Application.php:120
Symfony\Component\Console\Application->run() at /var/www/html/desk-application/app/console:23

`

The cron was getting initiated every 5 minutes while the existing email processing was on going. So we created a file based locking mechanism to prevent this parallel execution.

File location :: "/vendor/diamante/email-processing-bundle/Diamante/EmailProcessingBundle/Command/GeneralEmailProcessingCommand.php "

Modification :

` protected function execute(InputInterface $input, OutputInterface $output) {

	//$flagFile = 'cronFlg.flg';

	$flagFile = dirname(__FILE__).'/cronFlg.flg';

	$output->writeln("Flag-File: ".$flagFile." :  ".date("Y-m-d h:i:sa"));

	if (!file_exists($flagFile)) {
		if (file_put_contents($flagFile, "COMPLETED")) {
			$output->writeln("Flag-File Created : ".date("Y-m-d h:i:sa"));
		} else {
			$output->writeln("Error! Unable to create Flag-File Please check folder/file permissions: ".date("Y-m-d h:i:sa"));
		}
	} else {

		$flg = file_get_contents($flagFile);

		if ($flg == 'COMPLETED') {
			file_put_contents($flagFile, "START");

			$output->writeln("Start General Email Processing : ".date("Y-m-d h:i:sa"));
			$this->getContainer()->get('diamante.email_processing.service')->process();
			$output->writeln("General Email Processing Done : ".date("Y-m-d h:i:sa"));

			file_put_contents($flagFile, "COMPLETED");
		} else {
			$output->writeln("Processing Emails... : ".date("Y-m-d h:i:sa"));
		}
	}

} `