fix: bulletproof WS promise + cache bust, bump 1.0.24
Deploy loadtest / validate (push) Waiting to run
Deploy loadtest / validate (push) Waiting to run
This commit is contained in:
+1
-1
@@ -6,7 +6,7 @@ from flask_sock import Sock
|
||||
app = Flask(__name__)
|
||||
sock = Sock(app)
|
||||
|
||||
VERSION = '1.0.23'
|
||||
VERSION = '1.0.24'
|
||||
|
||||
|
||||
@app.route('/')
|
||||
|
||||
+18
-11
@@ -167,6 +167,7 @@ async function uploadAll() {
|
||||
renderTable();
|
||||
try {
|
||||
var result = await uploadFileWS(wsUrl, f);
|
||||
if (!result) throw new Error('Empty result');
|
||||
f.status = 'ok';
|
||||
f.elapsed = result.elapsed_ms;
|
||||
f.speed = result.elapsed_ms > 0 ? Math.round(result.bytes / (result.elapsed_ms / 1000)) : null;
|
||||
@@ -175,7 +176,7 @@ async function uploadAll() {
|
||||
okCount++;
|
||||
} catch (e) {
|
||||
f.status = 'err';
|
||||
f.error = e.message || 'Unknown error';
|
||||
f.error = (e && e.message) || String(e) || 'Unknown error';
|
||||
errCount++;
|
||||
}
|
||||
renderTable();
|
||||
@@ -201,10 +202,20 @@ function uploadFileWS(url, f) {
|
||||
var offset = 0;
|
||||
var startTime = Date.now();
|
||||
var lastProgress = 0;
|
||||
var timer = setTimeout(function () { ws.close(); reject(new Error('Timeout')); }, 300000);
|
||||
var done = false;
|
||||
|
||||
ws.binaryType = 'arraybuffer';
|
||||
|
||||
function finish(err, data) {
|
||||
if (done) return;
|
||||
done = true;
|
||||
try { ws.close(); } catch (e) {}
|
||||
if (err) reject(err);
|
||||
else resolve(data);
|
||||
}
|
||||
|
||||
setTimeout(function () { finish(new Error('Timeout')); }, 300000);
|
||||
|
||||
ws.onopen = function () {
|
||||
var reader = new FileReader();
|
||||
reader.onload = function (e) {
|
||||
@@ -228,20 +239,16 @@ function uploadFileWS(url, f) {
|
||||
ws.onmessage = function (e) {
|
||||
try {
|
||||
var r = JSON.parse(e.data);
|
||||
if (r.ok) {
|
||||
clearTimeout(timer);
|
||||
if (r && r.ok) {
|
||||
f.progress = 100;
|
||||
renderTable();
|
||||
ws.close();
|
||||
resolve({ bytes: r.bytes, elapsed_ms: Date.now() - startTime });
|
||||
finish(null, { bytes: r.bytes, elapsed_ms: Date.now() - startTime });
|
||||
}
|
||||
} catch (err) {
|
||||
reject(new Error('Bad response'));
|
||||
}
|
||||
} catch (err) {}
|
||||
};
|
||||
|
||||
ws.onerror = function () { reject(new Error('WebSocket error')); };
|
||||
ws.onclose = function () { if (offset < f.size) reject(new Error('WS closed early')); };
|
||||
ws.onerror = function () { finish(new Error('Connection failed')); };
|
||||
ws.onclose = function () { if (offset < f.size) finish(new Error('Closed early')); };
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user