use Friendica\Core\Logger;
use Friendica\Core\Protocol;
use Friendica\Core\Renderer;
-use Friendica\Core\System;
use Friendica\Core\Worker;
use Friendica\Database\DBA;
use Friendica\DI;
$data = Item::insert($item);
Logger::debug('Got repost', ['uid' => $uid, 'result' => $data, 'uri' => $uri]);
} else {
- Logger::info('Thread parent not found', ['uid' => $uid, 'parent' => $$item['thr-parent'], 'uri' => $uri]);
+ Logger::info('Thread parent not found', ['uid' => $uid, 'parent' => $item['thr-parent'], 'uri' => $uri]);
}
break;
return;
}
+ $feeddata = bluesky_xrpc_get($uid, 'app.bsky.feed.getFeedGenerator', ['feed' => $feed]);
+ if (!empty($feeddata)) {
+ $feedurl = $feeddata->view->uri;
+ $feedname = $feeddata->view->displayName;
+ } else {
+ $feedurl = $feed;
+ $feedname = $feed;
+ }
+
foreach (array_reverse($data->feed) as $entry) {
if (!Relay::isWantedLanguage($entry->post->record->text)) {
Logger::debug('Unwanted language detected', ['text' => $entry->post->record->text]);
continue;
}
- bluesky_process_post($entry->post, $uid, Item::PR_TAG, 0);
+ $id = bluesky_process_post($entry->post, $uid, Item::PR_TAG, 0);
+ if (!empty($id)) {
+ $post = Post::selectFirst(['uri-id'], ['id' => $id]);
+ if (!empty($post['uri-id'])) {
+ $stored = Post\Category::storeFileByURIId($post['uri-id'], $uid, Post\Category::SUBCRIPTION, $feedname, $feedurl);
+ Logger::debug('Stored tag subscription for user', ['uri-id' => $post['uri-id'], 'uid' => $uid, 'name' => $feedname, 'url' => $feedurl, 'stored' => $stored]);
+ } else {
+ Logger::notice('Post not found', ['id' => $id, 'entry' => $entry]);
+ }
+ }
if (!empty($entry->reason)) {
bluesky_process_reason($entry->reason, bluesky_get_uri($entry->post), $uid);
}
{
$uri = bluesky_get_uri($post);
- if (Post::exists(['uri' => $uri, 'uid' => $uid]) || Post::exists(['extid' => $uri, 'uid' => $uid])) {
- return 0;
+ if ($id = Post::selectFirst(['id'], ['uri' => $uri, 'uid' => $uid])) {
+ return $id['id'];
+ }
+
+ if ($id = Post::selectFirst(['id'], ['extid' => $uri, 'uid' => $uid])) {
+ return $id['id'];
}
Logger::debug('Importing post', ['uid' => $uid, 'indexedAt' => $post->indexedAt, 'uri' => $post->uri, 'cid' => $post->cid, 'root' => $post->record->reply->root ?? '']);
'author-link' => $contact['url'],
'author-avatar' => $contact['avatar'],
'plink' => $contact['alias'] . '/post/' . $parts->rkey,
+ 'source' => json_encode($post),
];
$item['uri-id'] = ItemURI::getIdByURI($uri);
function bluesky_get_text(stdClass $record): string
{
- $text = $record->text;
+ $text = $record->text ?? '';
if (empty($record->facets)) {
return $text;
$shared = bluesky_add_media($single, $shared, $fetch_uid, $level);
}
}
- $id = Item::insert($shared);
- $shared = Post::selectFirst(['uri-id'], ['id' => $id]);
+ Item::insert($shared);
}
}
- if (!empty($shared)) {
+ if (!empty($shared['uri-id'])) {
$item['quote-uri-id'] = $shared['uri-id'];
}
break;
$shared = bluesky_add_media($single, $shared, $fetch_uid, $level);
}
}
-
- $id = Item::insert($shared);
- $shared = Post::selectFirst(['uri-id'], ['id' => $id]);
+ Item::insert($shared);
}
}
- if (!empty($shared)) {
+ if (!empty($shared['uri-id'])) {
$item['quote-uri-id'] = $shared['uri-id'];
}
if (!empty($embed->media)) {
- bluesky_add_media($embed->media, $item, $fetch_uid, $level);
+ $item = bluesky_add_media($embed->media, $item, $fetch_uid, $level);
}
break;
function bluesky_get_uri(stdClass $post): string
{
if (empty($post->cid)) {
- Logger::info('Invalid URI', ['post' => $post, 'callstack' => System::callstack(10, 0, true)]);
+ Logger::info('Invalid URI', ['post' => $post]);
return '';
}
return $post->uri . ':' . $post->cid;
function bluesky_process_thread(stdClass $thread, int $uid, array $cdata, int $level): string
{
+ if (empty($thread->post)) {
+ Logger::info('Invalid post', ['post' => $thread]);
+ return '';
+ }
$uri = bluesky_get_uri($thread->post);
+
$fetched_uri = bluesky_fetch_post($uri, $uid);
if (empty($fetched_uri)) {
Logger::debug('Process missing post', ['uri' => $uri]);