Merge pull request 'Bluesky: more logging added' (#1512) from heluecht/friendica-addons:bluesky-logging into 2024.06-rc
Reviewed-on: https://git.friendi.ca/friendica/friendica-addons/pulls/1512pull/1513/head
commit
b6f2e7dd50
|
@ -516,6 +516,7 @@ function bluesky_cron()
|
||||||
$pconfigs = DBA::selectToArray('pconfig', [], ["`cat` = ? AND `k` IN (?, ?) AND `v`", 'bluesky', 'import', 'import_feeds']);
|
$pconfigs = DBA::selectToArray('pconfig', [], ["`cat` = ? AND `k` IN (?, ?) AND `v`", 'bluesky', 'import', 'import_feeds']);
|
||||||
foreach ($pconfigs as $pconfig) {
|
foreach ($pconfigs as $pconfig) {
|
||||||
if (empty(bluesky_get_user_did($pconfig['uid']))) {
|
if (empty(bluesky_get_user_did($pconfig['uid']))) {
|
||||||
|
Logger::debug('User has got no valid DID', ['uid' => $pconfig['uid']]);
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -527,6 +528,7 @@ function bluesky_cron()
|
||||||
}
|
}
|
||||||
|
|
||||||
// Refresh the token now, so that it doesn't need to be refreshed in parallel by the following workers
|
// Refresh the token now, so that it doesn't need to be refreshed in parallel by the following workers
|
||||||
|
Logger::debug('Refresh the token', ['uid' => $pconfig['uid']]);
|
||||||
bluesky_get_token($pconfig['uid']);
|
bluesky_get_token($pconfig['uid']);
|
||||||
|
|
||||||
Worker::add(['priority' => Worker::PRIORITY_MEDIUM, 'force_priority' => true], 'addon/bluesky/bluesky_notifications.php', $pconfig['uid'], $last);
|
Worker::add(['priority' => Worker::PRIORITY_MEDIUM, 'force_priority' => true], 'addon/bluesky/bluesky_notifications.php', $pconfig['uid'], $last);
|
||||||
|
@ -534,13 +536,19 @@ function bluesky_cron()
|
||||||
Worker::add(['priority' => Worker::PRIORITY_MEDIUM, 'force_priority' => true], 'addon/bluesky/bluesky_timeline.php', $pconfig['uid'], $last);
|
Worker::add(['priority' => Worker::PRIORITY_MEDIUM, 'force_priority' => true], 'addon/bluesky/bluesky_timeline.php', $pconfig['uid'], $last);
|
||||||
}
|
}
|
||||||
if (DI::pConfig()->get($pconfig['uid'], 'bluesky', 'import_feeds')) {
|
if (DI::pConfig()->get($pconfig['uid'], 'bluesky', 'import_feeds')) {
|
||||||
|
Logger::debug('Fetch feeds for user', ['uid' => $pconfig['uid']]);
|
||||||
$feeds = bluesky_get_feeds($pconfig['uid']);
|
$feeds = bluesky_get_feeds($pconfig['uid']);
|
||||||
foreach ($feeds as $feed) {
|
foreach ($feeds as $feed) {
|
||||||
Worker::add(['priority' => Worker::PRIORITY_MEDIUM, 'force_priority' => true], 'addon/bluesky/bluesky_feed.php', $pconfig['uid'], $feed, $last);
|
Worker::add(['priority' => Worker::PRIORITY_MEDIUM, 'force_priority' => true], 'addon/bluesky/bluesky_feed.php', $pconfig['uid'], $feed, $last);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Logger::debug('Polling done for user', ['uid' => $pconfig['uid']]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Logger::notice('Polling done for all users');
|
||||||
|
|
||||||
|
DI::keyValue()->set('bluesky_last_poll', time());
|
||||||
|
|
||||||
$last_clean = DI::keyValue()->get('bluesky_last_clean');
|
$last_clean = DI::keyValue()->get('bluesky_last_clean');
|
||||||
if (empty($last_clean) || ($last_clean + 86400 < time())) {
|
if (empty($last_clean) || ($last_clean + 86400 < time())) {
|
||||||
Logger::notice('Start contact cleanup');
|
Logger::notice('Start contact cleanup');
|
||||||
|
@ -554,8 +562,6 @@ function bluesky_cron()
|
||||||
}
|
}
|
||||||
|
|
||||||
Logger::notice('cron_end');
|
Logger::notice('cron_end');
|
||||||
|
|
||||||
DI::keyValue()->set('bluesky_last_poll', time());
|
|
||||||
}
|
}
|
||||||
|
|
||||||
function bluesky_hook_fork(array &$b)
|
function bluesky_hook_fork(array &$b)
|
||||||
|
|
Loading…
Reference in New Issue