Почему событие срабатывает несколько раз?

Question

[Senbonzakuraa]

Основной класс:

class Random {
        constructor(timer) {
            this.timer = timer
            this.status = 0
            this.emitter = new EventEmitter()
        }
        async setStatus() {
            const interval = setInterval(()=> {
                this.timer -= 1
                if(this.timer <= 0) {
                    this.status = 1
                    this.emitter.emit('end', this.status)
                }
            }, 1000)
        }
    
}

Клиентский код:

const Random = require('../Random').Random
const chanels = {}
const timers = [{timer: 20, name: "chanel1"},{timer: 400, "chanel2"}]
timers.map((timer,id) => chanels[timer.name] = new Random(timer.time))
socket.on('startTimer', async (name, callback) => {
    await chanels[name].setStatus()
    chanels[name].emitter.on('end', (data)=> {
        console.log(data) //Выводит несколько раз подряд содержимое Data
    })
})

Я думал, что это возможно из-за того, что каждый раз при коннекте юзера создается новый слушатель события chanels[name].emitter.on('end'), но я пробовал ставить вместо on - once, но все равно событие срабатывает рандомное кол-во раз. Пробовал очищать слушателей chanels[name].emitter.removeAllListeners(['end']); перед созданием нового, но результат тот же. Почему так происходит?

Comments

[Senbonzakuraa]

DevMan, зачем править теги вопроса, если у меня вопрос по либе emitter

[Роман]

Senbonzakuraa, вот вам подсказка

код

const EventEmitter = require('events');

class Counter extends EventEmitter {
    constructor(timer) {
        super();
        if (typeof timer === "number" && timer > 0) {
            this.start(timer);
        }
    }
    start(timer = 0) {
        if (this.intervalId) {
            this.stop();
        }
        this.timer = timer;
        this.emit('start', this.timer);
        this.intervalId = setInterval(() => {
            this.timer -= 1
            if (this.timer > 0) {
                this.emit('process', this.timer);
            } else {
                this.stop();
            }

        }, 1000)
    }
    stop() {
        clearInterval(this.intervalId);
        this.intervalId = undefined;
        this.emit('end', this.timer);

    }

}

const counter = new Counter();

counter.on("start", timer => console.log("start", timer));
counter.on("process", timer => console.log("process", timer));
counter.on("end", timer => console.log("end", timer));

counter.start(10)

вывод в консоль

start 10
process 9
process 8
process 7
process 6
process 5
process 4
process 3
process 2
process 1
end 0

[DevMan]

Senbonzakuraa, зачем ставить тег экспресс, если вопрос по конкретной нодовой либе?

Answer 1

[Роман]

у вас 2 косяка в коде.

Первый вы поняли сами, каждый раз при коннекте вы запускаете новый слушатель события "end", и даже если событие возникнит 1 раз, а слушатели стоят как once то все равно сработает каждый из уже запущенных, но еще ни разу не сработавших слушателей.

Второй косяк - это то что вы не завершаете запущенный setInterval, который каждую секунду продолжает уменьшать таймер, даже после того как таймер станет меньше нуля. В результате, когда таймер достигает нуля у вас начинает срабатывать условие if(this.timer <= 0) на каждый тик

Comments

[Senbonzakuraa]

С интервалом я тоже понял практически сразу же. Получается в моем случае никак не сделать чтоб событие срабатывало 1 раз, уже с исправленным интервалом?

[Роман]

Senbonzakuraa, почему никак, все нормально реализуемо. Просто при реконнекте проверяйте не висят ли у вас старые таймеры от предыдущих коннектов и делайте им stop(). Смотрите пример кода в моем комментарии к вопросу. Отловить досрочное завершение в событии on можно по значению таймера, если оно больше нуля, таймер завершен досрочно (скорее всего при реконнекте)))

[Роман]

Senbonzakuraa, или немного измените серверный код, чтобы он не посылал событие startTimer при реконнекте если на клиенте уже запущен таймер.

[Роман]

Senbonzakuraa, ну и если бы я знал что это за задача, и как именно должны вести себя таймеры при реконнектах, то всю логику, нацеленную на достижение нужного поведения можно было бы убрать в класс и не парится.