From 37b9ff3b1946d309f92d4a241ee25dfb6c73b992 Mon Sep 17 00:00:00 2001
From: Eric Peterson <ericpeterson@spotify.com>
Date: Sat, 26 Feb 2022 21:28:11 +0100
Subject: [PATCH] Update AuthorizedSearchEngine for stream-based indexing.

Signed-off-by: Eric Peterson <ericpeterson@spotify.com>
---
 .../src/service/AuthorizedSearchEngine.test.ts              | 2 +-
 .../search-backend/src/service/AuthorizedSearchEngine.ts    | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/plugins/search-backend/src/service/AuthorizedSearchEngine.test.ts b/plugins/search-backend/src/service/AuthorizedSearchEngine.test.ts
index 0a7b45e164..137ffc24f1 100644
--- a/plugins/search-backend/src/service/AuthorizedSearchEngine.test.ts
+++ b/plugins/search-backend/src/service/AuthorizedSearchEngine.test.ts
@@ -62,7 +62,7 @@ describe('AuthorizedSearchEngine', () => {
     setTranslator: () => {
       throw new Error('Function not implemented. 1');
     },
-    index: () => {
+    getIndexer: () => {
       throw new Error('Function not implemented.2');
     },
     query: mockedQuery,
diff --git a/plugins/search-backend/src/service/AuthorizedSearchEngine.ts b/plugins/search-backend/src/service/AuthorizedSearchEngine.ts
index d0488af00d..82ed061196 100644
--- a/plugins/search-backend/src/service/AuthorizedSearchEngine.ts
+++ b/plugins/search-backend/src/service/AuthorizedSearchEngine.ts
@@ -25,7 +25,6 @@ import {
 } from '@backstage/plugin-permission-common';
 import {
   DocumentTypeInfo,
-  IndexableDocument,
   QueryRequestOptions,
   QueryTranslator,
   SearchEngine,
@@ -35,6 +34,7 @@ import {
 } from '@backstage/search-common';
 import { Config } from '@backstage/config';
 import { InputError } from '@backstage/errors';
+import { Writable } from 'stream';
 
 export function decodePageCursor(pageCursor?: string): { page: number } {
   if (!pageCursor) {
@@ -78,8 +78,8 @@ export class AuthorizedSearchEngine implements SearchEngine {
     this.searchEngine.setTranslator(translator);
   }
 
-  async index(type: string, documents: IndexableDocument[]): Promise<void> {
-    this.searchEngine.index(type, documents);
+  async getIndexer(type: string): Promise<Writable> {
+    return this.searchEngine.getIndexer(type);
   }
 
   async query(