Socket.io испускают не называется

Question

у меня есть этот код здесь

io.on("connection", function(socket){ 

    //other methods where emit works 

    socket.on("login", function(data) { 
     try { 
      pg.connect(conString, function(err, con) { 
       var query = con.query("SELECT * FROM accounts WHERE username" + 
       "='" + data.usn + "';"); 
       query.on("row", function(row, result) result.addRow(row); }); 
       query.on("end", function(result) { 
        if (sha512(data.pwd, result.rows[0].salt).hash === 
         result.rows[0].password) { 

         socket.emit("loginResponse", { status: "Success" }); 

         console.log("I GOT UP TO HERE WITHOUT EMITTING! WTF?"); 
         console.log(sha512(data.pwd,result.rows[0].salt).hash); 
         console.log(result.rows[0].password); 
        } 
       }); 
      }); 
     } catch (ex) { console.log(ex); } 
    }); 
}); 

Очевидно, что на стороне клиента, у меня есть что-то вроде этого:

socket.on("loginResponse", function(data) { 
    alert(data.status); 
}); 

Однако, когда я пытаюсь войти успешно, мой сервер ничего не передает клиенту, т. е. я увижу печатные строки на моем терминале, но клиент не получит ответа от сервера. Я был озадачен этим. У меня есть еще одна функция, которая касается драйвера PostgreSQL и успешно испускается, но этого нет. Кто-нибудь знает, почему это так?

Answer 1

У вас есть ошибка в коде. Асинхронные функции никогда не должны записываться внутри try/catch.

try { 
    setTimeout(function() { 
     do_something_that_throws(); 
    }, 1000); 
} 
catch (e) { 
    alert("You won't see this!"); 
} 

Проблема заключается в том, что поток управления покидает блок Try Before do_something_that_throws() запускается на выполнение, так что ошибка брошено внутри обратного вызова никогда не получает поймают.

socket.on("login", function(data) {  
    pg.connect(conString, function(err, con) { 
    if(err) { 
     // handle error 
    } 
    var query = con.query("SELECT * FROM accounts WHERE username" + 
    "='" + data.usn + "';"); 
    query.on("row", function(row, result) result.addRow(row); }); 
    query.on("end", function(result) { 
     if (sha512(data.pwd, result.rows[0].salt).hash === 
     result.rows[0].password) { 

     socket.emit("loginResponse", { status: "Success" }); 

     console.log("I GOT UP TO HERE WITHOUT EMITTING! WTF?"); 
     console.log(sha512(data.pwd,result.rows[0].salt).hash); 
     console.log(result.rows[0].password); 
     } 
    }); 
    }); 
}); 

Попробуйте этот подход и сообщите мне, если он работает.