From 9974f3fd48e4edd56ab162771cf8301472d32cde Mon Sep 17 00:00:00 2001
From: Michael Telatynski <7t3chguy@gmail.com>
Date: Mon, 14 Nov 2022 15:23:50 +0000
Subject: [PATCH] Add way to abort search requests

---
 src/@types/search.ts | 1 +
 src/client.ts        | 6 ++++--
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/@types/search.ts b/src/@types/search.ts
index 0aa8a34a407..3a6d4fdd57f 100644
--- a/src/@types/search.ts
+++ b/src/@types/search.ts
@@ -114,5 +114,6 @@ export interface ISearchResults {
     count?: number;
     next_batch?: string;
     pendingRequest?: Promise<ISearchResults>;
+    abortSignal?: AbortSignal;
 }
 /* eslint-enable camelcase */
diff --git a/src/client.ts b/src/client.ts
index 40ee4e68e2f..69dd0591cb6 100644
--- a/src/client.ts
+++ b/src/client.ts
@@ -6389,7 +6389,7 @@ export class MatrixClient extends TypedEventEmitter<EmittedEvents, ClientEventHa
             next_batch: searchResults.next_batch,
         };
 
-        const promise = this.search(searchOpts)
+        const promise = this.search(searchOpts, searchResults.abortSignal)
             .then(res => this.processRoomEventsSearch(searchResults, res))
             .finally(() => {
                 searchResults.pendingRequest = undefined;
@@ -8439,17 +8439,19 @@ export class MatrixClient extends TypedEventEmitter<EmittedEvents, ClientEventHa
      * @param {Object} opts
      * @param {string} opts.next_batch the batch token to pass in the query string
      * @param {Object} opts.body the JSON object to pass to the request body.
+     * @param {AbortSignal=} abortSignal optional signal used to cancel the http request.
      * @return {Promise} Resolves: TODO
      * @return {module:http-api.MatrixError} Rejects: with an error response.
      */
     public search(
         opts: { body: ISearchRequestBody, next_batch?: string }, // eslint-disable-line camelcase
+        abortSignal?: AbortSignal,
     ): Promise<ISearchResponse> {
         const queryParams: any = {};
         if (opts.next_batch) {
             queryParams.next_batch = opts.next_batch;
         }
-        return this.http.authedRequest(Method.Post, "/search", queryParams, opts.body);
+        return this.http.authedRequest(Method.Post, "/search", queryParams, opts.body, { abortSignal });
     }
 
     /**