diff --git a/packages/api/src/resolvers/subscriptions/index.ts b/packages/api/src/resolvers/subscriptions/index.ts index 378b0d111..3904a5e06 100644 --- a/packages/api/src/resolvers/subscriptions/index.ts +++ b/packages/api/src/resolvers/subscriptions/index.ts @@ -28,6 +28,7 @@ import { import { getSubscribeHandler, unsubscribe } from '../../services/subscriptions' import { Merge } from '../../util' import { analytics } from '../../utils/analytics' +import { enqueueRssFeedFetch } from '../../utils/createTask' import { authorized } from '../../utils/helpers' type PartialSubscription = Omit @@ -242,6 +243,9 @@ export const subscribeResolver = authorized< icon: feed.image?.url, }) + // create a cloud task to fetch rss feed item for the new subscription + await enqueueRssFeedFetch(newSubscription) + return { subscriptions: [newSubscription], }