release flat ai teacher feature

config/defaults.yaml

@@ -182,6 +182,9 @@ agora:
       - productID:
         eventType:
         secret:
+  ai:
+    server_cn: "http://43.131.39.44:8082"
+    server_en: "http://43.131.39.44:8081"
 
 whiteboard:
   app_id:

config/test.yaml

@@ -177,6 +177,8 @@ agora:
       - productID:
         eventType:
         secret:
+  ai:
+    server: "http://106.13.114.185:8081"
 
 whiteboard:
   app_id: "test/flat-server"

src/constants/Config.ts

@@ -160,6 +160,10 @@ export const Agora = {
         enable: config.agora.messageNotification.enable,
         events: config.agora.messageNotification.events,
     },
+    ai: {
+        server_cn: config.agora.ai.server_cn,
+        server_en: config.agora.ai.server_en,
+    }
 };
 
 export const JWT = {

src/dao/index.ts

@@ -19,6 +19,7 @@ import { UserPhoneModel } from "../model/user/Phone";
 import { UserSensitiveModel } from "../model/user/Sensitive";
 import { UserEmailModel } from "../model/user/Email";
 import { UserPmiModel } from "../model/user/Pmi";
+import { UserAgreementModel } from "../model/user/Agreement";
 
 export const UserDAO = DAOImplement(UserModel) as ReturnType<DAO<UserModel>>;
 
@@ -42,6 +43,8 @@ export const UserSensitiveDAO = DAOImplement(UserSensitiveModel) as ReturnType<
 
 export const UserPmiDAO = DAOImplement(UserPmiModel) as ReturnType<DAO<UserPmiModel>>;
 
+export const UserAgreementDAO = DAOImplement(UserAgreementModel) as ReturnType<DAO<UserAgreementModel>>;
+
 export const RoomDAO = DAOImplement(RoomModel) as ReturnType<DAO<RoomModel>>;
 
 export const RoomUserDAO = DAOImplement(RoomUserModel) as ReturnType<DAO<RoomUserModel>>;

src/model/index.ts

@@ -20,6 +20,7 @@ import { OAuthUsersModel } from "./oauth/oauth-users";
 import { UserSensitiveModel } from "./user/Sensitive";
 import { UserEmailModel } from "./user/Email";
 import { UserPmiModel } from "./user/Pmi";
+import { UserAgreementModel } from "./user/Agreement";
 import { PartnerModel } from "./partner/Partner";
 import { PartnerRoomModel } from "./partner/PartnerRoom";
 
@@ -34,6 +35,7 @@ export type Model =
     | UserEmailModel
     | UserSensitiveModel
     | UserPmiModel
+    | UserAgreementModel
     | RoomModel
     | RoomUserModel
     | RoomPeriodicConfigModel

src/model/room/Room.ts

@@ -89,4 +89,9 @@ export class RoomModel extends Content {
         default: false,
     })
     has_record: boolean;
+
+    @Column({
+        default: false,
+    })
+    is_ai: boolean;
 }

src/model/room/RoomUser.ts

@@ -29,6 +29,12 @@ export class RoomUserModel extends Content {
     })
     rtc_uid: string;
 
