Feature/451 keep seeding after closing player

src/app/index.html

@@ -68,6 +68,7 @@
 	<script src="httpapi.js"></script>
 	<script src="language.js"></script>
 	<script src="lib/streamer.js"></script>
+	<script src="lib/seeder.js"></script>
 
 	<script src="lib/device/generic.js"></script>
 	<script src="lib/device/airplay.js"></script>
@@ -127,19 +128,20 @@
 	<script src="lib/views/player/loading.js"></script>
 	<script src="lib/views/player/player.js"></script>
 
-  	<script src="lib/views/browser/generic_browser.js"></script>
+  <script src="lib/views/browser/generic_browser.js"></script>
 	<script src="lib/views/browser/movie_browser.js"></script>
 	<script src="lib/views/browser/filter_bar.js"></script>
 	<script src="lib/views/browser/item.js"></script>
 	<script src="lib/views/browser/list.js"></script>
 
 	<script src="lib/views/browser/show_browser.js"></script>
-  	<script src="lib/views/browser/anime_browser.js"></script>
+  <script src="lib/views/browser/anime_browser.js"></script>
 	<script src="lib/views/browser/indie_browser.js"></script>
 
 	<script src="lib/views/browser/favorite_browser.js"></script>
-  	<script src="lib/views/browser/watchlist_browser.js"></script>
+  <script src="lib/views/browser/watchlist_browser.js"></script>
 
 	<script src="bootstrap.js"></script>
+
 </body>
 </html>

src/app/lib/seeder.js

@@ -0,0 +1,60 @@
+(function (App) {
+
+    var Seeder = function () {
+        this.worker = null;
+    };
+
+    Seeder.prototype = {
+        start: function() {
+            this.getWorkerInstance().send({action: 'start'});
+        },
+
+        stop: function() {
+            if (this.getWorkerInstance()) {
+                this.getWorkerInstance().send({action: 'stop'});
+                this.worker = null;
+            }
+        },
+
+        append: function(torrent) {
+            this.getWorkerInstance().send({action: 'append', payload: torrent.name});
+        },
+
+        save: function(torrent) {
+            var targetFile = path.join(App.settings.tmpLocation, 'TorrentCache', Common.md5(torrent.name) + '.torrent');
+            var wstream = fs.createWriteStream(targetFile);
+
+            wstream.write(torrent.torrentFile);
+            wstream.end();
+        },
+
+        getWorkerInstance: function () {
+            if (this.worker === null) {
+                var taskFile = 'src/app/lib/workers/seederTask.js';
+                // TODO: AdvSettings here should be trigger creation of worker instance
+                var args = JSON.stringify({
+                    connectionLimit: Settings.connectionLimit,
+                    trackerAnnouncement: Settings.trackers.forced,
+                    tmpLocation: App.settings.tmpLocation,
+                    seedLimit: Settings.seedLimit
+                });
+
+                this.worker = child.fork(taskFile, [args], {silent: true, execPath:'node'});
+
+                this.worker.on('message', function(msg) {
+                    win.info(msg);
+                });
+            }
+
+            return this.worker;
+        }
+    };
+
+    var seeder = new Seeder();
+
+    App.vent.on('seed:start', seeder.start.bind(seeder));
+    App.vent.on('seed:stop', seeder.stop.bind(seeder));
+    App.vent.on('seed:save', seeder.save.bind(seeder));
+    App.vent.on('seed:append', seeder.append.bind(seeder));
+
+})(window.App);

src/app/lib/streamer.js

