summaryrefslogtreecommitdiffstats
path: root/db/mysql/itemmapper.php
diff options
context:
space:
mode:
Diffstat (limited to 'db/mysql/itemmapper.php')
-rw-r--r--db/mysql/itemmapper.php88
1 files changed, 0 insertions, 88 deletions
diff --git a/db/mysql/itemmapper.php b/db/mysql/itemmapper.php
deleted file mode 100644
index 70eefe457..000000000
--- a/db/mysql/itemmapper.php
+++ /dev/null
@@ -1,88 +0,0 @@
-<?php
-/**
- * ownCloud - News
- *
- * This file is licensed under the Affero General Public License version 3 or
- * later. See the COPYING file.
- *
- * @author Alessandro Cosentino <cosenal@gmail.com>
- * @author Bernhard Posselt <dev@bernhard-posselt.com>
- * @copyright Alessandro Cosentino 2012
- * @copyright Bernhard Posselt 2012, 2014
- */
-
-namespace OCA\News\Db\Mysql;
-
-use OCA\News\Utility\Time;
-use OCP\IDBConnection;
-
-use OCA\News\Db\StatusFlag;
-
-
-class ItemMapper extends \OCA\News\Db\ItemMapper {
-
- public function __construct(IDBConnection $db, Time $time){
- parent::__construct($db, $time);
- }
-
-
- /**
- * Delete all items for feeds that have over $threshold unread and not
- * starred items
- * @param int $threshold the number of items that should be deleted
- */
- public function deleteReadOlderThanThreshold($threshold){
- $status = StatusFlag::STARRED | StatusFlag::UNREAD;
- $sql = 'SELECT (COUNT(*) - `feeds`.`articles_per_update`) AS `size`, ' .
- '`feeds`.`id` AS `feed_id`, `feeds`.`articles_per_update` ' .
- 'FROM `*PREFIX*news_items` `items` ' .
- 'JOIN `*PREFIX*news_feeds` `feeds` ' .
- 'ON `feeds`.`id` = `items`.`feed_id` ' .
- 'AND NOT ((`items`.`status` & ?) > 0) ' .
- 'GROUP BY `feeds`.`id`, `feeds`.`articles_per_update` ' .
- 'HAVING COUNT(*) > ?';
- $params = [$status, $threshold];
- $result = $this->execute($sql, $params);
-
- while($row = $result->fetch()) {
-
- $size = (int) $row['size'];
- $limit = $size - $threshold;
-
- if($limit > 0) {
- $params = [$status, $row['feed_id'], $limit];
-
- $sql = 'DELETE FROM `*PREFIX*news_items` ' .
- 'WHERE NOT ((`status` & ?) > 0) ' .
- 'AND `feed_id` = ? ' .
- 'ORDER BY `id` ASC ' .
- 'LIMIT ?';
-
- $this->execute($sql, $params);
- }
- }
-
- }
-
- public function readItem($itemId, $isRead, $lastModified, $userId) {
- $item = $this->find($itemId, $userId);
-
- if ($isRead) {
- $sql = 'UPDATE `*PREFIX*news_items` `items`
- JOIN `*PREFIX*news_feeds` `feeds`
- ON `feeds`.`id` = `items`.`feed_id`
- SET `items`.`status` = `items`.`status` & ?,
- `items`.`last_modified` = ?
- WHERE `items`.`fingerprint` = ?
- AND `feeds`.`user_id` = ?';
- $params = [~StatusFlag::UNREAD, $lastModified,
- $item->getFingerprint(), $userId];
- $this->execute($sql, $params);
- } else {
- $item->setLastModified($lastModified);
- $item->setUnread();
- $this->update($item);
- }
- }
-
-}