WIP: Magnet Streaming

lib/soundtrack.js

@@ -3,6 +3,7 @@ var util = require('../util');
 var rest = require('restler');
 var async = require('async');
 var slug = require('speakingurl');
+var meta = require('musicmetadata');
 
 var YouTube = require('./YouTube');
 
@@ -142,6 +143,28 @@ Soundtrack.prototype.trackFromSource = function(source, id, data, sourceCallback
     default:
       sourceCallback('Unknown source: ' + source);
     break;
+    case 'magnet':
+      Track.findOne({ 'sources.magnet.id': id  }).populate('_artist').exec(function(err, track) {
+        if (track) return sourceCallback(err, track);
+
+        var track = new Track({
+          title: data.title || 'Unknown',
+          duration: data.duration || 300
+        });
+
+        var artistName = data.artist || 'unknown';
+
+        Artist.findOne({ slug: slug(artistName) }).exec(function(err, artist) {
+          track._artist = (artist && artist._id) ? artist._id : new Artist({ name: artistName });
+          track.sources.magnet = [{ id: id }];
+          track.save(function(err) {
+            console.log('TRACK SAVED', err);
+            sourceCallback(err, track);
+          });
+        });
+
+      });
+    break;
     case 'direct':
       Track.findOne({ 'sources.direct.uri': id  }).populate('_artist').exec(function(err, track) {
         if (track) return sourceCallback(err, track);
@@ -158,7 +181,7 @@ Soundtrack.prototype.trackFromSource = function(source, id, data, sourceCallback
           track.sources.direct = [{ uri: id }];
           track.save(function(err) {
             console.log('TRACK SAVED', err);
-            sourceCallback(err, track);            
+            sourceCallback(err, track);
           });
         });
 

models/Track.js

@@ -31,6 +31,11 @@ var TrackSchema = new Schema({
         duration: { type: Number },
         data: {}
       })],
+      magnet: [ new Schema({
+        id: { type: String , required: true , index: true },
+        duration: { type: Number },
+        data: {}
+      })],
       lastfm: [ new Schema({
           id: { type: String , required: true , index: true }
         , duration: { type: Number }
@@ -83,10 +88,11 @@ TrackSchema.pre('save', function(next) {
     });
   }
 
-  ['direct', 'youtube', 'soundcloud'].forEach(function(source) {
+  ['direct', 'magnet', 'youtube', 'soundcloud'].forEach(function(source) {
 
     switch (source) {
       case 'direct':     var type = 'video/mp4';     break;
+      case 'magnet':     var type = 'video/mp4';     break;
       case 'youtube':    var type = 'video/youtube'; break;
       case 'soundcloud': var type = 'audio/mp3';     break;
     }

package.json

@@ -27,6 +27,7 @@
     "mongoose": "~3.6.14",
     "mongoose-agency": "0.0.0",
     "mongoose-slug": "~1.3.0",
+    "musicmetadata": "^2.0.2",
     "passport": "~0.1.17",
     "passport-changetip": "0.0.1",
     "passport-google-oauth": "^0.2.0",

views/layout.jade

@@ -68,6 +68,7 @@ html(lang="en-US", ng-app="soundtrack-io")
     script(src="/video-js/video.dev.js")
     script(src="/js/youtube.js")
     script(src="/js/sockjs-0.3.min.js")
+    script(src="https://cdn.jsdelivr.net/webtorrent/latest/webtorrent.min.js")
     script(src="/js/app.js")
 
     base