Почему массив всегда пуст?

Question

[historydev]

Пытаюсь передать данные выше из промиса:

const result = response.map(meeting => {
			const members: any[] = [];

			meeting['members'].forEach((user_id: string, i: number) => {
				query('users').then(data => {
					const user = data.collection.findOne({id: user_id});
					members.push(user);
				}).catch(console.error);
			});

			return {
				...meeting,
				members
			}
		});

Почему массив members пустой по итогу?

Comments

[Алексей Уколов]

А зачем вы запрос query('users') делаете в цикле снова и снова? Мало того, что это тормозит код и создаёт ненужную нагрузку, это ещё и с точки зрения асинхронности всё усложняет.

UPD: А, это моё незнание экосистемы Ноды. Query запрос не делает, а только готовит, а сам запрос идёт уже в findOne и его действительно нужно делать в цикле. Если, конечно, там нет конструкции, которая позволит за один запрос всё выбрать, передав массив id.

[historydev]

Алексей Уколов, поправил:

const users = query('users');

	query('meetings').then(async data => {
		const response = await data.collection.find({members: { $in: [res.locals['user'].id]}}).toArray();
		const result = response.map(meeting => {
			const members: any[] = [];

			meeting['members'].forEach((user_id: string, i: number) => {
				users.then(data => {
					return data.collection.findOne({id: user_id});
				}).then(user => members.push(user)).catch(console.error);
			});

			return {
				...meeting,
				members
			}
		});

		console.log(result);

		res.send({
			message: result
		});

	});

Answer 1

[Алексей Уколов]

Потому что асинхронность работает не так, как вы хотите. Колбэк в then вызывается уже после return.
Статей (и вопросов здесь) на тему «асинхронность в JavaScript» огромное количество — выбирайте какая понравится и изучайте.

Comments

[historydev]

Это я понимаю, как мне поступить в этой ситуации?

[Алексей Уколов]

Это я понимаю

По тексту вопроса не похоже ¯\_(ツ)_/¯

как мне поступить

выбирайте какая понравится и изучайте

Реально, мы в рамках ответа на вопрос вас асинхронности не научим. А в сотый раз повторять одни и те же принципы лично я не хочу.

[Алексей Уколов]

Вот вы привели пример кода. Там есть async/awit и then. Разберитесь, зачем они нужны и чем отличаются. Потом на псевдокоде для себя опишите процесс выполнения вашей задачи, помечая места с асинхронностью. Потом этот псевдокод превртите в настоящий.

[historydev]

Алексей Уколов, Что вы думаете на счёт такого решения?

export async function meetings_controller(req: Request, res: Response, next: NextFunction) {

	const users = await query('users');
	const meetings = await query('meetings');

	const response = await meetings.collection.find({members: { $in: [res.locals['user'].id]}}).toArray();

	for(let i = 0; i < response.length; i++) {
		for(let m = 0; m < response[i]['members'].length; m++) {
			response[i]['members'][m] = await users.collection.findOne({id: response[i]['members'][m]});
		}

	}

	console.log(response);

	res.send({
		message: response
	});
}

[Алексей Уколов]

Глубоко я его не анализировал, но на беглый взгляд выглядит как минимум работающим. Дальше уже можно наворачивать оптимизацию с параллельными запросами на поиск пользователей через Promise.all.

[historydev]

Алексей Уколов, спасибо

[historydev]

Алексей Уколов, спасибо

Answer 2

[Inviz Custos]

Потому, что Вы пытаетесь из синхронного кода вернуть результат работы асинхронного.

Comments

[historydev]

У меня функция работает с бд асинхронно, я не могу синхронной её сделать, как мне поступить?

[Inviz Custos]

Владимир, очевидно же - писать асинхронный код)

[historydev]

Inviz Custos,

query('meetings').then(async data => {
		const response = await data.collection.find({members: { $in: [res.locals['user'].id]}}).toArray();
		const result = response.map(meeting => {
			const members: any[] = [];

			meeting['members'].forEach((user_id: string, i: number) => {
				query('users').then(data => {
					return data.collection.findOne({id: user_id});
				}).then(user => members.push(user)).catch(console.error);
			});

			return {
				...meeting,
				members
			}
		});

		console.log(result);

		res.send({
			message: result
		});

	});

[historydev]

Inviz Custos, вот так у меня выглядит весь запрос

[Inviz Custos]

Владимир, выглядит ужасно, Вы попытались смешать все в кучу, при этом не понимая как оно должно работать. Я бы рекомендовал пока остановиться и вернуться к документации. Например:
https://developer.mozilla.org/en-US/docs/Web/JavaS...

[historydev]

Inviz Custos, что вы думаете на счёт такого решения?

export async function meetings_controller(req: Request, res: Response, next: NextFunction) {

	const users = await query('users');
	const meetings = await query('meetings');

	const response = await meetings.collection.find({members: { $in: [res.locals['user'].id]}}).toArray();

	for(let i = 0; i < response.length; i++) {
		for(let m = 0; m < response[i]['members'].length; m++) {
			response[i]['members'][m] = await users.collection.findOne({id: response[i]['members'][m]});
		}

	}

	console.log(response);

	res.send({
		message: response
	});
}

Answer 3

[dcooder]

в вашем случае вероятно подойдет трюк с async - await. То есть ваша функция должна быть асинхронной, например:

async getUsers() {
     const users = await query('users');
     const members = meeting['members'].map((user_id) => users.collection.findOne({id: user_id}));
     return [...meetings, members]
}

Comments

[historydev]

это тоже промис:

users.collection.findOne({id: member_id})

[historydev]

const users = await query('users');

	query('meetings').then(async data => {
		const response = await data.collection.find({members: { $in: [res.locals['user'].id]}}).toArray();
		const result = response.map(meeting => {

			const members = meeting['members'].map((member_id: string) => {
				return users.collection.findOne({id: member_id});
			});

			return {
				...meeting,
				members
			}
		});

		console.log(result);

		res.send({
			message: result
		});

	});

members: [Promise, Promise]

[dcooder]

В вашем случае от then лучше вообще отказаться.

const users = await query('users');

 const meetings = await query('meetings');

    const response = meetings.collection.find({members: { $in: [res.locals['user'].id]}}).toArray();
    const result = response.map(meeting => {

      const members = meeting['members'].map((member_id: string) => {
        return users.collection.findOne({id: member_id});
      });

      return {
        ...meeting,
        members
      }
    });

    console.log(result);

    res.send({
      message: result
    });

  });

[historydev]

dcooder, я отказался, вот так работает как нужно:

export async function meetings_controller(req: Request, res: Response, next: NextFunction) {

	const users = await query('users');
	const meetings = await query('meetings');

	const response = await meetings.collection.find({members: { $in: [res.locals['user'].id]}}).toArray();

	for(let i = 0; i < response.length; i++) {
		for(let m = 0; m < response[i]['members'].length; m++) {
			response[i]['members'][m] = await users.collection.findOne({id: response[i]['members'][m]});
		}

	}

	console.log(response);

	res.send({
		message: response
	});
}

[dcooder]

await как раз вытаскивает содержимое промиса, его стоит использовать вместо then внутри асинхронных функций

[historydev]

dcooder, если я функции в map установлю async, я получу промисы на уровень выше, вместо meeting будет промис