* * @license GNU AGPL version 3 or any later version * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . * */ namespace OCA\Talk\Search; use OCA\Talk\AppInfo\Application; use OCA\Talk\Chat\ChatManager; use OCA\Talk\Chat\MessageParser; use OCA\Talk\Exceptions\ParticipantNotFoundException; use OCA\Talk\Exceptions\UnauthorizedException; use OCA\Talk\Manager as RoomManager; use OCA\Talk\Model\Attendee; use OCA\Talk\Room; use OCP\Comments\IComment; use OCP\IL10N; use OCP\IURLGenerator; use OCP\IUser; use OCP\Search\IProvider; use OCP\Search\ISearchQuery; use OCP\Search\SearchResult; use OCP\Search\SearchResultEntry; class MessageSearch implements IProvider { protected RoomManager $roomManager; protected ChatManager $chatManager; protected MessageParser $messageParser; protected IURLGenerator $url; protected IL10N $l; public function __construct( RoomManager $roomManager, ChatManager $chatManager, MessageParser $messageParser, IURLGenerator $url, IL10N $l ) { $this->roomManager = $roomManager; $this->chatManager = $chatManager; $this->messageParser = $messageParser; $this->url = $url; $this->l = $l; } /** * @inheritDoc */ public function getId(): string { return 'talk-message'; } /** * @inheritDoc */ public function getName(): string { return $this->l->t('Messages'); } /** * @inheritDoc */ public function getOrder(string $route, array $routeParameters): int { if (strpos($route, Application::APP_ID . '.') === 0) { // Active app, prefer Talk results return -2; } return 15; } protected function getCurrentConversationToken(ISearchQuery $query): string { if ($query->getRoute() === 'spreed.Page.showCall') { return $query->getRouteParameters()['token']; } return ''; } protected function getSublineTemplate(): string { return $this->l->t('{user} in {conversation}'); } /** * @inheritDoc */ public function search(IUser $user, ISearchQuery $query): SearchResult { $title = $this->l->t('Messages'); if ($this->getCurrentConversationToken($query) !== '') { $title = $this->l->t('Messages in other conversations'); } $rooms = $this->roomManager->getRoomsForUser($user->getUID()); $roomMap = []; foreach ($rooms as $room) { if ($room->getType() === Room::TYPE_CHANGELOG) { continue; } if ($this->getCurrentConversationToken($query) === $room->getToken()) { // No search result from current conversation continue; } $roomMap[(string) $room->getId()] = $room; } if (empty($roomMap)) { return SearchResult::complete( $this->l->t('Messages'), [] ); } $offset = (int) $query->getCursor(); $comments = $this->chatManager->searchForObjects( $query->getTerm(), array_keys($roomMap), 'comment', $offset, $query->getLimit() ); $result = []; foreach ($comments as $comment) { $room = $roomMap[$comment->getObjectId()]; try { $result[] = $this->commentToSearchResultEntry($room, $user, $comment, $query); } catch (UnauthorizedException $e) { } catch (ParticipantNotFoundException $e) { } } return SearchResult::paginated( $title, $result, $offset + $query->getLimit() ); } protected function commentToSearchResultEntry(Room $room, IUser $user, IComment $comment, ISearchQuery $query): SearchResultEntry { $participant = $room->getParticipant($user->getUID(), false); $id = (int) $comment->getId(); $message = $this->messageParser->createMessage($room, $participant, $comment, $this->l); $this->messageParser->parseMessage($message); $messageStr = $message->getMessage(); $search = $replace = []; foreach ($message->getMessageParameters() as $key => $parameter) { $search[] = '{' . $key . '}'; if ($parameter['type'] === 'user') { $replace[] = '@' . $parameter['name']; } else { $replace[] = $parameter['name']; } } $messageStr = str_replace($search, $replace, $messageStr); $matchPosition = mb_stripos($messageStr, $query->getTerm()); if ($matchPosition > 30 && mb_strlen($messageStr) > 40) { // Mostlikely the result is not visible from the beginning, // so we cut of the message a bit. $messageStr = '…' . mb_substr($messageStr, $matchPosition - 10); } if (!$message->getVisibility()) { $commentIdToIndex[$id] = null; throw new UnauthorizedException('Not visible'); } $iconUrl = ''; if ($message->getActorType() === Attendee::ACTOR_USERS) { $iconUrl = $this->url->linkToRouteAbsolute('core.avatar.getAvatar', [ 'userId' => $message->getActorId(), 'size' => 64, ]); } $subline = $this->getSublineTemplate(); if ($room->getType() === Room::TYPE_ONE_TO_ONE) { $subline = '{user}'; } $entry = new SearchResultEntry( $iconUrl, str_replace( ['{user}', '{conversation}'], [$message->getActorDisplayName(), $room->getDisplayName($user->getUID())], $subline ), $messageStr, $this->url->linkToRouteAbsolute('spreed.Page.showCall', ['token' => $room->getToken()]) . '#message_' . $comment->getId(), 'icon-talk', // $iconClass, true ); $entry->addAttribute('conversation', $room->getToken()); $entry->addAttribute('messageId', $comment->getId()); return $entry; } }