Added method for deleting processed tasks

Author: mirko-bukilic

src/Model/Repository/Mysql/TaskRepository.php

@@ -2,7 +2,6 @@
 
 namespace G4\Tasker\Model\Repository\Mysql;
 
-
 use G4\Tasker\Consts;
 use G4\Tasker\Model\Domain\Task;
 use G4\Tasker\Model\Repository\TaskRepositoryInterface;
@@ -18,6 +17,10 @@ class TaskRepository implements TaskRepositoryInterface
     const REBALANCE_LIMIT = 1000;           // how many tasks to rebalance at once
     const REBALANCE_TIME_IN_FUTURE = 3600;  // seconds in future tasks to rebalance
 
+    const DELETE_TASKS_OLDER_THAN = 86400 * 2; // 2 days
+    const DELETE_TASKS_LIMIT = 2000;
+
+
     /**
      * @var \PDO
      */
@@ -263,6 +266,31 @@ private function prepareFields(\PDOStatement $stmt, Task $task)
         return $stmt;
     }
 
+    /**
+     * @param int $olderThan
+     * @param int $limit
+     * @return void
+     */
+    public function deleteProcessedTasks(
+        $olderThan = self::DELETE_TASKS_OLDER_THAN,
+        $limit = self::DELETE_TASKS_LIMIT
+    ) {
+        $query = sprintf(
+            'DELETE FROM %s
+                  WHERE status IN (:status_done, :status_sent_to_queue) AND ts_created <= :ts_created
+                  ORDER BY ts_created ASC LIMIT :limit',
+            Consts::TASKS_TABLE_NAME
+        );
+
+        $stmt = $this->pdo->prepare($query);
+        $stmt->bindValue(':status_done', Consts::STATUS_DONE, \PDO::PARAM_INT);
+        $stmt->bindValue(':status_sent_to_queue', Consts::STATUS_SENT_TO_QUEUE_FOR_EXECUTION, \PDO::PARAM_INT);
+        $stmt->bindValue(':limit', $limit, \PDO::PARAM_INT);
+        $stmt->bindValue(':ts_created', time() - $olderThan, \PDO::PARAM_INT);
+
+        $stmt->execute();
+    }
+
     private function execute(\PDOStatement $stmt, $data = null)
     {
         $inTransaction = $this->pdo->inTransaction();

src/Model/Repository/TaskRepositoryInterface.php

@@ -32,4 +32,11 @@ public function findWaitingForRetry();
     public function add(Task $task);
     public function update(Task $task);
     public function updateStatus($status, Task ...$tasks);
+
+    /**
+     * @param int $olderThan
+     * @param int $limit
+     * @return void
+     */
+    public function deleteProcessedTasks($olderThan, $limit);
 }