Update version number, update lockJobs to add locked_at time, and remove unused file (#1124)

bsuravech · Jan Petr · commit 7e9dce138c25 · 2019-04-15T09:49:36.000+02:00
diff --git a/app/code/community/Algolia/Algoliasearch/Model/Queue.php b/app/code/community/Algolia/Algoliasearch/Model/Queue.php
@@ -439,7 +439,10 @@ private function lockJobs($jobs)
 
         if ($jobsIds !== array()) {
             $pid = getmypid();
-            $this->db->update($this->table, array('pid' => $pid), array('job_id IN (?)' => $jobsIds));
+            $this->db->update($this->table, array(
+                'pid' => $pid,
+                'locked_at' => date('Y-m-d H:i:s'),
+            ), array('job_id IN (?)' => $jobsIds));
         }
     }
 
diff --git a/app/code/community/Algolia/Algoliasearch/Model/Source/MaxRecordSize.php b/app/code/community/Algolia/Algoliasearch/Model/Source/MaxRecordSize.php
diff --git a/app/code/community/Algolia/Algoliasearch/etc/config.xml b/app/code/community/Algolia/Algoliasearch/etc/config.xml
@@ -2,7 +2,7 @@
 <config>
     <modules>
         <Algolia_Algoliasearch>
-            <version>1.15.0</version>
+            <version>1.16.0</version>
         </Algolia_Algoliasearch>
     </modules>
     <frontend>

Original file line number	Diff line number	Diff line change
`@@ -439,7 +439,10 @@ private function lockJobs($jobs)`
`439`	`439`
`440`	`440`	`if ($jobsIds !== array()) {`
`441`	`441`	`$pid = getmypid();`
`442`		`- $this->db->update($this->table, array('pid' => $pid), array('job_id IN (?)' => $jobsIds));`
	`442`	`+ $this->db->update($this->table, array(`
	`443`	`+ 'pid' => $pid,`
	`444`	`+ 'locked_at' => date('Y-m-d H:i:s'),`
	`445`	`+ ), array('job_id IN (?)' => $jobsIds));`
`443`	`446`	`}`
`444`	`447`	`}`
`445`	`448`