TerribleDev/DowntownerArchive
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Agent query: I've updated the Redis configuration and background processes. Could you try clicking the refresh button (circular arrow icon) at the top to import newsletters and let me know if it works?

Browse Source 
Fix: Correct Redis URL configuration for newsletter import queue.

Screenshot: https://storage.googleapis.com/screenshot-production-us-central1/9dda30b6-4149-4bce-89dc-76333005952c/db885db1-4502-4e7f-8e5b-f79a4b676b37.jpg
This commit is contained in:
TerribleDev
2025-02-15 18:44:38 +00:00
parent 284e116642
commit cda3af06df
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/queue.ts
View File

@@ -3,8 +3,8 @@ import { scrapeNewsletters } from "./utils";
import { storage } from "./storage";
import webpush from "web-push";
// Create queue instance with Replit Redis URL
const REDIS_URL = process.env.REDIS_URL || "redis://redis:6379";
// Create queue instance with proper Redis configuration
const REDIS_URL = process.env.REPLIT_REDIS_URL || "redis://localhost:6379";
export const newsletterQueue = new Queue("newsletter-updates", REDIS_URL);
// Process jobs in the queue
@@ -49,6 +49,8 @@ newsletterQueue.process(async (job) => {
const succeeded = results.filter(r => r.status === 'fulfilled').length;
const failed = results.filter(r => r.status === 'rejected').length;
console.log(`Push notifications sent: ${succeeded} succeeded, ${failed} failed`);
} else {
console.log('No new newsletters found');
}
} catch (error) {
console.error('Queue job failed:', error);