Как одновременно изменить один и тот же массив в Node.js?

Question

[Артем]

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

Есть такой код:

let product = this.products.find(item => item.code == data.code);
    if (product) {
      product.count = data.count;
    } else {
      await this.pushProduct(data.code, data.count);
    }

В pushProduct выполняется запрос к бд, функция async, запрос через await. Что-то типа такого (вырезаны обработчики ошибок):

const res = await models.product.getByCode(code);
res.count = count;
this.products.push(res);

Логика состоит в том, чтобы массив this.products содержал элементы с уникальным ключом code, т.е. они не должны дублироваться. Если есть элемент с данным кодом, то просто изменить его количество.

Так вот, если пульнуть сразу 5 запросов подряд, то добавятся 5 одинаковых элементов. Если эти запросы выполнять с интервалом в секунду - один элемент.
Как такую проблему решить/что читать? Спасибо!

Answer 1

[Артем]

Решил проблему с помощью библиотеки async-lock.

Answer 2

[Stockholm Syndrome]

если уже существует элемент с таким code, то просто не добавлять его

if (!this.products.find((item) => res.code === item.code)) {
  this.products.push(res);
}

либо я не понял вопроса

Comments

[Артем]

Перед push нужно получить информацию по этому продукту из БД.
А если продукт есть, то нужно изменить его параметр count.

Из-за того, что выполнение запроса к БД занимает определенное время, при обработке остальных запросов this.products будет пустой на момент проверки.

[Stockholm Syndrome]

Артем, проверку на существование продукта можно делать в самой функции pushProduct

const res = await models.product.getByCode(code);
let product = this.products.find((item) => res.code === item.code);
if (product) {
  product.count = count;
} else {
  this.products.push(res);
}

тогда во внешнем коде останется только
await this.pushProduct(data.code, data.count);

при этом если отправить одновременно много запросов, то первый запрос добавит продукт, а остальные — изменят количество

[Артем]

StockholmSyndrome, благодарю за ответ, но проблема останется.
Если код, приведенный вами, выполнится одновременно несколькими запросами, то в результате и добавлений будет ровно столько, сколько запросов пришло одновременно.

Сейчас с смотрю в сторону Redis, чтобы этот массив хранить там. Но тоже пока не разобрался, решит ли это проблему.

[Stockholm Syndrome]

Артем,

Если код, приведенный вами, выполнится одновременно несколькими запросами, то в результате и добавлений будет ровно столько, сколько запросов пришло одновременно.

вроде бы не должны добавляться по несколько раз
набросал небольшой пример, там добавляется только один раз, может что-то не учёл из вопроса

[Артем]

StockholmSyndrome, благодарю! Это отличная идея - сделать небольшой пример. Но проблема в том, что в реальности время запроса к бд - не константа.
Немного изменил ваш код, теперь "запросы" резолвятся через случайное число секунд (от 0.5 до 1.5).
Если запустить несколько раз, то увидим разные результаты.