bump!: bump elastic to version 9

Author: Twiddlle

package.json

@@ -31,7 +31,7 @@
   },
   "homepage": "https://github.com/Twiddlle/elasticsearch-orm#readme",
   "devDependencies": {
-    "@elastic/elasticsearch": "^8.7.0",
+    "@elastic/elasticsearch": "^9.0.0",
     "@types/dotenv": "^8.2.0",
     "@types/jest": "^27.4.1",
     "@types/lorem-ipsum": "^2.0.0",
@@ -54,14 +54,16 @@
     "reflect-metadata": "^0.2.2"
   },
   "peerDependencies": {
-    "@elastic/elasticsearch": "^7.0.0 || ^8.0.0"
+    "@elastic/elasticsearch": "^8.0.0 || ^9.0.0"
   },
   "jest": {
     "moduleFileExtensions": [
       "js",
       "ts"
     ],
-    "setupFiles": ["<rootDir>/test/setup.ts"],
+    "setupFiles": [
+      "<rootDir>/test/setup.ts"
+    ],
     "rootDir": ".",
     "testEnvironment": "node",
     "testRegex": "\\.(integration|spec|performance)\\.ts$",

src/repository/EsRepository.ts

@@ -256,7 +256,7 @@ export class EsRepository<Entity> implements EsRepositoryInterface<Entity> {
           index: this.getIndex(entity),
           id: dbEntity.id,
           refresh: this.getRefreshOption(entity),
-          body: { doc: dbEntity.data },
+          doc: dbEntity.data,
         },
         params,
       );
@@ -324,7 +324,7 @@ export class EsRepository<Entity> implements EsRepositoryInterface<Entity> {
       const esParams = Object.assign(
         {
           index: this.metaLoader.getIndex(this.Entity),
-          body: indexInterface,
+          ...indexInterface,
         },
         params,
       );
@@ -363,7 +363,7 @@ export class EsRepository<Entity> implements EsRepositoryInterface<Entity> {
       const esParams = Object.assign(
         {
           index: this.metaLoader.getIndex(this.Entity),
-          body: mapping,
+          ...mapping,
         },
         params,
       );

test/setup.ts

@@ -1,3 +1,42 @@
 import { ReadableStream } from 'web-streams-polyfill';
-// eslint-disable-next-line no-undef
-global.ReadableStream = ReadableStream;
+import { Blob } from 'buffer';
+import { MessageChannel, MessagePort } from 'worker_threads';
+
+// File class polyfill for Node.js environments
+class File extends Blob {
+    name: string;
+    lastModified: number;
+
+    constructor(
+        chunks: Array<ArrayBuffer | ArrayBufferView | Blob | string>,
+        name: string,
+        options?: { type?: string; lastModified?: number },
+    ) {
+        super(chunks as unknown as Array<ArrayBuffer | Blob>, options);
+        this.name = name;
+        this.lastModified = options?.lastModified ?? Date.now();
+    }
+}
+
+// DOMException polyfill
+class DOMException extends Error {
+    code: number;
+    constructor(message?: string, name?: string) {
+        super(message);
+        this.name = name || 'Error';
+        this.code = 0;
+    }
+}
+
+// eslint-disable-next-line no-undef, @typescript-eslint/no-explicit-any
+(global as any).ReadableStream = ReadableStream;
+// eslint-disable-next-line no-undef, @typescript-eslint/no-explicit-any
+(global as any).Blob = Blob;
+// eslint-disable-next-line no-undef, @typescript-eslint/no-explicit-any
+(global as any).File = File;
+// eslint-disable-next-line no-undef, @typescript-eslint/no-explicit-any
+(global as any).MessagePort = MessagePort;
+// eslint-disable-next-line no-undef, @typescript-eslint/no-explicit-any
+(global as any).MessageChannel = MessageChannel;
+// eslint-disable-next-line no-undef, @typescript-eslint/no-explicit-any
+(global as any).DOMException = DOMException;