src/Navigation/Notifications/Repository/Notification.php

   1 <?php
   2 /**
   3  * @copyright Copyright (C) 2010-2022, the Friendica project
   4  *
   5  * @license GNU AGPL version 3 or any later version
   6  *
   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.
  11  *
  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.
  16  *
  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/>.
  19  *
  20  */
  21
  22 namespace Friendica\Navigation\Notifications\Repository;
  23
  24 use Exception;
  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;
  36
  37 class Notification extends BaseRepository
  38 {
  39         /** @var Factory\Notification  */
  40         protected $factory;
  41
  42         protected static $table_name = 'notification';
  43
  44         public function __construct(Database $database, LoggerInterface $logger, Factory\Notification $factory = null)
  45         {
  46                 parent::__construct($database, $logger, $factory ?? new Factory\Notification($logger));
  47         }
  48
  49         /**
  50          * @param array $condition
  51          * @param array $params
  52          * @return Entity\Notification
  53          * @throws NotFoundException
  54          */
  55         private function selectOne(array $condition, array $params = []): Entity\Notification
  56         {
  57                 return parent::_selectOne($condition, $params);
  58         }
  59
  60         private function select(array $condition, array $params = []): Collection\Notifications
  61         {
  62                 return new Collection\Notifications(parent::_select($condition, $params)->getArrayCopy());
  63         }
  64
  65         public function countForUser($uid, array $condition, array $params = []): int
  66         {
  67                 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
  68
  69                 return $this->count($condition, $params);
  70         }
  71
  72         public function existsForUser($uid, array $condition): bool
  73         {
  74                 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
  75
  76                 return $this->exists($condition);
  77         }
  78
  79         /**
  80          * @param int $id
  81          * @return Entity\Notification
  82          * @throws NotFoundException
  83          */
  84         public function selectOneById(int $id): Entity\Notification
  85         {
  86                 return $this->selectOne(['id' => $id]);
  87         }
  88
  89         public function selectOneForUser(int $uid, array $condition, array $params = []): Entity\Notification
  90         {
  91                 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
  92
  93                 return $this->selectOne($condition, $params);
  94         }
  95
  96         public function selectForUser(int $uid, array $condition = [], array $params = []): Collection\Notifications
  97         {
  98                 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
  99
 100                 return $this->select($condition, $params);
 101         }
 102
 103         public function selectAllForUser(int $uid): Collection\Notifications
 104         {
 105                 return $this->selectForUser($uid);
 106         }
 107
 108         /**
 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
 113          * @param int      $limit
 114          * @return BaseCollection
 115          * @throws Exception
 116          * @see _selectByBoundaries
 117          */
 118         public function selectByBoundaries(array $condition = [], array $params = [], int $min_id = null, int $max_id = null, int $limit = self::LIMIT)
 119         {
 120                 $BaseCollection = parent::_selectByBoundaries($condition, $params, $min_id, $max_id, $limit);
 121
 122                 return new Collection\Notifications($BaseCollection->getArrayCopy(), $BaseCollection->getTotalCount());
 123         }
 124
 125         public function setAllSeenForUser(int $uid, array $condition = []): bool
 126         {
 127                 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
 128
 129                 return $this->db->update(self::$table_name, ['seen' => true], $condition);
 130         }
 131
 132         public function setAllDismissedForUser(int $uid, array $condition = []): bool
 133         {
 134                 $condition = DBA::mergeConditions($condition, ['uid' => $uid]);
 135
 136                 return $this->db->update(self::$table_name, ['dismissed' => true], $condition);
 137         }
 138
 139         /**
 140          * @param Entity\Notification $Notification
 141          * @return Entity\Notification
 142          * @throws Exception
 143          */
 144         public function save(Entity\Notification $Notification): Entity\Notification
 145         {
 146                 $fields = [
 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,
 155                 ];
 156
 157                 if ($Notification->id) {
 158                         $this->db->update(self::$table_name, $fields, ['id' => $Notification->id]);
 159                 } else {
 160                         $fields['created'] = DateTimeFormat::utcNow();
 161                         $this->db->insert(self::$table_name, $fields);
 162
 163                         $Notification = $this->selectOneById($this->db->lastInsertId());
 164                 }
 165
 166                 return $Notification;
 167         }
 168 }