feat: rest adapter 추가

- fix: persistRouter가 실제 동작(network 추가)를 하도록 수정
- feat: express /network [post] 라우터 추가

Author: easdkr

example04/src/framework/adapter/input/rest/router-network.rest.adapter.ts

@@ -0,0 +1,25 @@
+import { RouterNetworkUseCase } from 'src/application/usecase/router-network.usecase';
+import { Router } from 'src/domain/entity/router';
+import { RouterNetworkAdapter } from 'src/framework/adapter/input/router-network.adapter';
+import { WebApp } from 'src/web-app.factory';
+
+export class RouterNetworkRestAdapter extends RouterNetworkAdapter {
+  constructor(protected readonly _routerNetworkUsecase: RouterNetworkUseCase) {
+    super();
+  }
+
+  public async processRequest(requestParams: WebApp): Promise<Router> {
+    const app = requestParams;
+
+    app.applyRouter('POST', '/network', async (req, res) => {
+      try {
+        this._router = await this._addNetworkToRouter(req.body);
+        res.send(this._router.toString());
+      } catch (e) {
+        res.status(400).json(e.message);
+      }
+    });
+
+    return this._router;
+  }
+}

example04/src/framework/adapter/output/prisma/mappers/router-prisma.mapper.ts

@@ -1,4 +1,4 @@
-import { IPData, Prisma, ProtocolData, RouterTypeData, SwitchTypeData } from '@prisma/client';
+import { Prisma, ProtocolData } from '@prisma/client';
 import { Router } from 'src/domain/entity/router';
 import { Switch } from 'src/domain/entity/switch';
 import { IP } from 'src/domain/vo/ip';
@@ -23,30 +23,24 @@ export class RouterPrismaMapper {
     return new Router(routerType, routerId, networkSwitch);
   }
 
-  public static toPrisma(router: Router): Prisma.RouterDataCreateInput {
-    const routerDataType = RouterTypeData[RouterType[router.type]];
+  public static toPrisma(router: Router): Prisma.NetworkDataCreateArgs {
     const routerDataId = router.routerId.toString();
-    const switchDataId = router.networkSwitch.id;
-    const switchTypeData = SwitchTypeData[SwitchType[router.networkSwitch.type]];
-    const ipData: IPData = {
-      address: router.networkSwitch.address.address,
-      protocol: ProtocolData[Protocol[router.networkSwitch.address.protocol]],
-    };
 
-    const networkDataList = this._getNetworksFromDomain(router.networkSwitch.getNetworks());
+    const networks = router.networkSwitch.getNetworks().at(-1);
 
     return {
-      id: routerDataId,
-      type: routerDataType,
-      networkSwitch: {
-        create: {
-          id: switchDataId.toString(),
-          type: switchTypeData,
-          ip: {
-            create: ipData,
+      data: {
+        switch: {
+          connect: {
+            routerId: routerDataId,
           },
-          networks: {
-            create: networkDataList,
+        },
+        cidr: networks.cidr,
+        name: networks.name,
+        ip: {
+          create: {
+            address: networks.address.address,
+            protocol: ProtocolData[Protocol[networks.address.protocol]],
           },
         },
       },
@@ -56,17 +50,4 @@ export class RouterPrismaMapper {
   private static _getNetworksFromData(networkData: NetworkDataType[]): Network[] {
     return networkData.map(({ ip: { address }, name, cidr }) => new Network(IP.fromAddress(address), name, cidr));
   }
-
-  private static _getNetworksFromDomain(networks: Network[]): Prisma.NetworkDataCreateWithoutSwitchInput[] {
-    return networks.map<Prisma.NetworkDataCreateWithoutSwitchInput>(({ cidr, address: { address, protocol }, name }) => ({
-      cidr,
-      name,
-      ip: {
-        create: {
-          address,
-          protocol: ProtocolData[Protocol[protocol]],
-        },
-      },
-    }));
-  }
 }

example04/src/framework/adapter/output/prisma/router-network.prisma.adapter.ts

@@ -26,14 +26,18 @@ class RouterNetworkPrismaAdapter implements RouterNetworkOutputPort {
         },
       },
     });
+
     return RouterPrismaMapper.toDomain(routerData);
   }
 
+  /**
+   * 원본 도서 예제의 java는 Router data 전체를 persist 를 사용하는데
+   * 실제로 의도한 동작은 input adapter로 부터 전달 받은 network 데이터만 해당 router에 추가하는 동작
+   */
   async persistRouter(router: Router): Promise<boolean> {
-    const routerData = RouterPrismaMapper.toPrisma(router);
-    await this._prisma.routerData.create({
-      data: routerData,
-    });
+    const networkData = RouterPrismaMapper.toPrisma(router);
+
+    await this._prisma.networkData.create(networkData);
 
     return true;
   }

example04/src/web-app.factory.ts

@@ -1,23 +1,32 @@
-import express from 'express';
+import bodyParser from 'body-parser';
+import express, { Handler, Router } from 'express';
 
-class WebApp {
+export class WebApp {
   private _app: express.Application;
 
-  constructor(private readonly _port: number) {
+  constructor(private readonly _port = 3000) {
     this._app = express();
+    this._init();
   }
 
   public start(): void {
     this._app.listen(this._port, () => {
       console.log(`Service listening on ${this._port}`);
     });
   }
-}
 
-export class WebAppFactory {
-  static create(port = 3000): WebApp {
-    const app = new WebApp(port);
+  public applyRouter(method: 'GET' | 'POST', url: string, handler: Handler): void {
+    switch (method) {
+      case 'GET':
+        this._app.get(url, handler);
+        return;
+      case 'POST':
+        this._app.post(url, handler);
+        return;
+    }
+  }
 
-    return app;
+  private _init(): void {
+    this._app.use(bodyParser.json());
   }
 }