refactor(sensitive): log user name and wechat name usage (#726)

Author: hyrious

src/model/user/Constants.ts

@@ -1,4 +1,6 @@
 export enum SensitiveType {
     Phone = "phone",
     Avatar = "avatar",
+    Name = "name",
+    WeChatName = "wechat_name",
 }

src/v1/controller/login/platforms/LoginWechat.ts

@@ -10,6 +10,7 @@ import { ServiceCloudStorageFiles } from "../../../service/cloudStorage/CloudSto
 import { ServiceCloudStorageConfigs } from "../../../service/cloudStorage/CloudStorageConfigs";
 import { ServiceCloudStorageUserFiles } from "../../../service/cloudStorage/CloudStorageUserFiles";
 import { dataSource } from "../../../../thirdPartyService/TypeORMService";
+import { ServiceUserSensitive } from "../../../service/user/UserSensitive";
 
 @Login()
 export class LoginWechat extends AbstractLogin {
@@ -21,6 +22,7 @@ export class LoginWechat extends AbstractLogin {
         this.svc = {
             user: new ServiceUser(this.userUUID),
             userWeChat: new ServiceUserWeChat(this.userUUID),
+            userSensitive: new ServiceUserSensitive(this.userUUID),
             cloudStorageFiles: new ServiceCloudStorageFiles(),
             cloudStorageConfigs: new ServiceCloudStorageConfigs(this.userUUID),
             cloudStorageUserFiles: new ServiceCloudStorageUserFiles(this.userUUID),
@@ -32,10 +34,12 @@ export class LoginWechat extends AbstractLogin {
             const createUser = this.svc.user.create(info, t);
 
             const createUserWeChat = this.svc.userWeChat.create(info, t);
+            const createUserSensitive = this.svc.userSensitive.wechatName({ name: info.userName }, t);
 
             return await Promise.all([
                 createUser,
                 createUserWeChat,
+                createUserSensitive,
                 this.setGuidePPTX(this.svc, t),
             ]);
         });
@@ -80,7 +84,7 @@ export class LoginWechat extends AbstractLogin {
         };
     }
 
-    private static async wechatRequest<T>(url: string): Promise<T> {
+    private static async wechatRequest<T extends {}>(url: string): Promise<T> {
         const response: AxiosResponse<T | WeChatRequestFailed> = await ax.get(url);
 
         if ("errmsg" in response.data) {
@@ -94,6 +98,7 @@ export class LoginWechat extends AbstractLogin {
 interface RegisterService {
     user: ServiceUser;
     userWeChat: ServiceUserWeChat;
+    userSensitive: ServiceUserSensitive,
     cloudStorageFiles: ServiceCloudStorageFiles;
     cloudStorageUserFiles: ServiceCloudStorageUserFiles;
     cloudStorageConfigs: ServiceCloudStorageConfigs;

src/v1/controller/user/binding/platform/wechat/Binding.ts

@@ -10,6 +10,7 @@ import { ServiceUserWeChat } from "../../../../../service/user/UserWeChat";
 import { ControllerError } from "../../../../../../error/ControllerError";
 import { ErrorCode } from "../../../../../../ErrorCode";
 import { Status } from "../../../../../../constants/Project";
+import { ServiceUserSensitive } from "../../../../../service/user/UserSensitive";
 
 @Controller<RequestType, any>({
     method: "get",
@@ -124,6 +125,7 @@ const wechatCallback = async (
     }
 
     const wechatSVC = new ServiceUserWeChat(userUUID);
+    const sensitiveSVC = new ServiceUserSensitive(userUUID);
 
     const exist = await wechatSVC.exist();
     if (exist) {
@@ -139,6 +141,7 @@ const wechatCallback = async (
     }
 
     await wechatSVC.create(userInfo);
+    await sensitiveSVC.wechatName({ name: userInfo.userName });
 };
 
 interface RequestType {

src/v1/controller/user/rename/index.ts

@@ -6,6 +6,7 @@ import { Status } from "../../../../constants/Project";
 import { aliGreenText } from "../../../utils/AliGreen";
 import { ControllerError } from "../../../../error/ControllerError";
 import { ErrorCode } from "../../../../ErrorCode";
+import { ServiceUserSensitive } from "../../../service/user/UserSensitive";
 
 @Controller<RequestType, ResponseType>({
     method: "post",
@@ -29,13 +30,15 @@ export class Rename extends AbstractController<RequestType, ResponseType> {
 
     public readonly svc: {
         user: ServiceUser;
+        userSensitive: ServiceUserSensitive;
     };
 
     public constructor(params: ControllerClassParams) {
         super(params);
 
         this.svc = {
             user: new ServiceUser(this.userUUID),
+            userSensitive: new ServiceUserSensitive(this.userUUID),
         };
     }
 
@@ -45,6 +48,7 @@ export class Rename extends AbstractController<RequestType, ResponseType> {
         }
 
         await this.svc.user.updateName(this.body.name);
+        await this.svc.userSensitive.name({ name: this.body.name });
 
         return {
             status: Status.Success,

src/v1/service/user/UserSensitive.ts

@@ -34,4 +34,31 @@ export class ServiceUserSensitive {
             content: data.avatarURL,
         });
     }
+
+    public async name(
+        data: {
+            name: string;
+        },
+        t?: EntityManager,
+    ): Promise<InsertResult> {
+        return await UserSensitiveDAO(t).insert({
+            user_uuid: this.userUUID,
+            type: SensitiveType.Name,
+            content: data.name,
+        });
+    }
+
+    public async wechatName(
+        data: {
+            name: string;
+        },
+        t?: EntityManager,
+    ): Promise<InsertResult> {
+        return await UserSensitiveDAO(t).insert({
+            user_uuid: this.userUUID,
+            type: SensitiveType.WeChatName,
+            content: data.name,
+        });
+    }
+
 }

src/v2/services/user/update.ts

@@ -25,6 +25,11 @@ export class UserUpdateService {
                 user_uuid: this.userUUID,
             },
         );
+        await userSensitiveDAO.insert(this.DBTransaction, {
+            user_uuid: this.userUUID,
+            type: SensitiveType.Name,
+            content: newUserName,
+        });
         this.logger.debug("user name updated", {
             userUpdate: {
                 newUserName,