projects.ts•2.73 kB
import { v } from "convex/values";
import { mutation, query } from "./_generated/server";
// プロジェクト一覧取得
export const getByUser = query({
args: { userId: v.id("users") },
handler: async (ctx, args) => {
return await ctx.db
.query("projects")
.withIndex("by_user", (q) => q.eq("userId", args.userId))
.filter((q) => q.eq(q.field("isArchived"), false))
.collect();
},
});
export const getBySession = query({
args: { sessionId: v.id("mcpSessions") },
handler: async (ctx, args) => {
const session = await ctx.db.get(args.sessionId);
if (!session) return [];
return await ctx.db
.query("projects")
.withIndex("by_user", (q) => q.eq("userId", session.userId))
.filter((q) => q.eq(q.field("isArchived"), false))
.collect();
},
});
export const get = query({
args: { id: v.id("projects") },
handler: async (ctx, args) => {
return await ctx.db.get(args.id);
},
});
// プロジェクト作成
export const create = mutation({
args: {
sessionId: v.id("mcpSessions"),
name: v.string(),
color: v.optional(v.string()),
parentId: v.optional(v.string()),
},
handler: async (ctx, args) => {
const session = await ctx.db.get(args.sessionId);
if (!session) {
throw new Error("Invalid session");
}
let parentObjectId = undefined;
if (args.parentId) {
const parent = await ctx.db
.query("projects")
.withIndex("by_user", (q) => q.eq("userId", session.userId))
.filter((q) => q.eq(q.field("todoistId"), args.parentId))
.first();
parentObjectId = parent?._id;
}
const now = Date.now();
const projectId = await ctx.db.insert("projects", {
userId: session.userId,
name: args.name,
color: args.color,
parentId: parentObjectId,
order: now,
isArchived: false,
createdAt: now,
updatedAt: now,
});
return await ctx.db.get(projectId);
},
});
// プロジェクト更新
export const update = mutation({
args: {
id: v.id("projects"),
name: v.optional(v.string()),
color: v.optional(v.string()),
parentId: v.optional(v.id("projects")),
},
handler: async (ctx, args) => {
const { id, ...updates } = args;
await ctx.db.patch(id, {
...updates,
updatedAt: Date.now(),
});
return await ctx.db.get(id);
},
});
// プロジェクト削除（アーカイブ）
export const archive = mutation({
args: { id: v.id("projects") },
handler: async (ctx, args) => {
await ctx.db.patch(args.id, {
isArchived: true,
updatedAt: Date.now(),
});
return await ctx.db.get(args.id);
},
});