Merge pull request #5 from divyenduz/fix_write_upsert

fix: write upsert
divyenduz · Oct 21, 2023 · bfe42f9 · bfe42f9
2 parents 7f9eb00 + 22ba73c
commit bfe42f9
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/packages/sqlite-backend/SQLiteBackend.ts b/packages/sqlite-backend/SQLiteBackend.ts
@@ -234,6 +234,22 @@ export class SQLiteBackend implements Backend {
       const rFile = await this.getFile(filepath);
       const file = rFile.file;
 
+      /**
+       *
+       * Simulate "upsert" by deleting anything within a block range for a file before bulk inserting!
+       * TODO: this should happen in a transaction
+       */
+
+      for await (const chunk of chunks) {
+        await this.prisma.content.deleteMany({
+          where: {
+            offset: chunk.offset,
+            size: chunk.size,
+            fileId: file?.id,
+          },
+        });
+      }
+
       await rawCreateMany<Omit<Content, "id">>(
         this.prisma,
         "Content",