Add options argument to search method

src/index.ts

@@ -1,5 +1,5 @@
 import { RxCollection, RxDatabase, RxDocument, RxPlugin } from 'rxdb';
-import { Index } from 'flexsearch';
+import { Index, SearchOptions, Limit } from 'flexsearch';
 
 export type RxExportIndexHandler = (key: string, value: string) => void | Promise<void>;
 
@@ -12,7 +12,11 @@ export type RxDatabaseSearch = RxDatabase & RxDatabaseIndexMethods;
 
 export type RxCollectionSearch<RxDocType = any> = RxCollection<RxDocType> & {
   $index: Index;
-  search(this: RxCollectionSearch, query: string): Promise<RxDocument[]>;
+  search(
+    this: RxCollectionSearch,
+    query: string,
+    options?: Limit | SearchOptions
+  ): Promise<RxDocument[]>;
 };
 
 function serialize(data: any, searchFields: string[]): string {
@@ -56,8 +60,12 @@ async function importIndexes(
   );
 }
 
-async function search(this: RxCollectionSearch, query: string): Promise<RxDocument[]> {
-  const ids = this.$index.search(query) as string[];
+async function search(
+  this: RxCollectionSearch,
+  query: string,
+  options?: Limit | SearchOptions
+): Promise<RxDocument[]> {
+  const ids = this.$index.search(query, options) as string[];
   const results = await this.findByIds(ids).exec();
   return Array.from(results.values());
 }

tests/search.spec.ts

@@ -70,6 +70,36 @@ describe('Replication', () => {
     expect(results.length).toBe(0);
   });
 
+  it('should perform search with options', async () => {
+    database = await initDatabase();
+
+    await database.addCollections({
+      users: {
+        schema: userSchema,
+        options: {
+          searchable: true,
+        },
+      },
+    });
+
+    const collection = database.users as RxCollectionSearch;
+
+    await collection.insert({
+      id: '1',
+      name: 'Bill Gates',
+      age: 67,
+    });
+
+    await collection.insert({
+      id: '2',
+      name: 'Bill James',
+      age: 53,
+    });
+
+    const results = await collection.search('bill', 1);
+    expect(results).toBe(1);
+  });
+
   it('should import/export indexes', async () => {
     let indexId: string;
     let indexData: string;