]> git.mxchange.org Git - friendica.git/blobdiff - src/Module/Api/Mastodon/Notifications.php
Merge pull request #13176 from MrPetovan/bug/warnings
[friendica.git] / src / Module / Api / Mastodon / Notifications.php
index 6704e958f6e277a42f8b0b04dda926633bcbd420..70ef068982e10e489b034bc47858cdbd997b8dfe 100644 (file)
@@ -1,6 +1,6 @@
 <?php
 /**
- * @copyright Copyright (C) 2010-2021, the Friendica project
+ * @copyright Copyright (C) 2010-2023, the Friendica project
  *
  * @license GNU AGPL version 3 or any later version
  *
@@ -25,8 +25,11 @@ use Friendica\Core\System;
 use Friendica\Database\DBA;
 use Friendica\DI;
 use Friendica\Model\Contact;
-use Friendica\Model\Notification;
+use Friendica\Model\Post;
+use Friendica\Model\Verb;
 use Friendica\Module\BaseApi;
+use Friendica\Object\Api\Mastodon\Notification;
+use Friendica\Protocol\Activity;
 
 /**
  * @see https://docs.joinmastodon.org/methods/notifications/
@@ -34,36 +37,44 @@ use Friendica\Module\BaseApi;
 class Notifications extends BaseApi
 {
        /**
-        * @param array $parameters
         * @throws \Friendica\Network\HTTPException\InternalServerErrorException
         */
