limit number of rss subscriptions to 20

packages/api/src/generated/graphql.ts

@@ -2707,6 +2707,7 @@ export type SubscribeError = {
 export enum SubscribeErrorCode {
   AlreadySubscribed = 'ALREADY_SUBSCRIBED',
   BadRequest = 'BAD_REQUEST',
+  ExceededMaxSubscriptions = 'EXCEEDED_MAX_SUBSCRIPTIONS',
   NotFound = 'NOT_FOUND',
   Unauthorized = 'UNAUTHORIZED'
 }

packages/api/src/generated/schema.graphql

@@ -2054,6 +2054,7 @@ type SubscribeError {
 enum SubscribeErrorCode {
   ALREADY_SUBSCRIBED
   BAD_REQUEST
+  EXCEEDED_MAX_SUBSCRIPTIONS
   NOT_FOUND
   UNAUTHORIZED
 }

packages/api/src/resolvers/subscriptions/index.ts

@@ -25,6 +25,7 @@ import {
   UpdateSubscriptionErrorCode,
   UpdateSubscriptionSuccess,
 } from '../../generated/graphql'
+import { AppDataSource } from '../../server'
 import { getSubscribeHandler, unsubscribe } from '../../services/subscriptions'
 import { Merge } from '../../util'
 import { analytics } from '../../utils/analytics'
@@ -234,20 +235,34 @@ export const subscribeResolver = authorized<
       // validate rss feed
       const feed = await parser.parseURL(input.url)
 
-      const newSubscription = await getRepository(Subscription).save({
-        name: feed.title,
-        url: input.url,
-        user: { id: uid },
-        type: SubscriptionType.Rss,
-        description: feed.description,
-        icon: feed.image?.url,
-      })
+      // limit number of rss subscriptions to 20
+      const newSubscriptions = (await AppDataSource.query(
+        `insert into omnivore.subscriptions (name, url, description, type, user_id, icon) 
+        select $1, $2, $3, $4, $5, $6 from omnivore.subscriptions 
+        where user_id = $5 and type = 'RSS' and status = 'ACTIVE' 
+        having count(*) < 20 
+        returning *;`,
+        [
+          feed.title,
+          input.url,
+          feed.description || null,
+          SubscriptionType.Rss,
+          uid,
+          feed.image?.url || null,
+        ]
+      )) as Subscription[]
+
+      if (newSubscriptions.length === 0) {
+        return {
+          errorCodes: [SubscribeErrorCode.ExceededMaxSubscriptions],
+        }
+      }
 
       // create a cloud task to fetch rss feed item for the new subscription
-      await enqueueRssFeedFetch(newSubscription)
+      await enqueueRssFeedFetch(uid, newSubscriptions[0])
 
       return {
-        subscriptions: [newSubscription],
+        subscriptions: newSubscriptions,
       }
     }
 

packages/api/src/routers/svc/rss_feed.ts

@@ -35,7 +35,7 @@ export function rssFeedRouter() {
       await Promise.all(
         subscriptions.map((subscription) => {
           try {
-            return enqueueRssFeedFetch(subscription)
+            return enqueueRssFeedFetch(subscription.user.id, subscription)
           } catch (error) {
             console.log('error creating rss feed fetch task', error)
           }

packages/api/src/schema.ts

@@ -1694,6 +1694,7 @@ const schema = gql`
     BAD_REQUEST
     NOT_FOUND
     ALREADY_SUBSCRIBED
+    EXCEEDED_MAX_SUBSCRIPTIONS
   }
 
   union AddPopularReadResult = AddPopularReadSuccess | AddPopularReadError

packages/api/src/utils/createTask.ts

@@ -567,6 +567,7 @@ export const enqueueThumbnailTask = async (
 }
 
 export const enqueueRssFeedFetch = async (
+  userId: string,
   rssFeedSubscription: Subscription
 ): Promise<string> => {
   const { GOOGLE_CLOUD_PROJECT } = process.env
@@ -577,9 +578,7 @@ export const enqueueRssFeedFetch = async (
   }
 
   const headers = {
-    [OmnivoreAuthorizationHeader]: generateVerificationToken(
-      rssFeedSubscription.user.id
-    ),
+    [OmnivoreAuthorizationHeader]: generateVerificationToken(userId),
   }
 
   // If there is no Google Cloud Project Id exposed, it means that we are in local environment

packages/web/locales/en/messages.ts

@@ -28,6 +28,7 @@ const errorMessages: Record<string, string> = {
   'error.INVALID_PASSWORD': 'Invalid password. Password must be at least 8 chars.',
   'error.ALREADY_SUBSCRIBED': 'You are already subscribed to this feed',
   'error.BAD_REQUEST': 'Bad request',
+  'error.EXCEEDED_MAX_SUBSCRIPTIONS': 'Exceeded max subscriptions',
 }
 
 const loginPageMessages: Record<string, string> = {