}
protected $subConsoles = [
- 'addon' => Friendica\Console\Addon::class,
- 'archivecontact' => Friendica\Console\ArchiveContact::class,
- 'autoinstall' => Friendica\Console\AutomaticInstallation::class,
- 'cache' => Friendica\Console\Cache::class,
- 'clearavatarcache' => Friendica\Console\ClearAvatarCache::class,
- 'config' => Friendica\Console\Config::class,
- 'contact' => Friendica\Console\Contact::class,
- 'createdoxygen' => Friendica\Console\CreateDoxygen::class,
- 'daemon' => Friendica\Console\Daemon::class,
- 'jetstream' => Friendica\Console\JetstreamDaemon::class,
- 'docbloxerrorchecker' => Friendica\Console\DocBloxErrorChecker::class,
- 'dbstructure' => Friendica\Console\DatabaseStructure::class,
- 'extract' => Friendica\Console\Extract::class,
+ 'addon' => Friendica\Console\Addon::class,
+ 'archivecontact' => Friendica\Console\ArchiveContact::class,
+ 'autoinstall' => Friendica\Console\AutomaticInstallation::class,
+ 'cache' => Friendica\Console\Cache::class,
+ 'clearavatarcache' => Friendica\Console\ClearAvatarCache::class,
+ 'config' => Friendica\Console\Config::class,
+ 'contact' => Friendica\Console\Contact::class,
+ 'createdoxygen' => Friendica\Console\CreateDoxygen::class,
+ 'daemon' => Friendica\Console\Daemon::class,
+ 'jetstream' => Friendica\Console\JetstreamDaemon::class,
+ 'docbloxerrorchecker' => Friendica\Console\DocBloxErrorChecker::class,
+ 'dbstructure' => Friendica\Console\DatabaseStructure::class,
+ 'extract' => Friendica\Console\Extract::class,
'fixapdeliveryworkertaskparameters' => Friendica\Console\FixAPDeliveryWorkerTaskParameters::class,
- 'globalcommunityblock' => Friendica\Console\GlobalCommunityBlock::class,
- 'globalcommunitysilence' => Friendica\Console\GlobalCommunitySilence::class,
- 'lock' => Friendica\Console\Lock::class,
- 'maintenance' => Friendica\Console\Maintenance::class,
- 'mergecontacts' => Friendica\Console\MergeContacts::class,
- 'movetoavatarcache' => Friendica\Console\MoveToAvatarCache::class,
- 'php2po' => Friendica\Console\PhpToPo::class,
- 'postupdate' => Friendica\Console\PostUpdate::class,
- 'po2php' => Friendica\Console\PoToPhp::class,
- 'relay' => Friendica\Console\Relay::class,
- 'relocate' => Friendica\Console\Relocate::class,
- 'serverblock' => Friendica\Console\ServerBlock::class,
- 'storage' => Friendica\Console\Storage::class,
- 'test' => Friendica\Console\Test::class,
- 'typo' => Friendica\Console\Typo::class,
- 'user' => Friendica\Console\User::class,
+ 'globalcommunityblock' => Friendica\Console\GlobalCommunityBlock::class,
+ 'globalcommunitysilence' => Friendica\Console\GlobalCommunitySilence::class,
+ 'lock' => Friendica\Console\Lock::class,
+ 'maintenance' => Friendica\Console\Maintenance::class,
+ 'mergecontacts' => Friendica\Console\MergeContacts::class,
+ 'movetoavatarcache' => Friendica\Console\MoveToAvatarCache::class,
+ 'php2po' => Friendica\Console\PhpToPo::class,
+ 'postupdate' => Friendica\Console\PostUpdate::class,
+ 'po2php' => Friendica\Console\PoToPhp::class,
+ 'relay' => Friendica\Console\Relay::class,
+ 'relocate' => Friendica\Console\Relocate::class,
+ 'serverblock' => Friendica\Console\ServerBlock::class,
+ 'storage' => Friendica\Console\Storage::class,
+ 'test' => Friendica\Console\Test::class,
+ 'typo' => Friendica\Console\Typo::class,
+ 'user' => Friendica\Console\User::class,
];
/**
*/
class Jetstream
{
- private $uids = [];
- private $self = [];
- private $capped = false;
+ private $uids = [];
+ private $self = [];
+ private $capped = false;
/** @var LoggerInterface */
private $logger;
if (!$this->capped && count($dids) < $did_limit) {
$condition = ["`uid` = ? AND `network` = ? AND EXISTS(SELECT `author-id` FROM `post-user` WHERE `author-id` = `contact`.`id` AND `post-user`.`uid` != ?)", 0, Protocol::BLUESKY, 0];
- $contacts = Contact::selectToArray(['url'], $condition, ['order' => ['last-item' => true], 'limit' => $did_limit]);
- $dids = $this->addDids($contacts, $uids, $did_limit, $dids);
+ $contacts = Contact::selectToArray(['url'], $condition, ['order' => ['last-item' => true], 'limit' => $did_limit]);
+ $dids = $this->addDids($contacts, $uids, $did_limit, $dids);
}
$this->keyValue->set('jetstream_did_count', count($dids));
<?php
+// Copyright (C) 2010-2025, the Friendica project
+// SPDX-FileCopyrightText: 2010-2024 the Friendica project
+//
+// SPDX-License-Identifier: AGPL-3.0-or-later
+
namespace Friendica\System;
use Friendica\Database\Database;
private LoggerInterface $logger;
private Database $dba;
private ?string $pidfile = null;
- private ?int $pid = null;
+ private ?int $pid = null;
/**
* The PID of the current daemon (null if either not set or not found)
if ($this->pid < 0) {
$this->logger->warning('Could not fork daemon');
return false;
- } elseif ($this->pid) {
+ } else if ($this->pid) {
// The parent process continues here
if (!file_put_contents($this->pidfile, $this->pid)) {
$this->logger->warning('Could not store pid file', ['pid' => $this->pid, 'pidfile' => $this->pidfile]);