streamer.js

var Streamer = require('./streamer-server');
var logger = require('./logger');
var format = require('util').format;

var torrent;
var ready = false;
var boundURL = "not ready";
var ID;
var ip;
var port;
function startStreamer(url, torrentID, localIp) {
	ID = torrentID;
	ip = localIp;
	url = decodeURIComponent(url);
	port = parseInt(Math.random() * (8000 - 6000) + 6000);
	var streamBuffer = 5 * 1024 * 1024;
	if (url.indexOf("youtube") >= 0){
		streamBuffer = 3 * 1024 * 1024;
	}
	torrent = new Streamer(url, 
	{
		youtube: {
			hd: true
		},
		hostname: ip,
		progressInterval: 10,
		buffer: streamBuffer,
		port: port,
		writeDir: '',
		index: __dirname + "/" + torrentID + '.mp4'
	});
	torrent.on('ready', function (data) {
		logger.Streamer('Ready to Stream, binding to ' + data.streamUrl);
		boundURL = data.streamUrl;
		ready = true;
	});
	torrent.on('close', function () {
		logger.Debug('Streamer: Stream Closed');
	});
	torrent.on('progress', function (progress) {
		logger.Debug(format('[%d%] Downloaded %dMB - %dMB/s | Peers: %d Seeds: %d | ETA: %dm',
				progress.progress.toFixed(0),
				(progress.downloaded / 1024 / 1024).toFixed(2),
				(progress.downloadSpeed / 1024 / 1024).toFixed(2),
				progress.peers,
				progress.seeds,
				(progress.eta / 60).toFixed(1)));
	});
	torrent.on('error', function (e) {
		logger.error(e);
	});
}

function getURL(){
	return "http://" + ip + ":" + port + "/" + ID + '.mp4';
}

function getStreamer(){
	return torrent;
}

exports.startStreamer = startStreamer;
exports.getURL = getURL;
exports.getStreamer = getStreamer;