NodeJS async\await в классах ES6, не работает?

Question

[ettaluni]

Доброго дня! Пытаюсь заставить работать свой код как я его написал.
Есть цепочка вызовов:
module1.init()->module1.getProjectStatus()->module2.isNew(); Естественно все через await\async
Чтобы код отработал хоть немного так как написал я вынужден вставлять async\await функции обертки.
Проблема в том что он пропускает функцию isNew() например, в итоге переменная остается не про инициализированной, выполняет ее в конце, а мне нужно в начале.
Раньше писал на Prototype -> function и вообще проблем не было с асинхронностью, ставил await и будет ждать. Говонокод но работал. А тут решил идти в ногу со временем, на классах все реализовал, конструкторах код сладкий но работает как хочет.
Может эти сахарные конструкции ввиде constructor - class межают реализации await?
Вот пример кода:

let pState = false;
		await (async () => {
			pState = await this.getProjectStatus();
			console.log('pState is getProjectStatus' + pState);
			return;
		})();

		console.log('pState is ' + pState);

		if (pState == 'new')
			await this.prepare();

Пример кода с классом, не знаю зачем.

class SuperClass {
	constructor (settings) {
		if (!this.isCorrectSettings())
			console.log('Settings is incorect');

		let defaultSettings = {
			MAX_UPDATE_TIME: 5, //hours
			PRG_WORK_DIR: __dirname,
			PROJECT_DIR: __dirname,
		};	
		
		this.settings = Object.assign(defaultSettings, settings);


		//T-200
	}
		
	async init() {
		await this.initPaths();
		await this.initModules();
		await this.initVars();

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

isNew() {
	let res = false;
	let deDB = this.deDB;
	let fd =  deDB.run("SELECT id, dt FROM meta", function(err) {
		if (err)
			res = true;
			console.trace('Step1');
		});
	console.trace('Step2 ' + res);
	return res;
}

Я поставил метки в коде, вот собственно вывод. Step1 в конце, а должне быть в начале. Step6 вообще нет.

Step2 false
Step3 false
Step4 contunue
Step5 contunue
End of test - O213k4
getArrayRows - Error ads
getArrayRows - Error matrix
getArrayRows - Error meta
Step1

Comments

[Lynn «Кофеман»]

Не вижу класса

[WbICHA]

await (async () => {
      pState = await this.getProjectStatus();
      console.log('pState is getProjectStatus' + pState);
      return;
    })();

В чём смысл этой обёртки?

[ettaluni]

Lynn «Кофеман», А зачем, синтаксис у него стандартный. Там портянка здоровая из нескольких модулей

[ettaluni]

WbICHA, Без нее программа выполняет нужные мне операции в конце. У меня вся программа так прыгает. Здесь захочу там выполню, это захочу потом.

[WbICHA]

ettaluni, что??? Ты вообще не понимаешь как работает асинк/эвейт?

[ettaluni]

WbICHA, Может быть, давай сверимся

[ettaluni]

WbICHA, Если ты знаешь что, то расскажи. Я убрал все Async await. но все равно часть функций выполняться в конце.

[Lynn «Кофеман»]

ettaluni, без него непонятно о чём вообще вопрос.
Покажите хоть какой-то пример который работает не так как вы хотите.

[Lynn «Кофеман»]

ettaluni, и какая связь между этими кусками кода?
И что же таки не работает?

[ettaluni]

Lynn «Кофеман», Я уточнил вопрос

[Lynn «Кофеман»]

ettaluni, теперь я вижу три несвязанных куска кода.
Где вызывается isNew? Почему это не async-функция?

[ettaluni]

Lynn «Кофеман»,

let fd =  deDB.run("SELECT id, dt FROM meta", function(err) {
		if (err)
			res = true;
     	console.log('Step1');
  		});

callback для функции работы с бд срабатывает последним. А должен первым.

[Lynn «Кофеман»]

Кажется у вас (как обычно у многих) путаница между асинком и коллбеками.

[ettaluni]

Lynn «Кофеман», В документации так, callback запускается по завершении. Библиотека sqlite3. async\await я убрал с ними вообще все в разнабой, безних хотя бы часть по порядку.

[Lynn «Кофеман»]

ettaluni, кому должен?
Он срабатывает тогда когда БД вернёт данные. Но вы нигде не ждёте этого коллбека, а просто продолжаете выполнять код.

Изучать до просветления
https://learn.javascript.ru/promise-basics
https://learn.javascript.ru/promisify

[ettaluni]

Lynn «Кофеман», Я ставил промис, вызвал его выполнение сразу. В итоге сам промис выполняется чуть раньше step1 но все равно в конце оба.

[Максим Анциферов]

async isNew() {
    let res = false;
    let deDB = this.deDB;
    let fd = await new Promise((resolve) => {
      deDB.run('SELECT id, dt FROM meta', function(err) {
        if (err) {
          res = true;
        }
        console.trace('Step1');
        resolve();
      });
    });
    console.trace('Step2 ' + res);
    return res;
  }

[ettaluni]

Максим Анциферов,

[Максим Анциферов]

ettaluni, попробуйте тогда оформить весь свой код в codepen и заменить вызовы к базе на setTimeout, например

deDB.run('SELECT id, dt FROM meta', function(err) {
  if (err) {
    res = true;
  }
  console.trace('Step1');
  resolve();
});

Заменить на

setTimeout(() => {
  if (err) {
    res = true;
  }
  console.trace('Step1');
}, 1000)

Answer 1

[DimaIs]

Если вы хотите вызывать ваши функции после сработки коллбека запроса к БД, то нужно либо:
1) Указать эти функции уже внутри коллбека (он сам вызовет эти функции)
2) Промисифировать функцию вызова бд, чтобы можно было применять к ней await (или then, кому как удобно):

const runBdQuery = query =>  new Promise((resolve, reject) => {
        deDB.run(query, function(err) {
            if (err)
                   reject(err);
               res = true;
               resolve(res) // тут все что угодно
     	    console.log('Step1');
  	});
    })

Далее можно делать так:

const makeQuery = async () => {
    const query = "SELECT id, dt FROM meta";
    await runBdQuery(query);
    await step1();
   ----------
     await step6();
}
makeQuery();

Comments

[ettaluni]

let promise = new Promise(function(resolve, reject) {
			let pRes = false;
  			deDB.run("SELECT id, dt FROM meta", function(err) {
				if (err)
					pRes = true;

     			console.log('Step1');
  			});

  			resolve(pRes);
  		});

  		await promise.then(
		  function(result) { res = result;/* обработает успешное выполнение */ 
		  	console.log('Я в промисе');
		  },
		  function(error) { /* обработает ошибку */ console.log('Я в промисе');}
		);

Я оборачивал ее в промис step1 все равно в конце, по меткам "Я в промисе", созданный промис срабатывает раньше step1

[DimaIs]

ettaluni, вы вызываете метод resolve не внутри коллбека запроса к БД. Промис резолвится внезависимости от того, выполнился этот коллбек или нет. Посмотри еще раз на мой код

[DimaIs]

ettaluni, также непонятен ваш синтаксический оборот:
await asyncFunction().then(() =>);

[ettaluni]

DimaIs, Да извини, твой код сработал. Не знал что можно resolve запускать хоть откуда, думал что у него как у this своя область видимости.

[ettaluni]

Где же ты был раньше((( Я два-три дня эту фигню мусолю
Но, спасибо.