3 * @copyright Copyright (C) 2010-2022, the Friendica project
5 * @license GNU AGPL version 3 or any later version
7 * This program is free software: you can redistribute it and/or modify
8 * it under the terms of the GNU Affero General Public License as
9 * published by the Free Software Foundation, either version 3 of the
10 * License, or (at your option) any later version.
12 * This program is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 * GNU Affero General Public License for more details.
17 * You should have received a copy of the GNU Affero General Public License
18 * along with this program. If not, see <https://www.gnu.org/licenses/>.
22 namespace Friendica\Navigation\Notifications\Repository;
25 use Friendica\BaseCollection;
26 use Friendica\BaseRepository;
27 use Friendica\Database\Database;
28 use Friendica\Database\DBA;
29 use Friendica\Model\Verb;
30 use Friendica\Navigation\Notifications\Collection;
31 use Friendica\Navigation\Notifications\Entity;
32 use Friendica\Navigation\Notifications\Factory;
33 use Friendica\Network\HTTPException\NotFoundException;
34 use Friendica\Util\DateTimeFormat;
35 use Psr\Log\LoggerInterface;
37 class Notification extends BaseRepository
39 /** @var Factory\Notification */
42 protected static $table_name = 'notification';
44 public function __construct(Database $database, LoggerInterface $logger, Factory\Notification $factory = null)
46 parent::__construct($database, $logger, $factory ?? new Factory\Notification($logger));
50 * @param array $condition
51 * @param array $params
52 * @return Entity\Notification
53 * @throws NotFoundException
55 private function selectOne(array $condition, array $params = []): Entity\Notification
57 return parent::_selectOne($condition, $params);
60 private function select(array $condition, array $params = []): Collection\Notifications
62 return new Collection\Notifications(parent::_select($condition, $params)->getArrayCopy());
65 public function countForUser($uid, array $condition, array $params = []): int
67 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
69 return $this->count($condition, $params);
72 public function existsForUser($uid, array $condition): bool
74 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
76 return $this->exists($condition);
81 * @return Entity\Notification
82 * @throws NotFoundException
84 public function selectOneById(int $id): Entity\Notification
86 return $this->selectOne(['id' => $id]);
89 public function selectOneForUser(int $uid, array $condition, array $params = []): Entity\Notification
91 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
93 return $this->selectOne($condition, $params);
96 public function selectForUser(int $uid, array $condition = [], array $params = []): Collection\Notifications
98 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
100 return $this->select($condition, $params);
103 public function selectAllForUser(int $uid): Collection\Notifications
105 return $this->selectForUser($uid);
109 * @param array $condition
110 * @param array $params
111 * @param int|null $min_id Retrieve models with an id no fewer than this, as close to it as possible
112 * @param int|null $max_id Retrieve models with an id no greater than this, as close to it as possible
114 * @return BaseCollection
116 * @see _selectByBoundaries
118 public function selectByBoundaries(array $condition = [], array $params = [], int $min_id = null, int $max_id = null, int $limit = self::LIMIT)
120 $BaseCollection = parent::_selectByBoundaries($condition, $params, $min_id, $max_id, $limit);
122 return new Collection\Notifications($BaseCollection->getArrayCopy(), $BaseCollection->getTotalCount());
125 public function setAllSeenForUser(int $uid, array $condition = []): bool
127 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
129 return $this->db->update(self::$table_name, ['seen' => true], $condition);
132 public function setAllDismissedForUser(int $uid, array $condition = []): bool
134 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
136 return $this->db->update(self::$table_name, ['dismissed' => true], $condition);
140 * @param Entity\Notification $Notification
141 * @return Entity\Notification
144 public function save(Entity\Notification $Notification): Entity\Notification
147 'uid' => $Notification->uid,
148 'vid' => Verb::getID($Notification->verb),
149 'type' => $Notification->type,
150 'actor-id' => $Notification->actorId,
151 'target-uri-id' => $Notification->targetUriId,
152 'parent-uri-id' => $Notification->parentUriId,
153 'seen' => $Notification->seen,
154 'dismissed' => $Notification->dismissed,
157 if ($Notification->id) {
158 $this->db->update(self::$table_name, $fields, ['id' => $Notification->id]);
160 $fields['created'] = DateTimeFormat::utcNow();
161 $this->db->insert(self::$table_name, $fields);
163 $Notification = $this->selectOneById($this->db->lastInsertId());
166 return $Notification;