+    @Column({
+        default: -1,
+        type: "int",
+    })
+    grade: number;
+
     @Index("room_users_is_delete_index")
     @Column({
         default: false,

src/model/user/Agreement.ts

@@ -0,0 +1,26 @@
+import { Column, Entity, Index } from "typeorm";
+import { Content } from "../Content";
+
+@Entity({
+    name: "user_agreement",
+})
+export class UserAgreementModel extends Content {
+    @Index("user_agreement_user_uuid_uindex", {
+        unique: true,
+    })
+    @Column({
+        length: 40,
+    })
+    user_uuid: string;
+
+    @Column({
+        default: false,
+    })
+    is_agree_collect_data: boolean;
+
+    @Index("user_agreement_is_delete_index")
+    @Column({
+        default: false,
+    })
+    is_delete: boolean;
+}

src/thirdPartyService/TypeORMService.ts

@@ -23,6 +23,7 @@ import { OAuthSecretsModel } from "../model/oauth/oauth-secrets";
 import { OAuthUsersModel } from "../model/oauth/oauth-users";
 import { UserEmailModel } from "../model/user/Email";
 import { UserPmiModel } from "../model/user/Pmi";
+import { UserAgreementModel } from "../model/user/Agreement";
 import { PartnerModel } from "../model/partner/Partner";
 import { PartnerRoomModel } from "../model/partner/PartnerRoom";
 
@@ -44,6 +45,7 @@ export const dataSource = new DataSource({
         UserEmailModel,
         UserSensitiveModel,
         UserPmiModel,
+        UserAgreementModel,
         RoomModel,
         RoomUserModel,
         RoomPeriodicConfigModel,

src/utils/ParseConfig.ts

@@ -202,6 +202,10 @@ type Config = {
                 secret: string;
             }>;
         };
+        ai: {
+            server_cn: string;
+            server_en: string;
+        }
     };
     whiteboard: {
         app_id: string;

src/v1/controller/agora/Router.ts

@@ -3,10 +3,16 @@ import { GenerateRTM } from "./token/RTM";
 import { ControllerClass } from "../../../abstract/controller";
 import { MessageCallback } from "./message/Callback";
 import { RTMCensor } from "./rtm/censor";
+import { AgoraAIPing } from "./ai/ping";
+import { AgoraAIStart } from "./ai/start";
+import { AgoraAIStop } from "./ai/stop";
 
 export const agoraRouters: Readonly<Array<ControllerClass<any, any>>> = Object.freeze([
     GenerateRTC,
     GenerateRTM,
     MessageCallback,
     RTMCensor,
+    AgoraAIPing,
+    AgoraAIStart,
+    AgoraAIStop
 ]);

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

@@ -0,0 +1,4 @@
+import { Agora } from "../../../../constants/Config";
+
+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

@@ -0,0 +1,63 @@
+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_CN, AI_SERVER_URL_EN } from "./const";
+import { Status } from "../../../../constants/Project";
+
+@Controller<RequestType, any>({
+    method: "post",
+    path: "agora/ai/ping",
+    auth: true,
+})
+export class AgoraAIPing extends AbstractController<RequestType, any> {
+    public static readonly schema: FastifySchema<RequestType> = {
+        body: {
+            type: "object",
+            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, language } = this.body;
+        const api = language === "zh" ? AI_SERVER_URL_CN : AI_SERVER_URL_EN;
+        const res = await ax.post<any>(`${api}/ping`, {
+                request_id, 
+                channel_name
+            }, 
+            {    
+                headers: {
+                    "Content-Type": "application/json"
+                }
+            }
+        )
+        return {
+            status: Status.Success,
+            data: res.data,
+        }
+
+    }
+
+    public errorHandler(error: Error): ResponseError {
+        return this.autoHandlerError(error);
+    }
+}
+
+interface RequestType {
+    body: {
+        request_id: string;
+        channel_name: string;
+        language: string;
+    };
+}

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

@@ -0,0 +1,72 @@
+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_CN, AI_SERVER_URL_EN } from "./const";
+import { Status } from "../../../../constants/Project";
+@Controller<RequestType, any>({
+    method: "post",
+    path: "agora/ai/start",
+    auth: true,
+})
+export class AgoraAIStart extends AbstractController<RequestType, any> {
+    public static readonly schema: FastifySchema<RequestType> = {
+        body: {
+            type: "object",
+            required: ["request_id", "channel_name", "user_uid", "language", "role"],
+            properties: {
+                request_id: {
+                    type: "string",
+                },
+                channel_name: {
+                    type: "string",
+                },
+                user_uid: {
+                    type: "number",
+                },
+                language: {
+                    type: "string",
+                },
+                role: {
+                    type: "string",
+                },
+            },
+        },
+    };
+
+    public async execute(): Promise<Response<any>> {
+        const { request_id, channel_name, user_uid, language, role  } = this.body;
+        const api = language === "zh" ? AI_SERVER_URL_CN : AI_SERVER_URL_EN;
+        const res = await ax.post<any>(`${api}/start`, {
+                request_id, 
+                channel_name,
+                user_uid,
+                timbre_type: role
+            }, 
+            {    
+                headers: {
+                    "Content-Type": "application/json"
+                }
+            }
+        )
+
+        return {
+            status: Status.Success,
+            data: res.data,
+        }
+    }
+
+    public errorHandler(error: Error): ResponseError {
+        return this.autoHandlerError(error);
+    }
+}
+
+interface RequestType {
+    body: {
+        request_id: string;
+        channel_name: string;
+        user_uid: number;
+        language: string;
+        role: string;
+    };
+}

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

@@ -0,0 +1,62 @@
+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_CN, AI_SERVER_URL_EN } from "./const";
+import { Status } from "../../../../constants/Project";
+
+@Controller<RequestType, any>({
+    method: "post",
+    path: "agora/ai/stop",
+    auth: true,
+})
+export class AgoraAIStop extends AbstractController<RequestType, any> {
+    public static readonly schema: FastifySchema<RequestType> = {
+        body: {
+            type: "object",
+            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, language  } = this.body;
+        const api = language === "zh" ? AI_SERVER_URL_CN : AI_SERVER_URL_EN;
+        const res = await ax.post<any>(`${api}/start`, {
+                request_id, 
+                channel_name,
+            }, 
+            {    
+                headers: {
+                    "Content-Type": "application/json"
+                }
+            }
+        )
+        return {
+            status: Status.Success,
+            data: res.data,
+        }
+    }
+
+    public errorHandler(error: Error): ResponseError {
+        return this.autoHandlerError(error);
+    }
+}
+
+interface RequestType {
+    body: {
+        request_id: string;
+        channel_name: string;
+        language: string;
+    };
+}

src/v1/controller/room/Router.ts

@@ -25,6 +25,8 @@ import { UpdatePeriodic } from "./update/Periodic";
 import { RecordStarted } from "./record/Started";
 import { RecordStopped } from "./record/Stopped";
 import { ControllerClass } from "../../../abstract/controller";
+import { SetGrade } from "./grade/Set";
+import { GetGrade } from "./grade/Get";
 
 export const roomRouters: Readonly<Array<ControllerClass<any, any>>> = Object.freeze([
     CreateOrdinary,
@@ -53,4 +55,6 @@ export const roomRouters: Readonly<Array<ControllerClass<any, any>>> = Object.fr
     RecordAgoraUpdateLayout,
     RecordAgoraStopped,
     RecordInfo,
+    SetGrade,
+    GetGrade
 ]);

src/v1/controller/room/create/Ordinary.ts

@@ -58,6 +58,10 @@ export class CreateOrdinary extends AbstractController<RequestType, ResponseType
                     type: "boolean",
                     nullable: true,
                 },
+                isAI: {
+                    type: "boolean",
+                    nullable: true,
+                },
             },
         },
     };
@@ -183,6 +187,7 @@ export interface RequestType {
         endTime?: number;
         region?: Region;
         pmi?: boolean;
+        isAI?: boolean;
     };
 }