Merge pull request #34 from boostcampwm-2024/feature-be-#26

[#26] Pod 생성 및 삭제 이벤트 발생 구독

Author: mintaek22

DBManager/package-lock.json

@@ -1,26 +1,26 @@
-import { Controller, Delete, Get, Query } from '@nestjs/common';
-import { KubernetesService } from './K8S/KubernetesService';
+import { Controller, Delete, Get, Param, Query } from '@nestjs/common';
+import { K8SApiService } from './k8s/K8SApi.service';
 
 @Controller()
 export class AppController {
-  constructor(private readonly kubernetesService: KubernetesService) {}
+  constructor(private readonly k8SApiService: K8SApiService) {}
 
   @Get('/pods')
   async getAllPods() {
-    const pods = await this.kubernetesService.getAllPods();
+    const pods = await this.k8SApiService.getAllPods();
     return pods;
   }
 
   @Get('/create-pod')
   async createPod() {
-    const pod = await this.kubernetesService.createPod();
+    const pod = await this.k8SApiService.createPod();
     return pod;
   }
 
   @Delete('/delete-pod')
   async deletePod(@Query('podName') podName: string) {
     console.log(podName);
-    const pod = await this.kubernetesService.deletePod(podName);
+    const pod = await this.k8SApiService.deletePod(podName);
     return pod;
   }
 }

DBManager/src/K8S/KubernetesService.ts

@@ -1,15 +1,16 @@
 import { Module } from '@nestjs/common';
 import { AppController } from './app.controller';
-import { KubernetesService } from './K8S/KubernetesService';
 import { ConfigModule } from '@nestjs/config';
+import { K8SApiModule } from './k8s/K8SApi.module';
 
 @Module({
   imports: [
     ConfigModule.forRoot({
       isGlobal: true,
     }),
+    K8SApiModule,
   ],
   controllers: [AppController],
-  providers: [KubernetesService],
+  providers: [],
 })
 export class AppModule {}

DBManager/src/app.controller.ts

@@ -36,10 +36,14 @@ export class RedisService {
     return this.podConnection.hget(key, field);
   }
 
-  async hsetPod(key: string, field: string, value: number): Promise<void> {
+  async hsetPod(key: string, field: string, value: number | string): Promise<void> {
     await this.podConnection.hset(key, field, value);
   }
 
+  async delPod(key: string): Promise<void> {
+    await this.podConnection.del(key);
+  }
+
   async subscribeActiveUser(
     channel: string,
     onMessage: (message: string) => void,

DBManager/src/app.module.ts

@@ -0,0 +1,10 @@
+import { Module } from '@nestjs/common';
+import { K8SApiService } from './K8SApi.service';
+import { RedisModule } from 'src/config/redis/redis.module';
+
+@Module({
+  imports: [RedisModule],
+  exports: [K8SApiService],
+  providers: [K8SApiService],
+})
+export class K8SApiModule {}

DBManager/src/config/redis/redis.service.ts

@@ -0,0 +1,98 @@
+import { Injectable, OnModuleInit } from '@nestjs/common';
+import * as k8s from '@kubernetes/client-node';
+import { RedisService } from 'src/config/redis/redis.service';
+
+@Injectable()
+export class K8SApiService {
+  private podCnt = 0;
+  private k8sApi;
+  private k8sWatch : k8s.Watch;
+  private namespace = 'default';
+
+  constructor(private readonly redisService: RedisService) {}
+
+  async onModuleInit() {
+    const kc = new k8s.KubeConfig();
+    kc.loadFromDefault();
+    this.k8sApi = kc.makeApiClient(k8s.CoreV1Api);
+    this.k8sWatch = new k8s.Watch(kc);
+    this.startWatchPod();
+  }
+  
+  async getPodIp(podName: string): Promise<string> {
+    const podInfo = await this.k8sApi.readNamespacedPod(podName, this.namespace);
+    return podInfo.body.status.podIP || 'Pending';
+  }
+
+  startWatchPod() {
+    const path = `/api/v1/namespaces/${this.namespace}/pods`;
+    const queryParams = {
+      allowWatchBookmarks: true,
+      labelSelector: 'app=mysql',
+    };
+    const handlePodEvent = async (type : String, apiObj: any, watchObj: any) => {
+      const podName = watchObj.object.metadata.name;
+      const podStatus = watchObj.object.status;
+      const curPodIp = await this.redisService.hgetPod(podName, 'podIp');
+
+      if (type === 'ADDED') {
+          await this.redisService.hsetPod(podName, 'activeUser', 0);
+          await this.redisService.hsetPod(podName, 'podIp', podStatus.podIp || '');
+      } else if (type === 'MODIFIED' && podStatus.podIP && curPodIp == '') {
+        const podIp = podStatus.podIP;
+        await this.redisService.hsetPod(podName, 'podIp', podIp);
+      } else if (type === 'DELETED') {
+          await this.redisService.delPod(podName);
+      }
+    };
+
+    this.k8sWatch.watch(path, queryParams, handlePodEvent, err => {});
+  }
+
+  async createPod() {
+    const mysqlPod = {
+      metadata: {
+        generateName: 'mysql-',
+        labels: {
+          app: 'mysql',
+        },
+      },
+      spec: {
+        containers: [
+          {
+            name: 'mysql',
+            image: 'mysql',
+          },
+        ],
+      },
+    };
+
+    const createdPod = await this.k8sApi.createNamespacedPod(this.namespace, mysqlPod);
+    return createdPod;
+  }
+
+  async deletePod(podName: string) {
+    const deletePod = await this.k8sApi.deleteNamespacedPod(podName, this.namespace);
+    return deletePod;
+  }
+
+  async getAllPods() {
+    const podList = await this.k8sApi.listNamespacedPod(this.namespace);
+    const podResult = {};
+
+    for (const pod of podList.body.items) {
+      const podName = pod.metadata.name;
+      console.log(podName);
+  
+      const podInfo = await this.k8sApi.readNamespacedPod(podName, this.namespace);
+      const podIp = podInfo.body.status.podIP;
+      console.log(podIp);
+  
+      podResult[podName] = podIp;
+    }
+    return {
+      podCnt : Object.keys(podResult).length,
+      podResult,
+    };
+  }
+}