MyFavMirrors/MeshCentral
1
0
Fork 0
mirror of https://github.com/Ylianst/MeshCentral.git synced 2025-02-09 04:38:07 -05:00
Code Issues Packages Projects Releases Wiki Activity

Updated terminal flow, to check for promise completion

Browse Source
This commit is contained in:
Bryan Roe 2020-05-19 01:21:07 -07:00
parent 0c1fbc4369
commit 52487cd4bf
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
agents/meshcore.js
View File

@ -1185,6 +1185,8 @@ function createMeshCore(agent) {
this.end = function () this.end = function ()
{ {
if (this.httprequest.tpromise._consent) { this.httprequest.tpromise._consent.close(); } if (this.httprequest.tpromise._consent) { this.httprequest.tpromise._consent.close(); }
if (this.httprequest.connectionPromise) { this.httprequest.connectionPromise._rej('Closed'); }
// Remove the terminal session to the count to update the server // Remove the terminal session to the count to update the server
if (this.httprequest.userid != null) if (this.httprequest.userid != null)
{ {
@ -1272,7 +1274,14 @@ function createMeshCore(agent) {
this.httprequest._dispatcher.httprequest = this.httprequest; this.httprequest._dispatcher.httprequest = this.httprequest;
this.httprequest._dispatcher.on('connection', function (c) this.httprequest._dispatcher.on('connection', function (c)
{ {
this.httprequest.connectionPromise._res(c); if (this.httprequest.connectionPromise.completed)
{
c.end();
}
else
{
this.httprequest.connectionPromise._res(c);
}
}); });
} }
else else
@ -1305,7 +1314,14 @@ function createMeshCore(agent) {
that.httprequest._dispatcher.ws = that; that.httprequest._dispatcher.ws = that;
that.httprequest._dispatcher.on('connection', function (c) that.httprequest._dispatcher.on('connection', function (c)
{ {
this.ws.httprequest.connectionPromise._res(c); if (this.ws.httprequest.connectionPromise.completed)
{
c.end();
}
else
{
this.ws.httprequest.connectionPromise._res(c);
}
}); });
} }
}); });