興味のある分野 (server のみ) (#488)

<!--変更したい場合は、`/.github/pull_request_template.md` を修正して下さい。-->
# PRの概要

<!-- 変更の目的 もしくは 関連する Issue 番号 -->
<!-- 以下のように書くと Issue にリンクでき、マージ時に自動で Issue を閉じられる-->
<!-- closes #1 -->

## 具体的な変更内容
<!-- ビューの変更がある場合はスクショによる比較などがあるとわかりやすい -->

## 影響範囲
<!-- この関数を変更したのでこの機能にも影響がある、など -->

## 動作要件
<!-- 動作に必要な 環境変数 / 依存関係 / DBの更新 など -->

## 補足
<!-- レビューをする際に見てほしい点、ローカル環境で試す際の注意点、など -->

## レビューリクエストを出す前にチェック！

- [x] 改めてセルフレビューしたか
- [x] 手動での動作検証を行ったか
- [x] server の機能追加ならば、テストを書いたか
  - 理由: 書いた | server の機能追加ではない
- [x] 間違った使い方が存在するならば、それのドキュメントをコメントで書いたか
  - 理由: 書いた | 間違った使い方は存在しない
- [x] わかりやすいPRになっているか

<!-- レビューリクエスト後は、Slackでもメンションしてお願いすることを推奨します。 -->

Author: aster-void

common/types.ts

@@ -6,6 +6,7 @@ export type {
   IDToken,
   Gender,
   RelationshipStatus,
+  InterestSubject,
   User,
   InitUser,
   UpdateUser,

common/zod/schemas.ts

@@ -32,6 +32,12 @@ export const IntroLongSchema = z
   // .min(2, { message: "自己紹介文は2文字以上です" })
   .max(225, { message: "自己紹介文は225文字以下です" });
 
+export const InterestSubjectSchema = z.object({
+  id: z.number(),
+  name: z.string(),
+  group: z.string(),
+});
+
 export const UserSchema = z.object({
   id: UserIDSchema,
   guid: GUIDSchema,

common/zod/types.ts

@@ -14,6 +14,7 @@ import type {
   InitRoomSchema,
   InitSharedRoomSchema,
   InitUserSchema,
+  InterestSubjectSchema,
   IntroLongSchema,
   IntroShortSchema,
   MessageIDSchema,
@@ -45,6 +46,7 @@ export type Name = z.infer<typeof NameSchema>;
 export type PictureUrl = z.infer<typeof PictureUrlSchema>;
 export type Gender = z.infer<typeof GenderSchema>;
 export type RelationshipStatus = z.infer<typeof RelationshipStatusSchema>;
+export type InterestSubject = z.infer<typeof InterestSubjectSchema>;
 export type User = z.infer<typeof UserSchema>;
 export type InitUser = z.infer<typeof InitUserSchema>;
 export type UpdateUser = z.infer<typeof UpdateUserSchema>;

server/package.json

@@ -11,7 +11,7 @@
     "prisma-generate-sql": "bunx dotenv -e .env.dev -- prisma generate --sql"
   },
   "prisma": {
-    "seed": "bun src/seeds/seed.ts"
+    "seed": "bun src/seeds/seed-test.ts"
   },
   "keywords": [],
   "author": "",

server/prisma/schema.prisma

@@ -1,7 +1,7 @@
 //schema.prisma
 generator client {
-  provider      = "prisma-client-js"
-  binaryTargets = ["native", "debian-openssl-3.0.x"]
+  provider        = "prisma-client-js"
+  binaryTargets   = ["native", "debian-openssl-3.0.x"]
   previewFeatures = ["typedSql"]
 }
 
@@ -39,6 +39,7 @@ model User {
   enrollments    Enrollment[]
   sendingUsers   Relationship[] @relation("sending") // 自分がマッチリクエストを送ったユーザー
   receivingUsers Relationship[] @relation("receiving") // 自分にマッチリクエストを送ったユーザー
+  interests      Interest[]
 }
 
 // プロフィールの画像。
@@ -47,6 +48,25 @@ model Avatar {
   data Bytes
 }
 
+model InterestSubject {
+  id       Int        @id @default(autoincrement())
+  name     String
+  group    String // such as Computer Science | name = ML
+
+  @@unique([name, group])
+  Interest Interest[] // ignore this
+}
+
+// User->Interest->InterestSubject
+model Interest {
+  userId    Int
+  user      User            @relation(fields: [userId], references: [id])
+  subjectId Int
+  subject   InterestSubject @relation(fields: [subjectId], references: [id])
+
+  @@unique([userId, subjectId])
+}
+
 // enum Gender {
 //   MALE
 //   FEMALE

server/src/database/interest.test.ts

@@ -0,0 +1,25 @@
+import { beforeAll, expect, test } from "bun:test";
+import { assertLocalDB } from "../load-env";
+import * as interest from "./interest";
+
+beforeAll(assertLocalDB);
+
+test("list", async () => {
+  const got = (await interest.all()).sort((a, b) => a.id - b.id);
+  expect(got).toEqual([
+    { id: 1, group: "Computer Science", name: "型システム" },
+    { id: 2, group: "Computer Science", name: "機械学習" },
+    { id: 3, group: "Computer Science", name: "CPU アーキテクチャ" },
+    { id: 4, group: "Computer Science", name: "分散処理" },
+    { id: 5, group: "Math", name: "Lean4" },
+  ]);
+});
+
+test("get by user id", async () => {
+  const got = (await interest.of(101)).sort((a, b) => a.id - b.id);
+  expect(got).toEqual([
+    { id: 1, group: "Computer Science", name: "型システム" },
+    { id: 2, group: "Computer Science", name: "機械学習" },
+    { id: 3, group: "Computer Science", name: "CPU アーキテクチャ" },
+  ]);
+});

server/src/database/interest.ts

@@ -0,0 +1,39 @@
+import type { InterestSubject, UserID } from "../common/types";
+import { prisma } from "./client";
+
+export async function all(): Promise<InterestSubject[]> {
+  return await prisma.interestSubject.findMany();
+}
+
+export async function get(id: number): Promise<InterestSubject | null> {
+  return await prisma.interestSubject.findUnique({ where: { id } });
+}
+
+export async function of(userId: UserID): Promise<InterestSubject[]> {
+  return await prisma.interest
+    .findMany({
+      where: {
+        userId,
+      },
+      select: {
+        subject: true,
+      },
+    })
+    .then((res) => res.map((interest) => interest.subject));
+}
+
+export async function add(userId: UserID, subjectId: number) {
+  return await prisma.interest.create({
+    data: {
+      userId,
+      subjectId,
+    },
+  });
+}
+export async function remove(userId: UserID, subjectId: number) {
+  return await prisma.interest.delete({
+    where: {
+      userId_subjectId: { userId, subjectId },
+    },
+  });
+}

server/src/functions/user.test.ts

@@ -16,7 +16,8 @@ test("get all users", async () => {
   expect(result.code).toBe(200);
   expect(result.body).toSatisfy((s) => s.length === 3);
   expect(result.body).toSatisfy(
-    (s) => typeof s !== "string" && s[0].name === "田中太郎",
+    (s) =>
+      typeof s !== "string" && s.some((person) => person.name === "田中太郎"),
   );
 });
 

server/src/seeds/data/subjects.ts

@@ -0,0 +1,10 @@
+export const subjects = [
+  {
+    group: "Computer Science",
+    subjects: ["機械学習", "CPU アーキテクチャ", "型システム", "分散処理"],
+  },
+  {
+    group: "Math",
+    subjects: ["Lean4"],
+  },
+];

server/src/seeds/seed-test.ts

@@ -0,0 +1,95 @@
+import { prisma } from "../database/client";
+import {
+  courses,
+  enrollments,
+  interest,
+  slots,
+  subjects,
+  users,
+} from "./test-data/data";
+
+async function main() {
+  await Promise.all(
+    subjects.map(async ({ group, subjects }) => {
+      for (const [id, name] of subjects) {
+        await prisma.interestSubject.upsert({
+          where: { id },
+          update: { name, group },
+          create: { id, name, group },
+        });
+      }
+    }),
+  );
+
+  await Promise.all(
+    users.map(async (user) => {
+      await prisma.user.upsert({
+        where: { id: user.id },
+        update: {},
+        create: user,
+      });
+    }),
+  );
+
+  await Promise.all(
+    interest.map(async (interest) => {
+      await prisma.interest.upsert({
+        where: {
+          userId_subjectId: interest,
+        },
+        update: interest,
+        create: interest,
+      });
+    }),
+  );
+
+  await Promise.all(
+    courses.map(async (course) => {
+      await prisma.course.upsert({
+        where: { id: course.id },
+        update: course,
+        create: course,
+      });
+    }),
+  );
+
+  await Promise.all(
+    slots.map(async (slot) => {
+      await prisma.slot.upsert({
+        where: {
+          courseId_period_day: {
+            courseId: slot.courseId,
+            period: slot.period,
+            day: slot.day,
+          },
+        },
+        update: slot,
+        create: slot,
+      });
+    }),
+  );
+
+  const promises = enrollments.map(async ([user, course]) => {
+    await prisma.enrollment.upsert({
+      where: {
+        userId_courseId: { userId: user, courseId: course },
+      },
+      update: {},
+      create: {
+        userId: user,
+        courseId: course,
+      },
+    });
+  });
+  await Promise.all(promises);
+}
+
+await main()
+  .then(async () => {
+    await prisma.$disconnect();
+  })
+  .catch(async (e) => {
+    console.error(e);
+    await prisma.$disconnect();
+    process.exit(1);
+  });