Upgrades the rss plugin to parse out date object and use health check (#19)

* upgrades the rss plugin to parse out date object and use health check

* fmt

Author: elliotBraem

packages/rss/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@curatedotfun/rss",
-  "version": "0.0.7",
+  "version": "0.0.8",
   "description": "RSS plugin for curatedotfun",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

packages/rss/service/src/index.ts

@@ -10,6 +10,7 @@ import {
   handleRawJson,
   handleGetItems,
   handleAddItem,
+  handleHealth,
 } from "./routes.js";
 import { authenticate } from "./middleware.js";
 import { initializeFeed } from "./storage.js";
@@ -48,6 +49,7 @@ app.use("/api/*", authenticate);
 
 // Register routes
 app.get("/", handleRoot);
+app.get("/health", handleHealth);
 app.get("/rss.xml", handleRss);
 app.get("/atom.xml", handleAtom);
 app.get("/feed.json", handleJsonFeed);

packages/rss/service/src/routes.ts

@@ -5,6 +5,20 @@ import { addItem, getItems } from "./storage.js";
 import { ApiFormat, RssItem } from "./types.js";
 import { sanitize } from "./utils.js";
 
+/**
+ * Health check endpoint
+ */
+export async function handleHealth(c: Context): Promise<Response> {
+  return c.json(
+    {
+      status: "ok",
+      timestamp: new Date().toISOString(),
+      service: "rss-service",
+    },
+    200,
+  );
+}
+
 /**
  * Health check and redirect to preferred format
  */

packages/rss/src/index.ts

@@ -132,7 +132,7 @@ export default class RssPlugin
 
     // Check if service is running with a health check
     try {
-      const healthCheckResponse = await fetch(`${this.serviceUrl}/`, {
+      const healthCheckResponse = await fetch(`${this.serviceUrl}/health`, {
         method: "GET",
       });
 
@@ -245,6 +245,16 @@ export default class RssPlugin
     }
 
     try {
+      // Convert Date objects to ISO strings to ensure proper JSON serialization
+      const serializedItem = {
+        ...item,
+        published:
+          item.published instanceof Date
+            ? item.published.toISOString()
+            : item.published,
+        date: item.date instanceof Date ? item.date.toISOString() : item.date,
+      };
+
       const response = await fetch(`${this.serviceUrl}/api/items`, {
         method: "POST",
         headers: {
@@ -253,7 +263,7 @@ export default class RssPlugin
             ? { Authorization: `Bearer ${this.apiSecret}` }
             : {}),
         },
-        body: JSON.stringify(item),
+        body: JSON.stringify(serializedItem),
       });
 
       if (!response.ok) {