Merge branch 'main' into feature/o-2941

Author: hiimjako

README.md

@@ -25,3 +25,5 @@ On browsers:
 ## License
 
 [AGPLv3](/LICENSE.md)
+
+<img referrerpolicy="no-referrer-when-downgrade" src="https://static.scarf.sh/a.png?x-pxid=83013fff-5997-4abd-9a5c-8163b59fa6e2" />

deno.json

@@ -1,14 +1,14 @@
 {
   "name": "@orama/core",
-  "version": "1.2.1",
+  "version": "1.2.16",
   "exports": "./src/index.ts",
   "nodeModulesDir": "auto",
   "tasks": {
     "build": "deno run -A ./dnt.ts",
     "test": "deno test tests --allow-env --allow-read --allow-net"
   },
   "fmt": {
-    "lineWidth": 120,
+    "lineWidth": 140,
     "semiColons": false,
     "singleQuote": true,
     "include": [
@@ -21,5 +21,17 @@
       "deno.window",
       "dom"
     ]
+  },
+  "lint": {
+    "include": [
+      "src/"
+    ],
+    "rules": {
+      "exclude": [
+        "no-import-prefix",
+        "no-explicit-any",
+        "no-process-global"
+      ]
+    }
   }
 }

dnt.ts

@@ -32,6 +32,9 @@ await build({
     bugs: {
       url: 'https://github.com/oramasearch/oramacore/repo/issues',
     },
+    devDependencies: {
+      "@scarf/scarf": "1.4.0"
+    }
   },
   testPattern: '**/*.test.{ts,js}',
   rootTestDir: './tests',

src/cloud.ts

@@ -49,16 +49,24 @@ export class OramaCloud {
     return this.client.search({ ...rest, indexes: datasources })
   }
 
-  dataSource(id: string) {
+  dataSource(id: string): DataSourceNamespace {
     const index = this.client.index.set(id)
-    return new DataSourceNamespace(index)
+    return new DataSourceNamespace(
+      index,
+      this.client,
+      undefined,
+    )
   }
 }
 
 class DataSourceNamespace {
   private index: Index
 
-  constructor(index: Index) {
+  constructor(
+    index: Index,
+    private client: CollectionManager,
+    private originalRuntimeIndexId?: string,
+  ) {
     this.index = index
   }
 
@@ -77,4 +85,37 @@ class DataSourceNamespace {
   upsertDocuments(documents: AnyObject[]): Promise<void> {
     return this.index.upsertDocuments(documents)
   }
+
+  async createTemporaryIndex(): Promise<DataSourceNamespace> {
+    if (this.originalRuntimeIndexId) {
+      throw new Error('Cannot create a temporary index from a temporary index')
+    }
+
+    const runtimeIndexID = this.index.getIndexID()
+
+    const temp_index_id = await this.index.createTemporaryIndex()
+
+    const index = this.client.index.set(temp_index_id)
+    return new DataSourceNamespace(
+      index,
+      this.client,
+      runtimeIndexID,
+    )
+  }
+
+  async swap(): Promise<void> {
+    if (!this.originalRuntimeIndexId) {
+      throw new Error('Cannot swap a non-temporary index')
+    }
+    const tempIndexId = this.index.getIndexID()
+
+    if (tempIndexId === this.originalRuntimeIndexId) {
+      throw new Error('Cannot swap the same index')
+    }
+
+    await this.index.swapTemporaryIndex(
+      this.originalRuntimeIndexId,
+      tempIndexId,
+    )
+  }
 }