Skip to content

Commit

Permalink
Implement unified search for Files
Browse files Browse the repository at this point in the history
Signed-off-by: Christoph Wurst <[email protected]>
  • Loading branch information
ChristophWurst committed Jun 22, 2020
1 parent 9f161c9 commit 4c3e89e
Show file tree
Hide file tree
Showing 6 changed files with 93 additions and 2 deletions.
2 changes: 2 additions & 0 deletions apps/files/composer/composer/autoload_classmap.php
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,8 @@
'OCA\\Files\\Listener\\LoadSidebarListener' => $baseDir . '/../lib/Listener/LoadSidebarListener.php',
'OCA\\Files\\Migration\\Version11301Date20191205150729' => $baseDir . '/../lib/Migration/Version11301Date20191205150729.php',
'OCA\\Files\\Notification\\Notifier' => $baseDir . '/../lib/Notification/Notifier.php',
'OCA\\Files\\Search\\FilesSearchProvider' => $baseDir . '/../lib/Search/FilesSearchProvider.php',
'OCA\\Files\\Search\\FilesSearchResultEntry' => $baseDir . '/../lib/Search/FilesSearchResultEntry.php',
'OCA\\Files\\Service\\DirectEditingService' => $baseDir . '/../lib/Service/DirectEditingService.php',
'OCA\\Files\\Service\\OwnershipTransferService' => $baseDir . '/../lib/Service/OwnershipTransferService.php',
'OCA\\Files\\Service\\TagService' => $baseDir . '/../lib/Service/TagService.php',
Expand Down
2 changes: 2 additions & 0 deletions apps/files/composer/composer/autoload_static.php
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,8 @@ class ComposerStaticInitFiles
'OCA\\Files\\Listener\\LoadSidebarListener' => __DIR__ . '/..' . '/../lib/Listener/LoadSidebarListener.php',
'OCA\\Files\\Migration\\Version11301Date20191205150729' => __DIR__ . '/..' . '/../lib/Migration/Version11301Date20191205150729.php',
'OCA\\Files\\Notification\\Notifier' => __DIR__ . '/..' . '/../lib/Notification/Notifier.php',
'OCA\\Files\\Search\\FilesSearchProvider' => __DIR__ . '/..' . '/../lib/Search/FilesSearchProvider.php',
'OCA\\Files\\Search\\FilesSearchResultEntry' => __DIR__ . '/..' . '/../lib/Search/FilesSearchResultEntry.php',
'OCA\\Files\\Service\\DirectEditingService' => __DIR__ . '/..' . '/../lib/Service/DirectEditingService.php',
'OCA\\Files\\Service\\OwnershipTransferService' => __DIR__ . '/..' . '/../lib/Service/OwnershipTransferService.php',
'OCA\\Files\\Service\\TagService' => __DIR__ . '/..' . '/../lib/Service/TagService.php',
Expand Down
3 changes: 3 additions & 0 deletions apps/files/lib/AppInfo/Application.php
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,7 @@
use OCA\Files\Listener\LegacyLoadAdditionalScriptsAdapter;
use OCA\Files\Listener\LoadSidebarListener;
use OCA\Files\Notification\Notifier;
use OCA\Files\Search\FilesSearchProvider;
use OCA\Files\Service\TagService;
use OCP\AppFramework\App;
use OCP\AppFramework\Bootstrap\IBootContext;
Expand Down Expand Up @@ -103,6 +104,8 @@ public function register(IRegistrationContext $context): void {

$context->registerEventListener(LoadAdditionalScriptsEvent::class, LegacyLoadAdditionalScriptsAdapter::class);
$context->registerEventListener(LoadSidebar::class, LoadSidebarListener::class);

$context->registerSearchProvider(FilesSearchProvider::class);
}

public function boot(IBootContext $context): void {
Expand Down
37 changes: 37 additions & 0 deletions apps/files/lib/Search/FilesSearchResultEntry.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,37 @@
<?php

declare(strict_types=1);

/**
* @copyright 2020 Christoph Wurst <[email protected]>
*
* @author 2020 Christoph Wurst <[email protected]>
*
* @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 <http://www.gnu.org/licenses/>.
*/

namespace OCA\Files\Search;

use OCP\Search\ASearchResultEntry;

class FilesSearchResultEntry extends ASearchResultEntry {
public function __construct(string $thumbnailUrl,
string $filename,
string $path,
string $url) {
parent::__construct($thumbnailUrl, $filename, $path, $url);
}
}
49 changes: 48 additions & 1 deletion lib/private/Search/SearchComposer.php
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,8 @@

namespace OC\Search;

use InvalidArgumentException;
use OCP\AppFramework\Bootstrap\IRegistrationContext;
use OCP\AppFramework\QueryException;
use OCP\ILogger;
use OCP\IServerContainer;
Expand All @@ -37,6 +39,21 @@
/**
* Queries individual \OCP\Search\IProvider implementations and composes a
* unified search result for the user's search term
*
* The search process is generally split into two steps
*
* 1. Get a list of provider (`getProviders`)
* 2. Get search results of each provider (`search`)
*
* The reasoning behind this is that the runtime complexity of a combined search
* result would be O(n) and linearly grow with each provider added. This comes
* from the nature of php where we can't concurrently fetch the search results.
* So we offload the concurrency the client application (e.g. JavaScript in the
* browser) and let it first get the list of providers to then fetch all results
* concurrently. The client is free to decide whether all concurrent search
* results are awaited or shown as they come in.
*
* @see IProvider::search() for the arguments of the individual search requests
*/
class SearchComposer {

Expand All @@ -58,6 +75,17 @@ public function __construct(IServerContainer $container,
$this->logger = $logger;
}

/**
* Register a search provider lazily
*
* Registers the fully-qualified class name of an implementation of an
* IProvider. The service will only be queried on demand. Apps will register
* the providers through the registration context object.
*
* @see IRegistrationContext::registerSearchProvider()
*
* @param string $class
*/
public function registerProvider(string $class): void {
$this->lazyProviders[] = $class;
}
Expand Down Expand Up @@ -85,6 +113,11 @@ private function loadLazyProviders(): void {
$this->lazyProviders = [];
}

/**
* Get a list of all provider IDs for the consecutive calls to `search`
*
* @return string[]
*/
public function getProviders(): array {
$this->loadLazyProviders();

Expand All @@ -97,12 +130,26 @@ public function getProviders(): array {
}, $this->providers));
}

/**
* Query an individual search provider for results
*
* @param IUser $user
* @param string $providerId one of the IDs received by `getProviders`
* @param ISearchQuery $query
*
* @return SearchResult
* @throws InvalidArgumentException when the $providerId does not correspond to a registered provider
*/
public function search(IUser $user,
string $providerId,
ISearchQuery $query): SearchResult {
$this->loadLazyProviders();

return $this->providers[$providerId]->search($user, $query);
$provider = $this->providers[$providerId] ?? null;
if ($provider === null) {
throw new InvalidArgumentException("Provider $providerId is unknown");
}
return $provider->search($user, $query);
}

}
2 changes: 1 addition & 1 deletion lib/public/Search/IProvider.php
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@
use OCP\IUser;

/**
* Interface for an app search providers
* Interface for search providers
*
* These providers will be implemented in apps, so they can participate in the
* global search results of Nextcloud. If an app provides more than one type of
Expand Down

0 comments on commit 4c3e89e

Please sign in to comment.