const EventEmitter = require("events");
const Redis = require("ioredis");
const Sub = new Redis();
const Pub = new Redis();
const { promisify } = require("util");
const uuid = require("uuid");
class LaravelService extends EventEmitter {
    constructor(action, data) {
        super();
        console.log("new LaravelService ...");
        this.response = null;
        this.channelName =
            process.env.LARAVEL_REDIS_CHANNEL ?? "laravel_database_general";
        this.data = data;
        this.action = action ?? "subscribed";
        this.configs = {};
        // ایجاد اشتراک بر روی کانال Redis
        Sub.subscribe(this.channelName, (err) => {
            if (err) {
                console.error("Subscription error:", err);
                return;
            }

            //  console.log(`Subscribed to channel: ${this.channelName}`);
        });

        // رویداد دریافت داده‌ها از کانال Redis
        Sub.on("message", (channel, message) => {
            this.parseResponse(message);
        });
        this.call(this.action, this.data);
    }

    async call2(action, data) {
        await Pub.publish(
            this.channelName + "_sender",
            JSON.stringify({ action, data, source: "nodejs" })
        );
    }

    call(action, data) {
        return new Promise((resolve, reject) => {
            const requestId = uuid.v4(); // ایجاد کد یونیک
            const requestData = { action, data, requestId, source: "nodejs" };
            const requestChannel = this.channelName + "_sender";

            const responseCallback = (channel, message) => {
                //console.log("Response received:", message);

                const response = this.parseResponse(message);
                if (response.requestId === requestId) {
                    // بررسی تطابق کد یونیک
                    Sub.removeListener("message", responseCallback);
                    resolve({ response, channel });
                }
            };
            Sub.on("message", responseCallback);

            Pub.publish(requestChannel, JSON.stringify(requestData), (err) => {
                if (err) {
                    reject(err);
                }
            });

            // تنظیم timeout برای 5 ثانیه
            const timeoutDuration = 5000; // 5 ثانیه
            setTimeout(() => {
                Sub.removeListener("message", responseCallback);
                reject(new Error("Timeout exceeded")); // ارسال خطای timeout
            }, timeoutDuration);
        });
    }

    parseResponse(message) {
        const data = JSON.parse(message);
        if (data && data.source && data.source !== "nodejs") {
            this.response = data;
            if (data.action == "configs") this.configs = data;
            this.emit("message", data);
        }
        return data;
    }
}

module.exports = LaravelService;

const LaravelService = require("./path/to/LaravelService.js");
const LaravelServiceInstance = new LaravelService("commandName", { foo: "bar" });