<?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
*
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/
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(['max_id' => 0, 'since_id' => 0, 'min_id' => 0, 'limit' => 20,
- 'exclude_types' => [], 'account_id' => 0, 'with_muted' => false]);
-
- // Return results older than this ID
- $max_id = $request['max_id'];
-
- // Return results newer than this ID
- $since_id = $request['since_id'];
-
- // Return results immediately newer than this ID
- $min_id = $request['min_id'];
-
- // Maximum number of results to return (default 20)
- $limit = $request['limit'];
-
- // Array of types to exclude (follow, favourite, reblog, mention, poll, follow_request)
- $exclude_types = $request['exclude_types'];
-
- // Return only notifications received from this account
- $account_id = $request['account_id'];
-
- // Unknown parameter
- $with_muted = $request['with_muted'];
-
- $params = ['order' => ['id' => true], 'limit' => $limit];
-
- $condition = ['uid' => $uid, 'seen' => false, 'type' => []];
+ $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' => 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, // Pleroma extension: return activities by muted (not by blocked!) users.
+ 'include_all' => false, // Include dismissed and undismissed
+ 'summary' => false,
+ ], $request);
+
+ $params = ['order' => ['id' => true]];
+
+ $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($account_id)) {
- $contact = Contact::getById($account_id, ['url']);
+ if (!empty($request['account_id'])) {
+ $contact = Contact::getById($request['account_id'], ['url']);
if (!empty($contact['url'])) {
$condition['url'] = $contact['url'];
}
}
- if (!in_array('follow_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', $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', $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($max_id)) {
- $condition = DBA::mergeConditions($condition, ["`id` < ?", $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($since_id)) {
- $condition = DBA::mergeConditions($condition, ["`id` > ?", $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($min_id)) {
- $condition = DBA::mergeConditions($condition, ["`id` > ?", $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($min_id)) {
- array_reverse($notifications);
+ self::setLinkHeader();
+ System::jsonExit($mstdnNotifications);
}
-
- System::jsonExit($notifications);
}
}
projects / friendica.git / blobdiff