Clean up redis code, remove connection close in job

packages/api/src/jobs/rss/refreshFeed.ts

@@ -671,13 +671,10 @@ export const _refreshFeed = async (request: RefreshFeedRequest) => {
         lastFetchedChecksums[i],
         fetchContents[i] && allowFetchContent,
         folders[i],
-        feed,
-        redisClient
+        feed
       )
     }
   } catch (e) {
     console.error('Error while saving RSS feeds', e)
-  } finally {
-    await redisClient.quit()
   }
 }

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

@@ -31,7 +31,7 @@ export function rssFeedRouter() {
       }
 
       if (redisDataSource.workerRedisClient) {
-        await queueRSSRefreshAllFeedsJob(redisDataSource.workerRedisClient)
+        await queueRSSRefreshAllFeedsJob()
       } else {
         console.log('unable to fetchAll feeds, redis is not configured')
         return res.status(500).send('Expired')

packages/api/src/utils/createTask.ts

@@ -663,11 +663,7 @@ export const enqueueRssFeedFetch = async (
   )}_${stringToHash(JSON.stringify(subscriptionGroup.userIds.sort()))}`
 
   if (redisDataSource.workerRedisClient) {
-    let job = await queueRSSRefreshFeedJob(
-      redisDataSource.workerRedisClient,
-      jobid,
-      payload
-    )
+    let job = await queueRSSRefreshFeedJob(jobid, payload)
     if (!job || !job.id) {
       throw 'unable to queue rss-refresh-feed-job, job did not enqueue'
     }