use Friendica\Model\APContact;
use Friendica\Model\Contact;
use Friendica\Model\GServer;
+use Friendica\Model\Item;
use Friendica\Model\Post;
use Friendica\Model\Search;
use Friendica\Model\Tag;
* @param string $url
* @return boolean "true" is the post is wanted by the system
*/
- public static function isSolicitedPost(array $tags, string $body, int $authorid, string $url, string $network = '')
+ public static function isSolicitedPost(array $tags, string $body, int $authorid, string $url, string $network = '', int $causerid = 0): bool
{
$config = DI::config();
return false;
}
+ if (!empty($causerid)) {
+ $contact = Contact::getById($causerid, ['url']);
+ $causer = $contact['url'] ?? '';
+ } else {
+ $causer = '';
+ }
+
+ $body = ActivityPub\Processor::normalizeMentionLinks($body);
+
$systemTags = [];
$userTags = [];
$denyTags = [];
foreach ($tags as $tag) {
$tag = mb_strtolower($tag);
if (in_array($tag, $denyTags)) {
- Logger::info('Unwanted hashtag found - rejected', ['hashtag' => $tag, 'network' => $network, 'url' => $url]);
+ Logger::info('Unwanted hashtag found - rejected', ['hashtag' => $tag, 'network' => $network, 'url' => $url, 'causer' => $causer]);
return false;
}
if (in_array($tag, $tagList)) {
- Logger::info('Subscribed hashtag found - accepted', ['hashtag' => $tag, 'network' => $network, 'url' => $url]);
+ Logger::info('Subscribed hashtag found - accepted', ['hashtag' => $tag, 'network' => $network, 'url' => $url, 'causer' => $causer]);
return true;
}
// We check with "strpos" for performance issues. Only when this is true, the regular expression check is used
// RegExp is taken from here: https://medium.com/@shiba1014/regex-word-boundaries-with-unicode-207794f6e7ed
if ((strpos($content, $tag) !== false) && preg_match('/(?<=[\s,.:;"\']|^)' . preg_quote($tag, '/') . '(?=[\s,.:;"\']|$)/', $content)) {
- Logger::info('Subscribed hashtag found in content - accepted', ['hashtag' => $tag, 'network' => $network, 'url' => $url]);
+ Logger::info('Subscribed hashtag found in content - accepted', ['hashtag' => $tag, 'network' => $network, 'url' => $url, 'causer' => $causer]);
return true;
}
}
}
+ $languages = [];
+ foreach (Item::getLanguageArray($body, 10) as $language => $reliability) {
+ if ($reliability > 0) {
+ $languages[] = $language;
+ }
+ }
+
+ Logger::debug('Got languages', ['languages' => $languages, 'body' => $body, 'causer' => $causer]);
+
+ if (!empty($languages)) {
+ if (in_array($languages[0], $config->get('system', 'relay_deny_languages'))) {
+ Logger::info('Unwanted language found - rejected', ['language' => $languages[0], 'network' => $network, 'url' => $url, 'causer' => $causer]);
+ return false;
+ }
+ } elseif ($config->get('system', 'relay_deny_undetected_language')) {
+ Logger::info('Undetected language found - rejected', ['body' => $body, 'network' => $network, 'url' => $url, 'causer' => $causer]);
+ return false;
+ }
+
if ($scope == self::SCOPE_ALL) {
- Logger::info('Server accept all posts - accepted', ['network' => $network, 'url' => $url]);
+ Logger::info('Server accept all posts - accepted', ['network' => $network, 'url' => $url, 'causer' => $causer]);
return true;
}
- Logger::info('No matching hashtags found - rejected', ['network' => $network, 'url' => $url]);
+ Logger::info('No matching hashtags found - rejected', ['network' => $network, 'url' => $url, 'causer' => $causer]);
return false;
}
*
* @param array $gserver Global server record
* @param array $fields Optional network specific fields
+ * @return void
* @throws \Exception
*/
public static function updateContact(array $gserver, array $fields = [])
* The relay contact is a technical contact entry that exists once per server.
*
* @param array $contact of the relay contact
+ * @return void
*/
public static function markForArchival(array $contact)
{
* @param integer $item_id id of the item that is sent
* @param array $contacts Previously fetched contacts
* @param array $networks Networks of the relay servers
- *
* @return array of relay servers
* @throws \Friendica\Network\HTTPException\InternalServerErrorException
*/
- public static function getDirectRelayList(int $item_id)
+ public static function getDirectRelayList(int $item_id): array
{
$serverlist = [];
- if (!DI::config()->get("system", "relay_directly", false)) {
+ if (!DI::config()->get('system', 'relay_directly', false)) {
return [];
}
* Return a list of relay servers
*
* @param array $fields Field list
- * @return array
+ * @return array List of relay servers
* @throws Exception
*/
- public static function getList($fields = []):array
+ public static function getList(array $fields = []): array
{
return DBA::selectToArray('apcontact', $fields,
["`type` = ? AND `url` IN (SELECT `url` FROM `contact` WHERE `uid` = ? AND `rel` = ?)", 'Application', 0, Contact::FRIEND]);
*
* @param array $gserver Global server record
* @param array $fields Fieldlist
- * @return array with the contact
+ * @return array|bool Array with the contact or false on error
* @throws \Exception
*/
private static function getContact(array $gserver, array $fields = ['batch', 'id', 'url', 'name', 'network', 'protocol', 'archive', 'blocked'])
// It should never happen that we arrive here
return [];
}
+
+ /**
+ * Resubscribe to all relay servers
+ *
+ * @return void
+ */
+ public static function reSubscribe()
+ {
+ foreach (self::getList() as $server) {
+ $success = ActivityPub\Transmitter::sendRelayFollow($server['url']);
+ Logger::debug('Resubscribed', ['profile' => $server['url'], 'success' => $success]);
+ }
+ }
}