AI Blog Automation Platform

const { Worker } = require("bullmq");
const Redis = require("ioredis");
const { generateArticleDraft } = require("../services/gemini");
const { saveDraftToDb } = require("../services/db");

const connection = new Redis(process.env.REDIS_URL);

const contentWorker = new Worker("content-generation", async (job) => {
  const { topic, outline, researchData } = job.data;
  
  // Call AI Service to write draft
  const draft = await generateArticleDraft({
    topic,
    outline,
    research: researchData
  });
  
  // Save intermediate draft to PostgreSQL
  const draftId = await saveDraftToDb(job.id, topic, draft);
  
  return { draftId, nextStep: "review" };
}, {
  connection,
  limiter: {
    max: 10,
    duration: 60000 // Limit to 10 API requests per minute to prevent Gemini rate limit errors
  }
});

import { Queue } from "bullmq";
import { checkDuplicateTopic } from "../services/db";

const researchQueue = new Queue("research-queue");

async function scanTrends() {
  const trendingTopics = await fetchTrendingTechTopics(); // Google News / GitHub APIs
  
  for (const topic of trendingTopics) {
    const isDuplicate = await checkDuplicateTopic(topic.title);
    if (!isDuplicate) {
      await researchQueue.add("fetch-topic-context", {
        topic: topic.title,
        source: topic.source,
        timestamp: new Date()
      }, {
        attempts: 3,
        backoff: { type: "exponential", delay: 5000 }
      });
    }
  }
}