implement members controller

packages/api/src/services/membersService.ts

@@ -1,6 +1,67 @@
-import { Injectable } from "../infrastructure/di/index.js";
+import { inject, Injectable } from "../infrastructure/di/index.js";
+import { ErrorStates } from "../infrastructure/errorStates.js";
+import {
+    type Member,
+    type MemberCreateArgs,
+    mapDbMemberToMember,
+} from "../models/member.js";
+import { DatabaseService } from "./db/prisma.js";
 
 @Injectable()
 export class MembersService {
-    // public async getMembers(): Promise<Member[]> {}
+    private readonly database = inject(DatabaseService);
+
+    public async getMembers(): Promise<Member[]> {
+        const dbMembers = await this.database.doRequest(prisma =>
+            prisma.member.findMany(),
+        );
+        return dbMembers.map(mapDbMemberToMember);
+    }
+
+    public async getMemberById(memberId: string): Promise<Member> {
+        const member = await this.database.doRequest(prisma =>
+            prisma.member.findFirst({ where: { id: memberId } }),
+        );
+
+        if (!member) {
+            throw new Error(`Member with id ${memberId} not found`, {
+                cause: ErrorStates.ENTITY_NOT_FOUND,
+            });
+        }
+
+        return mapDbMemberToMember(member);
+    }
+
+    public async createMember(createArgs: MemberCreateArgs): Promise<Member> {
+        const newMember = await this.database.doRequest(prisma =>
+            prisma.member.create({ data: createArgs }),
+        );
+        return mapDbMemberToMember(newMember);
+    }
+
+    public async updateMember(member: Member): Promise<Member> {
+        const id = member.id;
+        if (!id) {
+            throw new Error("Member id is required for update", {
+                cause: ErrorStates.BAD_REQUEST,
+            });
+        }
+        const modifiedMember = await this.database.doRequest(prisma =>
+            prisma.member.update({
+                data: { ...member, id: id },
+                where: { id: id },
+            }),
+        );
+
+        return mapDbMemberToMember(modifiedMember);
+    }
+
+    public async scheduleDeletion(memberId: string, cancelDate: Date) {
+        await this.database.doRequest(prisma =>
+            prisma.member.update({
+                where: { id: memberId },
+                data: { kuendigungzum: cancelDate },
+            }),
+        );
+    }
 }