diff options
Diffstat (limited to 'db')
| -rw-r--r-- | db/itemmapper.php | 24 | ||||
| -rw-r--r-- | db/mysql/itemmapper.php | 17 |
2 files changed, 41 insertions, 0 deletions
diff --git a/db/itemmapper.php b/db/itemmapper.php index 895b0f7ae..a2ad70a67 100644 --- a/db/itemmapper.php +++ b/db/itemmapper.php @@ -379,5 +379,29 @@ class ItemMapper extends NewsMapper { } } + public function readItem($itemId, $isRead, $lastModified, $userId) { + $item = $this->find($itemId, $userId); + + // reading an item should set all of the same items as read, whereas + // marking an item as unread should only mark the selected instance + // as unread + if ($isRead) { + $sql = 'UPDATE `*PREFIX*news_items` + SET `status` = `status` & ? + AND `last_modified` = ? + WHERE `fingerprint` = ? + AND feed_id IN ( + SELECT `f`.`id` FROM `*PREFIX*news_feeds` `f` + WHERE `f`.`user_id` = ? + )'; + $params = [~StatusFlag::UNREAD, $lastModified, + $item->getFingerprint(), $userId]; + $this->execute($sql, $params); + } else { + $item->setLastModified($lastModified); + $item->setUnread(); + $this->update($item); + } + } } diff --git a/db/mysql/itemmapper.php b/db/mysql/itemmapper.php index 5fb28880b..720f03744 100644 --- a/db/mysql/itemmapper.php +++ b/db/mysql/itemmapper.php @@ -63,5 +63,22 @@ class ItemMapper extends \OCA\News\Db\ItemMapper { } + public function readItem($itemId, $isRead, $lastModified, $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` & ? + AND `items`.`last_modified` = ? + WHERE `items`.`fingerprint` = ? + AND `feeds`.`user_id` = ?'; + $params = [~StatusFlag::UNREAD, $lastModified, + $item->getFingerprint(), $userId]; + $this->execute($sql, $params); + } else { + // no other behavior for mysql if should be marked unread + parent::readItem($itemId, $isRead, $lastModified, $userId); + } + } } |