Guest User

Untitled

a guest
Jul 17th, 2018
107
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.12 KB | None | 0 0
  1. import express from 'express';
  2. import conn from '../models/connection';
  3. const c = conn;
  4.  
  5. class ClientRoutes {
  6. ...
  7. getMainPage(req, res, next) {
  8. c.openConection().then((a) => {
  9. console.log(a);
  10. res.render('index', {title: 'Abner'})
  11. })
  12. }
  13. ...
  14.  
  15. import r from 'rethinkdb';
  16.  
  17. class Db_Conection {
  18.  
  19. openConection(req, res, next) {
  20. return new Promise((resolve) => {
  21. r.connect({host: process.env.DB_HOST, port: process.env.DB_PORT}, (err, conn) => {
  22. if ( err && err.name === 'ReqlDriverError' && err.message.indexOf( 'Could not connect' ) === 0 && ++count < 3 ) {
  23. console.log( err );
  24. return;
  25. }
  26. resolve(conn);
  27. })
  28. })
  29. }
  30. ...
  31.  
  32. ...
  33. async openConection(req, res, next) {
  34. r.connect({host: process.env.DB_HOST, port: process.env.DB_PORT}, (err, conn) => {
  35. if ( err && err.name === 'ReqlDriverError' && err.message.indexOf( 'Could not connect' ) === 0 && ++count < 3 ) {
  36. console.log( err );
  37. return;
  38. }
  39. return conn;
  40. })
  41. }
  42. ...
  43.  
  44. ...
  45. async getMainPage(req, res, next) {
  46. const b = await c.openConection();
  47. console.log(b);
  48. // res.render('index', {title: 'Abner'})
  49. }
  50. ...
  51.  
  52. openConection(req, res, next) {
  53. return new Promise((resolve) => {
  54. r.connect({host: process.env.DB_HOST, port: process.env.DB_PORT}, (err, conn) => {
  55. if ( err && err.name === 'ReqlDriverError' && err.message.indexOf( 'Could not connect' ) === 0 && ++count < 3 ) {
  56. console.log( err );
  57. return;
  58. }
  59. resolve(conn);
  60. })
  61. })
  62. }
  63.  
  64. async getMainPage(req, res, next) {
  65. try {
  66. const b = await c.openConnection();
  67. console.log(b);
  68. res.render('index', {title: 'Abner'})
  69. } catch (error) {
  70. // Caso a promise seja rejeitada, trata o erro
  71. res.status(500).json({mgs: "Um erro ocorreu"})
  72. }
Add Comment
Please, Sign In to add comment