delete group api

packages/cli/src/server/api/agent.ts

@@ -1850,5 +1850,24 @@ export function agentRouter(
     });
   });
 
+  router.delete('/groups/:serverId', async (req, res) => {
+    const serverId = validateUuid(req.params.serverId);
+    try {
+      await db.deleteRoomsByServerId(serverId);
+
+      res.status(204).send();
+    } catch (error) {
+      logger.error('[GROUP DELETE] Error deleting group:', error);
+      res.status(500).json({
+        success: false,
+        error: {
+          code: 'DELETE_ERROR',
+          message: 'Error deleting group',
+          details: error.message,
+        },
+      });
+    }
+  });
+
   return router;
 }

packages/client/src/lib/api.ts

@@ -499,4 +499,11 @@ export const apiClient = {
       },
     });
   },
+
+  deleteGroupChat: (serverId: string) => {
+    return fetcher({
+      url: `/agents/groups/${serverId}`,
+      method: 'DELETE',
+    });
+  },
 };

packages/plugin-sql/src/base.ts

@@ -2250,4 +2250,21 @@ export abstract class BaseDrizzleAdapter<
       }));
     });
   }
+
+  /**
+   * Asynchronously deletes all rooms associated with a specific serverId.
+   * @param {UUID} serverId - The server ID to delete rooms for.
+   * @returns {Promise<void>} A Promise that resolves when the rooms are deleted.
+   */
+  async deleteRoomsByServerId(serverId: UUID): Promise<void> {
+    return this.withDatabase(async () => {
+      await this.db.transaction(async (tx) => {
+        await tx.delete(roomTable).where(eq(roomTable.serverId, serverId));
+      });
+
+      logger.debug('Rooms deleted successfully for server:', {
+        serverId,
+      });
+    });
+  }
 }