3 files changed, 188 insertions, 0 deletions
diff --git a/apps/files/src/services/Search.spec.ts b/apps/files/src/services/Search.spec.ts
new file mode 100644
index 00000000000..c2840521a15
--- /dev/null
+++ b/apps/files/src/services/Search.spec.ts
@@ -0,0 +1,61 @@
+/*!
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+import { createPinia, setActivePinia } from 'pinia'
+import { beforeAll, beforeEach, describe, expect, it, vi } from 'vitest'
+import { getContents } from './Search.ts'
+import { Folder, Permission } from '@nextcloud/files'
+
+const searchNodes = vi.hoisted(() => vi.fn())
+vi.mock('./WebDavSearch.ts', () => ({ searchNodes }))
+vi.mock('@nextcloud/auth')
+
+describe('Search service', () => {
+	const fakeFolder = new Folder({ owner: 'owner', source: 'https://cloud.example.com/remote.php/dav/files/owner/folder', root: '/files/owner' })
+
+	beforeAll(() => {
+		window.OCP ??= {}
+		window.OCP.Files ??= {}
+		window.OCP.Files.Router ??= { params: {}, query: {} }
+		vi.spyOn(window.OCP.Files.Router, 'params', 'get').mockReturnValue({ view: 'files' })
+	})
+
+	beforeEach(() => {
+		vi.restoreAllMocks()
+		setActivePinia(createPinia())
+	})
+
+	it('rejects on error', async () => {
+		searchNodes.mockImplementationOnce(() => { throw new Error('expected error') })
+		expect(getContents).rejects.toThrow('expected error')
+	})
+
+	it('returns the search results and a fake root', async () => {
+		searchNodes.mockImplementationOnce(() => [fakeFolder])
+		const { contents, folder } = await getContents()
+
+		expect(searchNodes).toHaveBeenCalledOnce()
+		expect(contents).toHaveLength(1)
+		expect(contents).toEqual([fakeFolder])
+		// read only root
+		expect(folder.permissions).toBe(Permission.READ)
+	})
+
+	it('can be cancelled', async () => {
+		const { promise, resolve } = Promise.withResolvers<Event>()
+		searchNodes.mockImplementationOnce(async (_, { signal }: { signal: AbortSignal}) => {
+			signal.addEventListener('abort', resolve)
+			await promise
+			return []
+		})
+
+		const content = getContents()
+		content.cancel()
+
+		// its cancelled thus the promise returns the event
+		const event = await promise
+		expect(event.type).toBe('abort')
+	})
+})
diff --git a/apps/files/src/services/Search.ts b/apps/files/src/services/Search.ts
new file mode 100644
index 00000000000..ae6f1ee50e0
--- /dev/null
+++ b/apps/files/src/services/Search.ts
@@ -0,0 +1,44 @@
+/*!
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+import type { ContentsWithRoot } from '@nextcloud/files'
+
+import { getCurrentUser } from '@nextcloud/auth'
+import { Folder, Permission } from '@nextcloud/files'
+import { defaultRemoteURL } from '@nextcloud/files/dav'
+import { CancelablePromise } from 'cancelable-promise'
+import { searchNodes } from './WebDavSearch.ts'
+import logger from '../logger.ts'
+import { useSearchStore } from '../store/search.ts'
+import { getPinia } from '../store/index.ts'
+
+/**
+ * Get the contents for a search view
+ */
+export function getContents(): CancelablePromise<ContentsWithRoot> {
+	const controller = new AbortController()
+
+	const searchStore = useSearchStore(getPinia())
+	const dir = searchStore.base?.path
+
+	return new CancelablePromise<ContentsWithRoot>(async (resolve, reject, cancel) => {
+		cancel(() => controller.abort())
+		try {
+			const contents = await searchNodes(searchStore.query, { dir, signal: controller.signal })
+			resolve({
+				contents,
+				folder: new Folder({
+					id: 0,
+					source: `${defaultRemoteURL}#search`,
+					owner: getCurrentUser()!.uid,
+					permissions: Permission.READ,
+				}),
+			})
+		} catch (error) {
+			logger.error('Failed to fetch search results', { error })
+			reject(error)
+		}
+	})
+}
diff --git a/apps/files/src/services/WebDavSearch.ts b/apps/files/src/services/WebDavSearch.ts
new file mode 100644
index 00000000000..feb7f30b357
--- /dev/null
+++ b/apps/files/src/services/WebDavSearch.ts
@@ -0,0 +1,83 @@
+/*!
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+import type { INode } from '@nextcloud/files'
+import type { ResponseDataDetailed, SearchResult } from 'webdav'
+
+import { getCurrentUser } from '@nextcloud/auth'
+import { defaultRootPath, getDavNameSpaces, getDavProperties, resultToNode } from '@nextcloud/files/dav'
+import { getBaseUrl } from '@nextcloud/router'
+import { client } from './WebdavClient.ts'
+import logger from '../logger.ts'
+
+export interface SearchNodesOptions {
+	dir?: string,
+	signal?: AbortSignal
+}
+
+/**
+ * Search for nodes matching the given query.
+ *
+ * @param query - Search query
+ * @param options - Options
+ * @param options.dir - The base directory to scope the search to
+ * @param options.signal - Abort signal for the request
+ */
+export async function searchNodes(query: string, { dir, signal }: SearchNodesOptions): Promise<INode[]> {
+	const user = getCurrentUser()
+	if (!user) {
+		// the search plugin only works for user roots
+		return []
+	}
+
+	query = query.trim()
+	if (query.length < 3) {
+		// the search plugin only works with queries of at least 3 characters
+		return []
+	}
+
+	if (dir && !dir.startsWith('/')) {
+		dir = `/${dir}`
+	}
+
+	logger.debug('Searching for nodes', { query, dir })
+	const { data } = await client.search('/', {
+		details: true,
+		signal,
+		data: `
+<d:searchrequest ${getDavNameSpaces()}>
+	 <d:basicsearch>
+		 <d:select>
+			 <d:prop>
+			 ${getDavProperties()}
+			 </d:prop>
+		 </d:select>
+		 <d:from>
+			 <d:scope>
+				 <d:href>/files/${user.uid}${dir || ''}</d:href>
+				 <d:depth>infinity</d:depth>
+			 </d:scope>
+		 </d:from>
+		 <d:where>
+			 <d:like>
+				 <d:prop>
+					 <d:displayname/>
+				 </d:prop>
+				 <d:literal>%${query.replace('%', '')}%</d:literal>
+			 </d:like>
+		 </d:where>
+		 <d:orderby/>
+	</d:basicsearch>
+</d:searchrequest>`,
+	}) as ResponseDataDetailed<SearchResult>
+
+	// check if the request was aborted
+	if (signal?.aborted) {
+		return []
+	}
+
+	// otherwise return the result mapped to Nextcloud nodes
+	return data.results.map((result) => resultToNode(result, defaultRootPath, getBaseUrl()))
+}