. // }}} namespace Component\Feed; use App\Core\DB\DB; use App\Core\Event; use App\Core\Modules\Component; use App\Entity\Actor; use App\Entity\Subscription; use App\Util\Formatting; use Component\Search\Util\Parser; use Doctrine\Common\Collections\ExpressionBuilder; use Doctrine\ORM\Query\Expr; use Doctrine\ORM\QueryBuilder; class Feed extends Component { /** * Perform a high level query on notes or actors * * Supports a variety of query terms and is used both in feeds and * in search. Uses query builders to allow for extension */ public static function query(string $query, int $page, ?string $language = null, ?Actor $actor = null): array { $note_criteria = null; $actor_criteria = null; if (!empty($query = trim($query))) { [$note_criteria, $actor_criteria] = Parser::parse($query, $language, $actor); } $note_qb = DB::createQueryBuilder(); $actor_qb = DB::createQueryBuilder(); $note_qb->select('note')->from('App\Entity\Note', 'note')->orderBy('note.created', 'DESC')->orderBy('note.id', 'DESC'); $actor_qb->select('actor')->from('App\Entity\Actor', 'actor')->orderBy('actor.created', 'DESC')->orderBy('actor.id', 'DESC'); Event::handle('SearchQueryAddJoins', [&$note_qb, &$actor_qb, $note_criteria, $actor_criteria]); $notes = []; $actors = []; if (!\is_null($note_criteria)) { $note_qb->addCriteria($note_criteria); } $notes = $note_qb->getQuery()->execute(); if (!\is_null($actor_criteria)) { $actor_qb->addCriteria($actor_criteria); } $actors = $actor_qb->getQuery()->execute(); // TODO: Enforce scoping on the notes before returning return ['notes' => $notes ?? null, 'actors' => $actors ?? null]; } public function onSearchQueryAddJoins(QueryBuilder &$note_qb, QueryBuilder &$actor_qb) { $note_qb->leftJoin(Subscription::class, 'subscription', Expr\Join::WITH, 'note.actor_id = subscription.subscribed'); return Event::next; } /** * Convert $term to $note_expr and $actor_expr, search criteria. Handles searching for text * notes, for different types of actors and for the content of text notes */ public function onSearchCreateExpression(ExpressionBuilder $eb, string $term, ?string $language, ?Actor $actor, &$note_expr, &$actor_expr) { if (str_contains($term, ':')) { $term = explode(':', $term); if (Formatting::startsWith($term[0], 'note-')) { switch ($term[0]) { case 'note-local': $note_expr = $eb->eq('note.is_local', filter_var($term[1], \FILTER_VALIDATE_BOOLEAN)); break; case 'note-types': case 'notes-include': case 'note-filter': if (\is_null($note_expr)) { $note_expr = []; } if (array_intersect(explode(',', $term[1]), ['text', 'words']) !== []) { $note_expr[] = $eb->neq('note.content', null); } else { $note_expr[] = $eb->eq('note.content', null); } break; case 'note-conversation': $note_expr = $eb->eq('note.conversation_id', (int) trim($term[1])); break; case 'note-from': if ($term[1] === 'subscribed') { $note_expr = $eb->eq('subscription.subscriber', $actor->getId()); } break; } } elseif (Formatting::startsWith($term, 'actor-')) { switch ($term[0]) { case 'actor-types': case 'actors-include': case 'actor-filter': case 'actor-local': if (\is_null($actor_expr)) { $actor_expr = []; } foreach ( [ Actor::PERSON => ['person', 'people'], Actor::GROUP => ['group', 'groups'], Actor::ORGANIZATION => ['org', 'orgs', 'organization', 'organizations', 'organisation', 'organisations'], Actor::BUSINESS => ['business', 'businesses'], Actor::BOT => ['bot', 'bots'], ] as $type => $match) { if (array_intersect(explode(',', $term[1]), $match) !== []) { $actor_expr[] = $eb->eq('actor.type', $type); } else { $actor_expr[] = $eb->neq('actor.type', $type); } } break; } } } else { $note_expr = $eb->contains('note.content', $term); } return Event::next; } }