@@ -44,6 +44,9 @@
             this.setModels(model);
 
             this.fetchTorrent(this.torrentModel.get('torrent')).then(function (torrent) {
+                if (AdvSettings.get('autoSeed')) {
+                    App.vent.trigger('seed:save', torrent);
+                }
                 this.handleTorrent(torrent);
                 this.watchState();
                 this.handleStreamInfo();
@@ -54,6 +57,10 @@
 
         // kill the streamer
         stop: function() {
+            if (AdvSettings.get('autoSeed')) {
+                App.vent.trigger('seed:append', this.torrentModel.get('torrent'));
+            }
+
             if (this.webtorrent) {
                 // update ratio
                 AdvSettings.set('totalDownloaded', Settings.totalDownloaded + this.torrentModel.get('torrent').downloaded);

src/app/lib/views/main_window.js

@@ -238,17 +238,17 @@
                         $('.events').css('display', 'block');
                     }
 
+                    if (AdvSettings.get('autoSeed')) {
+                        App.vent.trigger('seed:start');
+                    }
+
                     // set player from settings
                     var players = App.Device.Collection.models;
                     for (var i in players) {
                         if (players[i].id === AdvSettings.get('chosenPlayer')) {
                             App.Device.Collection.setDevice(AdvSettings.get('chosenPlayer'));
                         }
                     }
-
-                    // Focus the window when the app opens
-                    win.focus();
-
                 });
 
             // Cancel all new windows (Middle clicks / New Tab)
@@ -258,7 +258,6 @@
 
             App.vent.trigger('updatePostersSizeStylesheet');
             App.vent.trigger('main:ready');
-
         },
 
         movieTabShow: function (e) {

src/app/lib/views/settings_container.js

@@ -242,6 +242,7 @@
             case 'opensubtitlesAutoUpload':
             case 'subtitles_bold':
             case 'rememberFilters':
+            case 'autoSeed':
                 value = field.is(':checked');
                 break;
             case 'httpApiUsername':
@@ -292,6 +293,13 @@
 
         syncSetting: function (setting, value) {
             switch (setting) {
+            case 'autoSeed':
+                if (value) {
+                    App.vent.trigger('seed:start');
+                } else {
+                    App.vent.trigger('seed:stop');
+                }
+                break;
             case 'coversShowRating':
                 if (value) {
                     $('.rating').show();

src/app/lib/workers/seederTask.js

@@ -0,0 +1,115 @@
+'use strict';
+
+var _ = require('underscore');
+var fs = require('fs');
+var path = require('path');
+var WebTorrent = require('webtorrent');
+var child = require('child_process');
+var crypt = require('crypto');
+
+var SeederTask = function (opt) {
+    this.webtorrent = null;
+    this.torrentFiles = null;
+    this.tmpLocation = opt.tmpLocation;
+    this.seedLimit = opt.seedLimit;
+    this.connectionLimit = opt.connectionLimit;
+    this.trackerAnnouncement = opt.trackerAnnouncement;
+    this.torrentDir = path.join(this.tmpLocation, 'TorrentCache');
+};
+
+SeederTask.prototype = {
+    start: function() {
+        if (this.webtorrent) {
+            this.stop();
+        }
+
+        process.send('Seeding started');
+
+        var seedTorrentFiles = this.seedLimit ?
+            _.sample(this.getTorrentFiles(), this.seedLimit) : this.getTorrentFiles();
+
+        seedTorrentFiles.forEach(this.joinSwarm.bind(this));
+    },
+
+    stop: function() {
+        if (this.webtorrent) {
+            this.webtorrent.destroy();
+        }
+
+        this.webtorrent = null;
+        this.torrentFiles = [];
+
+        process.send('Seeding stopped');
+        process.kill();
+    },
+
+    getTorrentFiles: function() {
+        if (this.torrentFiles === null) {
+            var regexp = /\.torrent$/i;
+            var files = fs.readdirSync(this.torrentDir);
+
+            this.torrentFiles = files.filter(function(val) {
+              return regexp.test(val);
+            }).map(function(filename) {
+              return path.join(this.torrentDir, filename);
+            }, this);
+        }
+
+        return this.torrentFiles;
+    },
+
+    joinSwarm: function (torrentId) {
+        var client = this.getWebTorrentInstance();
+
+        if (!client.get(torrentId)) {
+            var torrent = client.add(torrentId, {
+              path: this.tmpLocation
+            });
+
+            torrent.on('ready', function () {
+              process.send(`Seeding ${torrent.name} --- ${torrentId}`);
+            });
+        }
+    },
+
+    append: function(name) {
+        var targetFile = path.join(this.torrentDir, this._md5(name) + '.torrent');
+
+        this.torrentFiles.push(targetFile);
+        this.seedLimit += 1;
+        this.joinSwarm(targetFile);
+    },
+
+    _md5: function (arg) {
+        return crypt.createHash('md5').update(arg).digest('hex');
+    },
+
+    getWebTorrentInstance: function() {
+        if (this.webtorrent === null) {
+            this.webtorrent = new WebTorrent({
+                maxConns: parseInt(this.connectionLimit, 10) || 55,
+                tracker: {
+                    wrtc: false,
+                    announce: this.trackerAnnouncement
+                }
+            });
+
+            this.webtorrent.on('error', function (error) {
+                process.send('WebTorrent fatal error', error);
+            });
+        }
+
+        return this.webtorrent;
+    }
+};
+
+var args = JSON.parse(process.argv[2]);
+var seederTask = new SeederTask(args);
+
+process.on('message', function (params) {
+    if (params.action && seederTask[params.action]) {
+        seederTask[params.action].call(seederTask, params.payload);
+    } else {
+        process.send(`Invalid seederTask function`);
+    }
+});

src/app/settings.js

@@ -171,6 +171,8 @@ Settings.automaticUpdating = true;
 Settings.events = true;
 Settings.minimizeToTray = false;
 Settings.bigPicture = false;
+Settings.autoSeed = false;
+Settings.seedLimit = 2;
 
 // Features
 Settings.activateTorrentCollection = true;

src/app/templates/settings-container.tpl

@@ -518,6 +518,10 @@
                 <input class="settings-checkbox" name="deleteTmpOnClose" id="cb2" type="checkbox" <%=(Settings.deleteTmpOnClose? "checked='checked'":"")%>>
                 <label class="settings-label" for="cb2"><%= i18n.__("Clear Tmp Folder after closing app?") %></label>
             </span>
+            <span>
+                <input class="settings-checkbox" name="autoSeed" id="cb8" type="checkbox" <%=(Settings.autoSeed? "checked='checked'":"")%>>
+                <label class="settings-label" for="cb8"><%= i18n.__("Continue seeding from Tmp Folder") %></label>
+            </span>
         </div>
     </section>