로그인할 때마다 다른 디바이스에서 삭제된 파일을 스캔하여 현재 디바이스에서도 삭제하도록 구현

src/lib/indexedDB/filesystem.ts

@@ -55,6 +55,10 @@ export const deleteDirectoryInfo = async (id: number) => {
   await filesystem.directory.delete(id);
 };
 
+export const getAllFileInfos = async () => {
+  return await filesystem.file.toArray();
+};
+
 export const getFileInfos = async (parentId: DirectoryId) => {
   return await filesystem.file.where({ parentId }).toArray();
 };

src/lib/server/db/file.ts

@@ -341,6 +341,11 @@ export const getAllFilesByCategory = async (
   return files.map(({ file_id, depth }) => ({ id: file_id, isRecursive: depth > 0 }));
 };
 
+export const getAllFileIds = async (userId: number) => {
+  const files = await db.selectFrom("file").select("id").where("user_id", "=", userId).execute();
+  return files.map(({ id }) => id);
+};
+
 export const getAllFileIdsByContentHmac = async (
   userId: number,
   hskVersion: number,

src/lib/server/schemas/file.ts

@@ -42,6 +42,11 @@ export const fileThumbnailUploadRequest = z.object({
 });
 export type FileThumbnailUploadRequest = z.input<typeof fileThumbnailUploadRequest>;
 
+export const fileListResponse = z.object({
+  files: z.number().int().positive().array(),
+});
+export type FileListResponse = z.output<typeof fileListResponse>;
+
 export const duplicateFileScanRequest = z.object({
   hskVersion: z.number().int().positive(),
   contentHmac: z.string().base64().nonempty(),

src/lib/server/services/file.ts

@@ -9,6 +9,7 @@ import { v4 as uuidv4 } from "uuid";
 import { IntegrityError } from "$lib/server/db/error";
 import {
   registerFile,
+  getAllFileIds,
   getAllFileIdsByContentHmac,
   getFile,
   setFileEncName,
@@ -148,6 +149,11 @@ export const uploadFileThumbnail = async (
   }
 };
 
+export const getFileList = async (userId: number) => {
+  const fileIds = await getAllFileIds(userId);
+  return { files: fileIds };
+};
+
 export const scanDuplicateFiles = async (
   userId: number,
   hskVersion: number,

src/lib/services/file.ts

@@ -1,14 +1,17 @@
 import { callGetApi } from "$lib/hooks";
+import { getAllFileInfos } from "$lib/indexedDB/filesystem";
 import { decryptData } from "$lib/modules/crypto";
 import {
   getFileCache,
   storeFileCache,
+  deleteFileCache,
   getFileThumbnailCache,
   storeFileThumbnailCache,
+  deleteFileThumbnailCache,
   downloadFile,
 } from "$lib/modules/file";
 import { getThumbnailUrl } from "$lib/modules/thumbnail";
-import type { FileThumbnailInfoResponse } from "$lib/server/schemas";
+import type { FileThumbnailInfoResponse, FileListResponse } from "$lib/server/schemas";
 
 export const requestFileDownload = async (
   fileId: number,
@@ -41,3 +44,18 @@ export const requestFileThumbnailDownload = async (fileId: number, dataKey: Cryp
   storeFileThumbnailCache(fileId, thumbnailBuffer); // Intended
   return getThumbnailUrl(thumbnailBuffer);
 };
+
+export const requestDeletedFilesCleanup = async () => {
+  const res = await callGetApi("/api/file/list");
+  if (!res.ok) return;
+
+  const { files: liveFiles }: FileListResponse = await res.json();
+  const liveFilesSet = new Set(liveFiles);
+  const maybeCachedFiles = await getAllFileInfos();
+
+  await Promise.all(
+    maybeCachedFiles
+      .filter(({ id }) => !liveFilesSet.has(id))
+      .flatMap(({ id }) => [deleteFileCache(id), deleteFileThumbnailCache(id)]),
+  );
+};