feat: エントリーができるように(Controller/Handlerの実装)

packages/kcms/src/team/adaptor/controller/controller.ts

@@ -1,10 +1,9 @@
 import { z } from '@hono/zod-openapi';
 import { Result } from '@mikuroxina/mini-fn';
-import { SnowflakeIDGenerator } from '../../../id/main';
-import { TeamRepository } from '../../models/repository';
 import { TeamID } from '../../models/team';
 import { CreateTeamService } from '../../service/createTeam';
 import { DeleteTeamService } from '../../service/delete';
+import { EntryService } from '../../service/entry';
 import { FetchTeamService } from '../../service/get';
 import {
   GetTeamResponseSchema,
@@ -14,18 +13,12 @@ import {
 } from '../validator/team';
 
 export class TeamController {
-  private readonly createTeam: CreateTeamService;
-  private readonly findTeam: FetchTeamService;
-  private readonly deleteTeam: DeleteTeamService;
-
-  constructor(repository: TeamRepository) {
-    this.createTeam = new CreateTeamService(
-      repository,
-      new SnowflakeIDGenerator(1, () => BigInt(new Date().getTime()))
-    );
-    this.findTeam = new FetchTeamService(repository);
-    this.deleteTeam = new DeleteTeamService(repository);
-  }
+  constructor(
+    private readonly createTeam: CreateTeamService,
+    private readonly findTeam: FetchTeamService,
+    private readonly deleteTeam: DeleteTeamService,
+    private readonly entry: EntryService
+  ) {}
 
   async create(
     args: z.infer<typeof PostTeamsRequestSchema>
@@ -84,6 +77,7 @@ export class TeamController {
       }),
     });
   }
+
   async getByID(id: TeamID): Promise<Result.Result<Error, z.infer<typeof GetTeamResponseSchema>>> {
     const res = await this.findTeam.findByID(id);
     if (Result.isErr(res)) {
@@ -111,4 +105,12 @@ export class TeamController {
 
     return Result.ok(undefined);
   }
+
+  async enter(id: TeamID): Promise<Result.Result<Error, void>> {
+    const res = await this.entry.enter(id);
+    if (Result.isErr(res)) {
+      return Result.err(res[1]);
+    }
+    return Result.ok(undefined);
+  }
 }

packages/kcms/src/team/main.ts

@@ -1,17 +1,44 @@
 import { OpenAPIHono } from '@hono/zod-openapi';
+
+import {
+  DeleteTeamRoute,
+  GetTeamRoute,
+  GetTeamsRoute,
+  PostEntryTeamRoute,
+  PostTeamsRoute,
+} from './routing';
+
 import { Result } from '@mikuroxina/mini-fn';
 import { prismaClient } from '../adaptor';
 import { TeamController } from './adaptor/controller/controller';
 import { errorToCode } from './adaptor/errors';
 import { DummyRepository } from './adaptor/repository/dummyRepository';
 import { PrismaTeamRepository } from './adaptor/repository/prismaRepository';
 import { TeamID } from './models/team.js';
-import { DeleteTeamRoute, GetTeamRoute, GetTeamsRoute, PostTeamsRoute } from './routing';
+
+import { SnowflakeIDGenerator } from '../id/main';
+import { CreateTeamService } from './service/createTeam';
+import { DeleteTeamService } from './service/delete';
+import { EntryService } from './service/entry';
+import { FetchTeamService } from './service/get';
 
 export const teamHandler = new OpenAPIHono();
 const isProduction = process.env.NODE_ENV === 'production';
+const teamRepository = isProduction
+  ? new PrismaTeamRepository(prismaClient)
+  : new DummyRepository();
+const idGenerator = new SnowflakeIDGenerator(1, () => BigInt(new Date().getTime()));
+
+const fetchTeamService = new FetchTeamService(teamRepository);
+const createTeamService = new CreateTeamService(teamRepository, idGenerator);
+const deleteTeamService = new DeleteTeamService(teamRepository);
+const entryService = new EntryService(teamRepository);
+
 export const controller = new TeamController(
-  isProduction ? new PrismaTeamRepository(prismaClient) : new DummyRepository()
+  createTeamService,
+  fetchTeamService,
+  deleteTeamService,
+  entryService
 );
 
 /**
@@ -25,6 +52,7 @@ teamHandler.openapi(GetTeamsRoute, async (c) => {
 
   return c.json(Result.unwrap(res), 200);
 });
+
 /**
  * すべてのチームを返す (POST /team)
  */
@@ -38,6 +66,7 @@ teamHandler.openapi(PostTeamsRoute, async (c) => {
   const teams = Result.unwrap(res);
   return c.json(teams, 200);
 });
+
 /**
  * 指定されたIDのチームを返す (GET /team/{teamID})
  */
@@ -50,6 +79,7 @@ teamHandler.openapi(GetTeamRoute, async (c) => {
   const team = Result.unwrap(res);
   return c.json(team, 200);
 });
+
 /**
  * 指定されたIDのチームを削除する (DELETE /team/{teamID})
  */
@@ -61,3 +91,16 @@ teamHandler.openapi(DeleteTeamRoute, async (c) => {
   }
   return new Response(null, { status: 204 });
 });
+
+/**
+ * エントリーする (POST /team/{teamID}/entry)
+ */
+teamHandler.openapi(PostEntryTeamRoute, async (c) => {
+  const { teamID } = c.req.valid('param');
+  const res = await controller.enter(teamID as TeamID);
+  if (Result.isErr(res)) {
+    return c.json({ description: errorToCode(Result.unwrapErr(res)) }, 400);
+  }
+
+  return new Response(null, { status: 200 });
+});