feat: add DELETE /collection/:id/resources endpoint

src/controllers/rag.controller.js

@@ -526,6 +526,46 @@ export const getResourcesByCollectionAndOwner = async (req, res, next) => {
   }
 };
 
+export const deleteResourcesByCollectionAndOwner = async (req, res, next) => {
+  try {
+    const { id: collectionId } = req.params;
+    const { ownerId } = req.query;
+
+    const hippocampusUrl = "http://hippocampus.gtwy.ai";
+    const hippocampusApiKey = process.env.HIPPOCAMPUS_API_KEY;
+
+    // Build URL with optional ownerId query param
+    let deleteUrl = `${hippocampusUrl}/collection/${collectionId}/resources`;
+    if (ownerId) {
+      deleteUrl += `?ownerId=${ownerId}`;
+    }
+
+    // Call Hippocampus API to delete resources by collection (and optionally ownerId)
+    const response = await axios.delete(deleteUrl, {
+      headers: {
+        "Content-Type": "application/json",
+        "x-api-key": hippocampusApiKey
+      }
+    });
+
+    res.locals = {
+      success: true,
+      message: "Resources deleted successfully",
+      data: response.data
+    };
+    req.statusCode = 200;
+    return next();
+  } catch (error) {
+    console.error("Error deleting resources by collection and owner:", error);
+    res.locals = {
+      success: false,
+      error: error.response?.data || error.message
+    };
+    req.statusCode = error.response?.status || 500;
+    return next();
+  }
+};
+
 export const getOrCreateDefaultCollections = async (req, res, next) => {
   try {
     const org_id = req.profile?.org?.id;

src/routes/rag.routes.js

@@ -12,7 +12,8 @@ import {
   getResourceChunks,
   getAllResourcesByCollectionId,
   getOrCreateDefaultCollections,
-  getResourcesByCollectionAndOwner
+  getResourcesByCollectionAndOwner,
+  deleteResourcesByCollectionAndOwner
 } from "../controllers/rag.controller.js";
 import { EmbeddecodeToken, middleware, checkAgentAccessMiddleware } from "../middlewares/middleware.js";
 import validate from "../middlewares/validate.middleware.js";
@@ -23,7 +24,8 @@ import {
   createResourceSchema,
   resourceIdSchema,
   updateResourceSchema,
-  getResourcesByCollectionQuerySchema
+  getResourcesByCollectionQuerySchema,
+  deleteResourcesByCollectionQuerySchema
 } from "../validation/joi_validation/rag.validation.js";
 
 const routes = express.Router();
@@ -37,6 +39,7 @@ routes.post("/collection", middleware, checkAgentAccessMiddleware, validate({ bo
 routes.get("/collections", middleware, getAllCollections);
 routes.get("/collection/:collectionId", middleware, validate({ params: collectionIdSchema }), getCollectionById);
 routes.get("/collection/:collectionId/resources", middleware, validate({ params: collectionIdSchema }), getAllResourcesByCollectionId);
+routes.delete("/collection/:id/resources", middleware, checkAgentAccessMiddleware, validate({ query: deleteResourcesByCollectionQuerySchema }), deleteResourcesByCollectionAndOwner);
 
 // Resource routes
 routes.get("/resource", middleware, getOrCreateDefaultCollections);

src/validation/joi_validation/rag.validation.js

@@ -81,12 +81,17 @@ const getResourcesByCollectionQuerySchema = Joi.object({
   })
 }).unknown(true);
 
+const deleteResourcesByCollectionQuerySchema = Joi.object({
+  ownerId: Joi.string().optional()
+}).unknown(true);
+
 export {
   searchSchema,
   createCollectionSchema,
   createResourceSchema,
   collectionIdSchema,
   resourceIdSchema,
   updateResourceSchema,
-  getResourcesByCollectionQuerySchema
+  getResourcesByCollectionQuerySchema,
+  deleteResourcesByCollectionQuerySchema
 };