const { TelegramClient } = require("telegram");

module.exports = function (RED) {
    function IterDialogs(config) {
        RED.nodes.createNode(this, config);
        this.config = RED.nodes.getNode(config.config);
        var node = this;

        this.on('input', async function (msg) {
    
            /** @type {TelegramClient} */
            const client = msg.payload?.client ? msg.payload.client : this.config.client;
            const limit = msg.payload.limit || config.limit;
            const offsetDate = msg.payload.offsetDate || config.offsetDate;
            const offsetId = msg.payload.offsetId || config.offsetId;
            const offsetPeer = msg.payload?.offsetPeer || undefined; 
            const ignorePinned = msg.payload.ignorePinned || config.ignorePinned;
            const ignoreMigrated = msg.payload.ignoreMigrated || config.ignoreMigrated;
            const folder = msg.payload.folder || config.folder;
            const archived = msg.payload.archived || config.archived;
            
            const params = {
             limit: limit !== ""? parseInt(limit) : undefined,
             offsetDate: offsetDate !== "" ? offsetDate:undefined,
             offsetId: offsetId !== "" ? parseInt(offsetId):undefined,
             offsetPeer: offsetPeer,
             ignorePinned: ignorePinned,
             ignoreMigrated: ignoreMigrated,
             folder: folder !== "" ? parseInt(folder):undefined,
             archived: archived,
            }

            if (offsetDate) {
                params.offsetDate = new Date(offsetDate).getTime() / 1000;
            }

            try {
                const dialogs = {};
                for await (const dialog of client.iterDialogs(params)){
                    dialogs[dialog.id] = dialog;
                    console.log(`${dialog.id}: ${dialog.title}`);
                }
                node.send({
                    payload: { dialogs },
                });
            } catch (err) {
                node.error('Error iter dialogs: ' + err.message);
            }

        });
    }

    RED.nodes.registerType('iter-dialogs', IterDialogs);
};