Как заставить все запросы ждать один промис?

Question

[olezhenka]

Много пользователей совершают действие, где мне надо либо забрать с переменной объект, а если его нету - загрузить с бд и записать в эту переменную.
Проблема - когда много юзеров быстро совершают действие, у меня дублируются запросы в бд и собственно объекты тоже. Как заставить последующие запросы, после первогоо запроса загрузки, ждать именно первого, а не начинать грузить самим?

// внутри async function
chat.quiz = global_quizzes[quiz_id];
if(!chat.quiz) {
    // проблема в дубли
    chat.quiz = await Chat_Quizzes.findById(quiz_id).exec();
    global_quizzes[quiz_id] = chat.quiz;
}

Comments

[Егор Живагин]

ИМХО, лучшим решением тут будет настроить кэш на уровне БД. А одинаковые запросы - это нормально.

[olezhenka]

Егор Живагин, да просто в моем случае не нормально. После загрузки объекта из бд я добавляю в него ещё свои дополнительные функции и объекты которым дублировать не нужно.

Answer 1

[Inviz Custos]

Можете использовать очередь

Пример:

'use strict';

const { Queue } = require('plain-queue');
const queue = new Queue;

// внутри async function
    chat.quiz = global_quizzes[quiz_id];
    
    if(!chat.quiz) {
        chat.quiz = await queue.addTask(function () {
            return global_quizzes[quiz_id] || Chat_Quizzes.findById(quiz_id).exec();
        });

        global_quizzes[quiz_id] = chat.quiz;
    }

Answer 2

[Роман]

Как подсказал Inviz Custos, очередь решит вашу проблему (если конечно правильно будет работать с дублирующими запросами и промисами)

Вот простенький рабочий пример

// внутри async function
let quiz = global_quizzes[quiz_id];
if(!quiz) {
    global_quizzes[quiz_id] = quiz = Chat_Quizzes.findById(quiz_id).exec();
}

if( quiz instanceof Promise ){
    global_quizzes[quiz_id] = quiz = await quiz;
} 
chat.quiz = quiz;

PS: правда это не совсем очередь, но ваш global_quizzes в некоторой степени ее имитирует.

Comments

[olezhenka]

Спасибо за пример)

[Роман]

olezhenka, не за что. Всегда рад помочь)))

Answer 3

[Виталий]

ОРМ +КЕШ...