namespace Friendica\Factory\Api\Mastodon;
use Friendica\BaseFactory;
+use Friendica\Content\Conversation\Entity\Timeline;
use Friendica\Database\Database;
use Friendica\Network\HTTPException\InternalServerErrorException;
use Psr\Log\LoggerInterface;
$circle = $this->dba->selectFirst('group', ['name'], ['id' => $id, 'deleted' => false]);
return new \Friendica\Object\Api\Mastodon\ListEntity($id, $circle['name'] ?? '', 'list');
}
+
+ public function createFromChannel(Timeline $channel): \Friendica\Object\Api\Mastodon\ListEntity
+ {
+ return new \Friendica\Object\Api\Mastodon\ListEntity('channel:' . $channel->code, $channel->label, 'followed');
+ }
+
+ public function createFromGroup(array $group): \Friendica\Object\Api\Mastodon\ListEntity
+ {
+ return new \Friendica\Object\Api\Mastodon\ListEntity('group:' . $group['id'], $group['name'], 'followed');
+ }
}
namespace Friendica\Module\Api\Mastodon;
-use Friendica\Core\System;
+use Friendica\App;
+use Friendica\Core\L10n;
use Friendica\DI;
+use Friendica\Content\Conversation\Factory\Channel as ChannelFactory;
+use Friendica\Content\Conversation\Repository;
+use Friendica\Content\GroupManager;
use Friendica\Module\BaseApi;
use Friendica\Model\Circle;
+use Friendica\Module\Api\ApiResponse;
+use Friendica\Util\Profiler;
+use Psr\Log\LoggerInterface;
/**
* @see https://docs.joinmastodon.org/methods/timelines/lists/
*/
class Lists extends BaseApi
{
+ /** @var ChannelFactory */
+ protected $channel;
+ /** @var Repository\UserDefinedChannel */
+ protected $userDefinedChannel;
+
+ public function __construct(Repository\UserDefinedChannel $userDefinedChannel, ChannelFactory $channel, \Friendica\Factory\Api\Mastodon\Error $errorFactory, App $app, L10n $l10n, App\BaseURL $baseUrl, App\Arguments $args, LoggerInterface $logger, Profiler $profiler, ApiResponse $response, array $server, array $parameters = [])
+ {
+ parent::__construct($errorFactory, $app, $l10n, $baseUrl, $args, $logger, $profiler, $response, $server, $parameters);
+
+ $this->channel = $channel;
+ $this->userDefinedChannel = $userDefinedChannel;
+ }
+
protected function delete(array $request = [])
{
$this->checkAllowedScope(self::SCOPE_WRITE);
foreach (Circle::getByUserId($uid) as $circle) {
$lists[] = DI::mstdnList()->createFromCircleId($circle['id']);
}
+
+ foreach ($this->channel->getTimelines($uid) as $channel) {
+ $lists[] = DI::mstdnList()->createFromChannel($channel);
+ }
+
+ foreach ($this->userDefinedChannel->selectByUid($uid) as $channel) {
+ $lists[] = DI::mstdnList()->createFromChannel($channel);
+ }
+
+ foreach (GroupManager::getList($uid, true, true, true) as $group) {
+ $lists[] = DI::mstdnList()->createFromGroup($group);
+ }
} else {
$id = $this->parameters['id'];
namespace Friendica\Module\Api\Mastodon\Timelines;
+use Friendica\App;
+use Friendica\Core\L10n;
use Friendica\Core\Logger;
-use Friendica\Core\System;
use Friendica\Database\DBA;
use Friendica\DI;
+use Friendica\Model\Contact;
+use Friendica\Model\Conversation;
use Friendica\Model\Item;
use Friendica\Model\Post;
+use Friendica\Model\Verb;
+use Friendica\Module\Api\ApiResponse;
use Friendica\Module\BaseApi;
+use Friendica\Module\Conversation\Timeline;
use Friendica\Network\HTTPException;
use Friendica\Object\Api\Mastodon\TimelineOrderByTypes;
+use Friendica\Protocol\Activity;
+use Friendica\Util\Profiler;
+use Psr\Log\LoggerInterface;
/**
* @see https://docs.joinmastodon.org/methods/timelines/
*/
class ListTimeline extends BaseApi
{
+ /** @var Timeline */
+ protected $timeline;
+
+ public function __construct(Timeline $timeline, \Friendica\Factory\Api\Mastodon\Error $errorFactory, App $app, L10n $l10n, App\BaseURL $baseUrl, App\Arguments $args, LoggerInterface $logger, Profiler $profiler, ApiResponse $response, array $server, array $parameters = [])
+ {
+ parent::__construct($errorFactory, $app, $l10n, $baseUrl, $args, $logger, $profiler, $response, $server, $parameters);
+ $this->timeline = $timeline;
+ }
+
/**
* @throws HTTPException\InternalServerErrorException
*/
'friendica_order' => TimelineOrderByTypes::ID, // Sort order options (defaults to ID)
], $request);
+ $display_quotes = self::appSupportsQuotes();
+
+ if (substr($this->parameters['id'], 0, 6) == 'group:') {
+ $items = $this->getStatusesForGroup($uid, $request);
+ } elseif (substr($this->parameters['id'], 0, 8) == 'channel:') {
+ $items = $this->getStatusesForChannel($uid, $request);
+ } else{
+ $items = $this->getStatusesForCircle($uid, $request);
+ }
+
+ $statuses = [];
+ foreach ($items as $item) {
+ try {
+ $status = DI::mstdnStatus()->createFromUriId($item['uri-id'], $uid, $display_quotes);
+ $this->updateBoundaries($status, $item, $request['friendica_order']);
+ $statuses[] = $status;
+ } catch (\Throwable $th) {
+ Logger::info('Post not fetchable', ['uri-id' => $item['uri-id'], 'uid' => $uid, 'error' => $th]);
+ }
+ }
+
+ if (!empty($request['min_id'])) {
+ $statuses = array_reverse($statuses);
+ }
+
+ self::setLinkHeader($request['friendica_order'] != TimelineOrderByTypes::ID);
+ $this->jsonExit($statuses);
+ }
+
+ private function getStatusesForGroup(int $uid, array $request): array
+ {
+ $cdata = Contact::getPublicAndUserContactID((int)substr($this->parameters['id'], 6), $uid);
+ $cid = $cdata['public'];
+
+ $condition = ["(`uid` = ? OR (`uid` = ? AND NOT `global`))", 0, $uid];
+
+ $condition1 = DBA::mergeConditions($condition, ["`owner-id` = ? AND `gravity` = ?", $cid, Item::GRAVITY_PARENT]);
+
+ $condition2 = DBA::mergeConditions($condition, [
+ "`author-id` = ? AND `gravity` = ? AND `vid` = ? AND `protocol` != ? AND `thr-parent-id` = `parent-uri-id`",
+ $cid, Item::GRAVITY_ACTIVITY, Verb::getID(Activity::ANNOUNCE), Conversation::PARCEL_DIASPORA
+ ]);
+
+ $condition1 = $this->addPagingConditions($request, $condition1);
+ $condition2 = $this->addPagingConditions($request, $condition2);
+
+ $sql1 = "SELECT `uri-id` FROM `post-thread-user-view` WHERE " . array_shift($condition1);
+ $sql2 = "SELECT `thr-parent-id` AS `uri-id` FROM `post-user-view` WHERE " . array_shift($condition2);
+
+ $condition = array_merge($condition1, $condition2);
+ $sql = $sql1 . " UNION " . $sql2 . " GROUP BY `uri-id` " . DBA::buildParameter($this->buildOrderAndLimitParams($request));
+
+ return Post::toArray(DBA::p($sql, $condition));
+ }
+
+ private function getStatusesForChannel(int $uid, array $request): array
+ {
+ $request['friendica_order'] = TimelineOrderByTypes::ID;
+
+ return $this->timeline->getChannelItemsForAPI(substr($this->parameters['id'], 8), $uid, $request['limit'], $request['min_id'], $request['max_id']);
+ }
+
+ private function getStatusesForCircle(int $uid, array $request): array
+ {
$condition = [
"`uid` = ? AND `gravity` IN (?, ?) AND `contact-id` IN (SELECT `contact-id` FROM `group_member` WHERE `gid` = ?)",
$uid, Item::GRAVITY_PARENT, Item::GRAVITY_COMMENT, $this->parameters['id']
}
$items = Post::selectTimelineForUser($uid, ['uri-id'], $condition, $params);
-
- $display_quotes = self::appSupportsQuotes();
-
- $statuses = [];
- while ($item = Post::fetch($items)) {
- try {
- $status = DI::mstdnStatus()->createFromUriId($item['uri-id'], $uid, $display_quotes);
- $this->updateBoundaries($status, $item, $request['friendica_order']);
- $statuses[] = $status;
- } catch (\Throwable $th) {
- Logger::info('Post not fetchable', ['uri-id' => $item['uri-id'], 'uid' => $uid, 'error' => $th]);
- }
- }
- DBA::close($items);
-
- if (!empty($request['min_id'])) {
- $statuses = array_reverse($statuses);
- }
-
- self::setLinkHeader($request['friendica_order'] != TimelineOrderByTypes::ID);
- $this->jsonExit($statuses);
+ return Post::toArray($items);
}
}
}
if ($this->channel->isTimeline($this->selectedTab) || $this->userDefinedChannel->isTimeline($this->selectedTab, $this->session->getLocalUserId())) {
- $items = $this->getChannelItems($request);
+ $items = $this->getChannelItems($request, $this->session->getLocalUserId());
$order = 'created';
} else {
$items = $this->getCommunityItems();
try {
if ($this->channel->isTimeline($this->selectedTab) || $this->userDefinedChannel->isTimeline($this->selectedTab, $this->session->getLocalUserId())) {
- $items = $this->getChannelItems($request);
+ $items = $this->getChannelItems($request, $this->session->getLocalUserId());
} elseif ($this->community->isTimeline($this->selectedTab)) {
$items = $this->getCommunityItems();
} else {
/** @var UserDefinedChannel */
protected $channelRepository;
- public function __construct(UserDefinedChannel $channel, Mode $mode, IHandleUserSessions $session, Database $database, IManagePersonalConfigValues $pConfig, IManageConfigValues $config, ICanCache $cache, L10n $l10n, App\BaseURL $baseUrl, App\Arguments $args, LoggerInterface $logger, Profiler $profiler, Response $response, array $server, array $parameters = [])
+ public function __construct(UserDefinedChannel $channel, Mode $mode, IHandleUserSessions $session, Database $database, IManagePersonalConfigValues $pConfig, IManageConfigValues $config, ICanCache $cache, L10n $l10n, App\BaseURL $baseUrl, App\Arguments $args, LoggerInterface $logger, Profiler $profiler, Response $response, array $server = [], array $parameters = [])
{
parent::__construct($l10n, $baseUrl, $args, $logger, $profiler, $response, $server, $parameters);
$this->maxId = $request['last_created'] ?? $this->maxId;
$this->minId = $request['first_created'] ?? $this->minId;
break;
- case 'uriid':
+ case 'uri-id':
$this->maxId = $request['last_uriid'] ?? $this->maxId;
$this->minId = $request['first_uriid'] ?? $this->minId;
break;
return $tabs;
}
+ public function getChannelItemsForAPI(string $channel, int $uid, int $limit, int $min = null, int $max = null): array
+ {
+ $this->itemsPerPage = $limit;
+ $this->itemUriId = 0;
+ $this->maxId = $max;
+ $this->minId = $min;
+ $this->noSharer = false;
+ $this->order = 'uri-id';
+ $this->ping = false;
+ $this->selectedTab = $channel;
+
+ return $this->getChannelItems([], $uid);
+ }
+
/**
* Database query for the channel page
*
* @return array
* @throws \Exception
*/
- protected function getChannelItems(array $request)
+ protected function getChannelItems(array $request, int $uid): array
{
- $items = $this->getRawChannelItems($request);
+ $items = $this->getRawChannelItems($request, $uid);
$total = min(count($items), $this->itemsPerPage);
$contacts = $this->database->selectToArray('user-contact', ['cid'], ['channel-frequency' => Contact\User::FREQUENCY_REDUCED, 'cid' => array_column($items, 'owner-id')]);
}
if (count($selected_items) < $total) {
- $items = $this->getRawChannelItems($request);
+ $items = $this->getRawChannelItems($request, $uid);
}
}
} else {
$selected_items = $items;
}
- $condition = ['unseen' => true, 'uid' => $this->session->getLocalUserId(), 'parent-uri-id' => array_column($selected_items, 'uri-id')];
+ $condition = ['unseen' => true, 'uid' => $uid, 'parent-uri-id' => array_column($selected_items, 'uri-id')];
$this->setItemsSeenByCondition($condition);
return $selected_items;
* @return array
* @throws \Exception
*/
- private function getRawChannelItems(array $request)
+ private function getRawChannelItems(array $request, int $uid): array
{
- $uid = $this->session->getLocalUserId();
-
$table = 'post-engagement';
if ($this->selectedTab == ChannelEntity::WHATSHOT) {
$this->itemsPerPage = 100;
if ($this->channel->isTimeline($this->selectedTab) || $this->userDefinedChannel->isTimeline($this->selectedTab, $this->session->getLocalUserId())) {
- $items = $this->getChannelItems($request);
+ $items = $this->getChannelItems($request, $this->session->getLocalUserId());
} elseif ($this->community->isTimeline($this->selectedTab)) {
$items = $this->getCommunityItems();
} else {
$o = '';
if ($this->update || $this->force) {
if ($this->channel->isTimeline($this->selectedTab) || $this->userDefinedChannel->isTimeline($this->selectedTab, $this->session->getLocalUserId())) {
- $items = $this->getChannelItems($request);
+ $items = $this->getChannelItems($request, $this->session->getLocalUserId());
} else {
$items = $this->getCommunityItems();
}
}
if ($this->channel->isTimeline($this->selectedTab) || $this->userDefinedChannel->isTimeline($this->selectedTab, $this->session->getLocalUserId())) {
- $items = $this->getChannelItems($request);
+ $items = $this->getChannelItems($request, $this->session->getLocalUserId());
} elseif ($this->community->isTimeline($this->selectedTab)) {
$items = $this->getCommunityItems();
} else {
protected $id;
/** @var string */
protected $title;
+ /** @var string */
+ protected $replies_policy;
/**
* Creates an list record
* @param string $title
* @throws \Friendica\Network\HTTPException\InternalServerErrorException
*/
- public function __construct(int $id, string $title, string $policy)
+ public function __construct(string $id, string $title, string $policy)
{
- $this->id = (string)$id;
+ $this->id = $id;
$this->title = $title;
$this->replies_policy = $policy;
}
/**
* Returns the current created_at string or null if not set
- * @return \DateTime|null
+ * @return ?string
*/
public function createdAt(): ?string
{
'/tags/{hashtag}/unfollow' => [Module\Api\Mastodon\Tags\Unfollow::class, [ R::POST]],
'/timelines/direct' => [Module\Api\Mastodon\Timelines\Direct::class, [R::GET ]],
'/timelines/home' => [Module\Api\Mastodon\Timelines\Home::class, [R::GET ]],
- '/timelines/list/{id:\d+}' => [Module\Api\Mastodon\Timelines\ListTimeline::class, [R::GET ]],
+ '/timelines/list/{id}' => [Module\Api\Mastodon\Timelines\ListTimeline::class, [R::GET ]],
'/timelines/public' => [Module\Api\Mastodon\Timelines\PublicTimeline::class, [R::GET ]],
'/timelines/tag/{hashtag}' => [Module\Api\Mastodon\Timelines\Tag::class, [R::GET ]],
'/trends' => [Module\Api\Mastodon\Trends\Tags::class, [R::GET ]],
https://reisub.nsupdate.info/git / friendica.git / .git / commitdiff