revert: back to baseline (no flow control), bump 1.0.18

site/app.py

@@ -22,7 +22,7 @@ def health():
 
 @sock.route('/ws-upload')
 def ws_upload(ws):
-    """WebSocket: получает чанки, ACK после каждого, считает байты и время"""
+    """WebSocket: получает чанки, считает байты и время"""
     t0 = time.time()
     total = 0
     while True:
@@ -32,7 +32,6 @@ def ws_upload(ws):
         if isinstance(chunk, str) and chunk == 'DONE':
             break
         total += len(chunk)
-        ws.send(json.dumps({'ack': total}))
     elapsed = round((time.time() - t0) * 1000)
     ws.send(json.dumps({'ok': True, 'bytes': total, 'elapsed_ms': elapsed}))
 

site/static/app.js

@@ -210,9 +210,20 @@ function uploadFileWS(url, f, idx) {
 
     ws.onopen = function () {
       var reader = new FileReader();
-
       reader.onload = function (e) {
         ws.send(e.target.result);
+        offset += CHUNK;
+        if (offset < f.size) {
+          var pct = Math.round(offset / f.size * 100);
+          if (pct - lastProgress >= 10) {
+            lastProgress = pct;
+            f.progress = pct;
+            renderTable();
+          }
+          readNext();
+        } else {
+          ws.send('DONE');
+        }
       };
       function readNext() {
         var end = Math.min(offset + CHUNK, f.size);
@@ -224,28 +235,11 @@ function uploadFileWS(url, f, idx) {
     ws.onmessage = function (e) {
       try {
         var r = JSON.parse(e.data);
-        if (r.ack) {
-          // Сервер подтвердил получение N байт
-          offset = r.ack;
-          var pct = Math.round(offset / f.size * 100);
-          if (pct - lastProgress >= 10) {
-            lastProgress = pct;
-            f.progress = pct;
-            renderTable();
-          }
-          if (offset < f.size) {
-            readNext();
-          } else {
-            ws.send('DONE');
-          }
-        } else if (r.ok) {
-          // Финальный ответ
         clearTimeout(timer);
         f.progress = 100;
         renderTable();
         ws.close();
         resolve({ bytes: r.bytes, elapsed_ms: Date.now() - startTime });
-        }
       } catch (err) {
         reject(new Error('Bad response'));
       }