diff --git a/lib/Cron/CronHelper.php b/lib/Cron/CronHelper.php index 438af1d75d..2f669420c7 100644 --- a/lib/Cron/CronHelper.php +++ b/lib/Cron/CronHelper.php @@ -50,10 +50,7 @@ class CronHelper { 'timeout' => $timeout, 'user-agent' => 'MailPoet (www.mailpoet.com) Cron' ); - $result = wp_remote_get( - self::getSiteUrl() . $url, - $args - ); + $result = wp_remote_get($url, $args); return wp_remote_retrieve_body($result); } diff --git a/lib/Cron/Daemon.php b/lib/Cron/Daemon.php index 3578236e6d..111a6f660a 100644 --- a/lib/Cron/Daemon.php +++ b/lib/Cron/Daemon.php @@ -39,6 +39,8 @@ class Daemon { ) { $this->abortWithError(__('Invalid or missing token.')); } + $daemon['token'] = $this->token; + CronHelper::saveDaemon($daemon); $this->abortIfStopped($daemon); try { $scheduler = new SchedulerWorker($this->timer); @@ -55,15 +57,13 @@ class Daemon { // after each execution, re-read daemon data in case its status was changed // its status has changed $daemon = CronHelper::getDaemon(); - if(!$daemon || $daemon['token'] !== $this->data['token']) { + if(!$daemon || $daemon['token'] !== $this->token) { $this->terminateRequest(); } - $daemon['counter']++; $this->abortIfStopped($daemon); if($daemon['status'] === self::STATUS_STARTING) { $daemon['status'] = self::STATUS_STARTED; } - $daemon['token'] = $this->token; CronHelper::saveDaemon($daemon); $this->callSelf(); }