From 801b4162f2c8b48be2a523228809a00beabb66c2 Mon Sep 17 00:00:00 2001
From: Prateek Sunal <prtksunal@gmail.com>
Date: Mon, 20 Nov 2023 05:32:04 +0530
Subject: [PATCH] fix: file hash should not be unique

---
 mobile/lib/db/upload_locks_db.dart | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/mobile/lib/db/upload_locks_db.dart b/mobile/lib/db/upload_locks_db.dart
index 9995caefe4..257ca2691b 100644
--- a/mobile/lib/db/upload_locks_db.dart
+++ b/mobile/lib/db/upload_locks_db.dart
@@ -103,7 +103,7 @@ class UploadLocksDB {
                 CREATE TABLE ${_trackUploadTable.table} (
                   ${_trackUploadTable.columnID} INTEGER PRIMARY KEY,
                   ${_trackUploadTable.columnLocalID} TEXT NOT NULL,
-                  ${_trackUploadTable.columnFileHash} TEXT NOT NULL UNIQUE,
+                  ${_trackUploadTable.columnFileHash} TEXT NOT NULL,
                   ${_trackUploadTable.columnEncryptedFilePath} TEXT NOT NULL,
                   ${_trackUploadTable.columnEncryptedFileSize} INTEGER NOT NULL,
                   ${_trackUploadTable.columnFileKey} TEXT NOT NULL,
@@ -117,10 +117,11 @@ class UploadLocksDB {
     await db.execute(
       '''
                 CREATE TABLE ${_partsTable.table} (
-                  ${_partsTable.columnObjectKey} TEXT PRIMARY KEY NOT NULL REFERENCES ${_trackUploadTable.table}(${_trackUploadTable.columnObjectKey}) ON DELETE CASCADE,
+                  ${_partsTable.columnObjectKey} TEXT NOT NULL REFERENCES ${_trackUploadTable.table}(${_trackUploadTable.columnObjectKey}) ON DELETE CASCADE,
                   ${_partsTable.columnPartNumber} INTEGER NOT NULL,
                   ${_partsTable.columnPartUrl} TEXT NOT NULL,
-                  ${_partsTable.columnPartStatus} TEXT NOT NULL
+                  ${_partsTable.columnPartStatus} TEXT NOT NULL,
+                  PRIMARY KEY (${_partsTable.columnObjectKey}, ${_partsTable.columnPartNumber})
                 )
                 ''',
     );
@@ -191,10 +192,12 @@ class UploadLocksDB {
     final db = await instance.database;
     final rows = await db.query(
       _trackUploadTable.table,
-      where:
-          '${_trackUploadTable.columnLocalID} = ? AND ${_trackUploadTable.columnFileHash} = ?',
+      where: '${_trackUploadTable.columnFileHash} = ?',
+      whereArgs: [hash],
     );
 
+    print(rows);
+
     return rows.isNotEmpty;
   }