feat: impl file delete

Co-authored-by: Ona <no-reply@ona.com>
This commit is contained in:
2025-09-14 10:59:49 +00:00
parent aa3c086f03
commit a67a8795d8
12 changed files with 259 additions and 69 deletions

View File

@@ -15,6 +15,7 @@ import type {
} from "convex/server";
import type * as files from "../files.js";
import type * as model_directories from "../model/directories.js";
import type * as model_files from "../model/files.js";
import type * as users from "../users.js";
/**
@@ -28,6 +29,7 @@ import type * as users from "../users.js";
declare const fullApi: ApiFromModules<{
files: typeof files;
"model/directories": typeof model_directories;
"model/files": typeof model_files;
users: typeof users;
}>;
export declare const api: FilterApi<

View File

@@ -62,3 +62,15 @@ export const saveFile = mutation({
})
},
})
export const moveToTrash = mutation({
args: {
itemId: v.union(v.id("files"), v.id("directories")),
},
handler: async (ctx, { itemId }) => {
await ctx.db.patch(itemId, {
deletedAt: new Date().toISOString(),
})
return itemId
},
})

View File

@@ -12,6 +12,7 @@ type File = {
}
export type DirectoryItem = Directory | File
export type DirectoryItemKind = DirectoryItem["kind"]
export async function fetchContent(
ctx: QueryCtx,
@@ -20,7 +21,9 @@ export async function fetchContent(
const [files, directories] = await Promise.all([
ctx.db
.query("files")
.withIndex("byDirectoryId", (q) => q.eq("directoryId", directoryId))
.withIndex("byDirectoryId", (q) =>
q.eq("directoryId", directoryId).eq("deletedAt", undefined),
)
.collect(),
ctx.db
.query("directories")

13
convex/model/files.ts Normal file
View File

@@ -0,0 +1,13 @@
import { v } from "convex/values"
import { mutation } from "../_generated/server"
export const moveToTrash = mutation({
args: {
fileId: v.id("files"),
},
handler: async (ctx, { fileId }) => {
await ctx.db.patch(fileId, {
deletedAt: new Date().toISOString(),
})
},
})

View File

@@ -16,7 +16,10 @@ const schema = defineSchema({
size: v.number(),
createdAt: v.string(),
updatedAt: v.string(),
}).index("byDirectoryId", ["directoryId"]),
deletedAt: v.optional(v.string()),
})
.index("byDirectoryId", ["directoryId", "deletedAt"])
.index("byDeletedAt", ["deletedAt"]),
directories: defineTable({
name: v.string(),
parentId: v.optional(v.id("directories")),

View File

@@ -4,7 +4,7 @@ import { query } from "./_generated/server"
export const getCurrentUser = query({
handler: async (ctx) => {
return await ctx.db.get(
"j574n657f521n19v1stnr88ysd7qhbs1" as Id<"users">,
"jd7ampv4m200xr4yk2cfncccmh7qhj34" as Id<"users">,
)
},
})