From e05e8a2e35b6f5b8cb5126971178a37068e63bb5 Mon Sep 17 00:00:00 2001
From: Bryan Ashby <bryan@l33t.codes>
Date: Sun, 29 Nov 2020 16:24:51 -0700
Subject: [PATCH] Initial

---
 core/database.js           | 11 ++++++++---
 core/file_entry.js         |  9 +++++++++
 core/oputil/oputil_user.js |  1 +
 3 files changed, 18 insertions(+), 3 deletions(-)

diff --git a/core/database.js b/core/database.js
index 17bc3844..55ed4e2e 100644
--- a/core/database.js
+++ b/core/database.js
@@ -421,7 +421,8 @@ const DB_INIT_TABLE = {
                 hash_tag_id     INTEGER NOT NULL,
                 file_id         INTEGER NOT NULL,
 
-                UNIQUE(hash_tag_id, file_id)
+                UNIQUE(hash_tag_id, file_id),
+                FOREIGN KEY(file_id) REFERENCES file(file_id) ON DELETE CASCADE
             );`
         );
 
@@ -431,7 +432,10 @@ const DB_INIT_TABLE = {
                 user_id         INTEGER NOT NULL,
                 rating          INTEGER NOT NULL,
 
-                UNIQUE(file_id, user_id)
+                UNIQUE(file_id, user_id),
+                FOREIGN KEY(file_id) REFERENCES file(file_id) ON DELETE CASCADE
+                -- Note that we cannot CASCADE if user_id is removed from user.db
+                -- See processing in oputil's removeUser()
             );`
         );
 
@@ -447,7 +451,8 @@ const DB_INIT_TABLE = {
                 hash_id     VARCHAR NOT NULL,
                 file_id     INTEGER NOT NULL,
 
-                UNIQUE(hash_id, file_id)
+                UNIQUE(hash_id, file_id),
+                FOREIGN KEY(file_id) REFERENCES file(file_id) ON DELETE CASCADE
             );`
         );
 
diff --git a/core/file_entry.js b/core/file_entry.js
index 90a9bac2..476864ca 100644
--- a/core/file_entry.js
+++ b/core/file_entry.js
@@ -243,6 +243,15 @@ module.exports = class FileEntry {
         );
     }
 
+    static removeUserRatings(userId, cb) {
+        return fileDb.run(
+            `DELETE FROM file_user_rating
+            WHERE user_id = ?;`,
+            [ userId ],
+            cb
+        );
+    }
+
     static persistMetaValue(fileId, name, value, transOrDb, cb) {
         if(!_.isFunction(cb) && _.isFunction(transOrDb)) {
             cb = transOrDb;
diff --git a/core/oputil/oputil_user.js b/core/oputil/oputil_user.js
index 7c71523f..d3a13931 100644
--- a/core/oputil/oputil_user.js
+++ b/core/oputil/oputil_user.js
@@ -172,6 +172,7 @@ function removeUser(user) {
                     message : [ 'user_message_area_last_read' ],
                     system  : [ 'user_event_log', ],
                     user    : [ 'user_group_member', 'user' ],
+                    file    : [ 'file_user_rating']
                 };
 
                 async.eachSeries(Object.keys(DeleteFrom), (dbName, nextDbName) => {