Sync from main repo

Author: actions-user

src/index.ts

@@ -11,6 +11,7 @@ import { rateLimiter } from "./middleware/rate-limit.js";
 import {
   handleAddItem,
   handleAtom,
+  handleClearItems,
   handleCreateFeed,
   handleGetConfig,
   handleGetItems,
@@ -82,6 +83,10 @@ feedRoutes.get("/:feedId/rss.xml", handleRss);
 feedRoutes.get("/:feedId/atom.xml", handleAtom);
 feedRoutes.get("/:feedId/feed.json", handleJsonFeed);
 feedRoutes.get("/:feedId/raw.json", handleRawJson);
+feedRoutes.get("/:feedId", (c) => {
+  const feedId = c.req.param("feedId");
+  return c.redirect(`/${feedId}/feed.json`, 301);
+});
 
 // Protected API routes (authentication required)
 const protectedRoutes = new Hono();
@@ -91,6 +96,7 @@ protectedRoutes.get("/api/feeds/:feedId/config", handleGetConfig);
 protectedRoutes.put("/api/feeds/:feedId/config", handleUpdateConfig);
 protectedRoutes.get("/api/feeds/:feedId/items", handleGetItems);
 protectedRoutes.post("/api/feeds/:feedId/items", handleAddItem);
+protectedRoutes.delete("/api/feeds/:feedId/items", handleClearItems);
 
 app.route("/", publicRoutes);
 app.route("/", feedRoutes);

src/routes.ts

@@ -4,6 +4,7 @@ import { DuplicateItemError, FeedNotFoundError } from "./errors.js";
 import { formatItems, generateFeed } from "./formatters.js";
 import {
   addItem,
+  clearItems,
   createFeed,
   feedExists,
   getAllFeedIds,
@@ -83,6 +84,55 @@ export async function handleListFeeds(c: Context): Promise<Response> {
   }
 }
 
+/**
+ * Clear all items from a specific feed
+ */
+export async function handleClearItems(c: Context): Promise<Response> {
+  const feedId = c.req.param("feedId");
+  if (!feedId) {
+    return c.json({ error: "Feed ID is required" }, 400);
+  }
+
+  try {
+    if (!(await feedExists(feedId))) {
+      return c.json(
+        {
+          error: "Feed Not Found",
+          message: `Feed with ID '${feedId}' does not exist`,
+        },
+        404,
+      );
+    }
+
+    await clearItems(feedId);
+
+    return c.json({
+      message: "All items cleared successfully",
+      feedId,
+    });
+  } catch (error) {
+    console.error("Failed to clear feed items:", error);
+
+    if (error instanceof FeedNotFoundError) {
+      return c.json(
+        {
+          error: "Feed Not Found",
+          message: error.message,
+        },
+        404,
+      );
+    }
+
+    return c.json(
+      {
+        error: "Server Error",
+        message: `Failed to clear feed items: ${error}`,
+      },
+      500,
+    );
+  }
+}
+
 /**
  * Create a new feed
  */

src/storage.ts

@@ -332,6 +332,31 @@ export async function addItem(feedId: string, item: RssItem): Promise<void> {
   }
 }
 
+/**
+ * Clear all items from a specific feed
+ */
+export async function clearItems(feedId: string): Promise<void> {
+  try {
+    if (!(await feedExists(feedId))) {
+      throw new FeedNotFoundError(feedId);
+    }
+
+    const itemsKey = `feed:${feedId}:items`;
+    const guidsKey = `feed:${feedId}:guids`;
+
+    // Delete all items and GUIDs
+    await redis.del(itemsKey);
+    await redis.del(guidsKey);
+
+    console.log(`Cleared all items from feed: ${feedId}`);
+  } catch (error) {
+    if (error instanceof FeedNotFoundError) {
+      throw error;
+    }
+    throw new StorageError(`Failed to clear items: ${error}`);
+  }
+}
+
 /**
  * Get a list of all feed IDs
  */