const express = require("express");
const bodyParser = require("body-parser");
const { Pool } = require("pg");
const Redis = require("ioredis");
 
const app = express();
app.use(bodyParser.json());
 
// PostgreSQL ও Redis কানেকশন
const pool = new Pool({ connectionString: process.env.PG_URL });
const redis = new Redis(process.env.REDIS_URL);
 
// Webhook Endpoint
app.post("/webhook", async (req, res) => {
  const event = req.body;
 
  // ১. ডেটা Redis-এ ক্যাশ করুন (ফাস্ট প্রসেসিং)
  await redis.lpush("webhook_events", JSON.stringify(event));
 
  // ২. ডেটা PostgreSQL-এ সংরক্ষণ করুন (পারসিস্টেন্স)
  await pool.query(
    "INSERT INTO webhook_events (event_type, payload, received_at) VALUES ($1, $2, NOW())",
    [event.type, JSON.stringify(event.payload)]
  );
 
  res.status(200).json({ received: true });
});
 
app.listen(4000, () => console.log("Webhook server running on port 4000"));

CREATE TABLE webhook_events (
  id SERIAL PRIMARY KEY,
  event_type VARCHAR(255),
  payload JSONB,
  received_at TIMESTAMP DEFAULT NOW()
);

// worker.js
const Redis = require("ioredis");
const redis = new Redis(process.env.REDIS_URL);
 
async function processEvents() {
  while (true) {
    const event = await redis.brpop("webhook_events", 0);
    if (event) {
      const data = JSON.parse(event[1]);
      // এখানে ব্যাকগ্রাউন্ড প্রসেসিং (যেমন: ইমেইল, নোটিফিকেশন)
      console.log("Processing event:", data);
    }
  }
}
 
processEvents();