タグ追加

Author: nakaterm

server/src/database/interest.ts

@@ -9,6 +9,21 @@ export async function get(id: number): Promise<InterestSubject | null> {
   return await prisma.interestSubject.findUnique({ where: { id } });
 }
 
+export async function create(name: string): Promise<InterestSubject> {
+  const existingTag = await prisma.interestSubject.findMany({
+    where: { name },
+  });
+  if (existingTag.length > 0) {
+    throw new Error("同名のタグがすでに存在します");
+  }
+  return await prisma.interestSubject.create({
+    data: {
+      name,
+      group: "", // TODO: 運用次第
+    },
+  });
+}
+
 export async function of(userId: UserID): Promise<InterestSubject[]> {
   return await prisma.interest
     .findMany({
@@ -57,13 +72,3 @@ export async function updateMultipleWithTransaction(
     });
   });
 }
-
-export async function search(query: string): Promise<InterestSubject[]> {
-  return await prisma.interestSubject.findMany({
-    where: {
-      name: {
-        contains: query,
-      },
-    },
-  });
-}

server/src/router/subjects.ts

@@ -30,6 +30,20 @@ router.get("/mine", async (req: Request, res: Response) => {
   }
 });
 
+router.post("/", async (req: Request, res: Response) => {
+  const { name } = req.body;
+  if (typeof name !== "string") {
+    return res.status(400).json({ error: "name must be a string" });
+  }
+  try {
+    const newSubject = await interest.create(name);
+    res.status(201).json(newSubject);
+  } catch (error) {
+    console.error("Error creating subject:", error);
+    res.status(500).json({ error: "Failed to create subject" });
+  }
+});
+
 router.patch("/mine", async (req: Request, res: Response) => {
   const userId = await safeGetUserId(req);
   if (!userId.ok) return res.status(401).send("auth error");
@@ -104,18 +118,13 @@ router.put("/mine", async (req: Request, res: Response) => {
   }
 });
 
-router.get("/search/:query", async (req: Request, res: Response) => {
-  // TODO: token との兼ね合いで、クエリパラメータでなく一旦パスパラメータとしている
-  const q = req.params.query;
-  if (typeof q !== "string") {
-    return res.status(400).json({ error: "Invalid query" });
-  }
+router.get("/all", async (req: Request, res: Response) => {
   try {
-    const subjects = await interest.search(q);
+    const subjects = await interest.all();
     res.status(200).json(subjects);
   } catch (error) {
-    console.error("Error searching subjects:", error);
-    res.status(500).json({ error: "Failed to search subjects" });
+    console.error("Error fetching subjects:", error);
+    res.status(500).json({ error: "Failed to fetch subjects" });
   }
 });
 

web/api/internal/endpoints.ts

@@ -236,6 +236,17 @@ export const coursesDayPeriod = (day: Day, period: number) => {
   return `${API_ENDPOINT}/courses/day-period?day=${day}&period=${period}`;
 };
 
+/**
+ * [v] 実装済み
+ * POST -> create a new subject.
+ * - statuses:
+ *  - 200: ok.
+ *   - body: InterestSubject
+ *  - 401: unauthorized.
+ *  - 500: internal error.
+ */
+export const subjects = `${API_ENDPOINT}/subjects`;
+
 /**
  * [v] 実装済み
  * GET -> get subjects the user is interested in.
@@ -282,18 +293,15 @@ export const subjectsUserId = (userId: UserID) => {
 export const subjectsMine = `${API_ENDPOINT}/subjects/mine`;
 
 /**
- * [] 実装済み
- * GET -> search subjects.
+ * [v] 実装済み
+ * GET -> get all subjects.
  * - statuses:
- *   - 200: ok.
- *     - body: InterestSubject[]
- *   - 401: unauthorized.
- *   - 500: internal error.
- **/
-export const subjectsSearch = (query: string) => {
-  // TODO: token との兼ね合いで、クエリパラメータでなく一旦パスパラメータとしている
-  return `${API_ENDPOINT}/subjects/search/${query}`;
-};
+ *  - 200: ok.
+ *   - body: InterestSubject[]
+ *  - 401: unauthorized.
+ *  - 500: internal error.
+ */
+export const subjectsAll = `${API_ENDPOINT}/subjects/all`;
 
 /**
  * [v] 実装済み
@@ -459,9 +467,10 @@ export default {
   cancelRequest,
   coursesUserId,
   coursesDayPeriod,
+  subjects,
   subjectsUserId,
   subjectsMine,
-  subjectsSearch,
+  subjectsAll,
   roomOverview,
   dmTo,
   dmWith,

web/api/subject.ts

@@ -11,6 +11,11 @@ import endpoints from "./internal/endpoints.ts";
 
 const InterestSubjectListSchema = z.array(InterestSubjectSchema);
 
+// 興味分野を作成する
+export async function create(name: string) {
+  return await credFetch("POST", endpoints.subjects, { name });
+}
+
 // 自身の興味分野を取得する
 export function useMyInterests(): Hook<InterestSubject[]> {
   return useCustomizedSWR(
@@ -26,11 +31,9 @@ async function getMySubjects(): Promise<InterestSubject[]> {
 }
 
 // 自身の興味分野を更新する
-export async function update(
-  newSubjectIds: InterestSubjectID[],
-): Promise<void> {
+export async function update(newSubjectIds: InterestSubjectID[]) {
   const url = endpoints.subjectsMine;
-  await credFetch("PUT", url, { subjectIds: newSubjectIds });
+  return await credFetch("PUT", url, { subjectIds: newSubjectIds });
 }
 
 // 指定した userId のユーザの興味分野を取得
@@ -39,8 +42,8 @@ export async function get(id: UserID): Promise<InterestSubject[] | null> {
   return await res.json();
 }
 
-// 興味分野を検索
-export async function search(q: string): Promise<InterestSubject[]> {
-  const res = await credFetch("GET", endpoints.subjectsSearch(q));
+// すべての興味分野を取得
+export async function getAll(): Promise<InterestSubject[]> {
+  const res = await credFetch("GET", endpoints.subjectsAll);
   return await res.json();
 }