nobigtech
/
soselo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add a feature to filter posts by "local" (instance only)

This commit is contained in:
Bofh 2022-12-24 19:08:38 +01:00
parent 177b6a6804
commit 006067e851
1 changed files with 21 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
api/v1/database/mastodon/posts/mod.php
View File

@ -6,23 +6,36 @@ $_ = function() {
$MAX_LIMIT = 10000; $MAX_LIMIT = 10000;
$start = arg('*get.start', null, 'valid_mastodon_account_id'); $start = arg('*get.start', null, 'valid_mastodon_account_id');
$limit = arg('i:get.limit', $MAX_LIMIT); $limit = arg('i:get.limit', $MAX_LIMIT);
$local = arg('set:get.local');
if ($limit > $MAX_LIMIT) if ($limit > $MAX_LIMIT)
$limit = $MAX_LIMIT; $limit = $MAX_LIMIT;
$fields = "id, TRIM(CONCAT(spoiler_text, ' ', text)) AS post, created_at, updated_at";
$sql_all = '
SELECT '.$fields.', reblog_of_id
FROM statuses
WHERE id >= '.$start.'
ORDER BY id ASC LIMIT '.$limit.'
';
$pg = new PgDatabase(); $pg = new PgDatabase();
if (!$pg->is_ok()) if (!$pg->is_ok())
return apiresult(['error' => 'Unknown database error ocurred'], 500); return apiresult(['error' => 'Unknown database error ocurred'], 500);
$fields = "s.id, s.account_id, TRIM(CONCAT(s.spoiler_text, ' ', s.text)) AS post, s.created_at, s.updated_at";
$sql_all = '
SELECT '.$fields.', reblog_of_id
FROM statuses AS s
{innerJoinAccounts}
WHERE
{isLocal}
s.id >= '.$start.'
ORDER BY id ASC LIMIT '.$limit.'
';
if ($local) {
$sql_all = str_replace('{isLocal}', 'a.domain IS NULL AND', $sql_all);
$sql_all = str_replace('{innerJoinAccounts}', 'INNER JOIN accounts AS a ON a.id = s.account_id', $sql_all);
} else {
$sql_all = str_replace('{isLocal}', '', $sql_all);
$sql_all = str_replace('{innerJoinAccounts}', '', $sql_all);
}
$objects = $pg->fetch_all($sql_all); $objects = $pg->fetch_all($sql_all);
foreach ($objects as &$object) { foreach ($objects as &$object) {
if ($object['reblog_of_id'] !== null) if ($object['reblog_of_id'] !== null)
$object['original'] = $pg->fetch("SELECT $fields FROM statuses WHERE id = {$object['reblog_of_id']} LIMIT 1"); $object['original'] = $pg->fetch("SELECT $fields FROM statuses AS s WHERE s.id = {$object['reblog_of_id']} LIMIT 1");
unset($object['reblog_of_id']); unset($object['reblog_of_id']);
} }