blob: 54cefa1973c994d0a43345bb295000f3e94cd6c4 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
|
<?php
/**
* Nextcloud - 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 2020 Sean Molenaar
*/
namespace OCA\News\Service;
use OCA\News\AppInfo\Application;
use OCA\News\Db\Item;
use OCA\News\Db\ItemMapperV2;
use OCP\AppFramework\Db\DoesNotExistException;
use OCP\AppFramework\Db\Entity;
use OCP\IConfig;
use Psr\Log\LoggerInterface;
/**
* Class ItemService
*
* @package OCA\News\Service
*/
class ItemServiceV2 extends Service
{
/**
* @var IConfig
*/
protected $config;
/**
* ItemService constructor.
*
* @param ItemMapperV2 $mapper
* @param IConfig $config
* @param LoggerInterface $logger
*/
public function __construct(
ItemMapperV2 $mapper,
IConfig $config,
LoggerInterface $logger
) {
parent::__construct($mapper, $logger);
$this->config = $config;
}
/**
* Finds all items of a user
*
* @param string $userId The ID/name of the user
* @param array $params Filter parameters
*
*
* @return Item[]
*/
public function findAllForUser(string $userId, array $params = []): array
{
return $this->mapper->findAllFromUser($userId, $params);
}
/**
* Find all items
*
* @return Item[]
*/
public function findAll(): array
{
return $this->mapper->findAll();
}
/**
* Insert an item or update.
*
* @param Item $item
*
* @return Entity|Item The updated/inserted item
*/
public function insertOrUpdate(Item $item): Entity
{
try {
$db_item = $this->mapper->findByGuidHash($item->getFeedId(), $item->getGuidHash());
// Transfer user modifications
$item->setUnread($db_item->isUnread())
->setStarred($db_item->isStarred())
->setId($db_item->getId());
$item->generateSearchIndex();
// We don't want to update the database record if there is no
// change in the fetched item
if ($db_item->getFingerprint() === $item->getFingerprint()) {
$item->resetUpdatedFields();
}
return $this->mapper->update($item);
} catch (DoesNotExistException $exception) {
return $this->mapper->insert($item);
}
}
/**
* @param int $feedId
*
* @return array
*/
public function findAllForFeed(int $feedId): array
{
return $this->mapper->findAllForFeed($feedId);
}
public function purgeOverThreshold(int $threshold = null)
{
$threshold = (int) $threshold ?? $this->config->getAppValue(
Application::NAME,
'autoPurgeCount',
Application::DEFAULT_SETTINGS['autoPurgeCount']
);
if ($threshold === 0) {
return '';
}
return $this->mapper->deleteOverThreshold($threshold);
}
/**
* @param int $feedId
* @param string $guidHash
*/
public function findForGuidHash(int $feedId, string $guidHash)
{
return $this->mapper->findByGuidHash($feedId, $guidHash);
}
}
|
