Как в nodejs и модуля mysql вытащить данные для middleware?

Question

[RomanSS]

Подскажите как правильно решить задачу. Перед тем как подключится к socket.io, нужно запустить свой middleware который вытаскивает данные из базы и записывает в сокет, нужно чтобы при событии коннекта, в сокете уже хранилась информация из базы. Проблема в том, что запрос к базе асинхронный, и при коннекте данных еще может не быть.

var express = require('express');
var app = express();
var mysql = require('mysql');
var server = require('http').createServer(app);
var io = require('socket.io')(server);

io.use(function (socket, next) {

   // Как сделать запрос к mysql, так чтобы при коннекте к сокету они уже были прописаны в сокете?
    socket.mysql_data="значение из базы";
    next();

});

io.on('connection', function (socket) {
    // socket.mysql_data должна уже содержать данные из базы 
});

Answer 1

[Виталий]

Вызывать next() в колбэке бд - там где данные уже вернулись.

Comments

[RomanSS]

Виталий, я правильно понимаю, если не вызвать next() то соединение висит на ноде, но дальнейшая обработка приложения останавливается?

[Виталий]

RomanSS: не знаю, каким драйвером вы пользуетесь, обычно открытое соединение не даёт скрипту завершиться. Обработка приложения не останавливается.

[RomanSS]

Виталий: я наверное не правильно выразился, если я в io.use(function (socket, next) {} не выполню функцию next() у меня и событие коннекта не произойдет io.on('connection', function (socket) {}), верно? Т.е. я думал next() влияет только на цепочку функций и если его не вызвать, то он просто прерывает эту цепочку, а оказывается если его не вызвать он блокирует выполнение дальнейшего кода?

[Виталий]

RomanSS: а слабо просто взять и проверить?

[RomanSS]

Виталий: методом тыка можно много что проверить, но не факт что это правильное решение, хотелось бы понимания работы, в документации этот момент нигде найти не могу. Ваше решение рабочее, спасибо.

[Виталий]

RomanSS: в большинстве случаев node.js работает именно так - тут не нужны дополнительные пояснения, потому что это базовый принцип асинхронного программирования с использованием middleware.