chore: fix services

Author: coodos

platforms/cerberus/src/services/CharterSignatureService.ts

@@ -253,7 +253,11 @@ export class CharterSignatureService {
             }
 
             // Set charter as inactive
-            await this.groupRepository.update(groupId, { isCharterActive: false });
+            const group = await this.groupRepository.findOne({ where: { id: groupId } });
+            if (group) {
+                group.isCharterActive = false;
+                await this.groupRepository.save(group);
+            }
 
             // Delete all existing signatures
             await this.signatureRepository.delete({ groupId });

platforms/cerberus/src/services/GroupService.ts

@@ -20,8 +20,18 @@ export class GroupService {
     }
 
     async updateGroup(id: string, groupData: Partial<Group>): Promise<Group | null> {
-        await this.groupRepository.update(id, groupData);
-        return await this.getGroupById(id);
+        // Get the current group, merge the data, and save it to trigger ORM events
+        const currentGroup = await this.getGroupById(id);
+        if (!currentGroup) {
+            throw new Error("Group not found");
+        }
+        
+        // Merge the new data with the existing group
+        Object.assign(currentGroup, groupData);
+        
+        // Save the merged group to trigger ORM subscribers
+        const updatedGroup = await this.groupRepository.save(currentGroup);
+        return updatedGroup;
     }
 
     async saveGroup(group: Group): Promise<Group> {

platforms/cerberus/src/services/MessageService.ts

@@ -89,8 +89,18 @@ export class MessageService {
     }
 
     async updateMessage(id: string, messageData: Partial<Message>): Promise<Message | null> {
-        await this.messageRepository.update(id, messageData);
-        return await this.getMessageById(id);
+        // Get the current message, merge the data, and save it to trigger ORM events
+        const currentMessage = await this.getMessageById(id);
+        if (!currentMessage) {
+            throw new Error("Message not found");
+        }
+        
+        // Merge the new data with the existing message
+        Object.assign(currentMessage, messageData);
+        
+        // Save the merged message to trigger ORM subscribers
+        const updatedMessage = await this.messageRepository.save(currentMessage);
+        return updatedMessage;
     }
 
     async deleteMessage(id: string): Promise<boolean> {
@@ -99,15 +109,26 @@ export class MessageService {
     }
 
     async getUserMessages(userId: string): Promise<Message[]> {
-        return await this.messageRepository.find({
+        const messages = await this.messageRepository.find({
             where: { sender: { id: userId } },
             relations: ['sender', 'group'],
             order: { createdAt: 'DESC' }
         });
+        
+        return messages;
     }
 
     async archiveMessage(id: string): Promise<Message | null> {
-        await this.messageRepository.update(id, { isArchived: true });
-        return await this.getMessageById(id);
+        // Get the current message, set archived flag, and save it to trigger ORM events
+        const currentMessage = await this.getMessageById(id);
+        if (!currentMessage) {
+            throw new Error("Message not found");
+        }
+        
+        currentMessage.isArchived = true;
+        
+        // Save the updated message to trigger ORM subscribers
+        const archivedMessage = await this.messageRepository.save(currentMessage);
+        return archivedMessage;
     }
 } 

platforms/cerberus/src/services/UserService.ts

@@ -51,8 +51,18 @@ export class UserService {
     }
 
     async updateUser(id: string, userData: Partial<User>): Promise<User | null> {
-        await this.userRepository.update(id, userData);
-        return await this.getUserById(id);
+        // Get the current user, merge the data, and save it to trigger ORM events
+        const currentUser = await this.getUserById(id);
+        if (!currentUser) {
+            throw new Error("User not found");
+        }
+        
+        // Merge the new data with the existing user
+        Object.assign(currentUser, userData);
+        
+        // Save the merged user to trigger ORM subscribers
+        const updatedUser = await this.userRepository.save(currentUser);
+        return updatedUser;
     }
 
     async saveUser(user: User): Promise<User> {

platforms/group-charter-manager-api/src/services/MessageService.ts

@@ -108,8 +108,18 @@ export class MessageService {
      * Update a message
      */
     async updateMessage(id: string, messageData: Partial<Message>): Promise<Message | null> {
-        await this.messageRepository.update(id, messageData);
-        return await this.getMessageById(id);
+        // Get the current message, merge the data, and save it to trigger ORM events
+        const currentMessage = await this.getMessageById(id);
+        if (!currentMessage) {
+            throw new Error("Message not found");
+        }
+        
+        // Merge the new data with the existing message
+        Object.assign(currentMessage, messageData);
+        
+        // Save the merged message to trigger ORM subscribers
+        const updatedMessage = await this.messageRepository.save(currentMessage);
+        return updatedMessage;
     }
 
     /**
@@ -124,7 +134,16 @@ export class MessageService {
      * Archive a message
      */
     async archiveMessage(id: string): Promise<Message | null> {
-        await this.messageRepository.update(id, { isArchived: true });
-        return await this.getMessageById(id);
+        // Get the current message, set archived flag, and save it to trigger ORM events
+        const currentMessage = await this.getMessageById(id);
+        if (!currentMessage) {
+            throw new Error("Message not found");
+        }
+        
+        currentMessage.isArchived = true;
+        
+        // Save the updated message to trigger ORM subscribers
+        const archivedMessage = await this.messageRepository.save(currentMessage);
+        return archivedMessage;
     }
 } 

platforms/group-charter-manager-api/src/services/UserService.ts

@@ -97,8 +97,18 @@ export class UserService {
     }
 
     async updateUser(id: string, userData: Partial<User>): Promise<User | null> {
-        await this.userRepository.update(id, userData);
-        return await this.getUserById(id);
+        // Get the current user, merge the data, and save it to trigger ORM events
+        const currentUser = await this.getUserById(id);
+        if (!currentUser) {
+            throw new Error("User not found");
+        }
+        
+        // Merge the new data with the existing user
+        Object.assign(currentUser, userData);
+        
+        // Save the merged user to trigger ORM subscribers
+        const updatedUser = await this.userRepository.save(currentUser);
+        return updatedUser;
     }
 
     async saveUser(user: User): Promise<User> {