Merge pull request #11845 from annando/performance
Several performance improvements
This commit is contained in:
commit
efa1344c64
15
database.sql
15
database.sql
|
@ -1,6 +1,6 @@
|
||||||
-- ------------------------------------------
|
-- ------------------------------------------
|
||||||
-- Friendica 2022.09-dev (Giant Rhubarb)
|
-- Friendica 2022.09-dev (Giant Rhubarb)
|
||||||
-- DB_UPDATE_VERSION 1480
|
-- DB_UPDATE_VERSION 1481
|
||||||
-- ------------------------------------------
|
-- ------------------------------------------
|
||||||
|
|
||||||
|
|
||||||
|
@ -222,7 +222,7 @@ CREATE TABLE IF NOT EXISTS `contact` (
|
||||||
INDEX `uid_contact-type` (`uid`,`contact-type`),
|
INDEX `uid_contact-type` (`uid`,`contact-type`),
|
||||||
INDEX `uid_self_contact-type` (`uid`,`self`,`contact-type`),
|
INDEX `uid_self_contact-type` (`uid`,`self`,`contact-type`),
|
||||||
INDEX `self_network_uid` (`self`,`network`,`uid`),
|
INDEX `self_network_uid` (`self`,`network`,`uid`),
|
||||||
INDEX `gsid` (`gsid`),
|
INDEX `gsid_uid_failed` (`gsid`,`uid`,`failed`),
|
||||||
INDEX `uri-id` (`uri-id`),
|
INDEX `uri-id` (`uri-id`),
|
||||||
FOREIGN KEY (`uid`) REFERENCES `user` (`uid`) ON UPDATE RESTRICT ON DELETE CASCADE,
|
FOREIGN KEY (`uid`) REFERENCES `user` (`uid`) ON UPDATE RESTRICT ON DELETE CASCADE,
|
||||||
FOREIGN KEY (`uri-id`) REFERENCES `item-uri` (`id`) ON UPDATE RESTRICT ON DELETE CASCADE,
|
FOREIGN KEY (`uri-id`) REFERENCES `item-uri` (`id`) ON UPDATE RESTRICT ON DELETE CASCADE,
|
||||||
|
@ -920,6 +920,7 @@ CREATE TABLE IF NOT EXISTS `notification` (
|
||||||
INDEX `target-uri-id` (`target-uri-id`),
|
INDEX `target-uri-id` (`target-uri-id`),
|
||||||
INDEX `parent-uri-id` (`parent-uri-id`),
|
INDEX `parent-uri-id` (`parent-uri-id`),
|
||||||
INDEX `seen_uid` (`seen`,`uid`),
|
INDEX `seen_uid` (`seen`,`uid`),
|
||||||
|
INDEX `uid_type_parent-uri-id_actor-id` (`uid`,`type`,`parent-uri-id`,`actor-id`),
|
||||||
FOREIGN KEY (`uid`) REFERENCES `user` (`uid`) ON UPDATE RESTRICT ON DELETE CASCADE,
|
FOREIGN KEY (`uid`) REFERENCES `user` (`uid`) ON UPDATE RESTRICT ON DELETE CASCADE,
|
||||||
FOREIGN KEY (`vid`) REFERENCES `verb` (`id`) ON UPDATE RESTRICT ON DELETE RESTRICT,
|
FOREIGN KEY (`vid`) REFERENCES `verb` (`id`) ON UPDATE RESTRICT ON DELETE RESTRICT,
|
||||||
FOREIGN KEY (`actor-id`) REFERENCES `contact` (`id`) ON UPDATE RESTRICT ON DELETE CASCADE,
|
FOREIGN KEY (`actor-id`) REFERENCES `contact` (`id`) ON UPDATE RESTRICT ON DELETE CASCADE,
|
||||||
|
@ -1153,9 +1154,12 @@ CREATE TABLE IF NOT EXISTS `post-category` (
|
||||||
CREATE TABLE IF NOT EXISTS `post-collection` (
|
CREATE TABLE IF NOT EXISTS `post-collection` (
|
||||||
`uri-id` int unsigned NOT NULL COMMENT 'Id of the item-uri table entry that contains the item uri',
|
`uri-id` int unsigned NOT NULL COMMENT 'Id of the item-uri table entry that contains the item uri',
|
||||||
`type` tinyint unsigned NOT NULL DEFAULT 0 COMMENT '0 - Featured',
|
`type` tinyint unsigned NOT NULL DEFAULT 0 COMMENT '0 - Featured',
|
||||||
|
`author-id` int unsigned COMMENT 'Author of the featured post',
|
||||||
PRIMARY KEY(`uri-id`,`type`),
|
PRIMARY KEY(`uri-id`,`type`),
|
||||||
INDEX `type` (`type`),
|
INDEX `type` (`type`),
|
||||||
FOREIGN KEY (`uri-id`) REFERENCES `item-uri` (`id`) ON UPDATE RESTRICT ON DELETE CASCADE
|
INDEX `author-id` (`author-id`),
|
||||||
|
FOREIGN KEY (`uri-id`) REFERENCES `item-uri` (`id`) ON UPDATE RESTRICT ON DELETE CASCADE,
|
||||||
|
FOREIGN KEY (`author-id`) REFERENCES `contact` (`id`) ON UPDATE RESTRICT ON DELETE CASCADE
|
||||||
) DEFAULT COLLATE utf8mb4_general_ci COMMENT='Collection of posts';
|
) DEFAULT COLLATE utf8mb4_general_ci COMMENT='Collection of posts';
|
||||||
|
|
||||||
--
|
--
|
||||||
|
@ -1412,6 +1416,7 @@ CREATE TABLE IF NOT EXISTS `post-user` (
|
||||||
INDEX `author-id_uid` (`author-id`,`uid`),
|
INDEX `author-id_uid` (`author-id`,`uid`),
|
||||||
INDEX `author-id_received` (`author-id`,`received`),
|
INDEX `author-id_received` (`author-id`,`received`),
|
||||||
INDEX `parent-uri-id_uid` (`parent-uri-id`,`uid`),
|
INDEX `parent-uri-id_uid` (`parent-uri-id`,`uid`),
|
||||||
|
INDEX `uid_wall_received` (`uid`,`wall`,`received`),
|
||||||
INDEX `uid_contactid` (`uid`,`contact-id`),
|
INDEX `uid_contactid` (`uid`,`contact-id`),
|
||||||
INDEX `uid_unseen_contactid` (`uid`,`unseen`,`contact-id`),
|
INDEX `uid_unseen_contactid` (`uid`,`unseen`,`contact-id`),
|
||||||
INDEX `uid_unseen` (`uid`,`unseen`),
|
INDEX `uid_unseen` (`uid`,`unseen`),
|
||||||
|
@ -2423,7 +2428,7 @@ DROP VIEW IF EXISTS `collection-view`;
|
||||||
CREATE VIEW `collection-view` AS SELECT
|
CREATE VIEW `collection-view` AS SELECT
|
||||||
`post-collection`.`uri-id` AS `uri-id`,
|
`post-collection`.`uri-id` AS `uri-id`,
|
||||||
`post-collection`.`type` AS `type`,
|
`post-collection`.`type` AS `type`,
|
||||||
`post`.`author-id` AS `cid`,
|
`post-collection`.`author-id` AS `cid`,
|
||||||
`post`.`received` AS `received`,
|
`post`.`received` AS `received`,
|
||||||
`post`.`created` AS `created`,
|
`post`.`created` AS `created`,
|
||||||
`post-thread`.`commented` AS `commented`,
|
`post-thread`.`commented` AS `commented`,
|
||||||
|
@ -2431,7 +2436,7 @@ CREATE VIEW `collection-view` AS SELECT
|
||||||
`post`.`visible` AS `visible`,
|
`post`.`visible` AS `visible`,
|
||||||
`post`.`deleted` AS `deleted`,
|
`post`.`deleted` AS `deleted`,
|
||||||
`post`.`thr-parent-id` AS `thr-parent-id`,
|
`post`.`thr-parent-id` AS `thr-parent-id`,
|
||||||
`post`.`author-id` AS `author-id`,
|
`post-collection`.`author-id` AS `author-id`,
|
||||||
`post`.`gravity` AS `gravity`
|
`post`.`gravity` AS `gravity`
|
||||||
FROM `post-collection`
|
FROM `post-collection`
|
||||||
INNER JOIN `post` ON `post-collection`.`uri-id` = `post`.`uri-id`
|
INNER JOIN `post` ON `post-collection`.`uri-id` = `post`.`uri-id`
|
||||||
|
|
|
@ -121,7 +121,7 @@ Indexes
|
||||||
| uid_contact-type | uid, contact-type |
|
| uid_contact-type | uid, contact-type |
|
||||||
| uid_self_contact-type | uid, self, contact-type |
|
| uid_self_contact-type | uid, self, contact-type |
|
||||||
| self_network_uid | self, network, uid |
|
| self_network_uid | self, network, uid |
|
||||||
| gsid | gsid |
|
| gsid_uid_failed | gsid, uid, failed |
|
||||||
| uri-id | uri-id |
|
| uri-id | uri-id |
|
||||||
|
|
||||||
Foreign Keys
|
Foreign Keys
|
||||||
|
|
|
@ -31,6 +31,7 @@ Indexes
|
||||||
| target-uri-id | target-uri-id |
|
| target-uri-id | target-uri-id |
|
||||||
| parent-uri-id | parent-uri-id |
|
| parent-uri-id | parent-uri-id |
|
||||||
| seen_uid | seen, uid |
|
| seen_uid | seen, uid |
|
||||||
|
| uid_type_parent-uri-id_actor-id | uid, type, parent-uri-id, actor-id |
|
||||||
|
|
||||||
Foreign Keys
|
Foreign Keys
|
||||||
------------
|
------------
|
||||||
|
|
|
@ -7,17 +7,19 @@ Fields
|
||||||
------
|
------
|
||||||
|
|
||||||
| Field | Description | Type | Null | Key | Default | Extra |
|
| Field | Description | Type | Null | Key | Default | Extra |
|
||||||
| ------ | --------------------------------------------------------- | ---------------- | ---- | --- | ------- | ----- |
|
| --------- | --------------------------------------------------------- | ---------------- | ---- | --- | ------- | ----- |
|
||||||
| uri-id | Id of the item-uri table entry that contains the item uri | int unsigned | NO | PRI | NULL | |
|
| uri-id | Id of the item-uri table entry that contains the item uri | int unsigned | NO | PRI | NULL | |
|
||||||
| type | 0 - Featured | tinyint unsigned | NO | PRI | 0 | |
|
| type | 0 - Featured | tinyint unsigned | NO | PRI | 0 | |
|
||||||
|
| author-id | Author of the featured post | int unsigned | YES | | NULL | |
|
||||||
|
|
||||||
Indexes
|
Indexes
|
||||||
------------
|
------------
|
||||||
|
|
||||||
| Name | Fields |
|
| Name | Fields |
|
||||||
| ------- | ------------ |
|
| --------- | ------------ |
|
||||||
| PRIMARY | uri-id, type |
|
| PRIMARY | uri-id, type |
|
||||||
| type | type |
|
| type | type |
|
||||||
|
| author-id | author-id |
|
||||||
|
|
||||||
Foreign Keys
|
Foreign Keys
|
||||||
------------
|
------------
|
||||||
|
@ -25,5 +27,6 @@ Foreign Keys
|
||||||
| Field | Target Table | Target Field |
|
| Field | Target Table | Target Field |
|
||||||
|-------|--------------|--------------|
|
|-------|--------------|--------------|
|
||||||
| uri-id | [item-uri](help/database/db_item-uri) | id |
|
| uri-id | [item-uri](help/database/db_item-uri) | id |
|
||||||
|
| author-id | [contact](help/database/db_contact) | id |
|
||||||
|
|
||||||
Return to [database documentation](help/database)
|
Return to [database documentation](help/database)
|
||||||
|
|
|
@ -60,6 +60,7 @@ Indexes
|
||||||
| author-id_uid | author-id, uid |
|
| author-id_uid | author-id, uid |
|
||||||
| author-id_received | author-id, received |
|
| author-id_received | author-id, received |
|
||||||
| parent-uri-id_uid | parent-uri-id, uid |
|
| parent-uri-id_uid | parent-uri-id, uid |
|
||||||
|
| uid_wall_received | uid, wall, received |
|
||||||
| uid_contactid | uid, contact-id |
|
| uid_contactid | uid, contact-id |
|
||||||
| uid_unseen_contactid | uid, unseen, contact-id |
|
| uid_unseen_contactid | uid, unseen, contact-id |
|
||||||
| uid_unseen | uid, unseen |
|
| uid_unseen | uid, unseen |
|
||||||
|
|
|
@ -58,7 +58,7 @@ class Pager
|
||||||
|
|
||||||
$this->setQueryString($queryString);
|
$this->setQueryString($queryString);
|
||||||
$this->setItemsPerPage($itemsPerPage);
|
$this->setItemsPerPage($itemsPerPage);
|
||||||
$this->setPage(($_GET['page'] ?? 0) ?: 1);
|
$this->setPage((int)($_GET['page'] ?? 0) ?: 1);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -24,6 +24,7 @@ namespace Friendica\Model;
|
||||||
use Friendica\Content\Text\HTML;
|
use Friendica\Content\Text\HTML;
|
||||||
use Friendica\Core\Cache\Enum\Duration;
|
use Friendica\Core\Cache\Enum\Duration;
|
||||||
use Friendica\Core\Logger;
|
use Friendica\Core\Logger;
|
||||||
|
use Friendica\Core\Protocol;
|
||||||
use Friendica\Core\System;
|
use Friendica\Core\System;
|
||||||
use Friendica\Database\DBA;
|
use Friendica\Database\DBA;
|
||||||
use Friendica\DI;
|
use Friendica\DI;
|
||||||
|
@ -352,17 +353,18 @@ class APContact
|
||||||
|
|
||||||
if (!empty($apcontact['outbox'])) {
|
if (!empty($apcontact['outbox'])) {
|
||||||
if (!empty($local_owner)) {
|
if (!empty($local_owner)) {
|
||||||
$outbox = ActivityPub\Transmitter::getOutbox($local_owner);
|
$statuses_count = self::getStatusesCount($local_owner);
|
||||||
} else {
|
} else {
|
||||||
$outbox = ActivityPub::fetchContent($apcontact['outbox']);
|
$outbox = ActivityPub::fetchContent($apcontact['outbox']);
|
||||||
|
$statuses_count = $outbox['totalItems'] ?? 0;
|
||||||
}
|
}
|
||||||
if (!empty($outbox['totalItems'])) {
|
if (!empty($statuses_count)) {
|
||||||
// Mastodon seriously allows for this condition?
|
// Mastodon seriously allows for this condition?
|
||||||
// Jul 20 2021 - See https://chaos.social/@m11 for a negative posts count
|
// Jul 20 2021 - See https://chaos.social/@m11 for a negative posts count
|
||||||
if ($outbox['totalItems'] < 0) {
|
if ($statuses_count < 0) {
|
||||||
$outbox['totalItems'] = 0;
|
$statuses_count = 0;
|
||||||
}
|
}
|
||||||
$apcontact['statuses_count'] = $outbox['totalItems'];
|
$apcontact['statuses_count'] = $statuses_count;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -483,6 +485,30 @@ class APContact
|
||||||
return DBA::selectFirst('apcontact', [], ['url' => $apcontact['url']]) ?: [];
|
return DBA::selectFirst('apcontact', [], ['url' => $apcontact['url']]) ?: [];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Fetch the number of statuses for the given owner
|
||||||
|
*
|
||||||
|
* @param array $owner
|
||||||
|
*
|
||||||
|
* @return integer
|
||||||
|
*/
|
||||||
|
private static function getStatusesCount(array $owner): int
|
||||||
|
{
|
||||||
|
$condition = [
|
||||||
|
'private' => [Item::PUBLIC, Item::UNLISTED],
|
||||||
|
'author-id' => Contact::getIdForURL($owner['url'], 0, false),
|
||||||
|
'gravity' => [GRAVITY_PARENT, GRAVITY_COMMENT],
|
||||||
|
'network' => Protocol::DFRN,
|
||||||
|
'parent-network' => Protocol::FEDERATED,
|
||||||
|
'deleted' => false,
|
||||||
|
'visible' => true
|
||||||
|
];
|
||||||
|
|
||||||
|
$count = Post::countPosts($condition);
|
||||||
|
|
||||||
|
return $count;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Mark the given AP Contact as "to archive"
|
* Mark the given AP Contact as "to archive"
|
||||||
*
|
*
|
||||||
|
|
|
@ -100,7 +100,7 @@ class FContact
|
||||||
|
|
||||||
$interacted = DBA::count('contact-relation', ["`cid` = ? AND NOT `follows` AND `last-interaction` > ?", $contact['id'], $last_interaction]);
|
$interacted = DBA::count('contact-relation', ["`cid` = ? AND NOT `follows` AND `last-interaction` > ?", $contact['id'], $last_interaction]);
|
||||||
$interacting = DBA::count('contact-relation', ["`relation-cid` = ? AND NOT `follows` AND `last-interaction` > ?", $contact['id'], $last_interaction]);
|
$interacting = DBA::count('contact-relation', ["`relation-cid` = ? AND NOT `follows` AND `last-interaction` > ?", $contact['id'], $last_interaction]);
|
||||||
$posts = Post::countPosts(['author-id' => $contact['id'], 'gravity' => [GRAVITY_PARENT, GRAVITY_COMMENT]]);
|
$posts = DBA::count('post', ['author-id' => $contact['id'], 'gravity' => [GRAVITY_PARENT, GRAVITY_COMMENT]]);
|
||||||
}
|
}
|
||||||
|
|
||||||
$fields = [
|
$fields = [
|
||||||
|
|
|
@ -1273,10 +1273,6 @@ class Item
|
||||||
self::updateDisplayCache($posted_item['uri-id']);
|
self::updateDisplayCache($posted_item['uri-id']);
|
||||||
}
|
}
|
||||||
|
|
||||||
if ($posted_item['origin'] && ($posted_item['uid'] != 0) && in_array($posted_item['gravity'], [GRAVITY_PARENT, GRAVITY_COMMENT])) {
|
|
||||||
DI::cache()->delete(ActivityPub\Transmitter::CACHEKEY_OUTBOX . $posted_item['uid']);
|
|
||||||
}
|
|
||||||
|
|
||||||
return $post_user_id;
|
return $post_user_id;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -400,12 +400,12 @@ class Post
|
||||||
AND (NOT `causer-blocked` OR `causer-id` = ? OR `causer-id` IS NULL) AND NOT `contact-blocked`
|
AND (NOT `causer-blocked` OR `causer-id` = ? OR `causer-id` IS NULL) AND NOT `contact-blocked`
|
||||||
AND ((NOT `contact-readonly` AND NOT `contact-pending` AND (`contact-rel` IN (?, ?)))
|
AND ((NOT `contact-readonly` AND NOT `contact-pending` AND (`contact-rel` IN (?, ?)))
|
||||||
OR `self` OR `gravity` != ? OR `contact-uid` = ?)
|
OR `self` OR `gravity` != ? OR `contact-uid` = ?)
|
||||||
AND NOT EXISTS (SELECT `uri-id` FROM `post-user` WHERE `uid` = ? AND `uri-id` = `" . $view . "`.`uri-id` AND `hidden`)
|
AND NOT `" . $view . "`.`uri-id` IN (SELECT `uri-id` FROM `post-user` WHERE `uid` = ? AND `hidden`)
|
||||||
AND NOT EXISTS (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `cid` = `author-id` AND `blocked`)
|
AND NOT `author-id` IN (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `blocked`)
|
||||||
AND NOT EXISTS (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `cid` = `owner-id` AND `blocked`)
|
AND NOT `owner-id` IN (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `blocked`)
|
||||||
AND NOT EXISTS (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `cid` = `author-id` AND `ignored` AND `gravity` = ?)
|
AND NOT (`gravity` = ? AND `author-id` IN (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `ignored`))
|
||||||
AND NOT EXISTS (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `cid` = `owner-id` AND `ignored` AND `gravity` = ?)",
|
AND NOT (`gravity` = ? AND `owner-id` IN (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `ignored`))",
|
||||||
0, Contact::SHARING, Contact::FRIEND, GRAVITY_PARENT, 0, $uid, $uid, $uid, $uid, GRAVITY_PARENT, $uid, GRAVITY_PARENT]);
|
0, Contact::SHARING, Contact::FRIEND, GRAVITY_PARENT, 0, $uid, $uid, $uid, GRAVITY_PARENT, $uid, GRAVITY_PARENT, $uid]);
|
||||||
|
|
||||||
$select_string = implode(', ', array_map([DBA::class, 'quoteIdentifier'], $selected));
|
$select_string = implode(', ', array_map([DBA::class, 'quoteIdentifier'], $selected));
|
||||||
|
|
||||||
|
|
|
@ -37,15 +37,16 @@ class Collection
|
||||||
*
|
*
|
||||||
* @param integer $uri_id
|
* @param integer $uri_id
|
||||||
* @param integer $type
|
* @param integer $type
|
||||||
|
* @param integer $author_id
|
||||||
* @param integer $cache_uid If set to a non zero value, the featured cache is cleared
|
* @param integer $cache_uid If set to a non zero value, the featured cache is cleared
|
||||||
*/
|
*/
|
||||||
public static function add(int $uri_id, int $type, int $cache_uid = 0)
|
public static function add(int $uri_id, int $type, int $author_id, int $cache_uid = 0)
|
||||||
{
|
{
|
||||||
if (empty($uri_id)) {
|
if (empty($uri_id)) {
|
||||||
throw new BadMethodCallException('Empty URI_id');
|
throw new BadMethodCallException('Empty URI_id');
|
||||||
}
|
}
|
||||||
|
|
||||||
DBA::insert('post-collection', ['uri-id' => $uri_id, 'type' => $type], Database::INSERT_IGNORE);
|
DBA::insert('post-collection', ['uri-id' => $uri_id, 'type' => $type, 'author-id' => $author_id], Database::INSERT_IGNORE);
|
||||||
|
|
||||||
if (!empty($cache_uid) && ($type == self::FEATURED)) {
|
if (!empty($cache_uid) && ($type == self::FEATURED)) {
|
||||||
DI::cache()->delete(ActivityPub\Transmitter::CACHEKEY_FEATURED . $cache_uid);
|
DI::cache()->delete(ActivityPub\Transmitter::CACHEKEY_FEATURED . $cache_uid);
|
||||||
|
|
|
@ -41,12 +41,12 @@ class Pin extends BaseApi
|
||||||
DI::mstdnError()->UnprocessableEntity();
|
DI::mstdnError()->UnprocessableEntity();
|
||||||
}
|
}
|
||||||
|
|
||||||
$item = Post::selectFirstForUser($uid, ['id', 'gravity'], ['uri-id' => $this->parameters['id'], 'uid' => [$uid, 0]]);
|
$item = Post::selectFirstForUser($uid, ['id', 'gravity', 'author-id'], ['uri-id' => $this->parameters['id'], 'uid' => [$uid, 0]]);
|
||||||
if (!DBA::isResult($item)) {
|
if (!DBA::isResult($item)) {
|
||||||
DI::mstdnError()->RecordNotFound();
|
DI::mstdnError()->RecordNotFound();
|
||||||
}
|
}
|
||||||
|
|
||||||
Post\Collection::add($this->parameters['id'], Post\Collection::FEATURED, $uid);
|
Post\Collection::add($this->parameters['id'], Post\Collection::FEATURED, $item['author-id'], $uid);
|
||||||
|
|
||||||
System::jsonExit(DI::mstdnStatus()->createFromUriId($this->parameters['id'], $uid)->toArray());
|
System::jsonExit(DI::mstdnStatus()->createFromUriId($this->parameters['id'], $uid)->toArray());
|
||||||
}
|
}
|
||||||
|
|
|
@ -48,7 +48,7 @@ class Pin extends BaseModule
|
||||||
|
|
||||||
$itemId = intval($this->parameters['id']);
|
$itemId = intval($this->parameters['id']);
|
||||||
|
|
||||||
$item = Post::selectFirst(['uri-id', 'uid', 'featured'], ['id' => $itemId]);
|
$item = Post::selectFirst(['uri-id', 'uid', 'featured', 'author-id'], ['id' => $itemId]);
|
||||||
if (!DBA::isResult($item)) {
|
if (!DBA::isResult($item)) {
|
||||||
throw new HTTPException\NotFoundException();
|
throw new HTTPException\NotFoundException();
|
||||||
}
|
}
|
||||||
|
@ -60,7 +60,7 @@ class Pin extends BaseModule
|
||||||
$pinned = !$item['featured'];
|
$pinned = !$item['featured'];
|
||||||
|
|
||||||
if ($pinned) {
|
if ($pinned) {
|
||||||
Post\Collection::add($item['uri-id'], Post\Collection::FEATURED, local_user());
|
Post\Collection::add($item['uri-id'], Post\Collection::FEATURED, $item['author-id'], local_user());
|
||||||
} else {
|
} else {
|
||||||
Post\Collection::remove($item['uri-id'], Post\Collection::FEATURED, local_user());
|
Post\Collection::remove($item['uri-id'], Post\Collection::FEATURED, local_user());
|
||||||
}
|
}
|
||||||
|
|
|
@ -40,7 +40,7 @@ class Profile extends BaseModule
|
||||||
$a = DI::app();
|
$a = DI::app();
|
||||||
|
|
||||||
// Ensure we've got a profile owner if updating.
|
// Ensure we've got a profile owner if updating.
|
||||||
$a->setProfileOwner($_GET['p'] ?? 0);
|
$a->setProfileOwner((int)($_GET['p'] ?? 0));
|
||||||
|
|
||||||
if (DI::config()->get('system', 'block_public') && !local_user() && !Session::getRemoteContactID($a->getProfileOwner())) {
|
if (DI::config()->get('system', 'block_public') && !local_user() && !Session::getRemoteContactID($a->getProfileOwner())) {
|
||||||
throw new ForbiddenException();
|
throw new ForbiddenException();
|
||||||
|
|
|
@ -679,7 +679,7 @@ class Processor
|
||||||
* Fetch the Uri-Id of a post for the "featured" collection
|
* Fetch the Uri-Id of a post for the "featured" collection
|
||||||
*
|
*
|
||||||
* @param array $activity
|
* @param array $activity
|
||||||
* @return null|int
|
* @return null|array
|
||||||
*/
|
*/
|
||||||
private static function getUriIdForFeaturedCollection(array $activity)
|
private static function getUriIdForFeaturedCollection(array $activity)
|
||||||
{
|
{
|
||||||
|
@ -697,7 +697,7 @@ class Processor
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
$parent = Post::selectFirst(['uri-id'], ['uri' => $activity['object_id']]);
|
$parent = Post::selectFirst(['uri-id', 'author-id'], ['uri' => $activity['object_id']]);
|
||||||
if (empty($parent['uri-id'])) {
|
if (empty($parent['uri-id'])) {
|
||||||
if (self::fetchMissingActivity($activity['object_id'], $activity, '', Receiver::COMPLETION_AUTO)) {
|
if (self::fetchMissingActivity($activity['object_id'], $activity, '', Receiver::COMPLETION_AUTO)) {
|
||||||
$parent = Post::selectFirst(['uri-id'], ['uri' => $activity['object_id']]);
|
$parent = Post::selectFirst(['uri-id'], ['uri' => $activity['object_id']]);
|
||||||
|
@ -705,7 +705,7 @@ class Processor
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!empty($parent['uri-id'])) {
|
if (!empty($parent['uri-id'])) {
|
||||||
return $parent['uri-id'];
|
$parent;
|
||||||
}
|
}
|
||||||
|
|
||||||
return null;
|
return null;
|
||||||
|
@ -718,14 +718,14 @@ class Processor
|
||||||
*/
|
*/
|
||||||
public static function addToFeaturedCollection(array $activity)
|
public static function addToFeaturedCollection(array $activity)
|
||||||
{
|
{
|
||||||
$uriid = self::getUriIdForFeaturedCollection($activity);
|
$post = self::getUriIdForFeaturedCollection($activity);
|
||||||
if (empty($uriid)) {
|
if (empty($post)) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
Logger::debug('Add post to featured collection', ['uri-id' => $uriid]);
|
Logger::debug('Add post to featured collection', ['post' => $post]);
|
||||||
|
|
||||||
Post\Collection::add($uriid, Post\Collection::FEATURED);
|
Post\Collection::add($post['uri-id'], Post\Collection::FEATURED, $post['author-id']);
|
||||||
Queue::remove($activity);
|
Queue::remove($activity);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -736,14 +736,14 @@ class Processor
|
||||||
*/
|
*/
|
||||||
public static function removeFromFeaturedCollection(array $activity)
|
public static function removeFromFeaturedCollection(array $activity)
|
||||||
{
|
{
|
||||||
$uriid = self::getUriIdForFeaturedCollection($activity);
|
$post = self::getUriIdForFeaturedCollection($activity);
|
||||||
if (empty($uriid)) {
|
if (empty($post)) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
Logger::debug('Remove post from featured collection', ['uri-id' => $uriid]);
|
Logger::debug('Remove post from featured collection', ['post' => $post]);
|
||||||
|
|
||||||
Post\Collection::remove($uriid, Post\Collection::FEATURED);
|
Post\Collection::remove($post['uri-id'], Post\Collection::FEATURED);
|
||||||
Queue::remove($activity);
|
Queue::remove($activity);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -759,7 +759,7 @@ class Processor
|
||||||
public static function createEvent(array $activity, array $item): int
|
public static function createEvent(array $activity, array $item): int
|
||||||
{
|
{
|
||||||
$event['summary'] = HTML::toBBCode($activity['name'] ?: $activity['summary']);
|
$event['summary'] = HTML::toBBCode($activity['name'] ?: $activity['summary']);
|
||||||
$event['desc'] = HTML::toBBCode($activity['content']);
|
$event['desc'] = HTML::toBBCode($activity['content'] ?? '');
|
||||||
if (!empty($activity['start-time'])) {
|
if (!empty($activity['start-time'])) {
|
||||||
$event['start'] = DateTimeFormat::utc($activity['start-time']);
|
$event['start'] = DateTimeFormat::utc($activity['start-time']);
|
||||||
}
|
}
|
||||||
|
@ -1335,10 +1335,10 @@ class Processor
|
||||||
}
|
}
|
||||||
$id = Item::fetchByLink($post['id']);
|
$id = Item::fetchByLink($post['id']);
|
||||||
if (!empty($id)) {
|
if (!empty($id)) {
|
||||||
$item = Post::selectFirst(['uri-id', 'featured'], ['id' => $id]);
|
$item = Post::selectFirst(['uri-id', 'featured', 'author-id'], ['id' => $id]);
|
||||||
if (!empty($item['uri-id'])) {
|
if (!empty($item['uri-id'])) {
|
||||||
if (!$item['featured']) {
|
if (!$item['featured']) {
|
||||||
Post\Collection::add($item['uri-id'], Post\Collection::FEATURED);
|
Post\Collection::add($item['uri-id'], Post\Collection::FEATURED, $item['author-id']);
|
||||||
Logger::debug('Added featured post', ['uri-id' => $item['uri-id'], 'contact' => $url]);
|
Logger::debug('Added featured post', ['uri-id' => $item['uri-id'], 'contact' => $url]);
|
||||||
$new++;
|
$new++;
|
||||||
} else {
|
} else {
|
||||||
|
|
|
@ -59,7 +59,6 @@ class Transmitter
|
||||||
{
|
{
|
||||||
const CACHEKEY_FEATURED = 'transmitter:getFeatured:';
|
const CACHEKEY_FEATURED = 'transmitter:getFeatured:';
|
||||||
const CACHEKEY_CONTACTS = 'transmitter:getContacts:';
|
const CACHEKEY_CONTACTS = 'transmitter:getContacts:';
|
||||||
const CACHEKEY_OUTBOX = 'transmitter:getOutbox:';
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Add relay servers to the list of inboxes
|
* Add relay servers to the list of inboxes
|
||||||
|
@ -251,14 +250,6 @@ class Transmitter
|
||||||
*/
|
*/
|
||||||
public static function getOutbox(array $owner, int $page = null, string $requester = '', bool $nocache = false): array
|
public static function getOutbox(array $owner, int $page = null, string $requester = '', bool $nocache = false): array
|
||||||
{
|
{
|
||||||
if (empty($page)) {
|
|
||||||
$cachekey = self::CACHEKEY_OUTBOX . $owner['uid'];
|
|
||||||
$result = DI::cache()->get($cachekey);
|
|
||||||
if (!$nocache && !is_null($result)) {
|
|
||||||
return $result;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
$condition = ['private' => [Item::PUBLIC, Item::UNLISTED]];
|
$condition = ['private' => [Item::PUBLIC, Item::UNLISTED]];
|
||||||
|
|
||||||
if (!empty($requester)) {
|
if (!empty($requester)) {
|
||||||
|
@ -283,12 +274,12 @@ class Transmitter
|
||||||
'visible' => true
|
'visible' => true
|
||||||
]);
|
]);
|
||||||
|
|
||||||
$count = Post::count($condition);
|
$apcontact = APContact::getByURL($owner['url']);
|
||||||
|
|
||||||
$data = ['@context' => ActivityPub::CONTEXT];
|
$data = ['@context' => ActivityPub::CONTEXT];
|
||||||
$data['id'] = DI::baseUrl() . '/outbox/' . $owner['nickname'];
|
$data['id'] = DI::baseUrl() . '/outbox/' . $owner['nickname'];
|
||||||
$data['type'] = 'OrderedCollection';
|
$data['type'] = 'OrderedCollection';
|
||||||
$data['totalItems'] = $count;
|
$data['totalItems'] = $apcontact['statuses_count'] ?? 0;
|
||||||
|
|
||||||
if (!empty($page)) {
|
if (!empty($page)) {
|
||||||
$data['id'] .= '?' . http_build_query(['page' => $page]);
|
$data['id'] .= '?' . http_build_query(['page' => $page]);
|
||||||
|
@ -316,15 +307,17 @@ class Transmitter
|
||||||
$data['next'] = DI::baseUrl() . '/outbox/' . $owner['nickname'] . '?page=' . ($page + 1);
|
$data['next'] = DI::baseUrl() . '/outbox/' . $owner['nickname'] . '?page=' . ($page + 1);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Fix the cached total item count when it is lower than the real count
|
||||||
|
$total = (($page - 1) * 20) + $data['totalItems'];
|
||||||
|
if ($total > $data['totalItems']) {
|
||||||
|
$data['totalItems'] = $total;
|
||||||
|
}
|
||||||
|
|
||||||
$data['partOf'] = DI::baseUrl() . '/outbox/' . $owner['nickname'];
|
$data['partOf'] = DI::baseUrl() . '/outbox/' . $owner['nickname'];
|
||||||
|
|
||||||
$data['orderedItems'] = $list;
|
$data['orderedItems'] = $list;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!empty($cachekey)) {
|
|
||||||
DI::cache()->set($cachekey, $data, Duration::DAY);
|
|
||||||
}
|
|
||||||
|
|
||||||
return $data;
|
return $data;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -55,7 +55,7 @@
|
||||||
use Friendica\Database\DBA;
|
use Friendica\Database\DBA;
|
||||||
|
|
||||||
if (!defined('DB_UPDATE_VERSION')) {
|
if (!defined('DB_UPDATE_VERSION')) {
|
||||||
define('DB_UPDATE_VERSION', 1480);
|
define('DB_UPDATE_VERSION', 1481);
|
||||||
}
|
}
|
||||||
|
|
||||||
return [
|
return [
|
||||||
|
@ -284,7 +284,7 @@ return [
|
||||||
"uid_contact-type" => ["uid", "contact-type"],
|
"uid_contact-type" => ["uid", "contact-type"],
|
||||||
"uid_self_contact-type" => ["uid", "self", "contact-type"],
|
"uid_self_contact-type" => ["uid", "self", "contact-type"],
|
||||||
"self_network_uid" => ["self", "network", "uid"],
|
"self_network_uid" => ["self", "network", "uid"],
|
||||||
"gsid" => ["gsid"],
|
"gsid_uid_failed" => ["gsid", "uid", "failed"],
|
||||||
"uri-id" => ["uri-id"],
|
"uri-id" => ["uri-id"],
|
||||||
]
|
]
|
||||||
],
|
],
|
||||||
|
@ -971,6 +971,7 @@ return [
|
||||||
"target-uri-id" => ["target-uri-id"],
|
"target-uri-id" => ["target-uri-id"],
|
||||||
"parent-uri-id" => ["parent-uri-id"],
|
"parent-uri-id" => ["parent-uri-id"],
|
||||||
"seen_uid" => ["seen", "uid"],
|
"seen_uid" => ["seen", "uid"],
|
||||||
|
"uid_type_parent-uri-id_actor-id" => ["uid", "type", "parent-uri-id", "actor-id"],
|
||||||
]
|
]
|
||||||
],
|
],
|
||||||
"notify" => [
|
"notify" => [
|
||||||
|
@ -1187,10 +1188,12 @@ return [
|
||||||
"fields" => [
|
"fields" => [
|
||||||
"uri-id" => ["type" => "int unsigned", "not null" => "1", "primary" => "1", "foreign" => ["item-uri" => "id"], "comment" => "Id of the item-uri table entry that contains the item uri"],
|
"uri-id" => ["type" => "int unsigned", "not null" => "1", "primary" => "1", "foreign" => ["item-uri" => "id"], "comment" => "Id of the item-uri table entry that contains the item uri"],
|
||||||
"type" => ["type" => "tinyint unsigned", "not null" => "1", "default" => "0", "primary" => "1", "comment" => "0 - Featured"],
|
"type" => ["type" => "tinyint unsigned", "not null" => "1", "default" => "0", "primary" => "1", "comment" => "0 - Featured"],
|
||||||
|
"author-id" => ["type" => "int unsigned", "foreign" => ["contact" => "id"], "comment" => "Author of the featured post"],
|
||||||
],
|
],
|
||||||
"indexes" => [
|
"indexes" => [
|
||||||
"PRIMARY" => ["uri-id", "type"],
|
"PRIMARY" => ["uri-id", "type"],
|
||||||
"type" => ["type"],
|
"type" => ["type"],
|
||||||
|
"author-id" => ["author-id"],
|
||||||
]
|
]
|
||||||
],
|
],
|
||||||
"post-content" => [
|
"post-content" => [
|
||||||
|
@ -1440,6 +1443,7 @@ return [
|
||||||
"author-id_uid" => ["author-id", "uid"],
|
"author-id_uid" => ["author-id", "uid"],
|
||||||
"author-id_received" => ["author-id", "received"],
|
"author-id_received" => ["author-id", "received"],
|
||||||
"parent-uri-id_uid" => ["parent-uri-id", "uid"],
|
"parent-uri-id_uid" => ["parent-uri-id", "uid"],
|
||||||
|
"uid_wall_received" => ["uid", "wall", "received"],
|
||||||
"uid_contactid" => ["uid", "contact-id"],
|
"uid_contactid" => ["uid", "contact-id"],
|
||||||
"uid_unseen_contactid" => ["uid", "unseen", "contact-id"],
|
"uid_unseen_contactid" => ["uid", "unseen", "contact-id"],
|
||||||
"uid_unseen" => ["uid", "unseen"],
|
"uid_unseen" => ["uid", "unseen"],
|
||||||
|
|
|
@ -702,7 +702,7 @@
|
||||||
"fields" => [
|
"fields" => [
|
||||||
"uri-id" => ["post-collection", "uri-id"],
|
"uri-id" => ["post-collection", "uri-id"],
|
||||||
"type" => ["post-collection", "type"],
|
"type" => ["post-collection", "type"],
|
||||||
"cid" => ["post", "author-id"],
|
"cid" => ["post-collection", "author-id"],
|
||||||
"received" => ["post", "received"],
|
"received" => ["post", "received"],
|
||||||
"created" => ["post", "created"],
|
"created" => ["post", "created"],
|
||||||
"commented" => ["post-thread", "commented"],
|
"commented" => ["post-thread", "commented"],
|
||||||
|
@ -710,7 +710,7 @@
|
||||||
"visible" => ["post", "visible"],
|
"visible" => ["post", "visible"],
|
||||||
"deleted" => ["post", "deleted"],
|
"deleted" => ["post", "deleted"],
|
||||||
"thr-parent-id" => ["post", "thr-parent-id"],
|
"thr-parent-id" => ["post", "thr-parent-id"],
|
||||||
"author-id" => ["post", "author-id"],
|
"author-id" => ["post-collection", "author-id"],
|
||||||
"gravity" => ["post", "gravity"],
|
"gravity" => ["post", "gravity"],
|
||||||
],
|
],
|
||||||
"query" => "FROM `post-collection`
|
"query" => "FROM `post-collection`
|
||||||
|
|
10
update.php
10
update.php
|
@ -1100,9 +1100,9 @@ function update_1451()
|
||||||
|
|
||||||
function update_1457()
|
function update_1457()
|
||||||
{
|
{
|
||||||
$pinned = DBA::select('post-thread-user', ['uri-id'], ['pinned' => true]);
|
$pinned = DBA::select('post-thread-user', ['uri-id', 'author-id'], ['pinned' => true]);
|
||||||
while ($post = DBA::fetch($pinned)) {
|
while ($post = DBA::fetch($pinned)) {
|
||||||
Post\Collection::add($post['uri-id'], Post\Collection::FEATURED);
|
Post\Collection::add($post['uri-id'], Post\Collection::FEATURED, $post['author-id']);
|
||||||
}
|
}
|
||||||
DBA::close($pinned);
|
DBA::close($pinned);
|
||||||
|
|
||||||
|
@ -1115,3 +1115,9 @@ function update_1480()
|
||||||
DBA::update('post', ['deleted' => false], ["`uri-id` IN (SELECT `uri-id` FROM `post-user` WHERE NOT `deleted`)"]);
|
DBA::update('post', ['deleted' => false], ["`uri-id` IN (SELECT `uri-id` FROM `post-user` WHERE NOT `deleted`)"]);
|
||||||
return Update::SUCCESS;
|
return Update::SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function update_1481()
|
||||||
|
{
|
||||||
|
DBA::e("UPDATE `post-collection` INNER JOIN `post` ON `post`.`uri-id` = `post-collection`.`uri-id` SET `post-collection`.`author-id` = `post`.`author-id` WHERE `post-collection`.`author-id` IS null");
|
||||||
|
return Update::SUCCESS;
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user