From d3ce9198ce9d6fa7d78fa60e2f5431638dd90324 Mon Sep 17 00:00:00 2001
From: j <0x006A@0x2620.org>
Date: Sat, 21 Mar 2015 13:06:16 +0530
Subject: [PATCH] fix download queue

---
 static/js/fs.js | 70 ++++++++++++++++++++++++++-----------------------
 1 file changed, 37 insertions(+), 33 deletions(-)

diff --git a/static/js/fs.js b/static/js/fs.js
index f3b015bb..6ee7b3ee 100644
--- a/static/js/fs.js
+++ b/static/js/fs.js
@@ -6,6 +6,7 @@ pandora.fs = (function() {
             downloads: {},
             enabled: false,
         },
+        active,
         queue = [],
         requestedBytes = 100*1024*1024*1024; // 100GB
 
@@ -29,6 +30,40 @@ pandora.fs = (function() {
         return pandora.getVideoURLName(id, resolution, part, track).replace('/', '::');
     }
 
+    function cacheVideo(id, callback) {
+        active = true;
+        pandora.api.get({id: id, keys: ['parts']}, function(result) {
+            var parts = result.data.parts, sizes = [];
+            downloadPart(0);
+
+            function downloadPart(part) {
+                that.downloadVideoURL(id, pandora.user.ui.videoResolution, part + 1, false, function(result) {
+                    result.progress = 1/parts * (part + result.progress);
+                    that.downloads[id].progress = result.progress;
+                    if (result.cancel) {
+                        that.downloads[id].cancel = result.cancel;
+                    }
+                    if (result.total) {
+                        sizes[part] = result.total;
+                        that.downloads[id].size = Ox.sum(sizes);
+                    }
+                    if (result.url) {
+                        if (part + 1 == parts) {
+                            delete that.downloads[id];
+                            active = false;
+                            if (queue.length) {
+                                cacheVideo.apply(null, queue.shift());
+                            }
+                        } else {
+                            downloadPart(part + 1);
+                        }
+                    }
+                    callback && callback(result);
+                });
+            }
+        });
+    }
+
     that.cacheVideo = function(id, callback) {
         if (that.getVideoURL(id, pandora.user.ui.videoResolution, 1) || that.downloads[id]) {
             callback({progress: 1});
@@ -46,42 +81,11 @@ pandora.fs = (function() {
                 size: 0
             };
 
-            queue.length
+            (active || queue.length)
                 ? queue.push([id, callback])
-                : startDownload(id, callback);
+                : cacheVideo(id, callback);
         }
 
-        function startDownload(id, callback) {
-            pandora.api.get({id: id, keys: ['parts']}, function(result) {
-                var parts = result.data.parts, sizes = [];
-                downloadPart(0);
-
-                function downloadPart(part) {
-                    that.downloadVideoURL(id, pandora.user.ui.videoResolution, part + 1, false, function(result) {
-                        result.progress = 1/parts * (part + result.progress);
-                        that.downloads[id].progress = result.progress;
-                        if (result.cancel) {
-                            that.downloads[id].cancel = result.cancel;
-                        }
-                        if (result.total) {
-                            sizes[part] = result.total;
-                            that.downloads[id].size = Ox.sum(sizes);
-                        }
-                        if (result.url) {
-                            if (part + 1 == parts) {
-                                delete that.downloads[id];
-                                if (queue.length) {
-                                    startDownload.apply(null, queue.shift());
-                                }
-                            } else {
-                                downloadPart(part + 1);
-                            }
-                        }
-                        callback && callback(result);
-                    });
-                }
-            });
-        }
     };
 
     that.removeVideo = function(id, callback) {