feat: clean DB after user delete

functions/.eslintrc.cjs

@@ -11,6 +11,7 @@ module.exports = {
     "plugin:import/typescript",
     "google",
     "plugin:@typescript-eslint/recommended",
+    "prettier",
   ],
   parser: "@typescript-eslint/parser",
   parserOptions: {
@@ -25,10 +26,7 @@ module.exports = {
     "@typescript-eslint/ban-ts-comment": 0,
     "@typescript-eslint/no-explicit-any": 0,
     "@typescript-eslint/no-unused-vars": 0,
-    quotes: 0,
     "import/no-unresolved": 0,
-    indent: ["error", 2],
-    "object-curly-spacing": 0,
     "require-jsdoc": 0,
   },
 };

functions/.gitignore

@@ -7,3 +7,5 @@ typings/
 
 # Node.js dependency directory
 node_modules/
+
+/.parcel-cache/

functions/package.json

@@ -1,19 +1,4 @@
 {
-  "name": "functions",
-  "scripts": {
-    "lint": "eslint --ext .js,.ts .",
-    "build": "tsc",
-    "build:watch": "tsc --watch",
-    "serve": "npm run build && firebase emulators:start --only functions",
-    "shell": "npm run build && firebase functions:shell",
-    "start": "npm run shell",
-    "deploy": "firebase deploy --only functions",
-    "logs": "firebase functions:log"
-  },
-  "engines": {
-    "node": "18"
-  },
-  "main": "lib/index.js",
   "dependencies": {
     "firebase-admin": "^11.8.0",
     "firebase-functions": "^4.3.1"
@@ -23,9 +8,29 @@
     "@typescript-eslint/parser": "^5.12.0",
     "eslint": "^8.9.0",
     "eslint-config-google": "^0.14.0",
+    "eslint-config-prettier": "^8.10.0",
     "eslint-plugin-import": "^2.25.4",
     "firebase-functions-test": "^3.1.0",
+    "mocha": "^10.2.0",
+    "parcel": "^2.9.3",
     "typescript": "^4.9.0"
   },
-  "private": true
+  "engines": {
+    "node": "18"
+  },
+  "main": "lib/index.js",
+  "name": "functions",
+  "private": true,
+  "scripts": {
+    "build": "parcel build --no-content-hash",
+    "build:watch": "parcel watch",
+    "deploy": "firebase deploy --only functions",
+    "lint": "eslint --ext .js,.ts .",
+    "logs": "firebase functions:log",
+    "serve": "npm run build && firebase emulators:start --only functions",
+    "shell": "npm run build && firebase functions:shell",
+    "start": "npm run shell",
+    "test": "mocha --reporter spec"
+  },
+  "source": "src/index.ts"
 }

functions/src/index.ts

@@ -1,17 +1,25 @@
 /**
- * Import function triggers from their respective submodules:
- *
- * import {onCall} from "firebase-functions/v2/https";
- * import {onDocumentWritten} from "firebase-functions/v2/firestore";
  *
  * See a full list of supported triggers at https://firebase.google.com/docs/functions
  */
 
 import { initializeApp } from "firebase-admin/app";
-import { Query, getFirestore } from "firebase-admin/firestore";
+import {
+  type DocumentSnapshot,
+  FieldValue,
+  type Query,
+  getFirestore,
+} from "firebase-admin/firestore";
+import { auth } from "firebase-functions/v1";
 import { firestore } from "firebase-functions/v2";
 import * as logger from "firebase-functions/logger";
 
+import type {
+  place as Place,
+  personsIndex as PersonsIndex,
+} from "../../src/backend/FirestoreModels.gen";
+import { UserRole } from "../../src/backend/UserRoles";
+
 initializeApp();
 const db = getFirestore();
 
@@ -61,3 +69,51 @@ export const deletePlaceSubcollection = firestore.onDocumentDeleted(
     }
   }
 );
+
+export const truncateUserInDb = auth.user().onDelete(async (user) => {
+  logger.info(`Delete user`, user);
+  const placesQuery = db
+    .collection("places")
+    .where(`users.${user.uid}`, `>=`, 0);
+  const placesToRole: Array<[string, number]> = [];
+  placesQuery
+    .stream()
+    .on(`data`, async (placeSnapshot: DocumentSnapshot<Place>) => {
+      const placeData = placeSnapshot.data() as Place;
+      const userRole = placeData.users[user.uid];
+      placesToRole.push([placeSnapshot.ref.id, userRole]);
+      if (userRole === UserRole.owner) {
+        placeSnapshot.ref.delete();
+      } else {
+        const placePersonsIndexRef = db.doc(
+          `places/${placeSnapshot.id}/personsIndex/1`
+        );
+        const placePersonsIndexSnapshot = await placePersonsIndexRef.get();
+        const placePersonsIndex =
+          placePersonsIndexSnapshot.data() as PersonsIndex;
+        const personEntry = Object.entries(placePersonsIndex.all).find(
+          ([, personTuple]) => {
+            personTuple[3] === user.uid;
+          }
+        );
+        if (personEntry) {
+          const [personId, personTuple] = personEntry;
+          personTuple[3] = null;
+          placePersonsIndexRef.update({
+            [`all.${personId}`]: personTuple,
+          });
+        }
+        placeSnapshot.ref.update({
+          [`users.${user.uid}`]: FieldValue.delete(),
+        });
+      }
+    })
+    .on(`end`, () => {
+      logger.info(
+        `Delete user "${user.uid}" affected places:`,
+        placesToRole.length === 0
+          ? `none deleted`
+          : Object.fromEntries(placesToRole)
+      );
+    });
+});

functions/tsconfig.json

@@ -1,5 +1,6 @@
 {
   "compilerOptions": {
+    "jsx": "react",
     "module": "commonjs",
     "noImplicitReturns": true,
     "noUnusedLocals": true,
@@ -9,7 +10,5 @@
     "target": "es2017"
   },
   "compileOnSave": true,
-  "include": [
-    "src"
-  ]
+  "include": ["src"]
 }