estou tentando aprender a usar o async await mas, estou errando em algo e preciso de ajuda. Meu método funciona como esperado com Promise vejam:
import express from 'express';
import conn from '../models/connection';
const c = conn;
class ClientRoutes {
...
getMainPage(req, res, next) {
c.openConection().then((a) => {
console.log(a);
res.render('index', {title: 'Abner'})
})
}
...
quando eu vejo através do console.log chega normalmente os dados que preciso; a classe/método que fornece é:
import r from 'rethinkdb';
class Db_Conection {
openConection(req, res, next) {
return new Promise((resolve) => {
r.connect({host: process.env.DB_HOST, port: process.env.DB_PORT}, (err, conn) => {
if ( err && err.name === 'ReqlDriverError' && err.message.indexOf( 'Could not connect' ) === 0 && ++count < 3 ) {
console.log( err );
return;
}
resolve(conn);
})
})
}
...
Quero transformar isso usando async e await daí tentei mas deu errado o seguinte:
...
async openConection(req, res, next) {
r.connect({host: process.env.DB_HOST, port: process.env.DB_PORT}, (err, conn) => {
if ( err && err.name === 'ReqlDriverError' && err.message.indexOf( 'Could not connect' ) === 0 && ++count < 3 ) {
console.log( err );
return;
}
return conn;
})
}
...
Acima o retorna vira um promise, até ai ok... Mas quando vou receber só me retorna undefined.
...
async getMainPage(req, res, next) {
const b = await c.openConection();
console.log(b);
// res.render('index', {title: 'Abner'})
}
...
Não sei onde estou errando. Ficarei grato por sua ajuda.