feat: add timber_type and config product AI server (#867)

Author: hqer927

config/defaults.yaml

@@ -183,7 +183,8 @@ agora:
         eventType:
         secret:
   ai:
-    server: "http://106.13.114.185:8081"
+    server_cn: "http://43.131.39.44:8082"
+    server_en: "http://43.131.39.44:8081"
 
 whiteboard:
   app_id:

src/constants/Config.ts

@@ -161,7 +161,8 @@ export const Agora = {
         events: config.agora.messageNotification.events,
     },
     ai: {
-        server: config.agora.ai.server,
+        server_cn: config.agora.ai.server_cn,
+        server_en: config.agora.ai.server_en,
     }
 };
 

src/utils/ParseConfig.ts

@@ -203,7 +203,8 @@ type Config = {
             }>;
         };
         ai: {
-            server: string;
+            server_cn: string;
+            server_en: string;
         }
     };
     whiteboard: {

src/v1/controller/agora/ai/const.ts

@@ -1,3 +1,4 @@
 import { Agora } from "../../../../constants/Config";
 
-export const AI_SERVER_URL = Agora.ai.server || "http://106.13.114.185:8081";
+export const AI_SERVER_URL_CN = Agora.ai.server_cn || "http://43.131.39.44:8082";
+export const AI_SERVER_URL_EN = Agora.ai.server_en || "http://43.131.39.44:8081";

src/v1/controller/agora/ai/ping.ts

@@ -2,7 +2,7 @@ import { FastifySchema, Response, ResponseError } from "../../../../types/Server
 import { ax } from "../../../utils/Axios";
 import { AbstractController } from "../../../../abstract/controller";
 import { Controller } from "../../../../decorator/Controller";
-import { AI_SERVER_URL } from "./const";
+import { AI_SERVER_URL_CN, AI_SERVER_URL_EN } from "./const";
 
 @Controller<RequestType, any>({
     method: "post",
@@ -13,22 +13,25 @@ export class AgoraAIPing extends AbstractController<RequestType, any> {
     public static readonly schema: FastifySchema<RequestType> = {
         body: {
             type: "object",
-            required: ["request_id", "channel_name"],
+            required: ["request_id", "channel_name", "language"],
             properties: {
                 request_id: {
                     type: "string",
                 },
                 channel_name: {
                     type: "string",
                 },
+                language: {
+                    type: "string",
+                }
             },
         },
     };
 
     public async execute(): Promise<Response<any>> {
-        const { request_id, channel_name  } = this.body;
-
-        const res = await ax.post<any>(`${AI_SERVER_URL}/ping`, {
+        const { request_id, channel_name, language } = this.body;
+        const api = language === "cn" ? AI_SERVER_URL_CN : AI_SERVER_URL_EN;
+        const res = await ax.post<any>(`${api}/ping`, {
                 request_id, 
                 channel_name
             }, 
@@ -51,5 +54,6 @@ interface RequestType {
     body: {
         request_id: string;
         channel_name: string;
+        language: string;
     };
 }

src/v1/controller/agora/ai/start.ts

@@ -2,7 +2,7 @@ import { FastifySchema, Response, ResponseError } from "../../../../types/Server
 import { ax } from "../../../utils/Axios";
 import { AbstractController } from "../../../../abstract/controller";
 import { Controller } from "../../../../decorator/Controller";
-import { AI_SERVER_URL } from "./const";
+import { AI_SERVER_URL_CN, AI_SERVER_URL_EN } from "./const";
 
 @Controller<RequestType, any>({
     method: "post",
@@ -38,12 +38,13 @@ export class AgoraAIStart extends AbstractController<RequestType, any> {
     };
 
     public async execute(): Promise<Response<any>> {
-        const { request_id, channel_name, user_uid  } = this.body;
-
-        const res = await ax.post<any>(`${AI_SERVER_URL}/start`, {
+        const { request_id, channel_name, user_uid, language, role  } = this.body;
+        const api = language === "cn" ? AI_SERVER_URL_CN : AI_SERVER_URL_EN;
+        const res = await ax.post<any>(`${api}/start`, {
                 request_id, 
                 channel_name,
                 user_uid,
+                timber_type: role
             }, 
             {    
                 headers: {

src/v1/controller/agora/ai/stop.ts

@@ -2,7 +2,7 @@ import { FastifySchema, Response, ResponseError } from "../../../../types/Server
 import { ax } from "../../../utils/Axios";
 import { AbstractController } from "../../../../abstract/controller";
 import { Controller } from "../../../../decorator/Controller";
-import { AI_SERVER_URL } from "./const";
+import { AI_SERVER_URL_CN, AI_SERVER_URL_EN } from "./const";
 
 @Controller<RequestType, any>({
     method: "post",
@@ -13,22 +13,25 @@ export class AgoraAIStop extends AbstractController<RequestType, any> {
     public static readonly schema: FastifySchema<RequestType> = {
         body: {
             type: "object",
-            required: ["request_id", "channel_name"],
+            required: ["request_id", "channel_name", "language"],
             properties: {
                 request_id: {
                     type: "string",
                 },
                 channel_name: {
                     type: "string",
                 },
+                language: {
+                    type: "string",
+                }
             },
         },
     };
 
     public async execute(): Promise<Response<any>> {
-        const { request_id, channel_name  } = this.body;
-
-        const res = await ax.post<any>(`${AI_SERVER_URL}/start`, {
+        const { request_id, channel_name, language  } = this.body;
+        const api = language === "cn" ? AI_SERVER_URL_CN : AI_SERVER_URL_EN;
+        const res = await ax.post<any>(`${api}/start`, {
                 request_id, 
                 channel_name,
             }, 
@@ -50,5 +53,6 @@ interface RequestType {
     body: {
         request_id: string;
         channel_name: string;
+        language: string;
     };
 }