vermeide zu viele function triggers beim löschen von /spezifisch in neueSaison.ts

Author: LeonardNolting

functions/package-lock.json

@@ -15,7 +15,7 @@
 	"dependencies": {
 		"@google-cloud/tasks": "^2.3.6",
 		"firebase-admin": "^9.8.0",
-		"firebase-functions": "^3.14.1"
+		"firebase-functions": "^3.20.1"
 	},
 	"devDependencies": {
 		"firebase-functions-test": "^0.2.0",

functions/package.json

@@ -22,6 +22,27 @@ async function passeAnzahlFahrerAn(data: { schule: string, klasse: string, name:
 	await datenbank.ref().update(updates)
 }
 
-const passeAnzahlFahrerAnRef = functions.region(region).database.ref("/spezifisch/fahrer/{fahrer}")
-export const increment = passeAnzahlFahrerAnRef.onCreate((snap, context) => passeAnzahlFahrerAn(snap.val(), context.params.fahrer))
-export const decrement = passeAnzahlFahrerAnRef.onDelete((snap, context) => passeAnzahlFahrerAn(snap.val(), context.params.fahrer, true))
+export const onFahrerChange = functions.region(region).database.ref("/spezifisch/fahrer")
+	.onWrite(async (change) => {
+		if (!change.after.exists()) return null; // Bulk delete skip
+
+		const before = change.before.val() || {};
+		const after = change.after.val() || {};
+
+		const beforeKeys = Object.keys(before);
+		const afterKeys = Object.keys(after);
+
+		const addedKeys = afterKeys.filter(key => !before[key]);
+		const deletedKeys = beforeKeys.filter(key => !after[key]);
+
+		const promises = [];
+		for (const key of addedKeys) {
+			promises.push(passeAnzahlFahrerAn(after[key], key));
+		}
+		for (const key of deletedKeys) {
+			promises.push(passeAnzahlFahrerAn(before[key], key, true));
+		}
+
+		return Promise.all(promises);
+	});
+

functions/src/passeAnzahlFahrerAn.ts

@@ -32,6 +32,27 @@ async function passeStreckeUndAnzahlStreckenAn(data: { strecke: number, fahrer:
 	await datenbank.ref().update(updates)
 }
 
-const passeStreckeUndAnzahlStreckenAnRef = functions.region(region).database.ref("/spezifisch/strecken/{strecke}")
-export const increment = passeStreckeUndAnzahlStreckenAnRef.onCreate(snap => passeStreckeUndAnzahlStreckenAn(snap.val()))
-export const decrement = passeStreckeUndAnzahlStreckenAnRef.onDelete(snap => passeStreckeUndAnzahlStreckenAn(snap.val(), true))
+export const onStreckenChange = functions.region(region).database.ref("/spezifisch/strecken")
+	.onWrite(async (change) => {
+		if (!change.after.exists()) return null; // Bulk delete skip
+
+		const before = change.before.val() || {};
+		const after = change.after.val() || {};
+
+		const beforeKeys = Object.keys(before);
+		const afterKeys = Object.keys(after);
+
+		const addedKeys = afterKeys.filter(key => !before[key]);
+		const deletedKeys = beforeKeys.filter(key => !after[key]);
+
+		const promises = [];
+		for (const key of addedKeys) {
+			promises.push(passeStreckeUndAnzahlStreckenAn(after[key]));
+		}
+		for (const key of deletedKeys) {
+			promises.push(passeStreckeUndAnzahlStreckenAn(before[key], true));
+		}
+
+		return Promise.all(promises);
+	});
+