Как сделать асинхронным вызов setTimeout и рекурсии?

Question

[Александр Буки]

Коллеги, просьба помочь.
Есть несколько запросов на сервер. В замен сервер создает задачи по эти запросам и отдает id задачи, по которому я проверяю статус выполнения задачи другим запросом.
Когда все задачи выполнены, необходимо продолжить выполнение синхронного кода.
Как дождаться выполнения всех задач?

Вот как это устроено у меня:

async getTaskStatus(id, resolve) {
            if (!this.queryCounter) {
                this.queryCounter = 0;
            }
            if (this.queryCounter > 20) {
                return this.errHandler();
            }
            try {
                const { data: { data: { status } } } = await checkTaskStatus(id);
                if (status === 'done') {
                    return resolve();
                } if (status === 'error') {
                    this.$message.error('Ошибка проведения операции, попробуйте позже');
                    this.$router.push('/users');
                } else {
                    setTimeout( () => {
                        this.queryCounter++;
                        this.getTaskStatus(id, resolve);
                    }, 500);
                }
            } catch (e) {
                console.error(e);
            }
        };

       try {
                        const { id } = this.ruleForm.user_dto;
                        const tasks = [];
                        tasks.push(updateUserData(id));
                        tasks.push(updateATTRData(id));
                       tasks.push(updateOldATTRData(id));

                        const results = await Promise.all(tasks);
                        for (let i = 0; i < results.length; i++) {
                            if (results[i].data.validation_result.success === true) {
                                let resolve = () => Promise.resolve();
                                await this.getTaskStatus(results[i].data.data, resolve);
                            } else {
                                this.errHandler();
                            }
                        }
                        this.setUser(this.userId);
                        this.editAdmin = false;
                    } catch (e) {
                        this.errHandler();
                        console.error(e);
                    }

Соответственно идут первые запросы в цикле и продолжается выполнение кода.
В функции получении статуса есть рекурсия через SetTimeout, тут по сути код и перестает быть асинхронным.
Как дождаться получения статусов с выполненными задачами?

Answer 1

[Владимир Скибин]

Оберните все в анонимный async, а дальше два Promise.all. Суть в то, что Вам придется "внести" Ваш синхронный код в асинхронный "then" через await или Promise - не важно.
Примерно вот так должна быть конструкция

(async () => {
let reqs = [];

async function doTasks() {
return Promise.all( reqs.map((req) => doReq(req)) )
  .then((tasks) => Promise.all( tasks.map((task) => checkStatus(task)) ))
  .catch(console.error);
};

await doTasks();

// do some sync code
})();

Comments

[Александр Буки]

Спасибо, сейчас попробую

[Александр Буки]

получается, что checkStatus(task) выполняется асинхронно один раз, и=видимо из-за setTimeout асинхронность разваливается.
Код выполняется, но синхронно.

[Владимир Скибин]

alexbuki, checkStatus должен возвращать промис. Сам setTimeout тоже заверните в промис и сможете его прокинуть.

[Александр Буки]

да, получилось, сделал так:

return new Promise(async (res) => {
                        setTimeout(async () => {
                            this.queryCounter++;
                            res(this.getTaskStatus(id, resolve));
                        }, 500);
                    });

Подскажите это как-то через async await можно оформить?
Ну или вообще как-то посиматичнее?
для вывода ошибок использовать reject?

[Александр Буки]

Спасибо вам большое!

[Владимир Скибин]

alexbuki, я в своем коде стараюсь избегать async/await поскольку они являются синтаксическим сахаром над Promise по своей природе. У Вас в коде используется и то и другое, что, как по мне, является "грязью".
Для оборачивания setTimeout и прочих колбеков:

return new Promise((resolve, reject) => {
  setTimeout(function() {
    if (Math.random() > 0.5) {
      return reject(new Error('some error');
    }
    resolve(1);
  }, 1000);
})

[Александр Буки]

async убрал)