From c500997693c5499d743cc2742abc9664e854a577 Mon Sep 17 00:00:00 2001
From: Hongbo Wu <hongbo@omnivore.app>
Date: Tue, 11 Jul 2023 13:05:27 +0800
Subject: [PATCH] add lastFetchedAt to the cloud task payload

---
 packages/api/src/routers/svc/rss_feed.ts | 2 +-
 packages/api/src/utils/createTask.ts     | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/packages/api/src/routers/svc/rss_feed.ts b/packages/api/src/routers/svc/rss_feed.ts
index e19436bee..337fe79bb 100644
--- a/packages/api/src/routers/svc/rss_feed.ts
+++ b/packages/api/src/routers/svc/rss_feed.ts
@@ -23,7 +23,7 @@ export function rssFeedRouter() {
     try {
       // get all active rss feed subscriptions
       const subscriptions = await getRepository(Subscription).find({
-        select: ['id', 'url', 'user'],
+        select: ['id', 'url', 'user', 'lastFetchedAt'],
         where: {
           type: SubscriptionType.Rss,
           status: SubscriptionStatus.Active,
diff --git a/packages/api/src/utils/createTask.ts b/packages/api/src/utils/createTask.ts
index f928cf1c0..2820c864f 100644
--- a/packages/api/src/utils/createTask.ts
+++ b/packages/api/src/utils/createTask.ts
@@ -568,6 +568,7 @@ export const enqueueRssFeedFetch = async (
     subscriptionId: rssFeedSubscription.id,
     userId: rssFeedSubscription.user.id,
     feedUrl: rssFeedSubscription.url,
+    lastFetchedAt: rssFeedSubscription.lastFetchedAt,
   }
 
   const createdTasks = await createHttpTaskWithToken({