deps: upgrade meilisearch client package

Author: MohamedBassem

packages/plugins/package.json

@@ -25,7 +25,7 @@
     "@restatedev/restate-sdk-clients": "^1.10.3",
     "async-mutex": "^0.4.1",
     "liteque": "^0.8.0",
-    "meilisearch": "^0.45.0",
+    "meilisearch": "^0.58.0",
     "redis": "^5.11.0"
   },
   "devDependencies": {

packages/plugins/search-meilisearch/src/index.ts

@@ -1,6 +1,6 @@
 import type { Index } from "meilisearch";
 import { Mutex } from "async-mutex";
-import { MeiliSearch } from "meilisearch";
+import { Meilisearch } from "meilisearch";
 
 import type {
   BookmarkSearchDocument,
@@ -196,9 +196,9 @@ class BatchingDocumentQueue {
   }
 
   private async ensureTaskSuccess(taskUid: number): Promise<void> {
-    const task = await this.index.waitForTask(taskUid, {
-      intervalMs: 200,
-      timeOutMs: this.jobTimeoutSec * 1000 * 0.9,
+    const task = await this.index.tasks.waitForTask(taskUid, {
+      interval: 200,
+      timeout: this.jobTimeoutSec * 1000 * 0.9,
     });
     if (task.error) {
       throw new Error(`Search task failed: ${task.error.message}`);
@@ -286,9 +286,9 @@ class MeiliSearchIndexClient implements SearchIndexClient {
   }
 
   private async ensureTaskSuccess(taskUid: number): Promise<void> {
-    const task = await this.index.waitForTask(taskUid, {
-      intervalMs: 200,
-      timeOutMs: this.jobTimeoutSec * 1000 * 0.9,
+    const task = await this.index.tasks.waitForTask(taskUid, {
+      interval: 200,
+      timeout: this.jobTimeoutSec * 1000 * 0.9,
     });
     if (task.error) {
       throw new Error(`Search task failed: ${task.error.message}`);
@@ -297,14 +297,14 @@ class MeiliSearchIndexClient implements SearchIndexClient {
 }
 
 export class MeiliSearchProvider implements PluginProvider<SearchIndexClient> {
-  private client: MeiliSearch | undefined;
+  private client: Meilisearch | undefined;
   private indexClient: SearchIndexClient | undefined;
   private initPromise: Promise<SearchIndexClient | null> | undefined;
   private readonly indexName = "bookmarks";
 
   constructor() {
     if (MeiliSearchProvider.isConfigured()) {
-      this.client = new MeiliSearch({
+      this.client = new Meilisearch({
         host: envConfig.MEILI_ADDR!,
         apiKey: envConfig.MEILI_MASTER_KEY,
       });
@@ -339,10 +339,11 @@ export class MeiliSearchProvider implements PluginProvider<SearchIndexClient> {
     let indexFound = indices.results.find((i) => i.uid === this.indexName);
 
     if (!indexFound) {
-      const idx = await this.client.createIndex(this.indexName, {
-        primaryKey: "id",
-      });
-      await this.client.waitForTask(idx.taskUid);
+      await this.client
+        .createIndex(this.indexName, {
+          primaryKey: "id",
+        })
+        .waitTask();
       indexFound = await this.client.getIndex<BookmarkSearchDocument>(
         this.indexName,
       );
@@ -373,10 +374,9 @@ export class MeiliSearchProvider implements PluginProvider<SearchIndexClient> {
       console.log(
         `[meilisearch] Updating desired filterable attributes to ${desiredFilterableAttributes} from ${settings.filterableAttributes}`,
       );
-      const taskId = await index.updateFilterableAttributes(
-        desiredFilterableAttributes,
-      );
-      await this.client!.waitForTask(taskId.taskUid);
+      await index
+        .updateFilterableAttributes(desiredFilterableAttributes)
+        .waitTask();
     }
 
     if (
@@ -386,10 +386,9 @@ export class MeiliSearchProvider implements PluginProvider<SearchIndexClient> {
       console.log(
         `[meilisearch] Updating desired sortable attributes to ${desiredSortableAttributes} from ${settings.sortableAttributes}`,
       );
-      const taskId = await index.updateSortableAttributes(
-        desiredSortableAttributes,
-      );
-      await this.client!.waitForTask(taskId.taskUid);
+      await index
+        .updateSortableAttributes(desiredSortableAttributes)
+        .waitTask();
     }
   }
 }

pnpm-lock.yaml

@@ -5,7 +5,7 @@
   "exclude": ["node_modules", "build", "dist", ".next", ".expo"],
   "compilerOptions": {
     "module": "ESNext",
-    "moduleResolution": "node",
+    "moduleResolution": "bundler",
     "incremental": true,
     "isolatedModules": true,
     "strict": true,