refactor: Use single place for DB manipulation

Author: d3xter666

packages/project/lib/build/cache/BuildCacheStorage.js

@@ -550,6 +550,32 @@ export default class BuildCacheStorage {
 		return new Set(rows.map((row) => row.integrity));
 	}
 
+	/**
+	 * Clears all records from all tables and runs VACUUM.
+	 * Returns the number of bytes freed.
+	 *
+	 * @returns {number} Number of bytes freed
+	 */
+	clearAllRecords() {
+		const {page_count: pageCountBefore} = this.#db.prepare("PRAGMA page_count").get();
+		const {page_size: pageSize} = this.#db.prepare("PRAGMA page_size").get();
+		const bytesBefore = pageCountBefore * pageSize;
+
+		this.#db.exec("BEGIN");
+		this.#db.exec("DELETE FROM content");
+		this.#db.exec("DELETE FROM index_cache");
+		this.#db.exec("DELETE FROM stage_metadata");
+		this.#db.exec("DELETE FROM task_metadata");
+		this.#db.exec("DELETE FROM result_metadata");
+		this.#db.exec("COMMIT");
+		this.#db.exec("VACUUM");
+
+		const {page_count: pageCountAfter} = this.#db.prepare("PRAGMA page_count").get();
+		const bytesAfter = pageCountAfter * pageSize;
+
+		return bytesBefore - bytesAfter;
+	}
+
 	/**
 	 * Closes the database connection
 	 */

packages/project/lib/cache/CacheCleanup.js

@@ -1,6 +1,6 @@
 import path from "node:path";
 import fs from "node:fs/promises";
-import {DatabaseSync} from "node:sqlite";
+import BuildCacheStorage from "../build/cache/BuildCacheStorage.js";
 
 /**
  * Get the size of a directory tree recursively.
@@ -79,34 +79,17 @@ async function cleanBuildCache(buildCacheDir) {
 		return removed;
 	}
 
-	const tables = ["content", "index_cache", "stage_metadata", "task_metadata", "result_metadata"];
 
 	for (const versionDir of versionDirs) {
 		if (!versionDir.isDirectory()) {
 			continue;
 		}
 
-		const dbPath = path.join(buildCacheDir, versionDir.name, "cache.db");
-		try {
-			await fs.access(dbPath);
-		} catch {
-			continue;
-		}
-
-		const statBefore = await fs.stat(dbPath);
-		const sizeBefore = statBefore.size;
-
-		const db = new DatabaseSync(dbPath);
-		db.exec("BEGIN");
-		for (const table of tables) {
-			db.exec(`DELETE FROM ${table}`);
-		}
-		db.exec("COMMIT");
-		db.exec("VACUUM");
-		db.close();
+		const dbDir = path.join(buildCacheDir, versionDir.name);
 
-		const statAfter = await fs.stat(dbPath);
-		const freedSize = sizeBefore - statAfter.size;
+		const storage = new BuildCacheStorage(dbDir);
+		const freedSize = storage.clearAllRecords();
+		storage.close();
 
 		removed.push({
 			path: `buildCache/${versionDir.name}`,

packages/project/test/lib/package-exports.js

@@ -13,7 +13,7 @@ test("export of package.json", (t) => {
 // Check number of definied exports
 test("check number of exports", (t) => {
 	const packageJson = require("@ui5/project/package.json");
-	t.is(Object.keys(packageJson.exports).length, 14);
+	t.is(Object.keys(packageJson.exports).length, 15);
 });
 
 // Public API contract (exported modules)