-       public static function rawContent(array $parameters = [])
+       protected function rawContent(array $request = [])
        {
-               self::login(self::SCOPE_READ);
+               self::checkAllowedScope(self::SCOPE_READ);
                $uid = self::getCurrentUserID();
 
-               if (!empty($parameters['id'])) {
-                       $id = $parameters['id'];
-                       if (!DBA::exists('notify', ['id' => $id, 'uid' => $uid])) {
+               if (!empty($this->parameters['id'])) {
+                       $id = $this->parameters['id'];
+                       try {
+                               $notification = DI::notification()->selectOneForUser($uid, ['id' => $id]);
+                               System::jsonExit(DI::mstdnNotification()->createFromNotification($notification, self::appSupportsQuotes()));
+                       } catch (\Exception $e) {
                                DI::mstdnError()->RecordNotFound();
                        }
-                       System::jsonExit(DI::mstdnNotification()->createFromNotifyId($id));
                }
 
-               $request = self::getRequest([
+               $request = $this->getRequest([
                        'max_id'        => 0,     // Return results older than this ID
                        'since_id'      => 0,     // Return results newer than this ID
                        'min_id'        => 0,     // Return results immediately newer than this ID
-                       'limit'         => 20,    // Maximum number of results to return (default 20)
+                       'limit'         => 15,    // Maximum number of results to return. Defaults to 15 notifications. Max 30 notifications.
                        'exclude_types' => [],    // Array of types to exclude (follow, favourite, reblog, mention, poll, follow_request)
                        'account_id'    => 0,     // Return only notifications received from this account
-                       'with_muted'    => false, // Unknown parameter
-                       'count'         => 0,     // Unknown parameter
-               ]);
+                       'with_muted'    => false, // Pleroma extension: return activities by muted (not by blocked!) users.
+                       'include_all'   => false,  // Include dismissed and undismissed
+                       'summary'       => false,
+               ], $request);
 
-               $params = ['order' => ['id' => true], 'limit' => $request['limit']];
+               $params = ['order' => ['id' => true]];
 
-               $condition = ['uid' => $uid, 'seen' => false, 'type' => []];
+               $condition = ["`uid` = ? AND (NOT `type` IN (?, ?))", $uid,
+                       Post\UserNotification::TYPE_ACTIVITY_PARTICIPATION,
+                       Post\UserNotification::TYPE_COMMENT_PARTICIPATION];
+
+               if (!$request['include_all']) {
+                       $condition = DBA::mergeConditions($condition, ['dismissed' => false]);
+               }
 
                if (!empty($request['account_id'])) {
                        $contact = Contact::getById($request['account_id'], ['url']);
@@ -72,44 +83,78 @@ class Notifications extends BaseApi
                        }
                }
 
-               if (!in_array('follow_request', $request['exclude_types'])) {
-                       $condition['type'] = array_merge($condition['type'], [Notification\Type::INTRO]);
+               if (in_array(Notification::TYPE_INTRODUCTION, $request['exclude_types'])) {
+                       $condition = DBA::mergeConditions(
+                               $condition,
+                               ["(`vid` != ? OR `type` != ? OR NOT `actor-id` IN (SELECT `id` FROM `contact` WHERE `pending`))",
+                                       Verb::getID(Activity::FOLLOW),
+                                       Post\UserNotification::TYPE_NONE]
+                       );
                }
 
-               if (!in_array('mention', $request['exclude_types'])) {
-                       $condition['type'] = array_merge($condition['type'],
-                               [Notification\Type::WALL, Notification\Type::COMMENT, Notification\Type::MAIL, Notification\Type::TAG_SELF, Notification\Type::POKE]);
+               if (in_array(Notification::TYPE_FOLLOW, $request['exclude_types'])) {
+                       $condition = DBA::mergeConditions(
+                               $condition,
+                               ["(`vid` != ? OR `type` != ? OR NOT `actor-id` IN (SELECT `id` FROM `contact` WHERE NOT `pending`))",
+                                       Verb::getID(Activity::FOLLOW),
+                                       Post\UserNotification::TYPE_NONE]
+                       );
                }
 
-               if (!in_array('status', $request['exclude_types'])) {
-                       $condition['type'] = array_merge($condition['type'], [Notification\Type::SHARE]);
+               if (in_array(Notification::TYPE_LIKE, $request['exclude_types'])) {
+                       $condition = DBA::mergeConditions($condition, [
+                               "(NOT `vid` IN (?, ?) OR NOT `type` IN (?, ?))",
+                               Verb::getID(Activity::LIKE), Verb::getID(Activity::DISLIKE),
+                               Post\UserNotification::TYPE_DIRECT_COMMENT, Post\UserNotification::TYPE_THREAD_COMMENT
+                       ]);
                }
 
-               if (!empty($request['max_id'])) {
-                       $condition = DBA::mergeConditions($condition, ["`id` < ?", $request['max_id']]);
+               if (in_array(Notification::TYPE_RESHARE, $request['exclude_types'])) {
+                       $condition = DBA::mergeConditions($condition, [
+                               "(NOT `vid` IN (?) OR NOT `type` IN (?, ?))",
+                               Verb::getID(Activity::ANNOUNCE),
+                               Post\UserNotification::TYPE_DIRECT_COMMENT, Post\UserNotification::TYPE_THREAD_COMMENT
+                       ]);
                }
 
-               if (!empty($request['since_id'])) {
-                       $condition = DBA::mergeConditions($condition, ["`id` > ?", $request['since_id']]);
+               if (in_array(Notification::TYPE_MENTION, $request['exclude_types'])) {
+                       $condition = DBA::mergeConditions($condition, [
+                               "(NOT `vid` IN (?) OR NOT `type` IN (?, ?, ?, ?, ?))",
+                               Verb::getID(Activity::POST), Post\UserNotification::TYPE_EXPLICIT_TAGGED,
+                               Post\UserNotification::TYPE_IMPLICIT_TAGGED, Post\UserNotification::TYPE_DIRECT_COMMENT,
+                               Post\UserNotification::TYPE_DIRECT_THREAD_COMMENT, Post\UserNotification::TYPE_THREAD_COMMENT]);
                }
 
-               if (!empty($request['min_id'])) {
-                       $condition = DBA::mergeConditions($condition, ["`id` > ?", $request['min_id']]);
-
-                       $params['order'] = ['id'];
+               if (in_array(Notification::TYPE_POST, $request['exclude_types'])) {
+                       $condition = DBA::mergeConditions($condition, ["(NOT `vid` IN (?) OR NOT `type` IN (?))",
+                               Verb::getID(Activity::POST), Post\UserNotification::TYPE_SHARED]);
                }
 
-               $notifications = [];
-
-               $notify = DBA::select('notify', ['id'], $condition, $params);
-               while ($notification = DBA::fetch($notify)) {
-                       $notifications[] = DI::mstdnNotification()->createFromNotifyId($notification['id']);
-               }
+               if ($request['summary']) {
+                       $count = DI::notification()->countForUser($uid, $condition);
+                       System::jsonExit(['count' => $count]);
+               } else {
+                       $mstdnNotifications = [];
+
+                       $Notifications = DI::notification()->selectByBoundaries(
+                               $condition,
+                               $params,
+                               $request['min_id'] ?: $request['since_id'],
+                               $request['max_id'],
+                               min($request['limit'], 30)
+                       );
+
+                       foreach ($Notifications as $Notification) {
+                               try {
+                                       $mstdnNotifications[] = DI::mstdnNotification()->createFromNotification($Notification, self::appSupportsQuotes());
+                                       self::setBoundaries($Notification->id);
+                               } catch (\Exception $e) {
+                                       // Skip this notification
+                               }
+                       }
 
-               if (!empty($request['min_id'])) {
-                       array_reverse($notifications);
+                       self::setLinkHeader();
+                       System::jsonExit($mstdnNotifications);
                }
-
-               System::jsonExit($notifications);
        }
 }