Upload 2 files

dl-sw.js

@@ -44,6 +44,14 @@ self.addEventListener('backgroundfetchsuccess', (event) => {
       const w = await fh.createWritable();
       await res.body.pipeTo(w);                       // stream — haitumii RAM
       const size = (await fh.getFile()).size;
+      // Thibitisha ukubwa: usikubali "imehifadhiwa" kwa faili lililokatika nusu
+      let expected = 0;
+      const cr = /bytes\s+\d+-\d+\/(\d+)/i.exec(res.headers.get('content-range') || '');
+      if (cr) expected = Number(cr[1]);
+      else if (!res.headers.get('content-encoding')) expected = Number(res.headers.get('content-length')) || 0;
+      if (!size) throw new Error('empty_file');
+      if (expected && size !== expected) throw new Error('size_mismatch');
+      if (bgf.downloadTotal && size < bgf.downloadTotal) throw new Error('incomplete');
       await jmWriteMeta(dir, oid, { ...meta, state: 'done', size });
       ok = true;
     } catch (e) {

index.html

@@ -2288,6 +2288,8 @@ const I18N = {
     dq_saving: 'Inahifadhi kwenye app…',
     dq_saved_app: 'Imehifadhiwa kwenye app ✔',
     dq_sent_browser: 'Imetumwa kwa kivinjari (angalia Downloads za kivinjari)',
+    dq_err_net: 'Mtandao ulikatika — download haijakamilika. Gusa ↻ kujaribu tena.',
+    dq_reconnecting: 'Mtandao umekatika, inaunganisha tena…',
     dq_tab_saved: '▶ Zimehifadhiwa',
     dq_play: 'Cheza',
     dq_delete: 'Futa',
@@ -2425,6 +2427,8 @@ const I18N = {
     dq_saving: 'Saving to app…',
     dq_saved_app: 'Saved in the app ✔',
     dq_sent_browser: 'Sent to the browser (check your browser Downloads)',
+    dq_err_net: 'Connection lost — download not complete. Tap ↻ to retry.',
+    dq_reconnecting: 'Connection lost, reconnecting…',
     dq_tab_saved: '▶ Saved',
     dq_play: 'Play',
     dq_delete: 'Delete',
@@ -2818,6 +2822,13 @@ const I18N_EXTRA7 = {"sw": {"not_live_msg": "Haipatikani kwa LIVE", "vol_warn":
 Object.keys(I18N_EXTRA7).forEach(l => { I18N[l] = Object.assign(I18N[l] || {}, I18N_EXTRA7[l]); });
 const I18N_EXTRA8 = {"sw": {"dq_paused_resume": "Imesimamishwa — gusa ↻ kuendelea"}, "en": {"dq_paused_resume": "Paused — tap ↻ to resume"}, "ar": {"dq_paused_resume": "متوقف مؤقتاً — اضغط ↻ للمتابعة"}, "fr": {"dq_paused_resume": "En pause — touchez ↻ pour reprendre"}};
 Object.keys(I18N_EXTRA8).forEach(l => { I18N[l] = Object.assign(I18N[l] || {}, I18N_EXTRA8[l]); });
+const I18N_EXTRA9 = {
+  sw: { dq_pause: 'Simamisha', dq_continue: 'Endelea', dq_paused: 'Imesimamishwa', dq_eta_left: 'Imebaki ~{x}', dq_sec: 'sek', dq_min: 'dk', dq_hr: 'saa' },
+  en: { dq_pause: 'Pause', dq_continue: 'Resume', dq_paused: 'Paused', dq_eta_left: '~{x} left', dq_sec: 's', dq_min: 'min', dq_hr: 'h' },
+  ar: { dq_pause: 'إيقاف مؤقت', dq_continue: 'متابعة', dq_paused: 'متوقف مؤقتاً', dq_eta_left: 'متبقي ~{x}', dq_sec: 'ث', dq_min: 'د', dq_hr: 'س' },
+  fr: { dq_pause: 'Pause', dq_continue: 'Reprendre', dq_paused: 'En pause', dq_eta_left: '~{x} restantes', dq_sec: 's', dq_min: 'min', dq_hr: 'h' }
+};
+Object.keys(I18N_EXTRA9).forEach(l => { I18N[l] = Object.assign(I18N[l] || {}, I18N_EXTRA9[l]); });
 const I18N_EXTRA10 = {"sw": {}, "en": {}, "ar": {}, "fr": {}};
 Object.keys(I18N_EXTRA10).forEach(l => { I18N[l] = Object.assign(I18N[l] || {}, I18N_EXTRA10[l]); });
 function T(k, v) { return t(k, v); }
@@ -7793,29 +7804,203 @@ async function offlineCheckQuota(needBytes){
 }
 
 // Kutoka kwenye foleni ya downloads: pakua moja kwa moja kwenda OPFS
+// • Sehemu nyingi (Range) kwa wakati mmoja = kasi zaidi • Simamisha/Endelea • resume mtandao ukikatika
+// • "Imekamilika" tu kama kila sehemu imefika na ukubwa unalingana
+const JM_DL_USE_BG = false;   // true = rudisha Background Fetch (inaendelea app ikifungwa, lakini haina Simamisha wala kasi ya ziada)
+const DL_SEG = 8 * 1024 * 1024;
+const dlRuns = new Map();     // item.id -> { ac, pause, cancel, fail }
+function dlConns(){ return Math.max(2, Math.min(6, Math.floor(8 / Math.max(1, dlActiveCount)))); }
+function _dlWaitOnline(ms){
+  return new Promise(res => {
+    if (navigator.onLine !== false) return setTimeout(res, ms);
+    const h = () => { window.removeEventListener('online', h); setTimeout(res, 1000); };
+    window.addEventListener('online', h);
+    setTimeout(() => { window.removeEventListener('online', h); res(); }, 60000);
+  });
+}
+function dlResetPartialFields(item){ item.partId = null; item.segDone = null; item.partTotal = 0; item.partEtag = null; item.finalUrl = null; }
+async function dlDiscardPartial(item){
+  if (!item) return;
+  const run = dlRuns.get(item.id);
+  if (run) { run.cancel = true; try { run.ac.abort(); } catch (_) {} }
+  const pid = item.partId;
+  dlResetPartialFields(item);
+  if (pid) { try { const d = await offlineDirHandle(); await d.removeEntry(pid + '.bin'); } catch (_) {} }
+}
+function dlPause(item){
+  const run = dlRuns.get(item.id);
+  if (!run || item.noPause) return;
+  run.pause = true; item.progressText = t('dq_paused');
+  try { run.ac.abort(); } catch (_) {}
+}
+function dlContinue(item){
+  if (!item || item.status !== 'paused') return;
+  item.status = 'waiting'; item.autoRetries = 0; item.progressText = '';
+  saveDlQueue(); renderDownloadsScreenIfActive(); pumpDownloadQueue();
+}
+
 async function saveItemOffline(item, url, filename){
-  const res = await fetchRetry(proxiedDownloadUrl(url, filename), { mode: 'cors' });
-  if (!res.ok || !res.body) throw new Error('no_stream');
-  const ct = (res.headers.get('content-type') || '').toLowerCase();
-  if (/mpegurl|text\/|html|json/.test(ct)) throw new Error('not_direct_video');
-  const total = Number(res.headers.get('content-length')) || item.sizeBytes || 0;
-  await offlineCheckQuota(total);
-  await requestPersistentStorage();
-  const id = offlineNewId();
-  item.phase = 'download'; item.dlBytes = 0; item.dlTotal = total || 0; item.dlSpeed = 0;
-  item.progressText = t('dq_saving');
-  renderDownloadsScreenIfActive();
-  const size = await offlineWriteStream(id, res.body, total, (d, tot, speed) => {
-    item.dlBytes = d; item.dlTotal = tot || item.dlTotal || 0; item.dlSpeed = speed || 0;
+  const src = proxiedDownloadUrl(url, filename);
+  const dir = await offlineDirHandle();
+  const ac = new AbortController();
+  const run = { ac, pause: false, cancel: false, fail: false };
+  dlRuns.set(item.id, run);
+  item.noPause = false;
+  let id = item.partId || offlineNewId();
+  let segDone = new Set(Array.isArray(item.segDone) ? item.segDone : []);
+  let resumed = !!(item.partId && segDone.size);
+  const SEG = item.segSize || DL_SEG;
+  let total = 0, w = null, fh = null, chain = Promise.resolve(), tick = null, single = false;
+  let doneBytes = 0; const inflight = new Map(); let singleBytes = 0;
+  const segLen = (i) => Math.min(SEG, total - i * SEG);
+  const bytesNow = () => { let b = single ? singleBytes : doneBytes; inflight.forEach(v => { b += v; }); return b; };
+  const writeAt = (pos, data) => (chain = chain.then(() => w.write({ type: 'write', position: pos, data })));
+  const closeW = async () => { try { await chain; } catch (_) {} try { if (w) await w.close(); } catch (_) {} w = null; };
+  const abortW = async () => { try { await chain; } catch (_) {} try { if (w) await w.abort(); } catch (_) {} w = null; };
+  const removeFile = async (fid) => { try { await dir.removeEntry(fid + '.bin'); } catch (_) {} };
+  const stop = () => run.pause || run.cancel || run.fail;
+  try {
+    // 1) Uchunguzi: ukubwa kamili + je seva inaunga mkono Range?
+    const probe = await fetchRetry(src, { mode: 'cors', headers: { Range: 'bytes=0-0' }, signal: ac.signal });
+    if (!(probe.ok || probe.status === 206)) { const e = new Error('http_' + probe.status); e.fatal = probe.status >= 400 && probe.status < 500 && probe.status !== 429; throw e; }
+    const ct = (probe.headers.get('content-type') || '').toLowerCase();
+    if (/mpegurl|text\/|html|json/.test(ct)) throw new Error('not_direct_video');
+    let rangeOK = false;
+    if (probe.status === 206) {
+      const m = /bytes\s+\d+-\d+\/(\d+)/i.exec(probe.headers.get('content-range') || '');
+      if (m) { rangeOK = true; total = Number(m[1]); }
+    }
+    if (!rangeOK) total = Number(probe.headers.get('content-length')) || Number(item.sizeBytes) || 0;
+    const etag = probe.headers.get('etag') || '';
+    try { if (probe.body) probe.body.cancel(); } catch (_) {}
+
+    // 2) Resume: thibitisha kipande cha zamani bado ni cha faili lilelile
+    if (resumed) {
+      let okPart = rangeOK && total && total === item.partTotal && (!item.partEtag || !etag || item.partEtag === etag);
+      if (okPart) {
+        try {
+          const f = await (await dir.getFileHandle(id + '.bin')).getFile();
+          let maxEnd = 0; segDone.forEach(i => { maxEnd = Math.max(maxEnd, Math.min(total, (i + 1) * SEG)); });
+          if (f.size < maxEnd) okPart = false;
+        } catch (_) { okPart = false; }
+      }
+      if (!okPart) { await removeFile(id); id = offlineNewId(); segDone = new Set(); resumed = false; dlResetPartialFields(item); }
+    }
+    segDone.forEach(i => { doneBytes += segLen(i); });
+
+    if (!resumed) { await offlineCheckQuota(total); await requestPersistentStorage(); }
+    fh = await dir.getFileHandle(id + '.bin', { create: true });
+    w = await fh.createWritable({ keepExistingData: resumed });
+    item.partId = id; item.partTotal = total; item.segSize = SEG; item.partEtag = etag; item.segDone = [...segDone];
+    item.phase = 'download'; item.dlBytes = doneBytes; item.dlTotal = total || 0; item.dlSpeed = 0;
     item.progressText = t('dq_saving');
-    updateDqProgressDom(item);   // sasisha namba kwenye kipengele pekee — hakuna flicker
-  });
-  const list = getOfflineMeta();
-  list.push({ id, title: item.title, sub: item.sub || '', poster: item.poster || '', thumbLabel: item.thumbLabel || '',
-    filename, size, mime: 'video/mp4', addedAt: Date.now(), source: 'download' });
-  setOfflineMeta(list);
-  await offlineStoreSubEntries(id, dlSubCache.get(item.id));
-  return { id, size };
+    saveDlQueue(); renderDownloadsScreenIfActive();
+
+    // 3) Ticker: speed + ETA
+    let lastT = Date.now(), lastB = bytesNow(), sp = 0;
+    tick = setInterval(() => {
+      const n = Date.now(), bb = bytesNow(), dt = (n - lastT) / 1000;
+      if (dt > 0) { const inst = (bb - lastB) / dt; sp = sp ? sp * 0.7 + inst * 0.3 : inst; }
+      lastT = n; lastB = bb;
+      item.dlBytes = bb; item.dlTotal = total || item.dlTotal || 0; item.dlSpeed = sp;
+      item.progressText = t('dq_saving');
+      updateDqProgressDom(item);
+    }, 700);
+
+    if (rangeOK && total > 0) {
+      // ── Sehemu nyingi kwa wakati mmoja ──
+      const nSeg = Math.ceil(total / SEG);
+      const todo = []; for (let i = 0; i < nSeg; i++) if (!segDone.has(i)) todo.push(i);
+      let next = 0;
+      const ckptTimer = setInterval(() => {   // hifadhi kwa kudumu kila dakika 5 (kuokoa data app ikifungwa ghafla)
+        if (stop() || !w) return;
+        chain = chain.then(async () => { await w.close(); w = await fh.createWritable({ keepExistingData: true }); item.segDone = [...segDone]; saveDlQueue(); }).catch(() => {});
+      }, 300000);
+      const worker = async () => {
+        try {
+          while (!stop()) {
+            const i = todo[next++]; if (i === undefined) return;
+            const a = i * SEG, len = segLen(i), b2 = a + len - 1;
+            let ok = false, lastE = null;
+            for (let tr = 0; tr < 6 && !stop(); tr++) {
+              try {
+                inflight.set(i, 0);
+                const res = await fetch(src, { mode: 'cors', headers: { Range: 'bytes=' + a + '-' + b2 }, signal: ac.signal });
+                if (res.status !== 206 || !res.body) {
+                  const e = new Error(res.status === 200 ? 'range_unsupported' : 'http_' + res.status);
+                  e.fatal = (res.status >= 400 && res.status < 500 && res.status !== 429) || res.status === 200;
+                  throw e;
+                }
+                const buf = new Uint8Array(len); let off = 0;
+                const reader = res.body.getReader();
+                while (true) {
+                  const { value, done } = await reader.read(); if (done) break;
+                  if (off + value.byteLength > len) throw new Error('overrun');
+                  buf.set(value, off); off += value.byteLength; inflight.set(i, off);
+                }
+                if (off !== len) throw new Error('incomplete');
+                await writeAt(a, buf);
+                segDone.add(i); doneBytes += len; inflight.delete(i); ok = true; break;
+              } catch (e) {
+                inflight.delete(i);
+                if (stop()) return;
+                lastE = e;
+                if (e && e.fatal) throw e;
+                await _dlWaitOnline(1500 * (tr + 1));
+              }
+            }
+            if (!ok) { if (stop()) return; throw lastE || new Error('incomplete'); }
+          }
+        } catch (e) { run.fail = true; try { ac.abort(); } catch (_) {} throw e; }
+      };
+      const results = await Promise.allSettled(Array.from({ length: Math.min(dlConns(), todo.length) }, worker));
+      clearInterval(ckptTimer);
+      const bad = results.find(r => r.status === 'rejected');
+      if (run.cancel) { await abortW(); await removeFile(id); dlResetPartialFields(item); const e = new Error('cancelled'); e.cancelled = true; throw e; }
+      if (run.pause && !bad) { await closeW(); item.segDone = [...segDone]; saveDlQueue(); const e = new Error('paused'); e.paused = true; throw e; }
+      if (bad) {
+        const e = bad.reason;
+        if (e && e.fatal) { await abortW(); await removeFile(id); dlResetPartialFields(item); }
+        else { await closeW(); item.segDone = [...segDone]; saveDlQueue(); }   // acha kipande — jaribio lijalo litaendelea
+        throw e;
+      }
+    } else {
+      // ── Seva haiungi Range: mtiririko mmoja (hakuna Simamisha) ──
+      single = true; item.noPause = true; renderDownloadsScreenIfActive();
+      const res = await fetchRetry(src, { mode: 'cors', signal: ac.signal });
+      if (!res.ok || !res.body) throw new Error('no_stream');
+      const reader = res.body.getReader();
+      let pos = 0;
+      while (true) {
+        const { value, done } = await reader.read(); if (done) break;
+        await writeAt(pos, value); pos += value.byteLength; singleBytes = pos;
+      }
+      if (total && pos < total) throw new Error('incomplete');
+      total = pos;
+    }
+
+    // 4) Maliza + thibitisha
+    clearInterval(tick); tick = null;
+    await chain; await w.close(); w = null;
+    const real = (await (await dir.getFileHandle(id + '.bin')).getFile()).size;
+    if (!real || (total && real !== total)) throw new Error('size_mismatch');
+    const size = real;
+    const list = getOfflineMeta();
+    list.push({ id, title: item.title, sub: item.sub || '', poster: item.poster || '', thumbLabel: item.thumbLabel || '',
+      filename, size, mime: 'video/mp4', addedAt: Date.now(), source: 'download' });
+    setOfflineMeta(list);
+    await offlineStoreSubEntries(id, dlSubCache.get(item.id));
+    return { id, size };
+  } catch (e) {
+    if (!(e && (e.paused || e.cancelled))) {
+      await abortW();
+      if (single || !item.segDone || !item.segDone.length) { await removeFile(id); dlResetPartialFields(item); }
+    }
+    throw e;
+  } finally {
+    if (tick) clearInterval(tick);
+    dlRuns.delete(item.id);
+  }
 }
 
 // ══════════════════════════════════════════════════════════════
@@ -7860,6 +8045,16 @@ async function bgMetaWrite(oid, obj){
 }
 async function bgMetaDelete(oid){ try { const d = await offlineDirHandle(); await d.removeEntry(oid + '.json'); } catch (_) {} }
 async function bgMergeDone(oid, m){
+  // Thibitisha kwamba faili lipo kweli na ukubwa unalingana kabla ya kusema "imekamilika"
+  try {
+    const d0 = await offlineDirHandle();
+    const f0 = await (await d0.getFileHandle(oid + '.bin')).getFile();
+    if (!f0.size || (m.size && f0.size !== m.size)) throw new Error('size_mismatch');
+  } catch (e) {
+    try { const d1 = await offlineDirHandle(); await d1.removeEntry(oid + '.bin'); } catch (_) {}
+    await bgMetaDelete(oid);
+    throw new Error(t('dq_err_net') || 'Faili halikukamilika — jaribu tena.');
+  }
   const list = getOfflineMeta();
   if (!list.some(x => x.id === oid)) {
     list.push({ id: oid, title: m.title, sub: m.sub || '', poster: m.poster || '', thumbLabel: m.thumbLabel || '',
@@ -7906,7 +8101,7 @@ function bgTrack(item, bgf, oid, total){
     const check = async () => {
       if (finished) return;
       const m = await bgMetaRead(oid);
-      if (m && m.state === 'done') finish(resolve, await bgMergeDone(oid, m));
+      if (m && m.state === 'done') { try { finish(resolve, await bgMergeDone(oid, m)); } catch (e) { finish(reject, e); } }
       else if (m && m.state === 'failed') {
         await bgMetaDelete(oid);
         const err = new Error(m.reason === 'aborted' ? t('dq_status_error') : (m.reason || 'bg_failed'));
@@ -7978,8 +8173,12 @@ async function bgSyncAll(){
     const m = await bgMetaRead(oid); if (!m) continue;
     const item = dlQueueItems.find(x => x.bgId === 'jm-' + oid);
     if (m.state === 'done') {
-      const saved = await bgMergeDone(oid, m);
-      if (item && item.status !== 'done') bgFinishItem(item, saved);
+      try {
+        const saved = await bgMergeDone(oid, m);
+        if (item && item.status !== 'done') bgFinishItem(item, saved);
+      } catch (e) {
+        if (item) { item.bgId = null; item.phase = null; item.status = 'error'; item.autoRetries = 0; item.progressText = (e && e.message) || t('dq_status_error'); }
+      }
       changed = true;
     } else if (m.state === 'failed') {
       await bgMetaDelete(oid);
@@ -7997,7 +8196,7 @@ async function bgResumeItems(){
     for (const item of pend) {
       const oid = item.bgId.replace(/^jm-/, '');
       const m = await bgMetaRead(oid);
-      if (m && m.state === 'done') { bgFinishItem(item, await bgMergeDone(oid, m)); continue; }
+      if (m && m.state === 'done') { try { bgFinishItem(item, await bgMergeDone(oid, m)); } catch (e) { item.bgId = null; item.phase = null; item.status = 'error'; item.autoRetries = 0; item.progressText = (e && e.message) || t('dq_status_error'); } continue; }
       let bgf = null;
       try { bgf = reg && reg.backgroundFetch ? await reg.backgroundFetch.get(item.bgId) : null; } catch (_) {}
       if (bgf && !(m && m.state === 'failed')) {
@@ -8874,7 +9073,16 @@ function loadDlQueueFromStorage(){
     // Upakuaji uliokuwa 'downloading' ulipofungwa ukurasa haukuendelea kweli —
     // urudishe kwenye 'waiting' ili foleni iuanze upya.
     // Usianze upakuaji kiotomatiki app ikifunguliwa: vilivyokatizwa/vilivyokuwa vinasubiri vinasimamishwa hadi mtumiaji aguse ↻.
-    dlQueueItems = saved.map(it => ((it.status === 'downloading' && !it.bgId) || it.status === 'waiting') ? { ...it, status: 'error', autoRetries: 0, progressText: T('dq_paused_resume') } : it);
+    dlQueueItems = saved.map(it => {
+      if ((it.status === 'downloading' && !it.bgId) || it.status === 'waiting') {
+        if (it.partId && Array.isArray(it.segDone) && it.segDone.length) {
+          const sb = Math.min(it.partTotal || 0, it.segDone.length * (it.segSize || DL_SEG));
+          return { ...it, status: 'paused', phase: 'download', dlBytes: sb, dlTotal: it.partTotal || 0, dlSpeed: 0, autoRetries: 0, progressText: T('dq_paused') };
+        }
+        return { ...it, status: 'error', autoRetries: 0, progressText: T('dq_paused_resume') };
+      }
+      return it;
+    });
     dlIdSeq = dlQueueItems.reduce((max, it) => Math.max(max, it.id || 0), 0) + 1;
   } catch(_) {}
 }
@@ -8893,7 +9101,7 @@ async function notifyDownloadDone(item, ok){
 }
 
 function updateDownloadsBadge(){
-  const n = dlQueueItems.filter(it => it.status === 'waiting' || it.status === 'downloading').length;
+  const n = dlQueueItems.filter(it => it.status === 'waiting' || it.status === 'downloading' || it.status === 'paused').length;
   const badge = document.getElementById('dqNavBadge');
   if (!badge) return;
   if (n > 0) { badge.style.display = 'flex'; badge.textContent = n > 99 ? '99+' : String(n); }
@@ -9039,17 +9247,19 @@ async function processQueueItem(item){
     if (!videoUrl) throw new Error(t('dq_err_no_video'));
     dlSubCache.set(item.id, await fetchSubSidecars(subtitles));   // nakala za .vtt kwa ajili ya CC ya kicheza
     // HATUA 1: muunganisho (mux) wa video + manukuu — hii SIO download yenyewe
-    const finalUrl = await muxAndDownload(videoUrl, subtitles, filename, (msg) => {
+    const _resumeOk = !!(item.finalUrl && item.partId && Array.isArray(item.segDone) && item.segDone.length);
+    const finalUrl = _resumeOk ? item.finalUrl : await muxAndDownload(videoUrl, subtitles, filename, (msg) => {
       item.phase = 'mux';
       item.progressText = msg;
       updateDqProgressDom(item);
       if (!document.querySelector('[data-dq-id="' + item.id + '"]')) renderDownloadsScreenIfActive();
     });
+    item.finalUrl = finalUrl; saveDlQueue();
     // HATUA 2: download halisi — inaonyesha speed (MB/s) na ukubwa (kilichopakuliwa / jumla)
     let saved = null;
     if (offlineAutoOn() && offlineCanSave()) {
       // Njia bora: Background Fetch — inaendelea hata ukifunga app, na Android inaonyesha asilimia kwenye notification
-      if (bgFetchSupported() && await dlSwReady()) {
+      if (JM_DL_USE_BG && bgFetchSupported() && await dlSwReady()) {
         try { saved = await saveItemViaBackgroundFetch(item, finalUrl, filename); }
         catch (e) {
           if (item.cancelled) return;
@@ -9059,10 +9269,19 @@ async function processQueueItem(item){
       }
       if (!saved) {
         try { saved = await saveItemOffline(item, finalUrl, filename); }
-        catch (e) { console.warn('offline save failed — nitumia download ya kawaida', e); }
+        catch (e) {
+          console.warn('offline save failed', e);
+          // Kosa la mtandao/ukubwa/nafasi: USIONYESHE "imekamilika" — lisababishe retry / "Imeshindwa".
+          // Kutuma kwa kivinjari ni kwa video isiyo ya moja kwa moja tu.
+          if (!(e && (e.message === 'not_direct_video' || e.message === 'no_stream'))) {
+            if (e && /incomplete|size_mismatch|Failed to fetch|NetworkError|network/i.test(e.message || '')) e.message = t('dq_err_net') || 'Mtandao ulikatika — jaribu tena.';
+            throw e;
+          }
+        }
       }
     }
     item.bgId = null;
+    item.partId = null; item.segDone = null; item.finalUrl = null; item.partTotal = 0; item.noPause = false;
     item.phase = 'done'; item.dlSpeed = 0;
     if (saved) {
       item.offlineId = saved.id; item.dlBytes = saved.size; item.dlTotal = saved.size;
@@ -9076,6 +9295,11 @@ async function processQueueItem(item){
     dlSubCache.delete(item.id);
     if (!(saved && saved.viaBg)) notifyDownloadDone(item, true);
   } catch (e) {
+    if (e && e.paused) {   // mtumiaji alibonyeza Simamisha
+      item.status = 'paused'; item.phase = 'download'; item.dlSpeed = 0; item.progressText = t('dq_paused');
+      saveDlQueue(); renderDownloadsScreenIfActive(); updateDownloadsBadge(); return;
+    }
+    if (e && e.cancelled) return;   // mtumiaji aliondoa download
     const isPermanent = !!(e && e.permanent) || /DRM/i.test(e.message || '');
     item.phase = null; item.dlSpeed = 0;
     item.autoRetries = item.autoRetries || 0;
@@ -9137,13 +9361,24 @@ function dqStatusShort(it){
   if (it.phase === 'mux') return t('dq_phase_mux');
   return t('dq_status_downloading');
 }
+function fmtEta(sec){
+  if (!isFinite(sec) || sec <= 0) return '';
+  sec = Math.round(sec);
+  if (sec < 60) return sec + ' ' + t('dq_sec');
+  const m = Math.floor(sec / 60);
+  if (m < 60) return m + ' ' + t('dq_min') + (sec % 60 ? ' ' + (sec % 60) + ' ' + t('dq_sec') : '');
+  return Math.floor(m / 60) + ' ' + t('dq_hr') + ' ' + (m % 60) + ' ' + t('dq_min');
+}
 function dqProgressInner(it){
   if (it.phase === 'download') {
     const p = dqPercent(it);
+    const paused = it.status === 'paused';
     const bar = p != null ? `<div class="dq-bar-fill det" style="width:${p}%"></div>` : `<div class="dq-bar-fill"></div>`;
     const sizeTxt = fmtSize(it.dlBytes) + ' ' + t('dq_of') + ' ' + (it.dlTotal ? fmtSize(it.dlTotal) : '?');
-    return `<div class="dq-bar-track">${bar}</div>
-      <div class="dq-meta"><span>${esc(sizeTxt)}</span><span>${esc(fmtSpeed(it.dlSpeed))}</span></div>`;
+    const eta = (!paused && it.dlSpeed > 0 && it.dlTotal > it.dlBytes) ? fmtEta((it.dlTotal - it.dlBytes) / it.dlSpeed) : '';
+    return `<div class="dq-bar-track">${paused ? bar.replace('dq-bar-fill det', 'dq-bar-fill det') : bar}</div>
+      <div class="dq-meta"><span>${esc(sizeTxt)}</span><span>${esc(paused ? t('dq_paused') : fmtSpeed(it.dlSpeed))}</span></div>
+      ${eta ? `<div class="dq-meta"><span>${esc(t('dq_eta_left', { x: eta }))}</span><span>${p != null ? p + '%' : ''}</span></div>` : ''}`;
   }
   return `<div class="dq-bar-track"><div class="dq-bar-fill"></div></div>
     <div class="dq-meta"><span>${esc(it.progressText || t('dq_status_downloading'))}</span></div>`;
@@ -9165,6 +9400,7 @@ function dqItemNode(it){
   if (dqSelectMode) div.style.cursor = 'pointer';
   const statusClass = it.status === 'error' ? 'err' : it.status === 'done' ? 'ok' : '';
   const statusLabel = it.status === 'waiting' ? (it.heldByWifi ? t('dq_waiting_wifi') : t('dq_status_waiting'))
+    : it.status === 'paused' ? t('dq_paused')
     : it.status === 'downloading' ? dqStatusShort(it)
     : it.status === 'done' ? t('dq_status_done')
     : (it.progressText || t('dq_status_error'));
@@ -9173,7 +9409,7 @@ function dqItemNode(it){
     <div class="dq-text">
       <div class="dq-title">${esc(it.title)}</div>
       <div class="dq-sub">${esc(it.sub)}${it.sizeBytes ? ' · ' + esc(formatBytes(it.sizeBytes)) : ''}</div>
-      ${it.status === 'downloading' ? `<div class="dq-prog">${dqProgressInner(it)}</div>` : ''}
+      ${(it.status === 'downloading' || it.status === 'paused') ? `<div class="dq-prog">${dqProgressInner(it)}</div>` : ''}
       ${it.status === 'done' ? `<div class="dq-meta"><span>${esc(it.progressText || '')}</span>${it.dlBytes ? `<span>${esc(fmtSize(it.dlBytes))}</span>` : ''}</div>` : ''}
     </div>
     <div class="dq-status">${dqSelectMode
@@ -9192,6 +9428,19 @@ function dqItemNode(it){
     btn.className = 'dq-action-btn'; btn.textContent = '↻'; btn.title = t('dq_retry');
     btn.onclick = () => { it.status = 'waiting'; it.autoRetries = 0; it.progressText = ''; saveDlQueue(); renderDownloadsScreen(); pumpDownloadQueue(); };
     statusWrap.appendChild(btn);
+  } else if (it.status === 'paused' || (it.status === 'downloading' && !it.bgId && it.phase === 'download' && dlRuns.has(it.id))) {
+    const paused = it.status === 'paused';
+    if (paused || !it.noPause) {
+      const pb = document.createElement('button');
+      pb.className = 'dq-action-btn cc'; pb.style.cssText = 'height:26px;font-size:11px;white-space:nowrap';
+      pb.textContent = paused ? '▶ ' + t('dq_continue') : '⏸ ' + t('dq_pause');
+      pb.onclick = (ev) => { ev.stopPropagation(); if (paused) dlContinue(it); else dlPause(it); };
+      statusWrap.appendChild(pb);
+    }
+    const xb = document.createElement('button');
+    xb.className = 'dq-action-btn'; xb.textContent = '✕'; xb.title = t('dq_remove');
+    xb.onclick = (ev) => { ev.stopPropagation(); dlDiscardPartial(it); dlQueueItems = dlQueueItems.filter(x => x.id !== it.id); saveDlQueue(); renderDownloadsScreen(); updateDownloadsBadge(); };
+    statusWrap.appendChild(xb);
   } else if (it.status === 'downloading' && it.bgId) {
     const cb = document.createElement('button');
     cb.className = 'dq-action-btn'; cb.textContent = '✕'; cb.title = t('dq_remove');
@@ -9209,7 +9458,7 @@ function dqItemNode(it){
     }
     const btn = document.createElement('button');
     btn.className = 'dq-action-btn'; btn.textContent = '✕'; btn.title = t('dq_remove');
-    btn.onclick = (ev) => { ev.stopPropagation(); dlQueueItems = dlQueueItems.filter(x => x.id !== it.id); saveDlQueue(); renderDownloadsScreen(); updateDownloadsBadge(); };
+    btn.onclick = (ev) => { ev.stopPropagation(); dlDiscardPartial(it); dlQueueItems = dlQueueItems.filter(x => x.id !== it.id); saveDlQueue(); renderDownloadsScreen(); updateDownloadsBadge(); };
     statusWrap.appendChild(btn);
   }
   return div;
@@ -9217,7 +9466,7 @@ function dqItemNode(it){
 
 function renderDownloadsScreen(){
   const waiting = dlQueueItems.filter(it => it.status === 'waiting');
-  const downloading = dlQueueItems.filter(it => it.status === 'downloading');
+  const downloading = dlQueueItems.filter(it => it.status === 'downloading' || it.status === 'paused');
   const done = dlQueueItems.filter(it => it.status === 'done' || it.status === 'error');
   if (dqActiveTab === 'offline') { renderOfflineTab(waiting.length, downloading.length, done.length); updateDownloadsBadge(); return; }
   const list = dqActiveTab === 'waiting' ? waiting : dqActiveTab === 'downloading' ? downloading : done;
@@ -9263,6 +9512,7 @@ function renderDownloadsScreen(){
   });
   const clearDoneBtn = document.getElementById('dqClearDoneBtn');
   if (clearDoneBtn) clearDoneBtn.onclick = () => {
+    dlQueueItems.filter(x => x.status === 'error').forEach(dlDiscardPartial);
     dlQueueItems = dlQueueItems.filter(x => x.status !== 'done' && x.status !== 'error');
     saveDlQueue();
     renderDownloadsScreen();
@@ -9275,6 +9525,7 @@ function renderDownloadsScreen(){
   const deleteSelectedBtn = document.getElementById('dqDeleteSelectedBtn');
   if (deleteSelectedBtn) deleteSelectedBtn.onclick = () => {
     dlQueueItems.filter(x => dqSelection.has(x.id)).forEach(bgAbortItem);
+    dlQueueItems.filter(x => dqSelection.has(x.id)).forEach(dlDiscardPartial);
     dlQueueItems = dlQueueItems.filter(x => !dqSelection.has(x.id));
     dqSelectMode = false; dqSelection.clear();
     saveDlQueue(); renderDownloadsScreen(); updateDownloadsBadge();