Как удалить конкретный слушатель socket.io?

Question

[jenya7771]

Здравствуйте, есть вот такая функция

exports.list = () => {

	return new Promise((resolve, reject) => {

		try {

			if (conect) {

				const hash = crypto.randomBytes(30).toString('hex')
				
				socket
				.emit('list', JSON.stringify({
					auth: key,
					hash: hash
				}))
				.on('list', (data) => {

					data = JSON.parse(data) 

					if (data.hash === hash) {

						resolve(data.list)
					}
				});
			} else {

				reject(new Error('Disconnect to socket API'))
			}
		} catch (error) {

			reject(error)
		}	
	})
}

И она вызывается очень часто, и как я понимаю при каждом вызове я создаю слушатель list, и после того как я получаю ответ он не удаляется и из-за этого огромная нагрузка на сервер, сегодня уже задавал вопрос.
Как я понимаю после получения ответа от слушателя мне нужно его удалить, но как удалить конкретный слушатель List, а не все?
Socket использую для получения данных (как API), и как сделать тоже самое с одним слушателем не знаю, может кто делал что подобное, и есть выход из такой ситуации?

Answer 1

[Владлен Хеллсайт]

Есть два варианта:
1. Поставьте слушатель глобально и не удаляйте его. (Более правильно)
2. Использовать вместо .on(), .once(). Он создаёт слушатель и после одного события его удалит.

Comments

[jenya7771]

Я хотел бы конечно более правильный вариант использовать, но не не очень понимаю как. У меня есть сервис который отвечает за получение данных через сокеты (он в примере, list), как для глобального внедрения его переработать, если понимаете можете описать принцип?

[Владлен Хеллсайт]

jenya7771, при подключении сокета вешать на него обработчики. Просто не показано как именно он вызывает list()

[jenya7771]

Ну вот эту функцию List вот так вызываю

servises.socket.list()
		.then(data => {
})

[Владлен Хеллсайт]

jenya7771, покажите код подключения сокета.

[jenya7771]

Владлен Хеллсайт,

const socket = io(config.api.socketHost, {
	autoConnect: true,
	reconnection: true,
	timeout: 35000,
	reconnectionDelay: 600,
	reconnectionDelayMax: 3500,
	query: {
		auth: config.api.socketKey
	}
})
.open();

try {

	socket
	.on('connect', () => {

		logger.info('Connect to socket API')
	})
	.on('disconnect', () => {

		logger.error('Disconnect to socket API')
	})
	.on('connect_error', (error) => {

		logger.error('Error connect to socket API', error)
	})
	.on('connect_timeout', (error) => {

		logger.error('Сonnect to socket API timeout', error)
	})
	.on('reconnecting', (attempt) => {

		logger.warn('Error reconnecting to socket API', null, {
			attempt: attempt
		})
	})
	.on('reconnect_failed', (reconnectionAttempts) => {

		logger.warn('Failed connect to socket API', null, {
			reconnectionAttempts: reconnectionAttempts
		})
	})
	.on('reconnect_error', (error) => {

		logger.error('Error reconect to socket API', error)
	})
} catch (error) {

	logger.error('Error conect socket API', error)
}

Вот так у меня реализовано подключение

[Владлен Хеллсайт]

jenya7771, это клиентская или серверная часть?

[jenya7771]

Владлен Хеллсайт, Я являюсь клиентом.

[Владлен Хеллсайт]

jenya7771, тогда продолжайте цепочку socket c .on() и туда вешайте событие .on('list').

[jenya7771]

Владлен Хеллсайт, Насовсем понял? Можете пример пожалуйста показать?

[Владлен Хеллсайт]

const socket = io(config.api.socketHost, {
	autoConnect: true,
	reconnection: true,
	timeout: 35000,
	reconnectionDelay: 600,
	reconnectionDelayMax: 3500,
	query: {
		auth: config.api.socketKey
	}
})
.open();

const hashes = new Set();

try {

	socket
	.on('connect', () => {

		logger.info('Connect to socket API')
	})
	.on('disconnect', () => {

		logger.error('Disconnect to socket API')
	})
	.on('connect_error', (error) => {

		logger.error('Error connect to socket API', error)
	})
	.on('connect_timeout', (error) => {

		logger.error('Сonnect to socket API timeout', error)
	})
	.on('reconnecting', (attempt) => {

		logger.warn('Error reconnecting to socket API', null, {
			attempt: attempt
		})
	})
	.on('reconnect_failed', (reconnectionAttempts) => {

		logger.warn('Failed connect to socket API', null, {
			reconnectionAttempts: reconnectionAttempts
		})
	})
	.on('reconnect_error', (error) => {

		logger.error('Error reconect to socket API', error)
	})
	.on('list', (data) => {
		// Тут уже реализовывать другую логику с хэшами. Например так
		if (!hashes.has(data.hash)) {
			return; // Если нет хэша
		}

		hashes.delete(data.hash);

		doSomething(data);
	});
} catch (error) {

	logger.error('Error conect socket API', error)
}

function emitListHash() {
	const hash = crypto.randomBytes(30).toString('hex');

	hashes.add(hash);

	socket.emit('list', {
		auth: key,
		hash
	});
}

[jenya7771]

Владлен Хеллсайт, Примерно понял, спасибо огромное!

[jenya7771]

Владлен Хеллсайт, Может знаете как я могу в промис отослать результат? Например я буду использовать промис для получения данных, я через него отсылаю запрос (emit) и после того как ответ приходит в on promis мне нужно его вернуть обратно в промис, как можно вернуть?

[Владлен Хеллсайт]

jenya7771, почти тоже самое, emitListHash должен возвращать Promise, заменить Set на Map и уже по хешу держать функции hash: {resolve, reject}.