API tools faq
paste
fadhiilrachman

Peer5 (No APIKEY)

fadhiilrachman
May 21st, 2014
296
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
jQuery 184.70 KB | None | 0 0
raw download clone embed print report
  1. (function(){function e(){return null}function t(e,t){var i=1024,n=1024*i,r=1024*n,o=1024*r;return e>=0&&i>e?e+" B":e>=i&&n>e?(e/i).toFixed(t)+" KB":e>=n&&r>e?(e/n).toFixed(t)+" MB":e>=r&&o>e?(e/r).toFixed(t)+" GB":e>=o?(e/o).toFixed(t)+" TB":e+" B"}function i(e){function t(e){return e>9?""+e:"0"+e}if(1>e||isNaN(e))return"00:00:00";if(e>86400)return"Calculating...";var i=Math.floor(e%31536e3%86400/3600),n=Math.floor(e%31536e3%86400%3600/60),r=Math.floor(e%31536e3%86400%3600%60);return t(i)+":"+t(n)+":"+t(r)}function n(){var e=[],t=0;this.getLength=function(){return e.length-t},this.isEmpty=function(){return 0==e.length},this.enqueue=function(t){e.push(t)},this.dequeue=function(){if(0==e.length)return void 0;var i=e[t];return 2*++t>=e.length&&(e=e.slice(t),t=0),i},this.peek=function(){return e.length>0?e[t]:void 0}}var r={core:{apiValidators:{},dataStructures:{},data:{},controllers:{},protocol:{},transport:{},util:{},stats:{},workers:{}}};r.config={CHUNKY_HEAD:!0,CHUNKY_HEAD_LENGTH:1e5,DISABLE_CHROME:!1,DISABLE_FIREFOX:!1,LOG_LEVEL:1,USE_QUERYSTRING_FOR_HASH:!1,USE_PEERCONNECTION:!0,USE_TRACKER_PROTOCOL:!0,PC_FAIL_TIMEOUT:15e3,PC_RESEND_INTERVAL:1e3,REQUEST_DROPPED_FAIL:20,EMULATE_LOSS:!1,EMULATE_LOSS_PERCENTAGE:.2,MINIMUM_METADATA_SIZE:64e3,CHUNK_SIZE:1200,SEQUENTIAL_DOWNLOAD:!1,MONITOR_INTERVAL:200,WS_PORT:443,XHR_TIMEOUT:5e3,XHR_MAX_GET:1,XHR_CONCURRENT:6,BUFFERING_THRESHOLD:.1,URGENT_THRESHOLD:2,BYTE_NEEDED_THRESHOLD:10,ENOUGH_BYTES_THRESHOLD:20,STOP_BUFFERING_THRESHOLD:2,HTTP_IDLE_RESET_DURATION:3e4,XHR_SLOT_PROBE_INTERVAL:3e4,HTTP_ALWAYS_DOWNLOAD:!1,P2P_ALWAYS_DOWNLOAD:!1,P2P_REQUEST_BEGIN_THRESHOLD:0,P2P_REQUEST_END_THRESHOLD:2e4,HYBRID_REQUEST_THRESHOLD:1e4,HTTP_REQUEST_THRESHOLD:5e3,MAX_PENDING_CHUNKS:400,MOZ_MAX_PENDING_CHUNKS:200,REQUEST_CHUNK_THRESH:100,BLOCK_GAP:17,CHUNK_EXPIRATION_TIMEOUT:3e3,REPORT_INTERVAL:2e4,STAT_CALC_INTERVAL:500,REQUEST_INTERVAL:3e3,BANDWIDTH_INTERVAL:1e4,SOCKET_RECONNECTION_INTERVAL:2e3,WASTE_CHECK_INTERVAL:1e4,START_WITH_VIDEO_ANALYTICS:!0,USE_FS:!0,USE_PERSISTENT:!0,PROMPT_TIMEOUT:2e4,PERSISTENT_FS_SIZE:1099511627776,CACHE_SIZE:5e7,FS_ROOT_DIR:"peer5/",PREALLOCATE_FILE:!0,ALLOWED_FILE_SIZE:256e6,ALLOWED_FILE_SIZE_FF:104857600,CDN:"http://commondatastorage.googleapis.com/peer5_vod/",STUN_SERVERS:["stun.l.google.com:19302"],TURN_SERVERS:[],TURN_CREDENTIALS:[]},r.tracker={lib:{analytics:{},matching:{},util:{}}},r.client||(r.client={}),r.client.downloader={},r.client.apiValidators={},r.client.videoAnalytics={},function(e){function t(e,t,i,n){this.socketId=e,this.blockIds=t,this.secretId=i,this.swarmId=n}function i(e,t,i,n){this.swarmId=e,this.size=t,this.blockSize=n,this.hashes=i}function n(e,t,i,n,r,o,s,a,c,l,d){this.busySenders=l,this.Connections=e,this.Transactions=t,this.missingBlocks=i,this.numOfP2PCompletedBlocks=n,this.numOfP2PWasteBlocks=c,this.numOfHttpCompletedBlocks=r,this.numOfHttpWasteBlocks=a,this.Size=o,this.downloadTime=s,this.recentBlocks=d}function r(e,t,i,n,r){this.bufferingSegments=e,this.totalBufferingDuration=t,this.currentTime=i,this.currentBlock=n,this.blockGap=r}function o(e,t,i,n,r,o,s,a){this.loadStart=e,this.canPlay=t,this.playTime=i,this.seek=n,this.waste=r,this.canPlay=t,this.buffering=o,this.videoFullyWatched=s,this.fallback=a}function s(e){this.connectionOpenTime=e}function a(e,t,i){this.upBW=e,this.downBW=t,this.sendBufferSize=i}function c(e,t,i,n,r,o){this.id=e,this.transfer=t,this.ux=i,this.ws=n,this.dum=r,this.videoAnalyticsState=o}function l(e,t,i){this.BlockID=e,this.Rate=t,this.Completion=i}function d(e,t,i,n){this.ClientID=e,this.Health=t,this.Total_Downloaded=i,this.Avg_Download_Rate=n}function u(e,t,i){this.op="sdp",this.sdp=e,this.targetId=t,this.originId=i}defaultClientState=new c(0,new n(-100,-100,-100,-100,-100,-100,-100,-100,-100,{},{}),new r(-100,-100,-100,-100,-100),new s(-100),new a(-100,-100,-100),new o(-100,-100,-100,-100,-100,-100,-100,-100)),e.sdp=u,e.Command=t,e.FileInfo=i,e.Connection=d,e.Transaction=l,e.ClientState=c,e.transferState=n,e.uxState=r,e.wsState=s,e.dumState=a,e.defaultClientState=defaultClientState}("undefined"==typeof exports?this.api={}:exports),function(e){function t(e,t){if(this.myDict={},this.keys=[],e){t||(t=1);for(var i=0;e>i;i++){this.keys.push(i);var n=[t,this.keys.length-1];this.myDict[i]=n}}}t.prototype={has:function(e){return e in this.myDict},set:function(e,t){if(this.has(e)){r.warn("Trying to set a key to Dictionary.js that already exists: "+e),r.log("The old value was connected: "+this.myDict[e][0].connected);var i=this.myDict[e][1],n=[t,i];this.myDict[e]=n}else{this.keys.push(e);var n=[t,this.keys.length-1];this.myDict[e]=n}},get:function(e){return this.myDict[e]?this.myDict[e][0]:void 0},getKeys:function(){return this.keys},randomSample:function(e,t){for(var i=t(this.keys,e),n=[],o=0;i.length>o;++o)this.myDict[i[o]]&&this.myDict[i[o]][0]?n.push(this.myDict[i[o]][0]):r.warn("Error in randomSampling, the key: "+i[o]+" is undefined");return n},keys:function(){return this.keys},length:function(){return this.keys.length},filterValues:function(e){for(var t=[],i=0;this.keys.length>i;++i)e(this.myDict[this.keys[i]][0])&&t.push(this.myDict[this.keys[i]][0]);return t},values:function(){for(var e=[],t=0;this.keys.length>t;++t)e.push(this.myDict[this.keys[t]][0]);return e},getFirstVals:function(e){var t=[];for(var i in this.myDict)if(this.myDict.hasOwnProperty(i)&&t.push(this.myDict[i][0]),t.length==e)break;return t},getFirstKeys:function(e,t){var i=[];for(var n in this.myDict){if(i.length>=e)break;t&&t>=parseInt(n)||this.myDict.hasOwnProperty(parseInt(n))&&i.push(parseInt(n))}return i},slice:function(e){for(var t=[],i=0;e.length>i;++i)this.myDict[e[i]]&&t.push(this.myDict[e[i]][0]);return t},remove:function(e){var t=this.myDict[e];t||console.log(t),delete this.myDict[e];var i=t[1];this.keys[i]=this.keys[this.keys.length-1],this.keys[i]in this.myDict&&(this.myDict[this.keys[i]][1]=i),this.keys.length--}},e.Dictionary=t}("undefined"==typeof exports?this.Dictionary={}:exports),function(e){e.shortId=function(){return"xxxxxxxx".replace(/[xy]/g,function(e){var t=0|16*Math.random(),i="x"==e?t:8|3&t;return i.toString(16)})},e.generate_uuid=function(){return"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,function(e){var t=0|16*Math.random(),i="x"==e?t:8|3&t;return i.toString(16)})}}("undefined"==typeof exports?r.core.util:exports),function(e,t,i){"undefined"!=typeof module?module.exports=i(e,t):"function"==typeof define&&"object"==typeof define.amd?define(i):t[e]=i(e,t)}("radio",this,function(e,t){"use strict";function i(e){return arguments.length?i.$.channel(e):i.$.reset(),i.$}return i.$={version:"0.2",channelName:"",channels:[],reset:function(){i.$.channelName="",i.$.channels=[]},broadcast:function(){var e,i,n,r,o=this.channels[this.channelName],s=o.length;for(e=0;s>e;e++)i=o[e],"object"==typeof i&&i.length&&(n=i[0],r=i[1]||t),n.apply(r,arguments);return this},channel:function(e){var t=this.channels;return t[e]||(t[e]=[]),this.channelName=e,this},subscribe:function(){var e,t,i=arguments,n=this.channels[this.channelName],r=i.length,o=[];for(e=0;r>e;e++)o=i[e],t="function"==typeof o?[o]:o,"object"==typeof t&&t.length&&n.push(t);return this},unsubscribe:function(){var e,t,i,n=arguments,r=this.channels[this.channelName],o=n.length,s=r.length,a=0;for(e=0;o>e;e++)for(a=0,s=r.length,t=0;s>t;t++)i=t-a,(!(n[e]instanceof Array)&&r[i][0]===n[e]||n[e]instanceof Array&&r[i][0]===n[e][0])&&(n[e]instanceof Array&&r[i][1]!==n[e][1]||(r.splice(i,1),a++));return this}},i}),function(){r===void 0&&(r={});var e=!1,t=r.config?r.config.LOG_LEVEL:2,i=["0","ERROR","WARNING","info","log","debug"],n=function(n,r){function o(e,t){this.title=t,this.title||(this.title=""),this.severity=i[n];var r=new Date;if(this.time=r.toISOString(),this.content=e,3>n){var o=Error().stack;this.stack=o?Error().stack.replace("Error\n",""):""}}if(!(n>t))switch(o.prototype.toString=function(){var e;return e=this.content.stack?[this.title,this.severity,this.time,this.content,this.content.stack]:[this.title,this.severity,this.time,JSON.stringify(this.content),this.stack],e.join("   ")},r=e?""+new o(r):new o(r),n){case 1:console.error(r);break;case 2:console.warn(r);break;case 3:console.info(r);break;case 4:case 5:console.log(r)}};r.setLogFlat=function(t){e=t},r.setLogLevel=function(e){t=e},r.isVerbose=function(){return t>2},r.isDebug=function(){return 5==t},r.debug=function(e,t){n(5,e,t)},r.log=function(e){n(4,e)},r.info=function(e){n(3,e)},r.warn=function(e){n(2,e)},r.error=function(e){n(1,e)}}(),function(e){var t="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-/=",i={decode:function(e){var i=t.indexOf(e.charAt(e.length-1)),n=t.indexOf(e.charAt(e.length-2)),r=3*(e.length/4);64==i&&r--,64==n&&r--;var o,s,a,c,l,d,u,h=0,f=0,p=new Uint8Array(r);for(h=0;r>h;h+=3)c=t.indexOf(e.charAt(f++)),l=t.indexOf(e.charAt(f++)),d=t.indexOf(e.charAt(f++)),u=t.indexOf(e.charAt(f++)),o=c<<2|l>>4,s=(15&l)<<4|d>>2,a=(3&d)<<6|u,p[h]=o,64!=d&&(p[h+1]=s),64!=u&&(p[h+2]=a);return p},encode:function(e){for(var i,n,r,o,s,a="",c=new Uint8Array(e),l=c.byteLength,d=l%3,u=l-d,h=0;u>h;h+=3)s=c[h]<<16|c[h+1]<<8|c[h+2],i=(16515072&s)>>18,n=(258048&s)>>12,r=(4032&s)>>6,o=63&s,a+=t[i]+t[n]+t[r]+t[o];return 1==d?(s=c[u],i=(252&s)>>2,n=(3&s)<<4,a+=t[i]+t[n]+"=="):2==d&&(s=c[u]<<8|c[u+1],i=(64512&s)>>10,n=(1008&s)>>4,r=(15&s)<<2,a+=t[i]+t[n]+t[r]+"="),a}};e.base64=i}("undefined"==typeof exports?r.core.util:exports),function(e){var t={registerEvents:function(){var e=null;e=window.onerror,window.onerror=function(t,i,n){r.warn("peer5 caught an unhandled error: msg/"+t+" url/"+i+" lineNumber/"+n),radio("unhandledError").broadcast(t,i,n),e&&"function"==typeof e&&e(t,i,n)}}};t.registerEvents(),e.errorHandler=t}("undefined"==typeof exports?r.core.util:exports),function(e){function t(t,i,n){this.tag=e.P2P_DATA,this.swarmId=t,this.chunkId=i,this.payload=n}function i(t,i){this.tag=e.P2P_REQUEST,this.swarmId=t,i||(i=[]),this.chunkIds=i}function n(t,i){this.tag=e.P2P_CANCEL,this.swarmId=t,i||(i=[]),this.all=0==i.length,this.chunkIds=i}function r(t,i,n,r){this.tag=e.P2P_HAVE,this.swarmId=t,this.seeder=i,this.blockIds=[],i||(n?(this.complete=!0,this.availabilityMap=n):(this.complete=!1,this.blockIds=r))}function o(t){this.tag=e.P2P_HAVE_REQUEST,this.swarmId=t}function s(t,i,n,r,o,s,a,c,l,d,u,h,f,p,g){this.tag=e.REPORT,this.swarmId=t,this.lastRequestedBlockId=i,this.totalBytesUpP2P=n,this.totalBytesDownP2P=r,this.totalBytesDownHTTP=o,this.totalWasteP2P=s,this.totalWasteHTTP=a,this.speedUp=c,this.speedDown=l,this.connections=d,this.ua=u,this.availabilityMap=h,this.numOfBlocksHave=f,this.fileSize=p,this.completedDownload=g}function a(t){this.tag=e.JOIN,this.swarmId=t}function c(t,i,n,r,o,s,a,c,l){this.tag=e.FILE_INFO,this.swarmId=t,this.size=i,this.hash=n,this.hashes=r,this.blockSize=o,this.origin=s,this.name=a,this.lastModified=c,this.type=l}function l(t,i){this.tag=e.SWARM_ERROR,this.swarmId=t,this.error=i}function d(t,i,n){this.tag=e.MATCH,this.swarmId=t,this.peerId=i,this.availabilityMap=n}function u(e,t,i,n,r,o,s,a,c,l){this.totalBytesDown=e,this.totalBytesUp=t,this.speedDown=i,this.speedUp=n,this.chunksRequested=o,this.chunksExpired=r,this.latency=s,this.connected=a,this.connectingDuration=c,this.failure=l}function h(t,i,n,r,o){this.tag=e.SDP,this.originId=t,this.destId=i,this.sdpMessage=n,this.port=r,this.type=o}function f(t,i,n,r){this.tag=e.SWARM_HEALTH,this.swarmId=t,this.numOfSeedersInSwarm=i,this.NumOfPeersInSwarm=n,this.totalCompletedDownloads=r}e.P2P_DATA=17,e.P2P_REQUEST=18,e.P2P_CANCEL=19,e.P2P_HAVE=20,e.P2P_HAVE_REQUEST=21,e.REPORT=33,e.FILE_INFO=34,e.MATCH=35,e.JOIN=36,e.SWARM_HEALTH=41,e.SWARM_ERROR=48,e.SDP=49,e.COMPLETED_DOWNLOAD=50,e.SWARM_NOT_FOUND=0,e.SWARM_ONLY_DEVCHANNEL=1,e.SWARM_ONLY_FIREFOX=11,e.SWARM_ONLY_CHROME=12,e.SWARM_NOT_COMPAT=13,e.Have=r,e.HaveRequest=o,e.Cancel=n,e.Request=i,e.Data=t,e.Report=s,e.Connection=u,e.FileInfo=c,e.Match=d,e.Join=a,e.Sdp=h,e.SwarmHealth=f,e.SwarmError=l}("undefined"==typeof exports?r.core.protocol:exports),function(t){function i(e){return"function"==typeof Buffer&&Buffer.isBuffer(e)?e.toString("ucs2"):String.fromCharCode.apply(null,new Uint16Array(e.buffer.slice(e.byteOffset))).trim()}function n(e){if("function"==typeof Buffer)return new Buffer(e,"ucs2");for(var t=new ArrayBuffer(2*e.length),i=new Uint16Array(t),n=0,r=e.length;r>n;n++)i[n]=e.charCodeAt(n);return new Uint8Array(t)}var o={},s=e("./ProtocolMessages.js")||r.core.protocol;"function"==typeof Uint8Array&&Uint8Array.prototype.subarray&&(Uint8Array.prototype.slice=Uint8Array.prototype.subarray),(e("./../util/base64.js")||r.core.util).base64;var a=1,c=4,l=function(e){return String.fromCharCode.apply(null,e).trim()},d=function(e,t){for(var i=new Uint8Array(e.length),n=0;e.length>n;n++)i[n]=e.charCodeAt(n);if(t)for(var r=e.length;t>r;r++)i[r]=" ";return i},u=function(e,t){t||(t=0);var i=0;return i+=e[t++]<<24,i+=e[t++]<<16,i+=e[t++]<<8,i+=e[t]},h=function(e){var t=0;"number"!=typeof e.length&&(e=Array.prototype.slice.call(arguments));for(var i=new Uint8Array(4*e.length),n=0;e.length>n;n++){var r=e[n];i[t++]=(4278190080&r)>>24,i[t++]=(16711680&r)>>16,i[t++]=(65280&r)>>8,i[t++]=255&r}return i},f=function(e){return e?new Uint8Array([1]):new Uint8Array([0])},p=function(e,t){return 0!=e[t]},g=function(e){var t=d(o.packSwarmId(e.swarmId)),i=h(e.chunkId);return o.concat([t,i,e.payload])},v=function(e){var t=[],i=d(o.packSwarmId(e.swarmId));t.push(i);var n=h(e.chunkIds);return t.push(n),o.concat(t)},b=function(e){var t=[],i=d(o.packSwarmId(e.swarmId));t.push(i);var n=h(e.chunkIds);return t.push(n),o.concat(t)},m=function(e){var t=[],i=d(o.packSwarmId(e.swarmId));t.push(i);var n=f(e.seeder);t.push(n);var r=f(e.complete);if(t.push(r),e.complete)t.push(e.availabilityMap);else{var s=h(e.blockIds);t.push(s)}return o.concat(t)},_=function(e,t,i){var n=l(e.slice(t,t+o.transferedSwarmIdSize));t+=o.transferedSwarmIdSize;var r=u(e,t);t+=4;var a=e.slice(t,t+i);return new s.Data(n,r,a)},w=function(e,t,i){var n=l(e.slice(t,t+o.transferedSwarmIdSize));t+=o.transferedSwarmIdSize,i-=o.transferedSwarmIdSize;for(var r=[];i>0;)r.push(u(e,t)),i-=4,t+=4;return new s.Request(n,r)},k=function(e,t,i){var n=l(e.slice(t,t+o.transferedSwarmIdSize));t+=o.transferedSwarmIdSize,i-=o.transferedSwarmIdSize;for(var r=[];i>0;)r.push(u(e,t)),i-=4,t+=4;return new s.Cancel(n,r)},C=function(e,t,i){var n,r,a=l(e.slice(t,t+o.transferedSwarmIdSize));t+=o.transferedSwarmIdSize,i-=o.transferedSwarmIdSize;var c=p(e,t);if(t++,i--,!c){var d=p(e,t);if(t++,i--,d)r=e.slice(t,t+i);else for(n=[];i>0;)n.push(u(e,t)),t+=4,i-=4}return new s.Have(a,c,r,n)},S=function(e){var t=JSON.stringify(e);return d(t)},y=function(e,t,i){try{var n=l(e.slice(t,t+i));return JSON.parse(n)}catch(o){r.error(o),r.error("printing out the buggy json"),r.error(n)}},R=function(e){var t=JSON.stringify(e);return n(t)},T=function(e,t,n){var r=i(e.slice(t,t+n));return JSON.parse(r)},E={encode:S,decode:y},I={encode:R,decode:T},P={};P[s.P2P_DATA]={encode:g,decode:_},P[s.P2P_REQUEST]={encode:v,decode:w},P[s.P2P_CANCEL]={encode:b,decode:k},P[s.P2P_HAVE]={encode:m,decode:C},P[s.P2P_HAVE_REQUEST]=E,P[s.REPORT]=E,P[s.MATCH]=E,P[s.SDP]=E,P[s.FILE_INFO]=I,P[s.SWARM_HEALTH]=E,P[s.SWARM_ERROR]=E,P[s.JOIN]=E;var O=function(e,t,i,n){var r=i;n&&t in P&&P[t].encode&&(r=P[t].encode(i));var o=new Uint8Array(5+r.length),s=r.length;return o[e++]=t,o.set(h(s),e),e+=c,o.set(r,e),o},A=function(e,t){var i=e[t++],n=u(e,t);t+=c;var r=e.slice(t,t+n);return[i,r]};o.concat=function(e){var t=0;e.map(function(e){t+=e.length});var i=new Uint8Array(t),n=0;return e.map(function(e){i.set(e,n),n+=e.length}),i},o.encode=function(e){var t=[];return e.forEach(function(e){if(e&&e.tag&&P[e.tag]&&P[e.tag].encode){var i=P[e.tag].encode(e);t.push(O(0,e.tag,i))}}),o.concat(t)},o.decode=function(e){for(var t=0,i=[];e.length>t;){var n=A(e,t),r=n[0],o=n[1];t+=a+c;var s=P[r];if(!s||!s.decode)return null;i.push(s.decode(e,t,o.length)),t+=o.length}return i},o.transferedSwarmIdSize=20,o.packSwarmId=function(e){return e.length>o.transferedSwarmIdSize&&(r.warn("trimming swarmId to be at size of "+o.transferedSwarmIdSize),e=e.substr(0,o.transferedSwarmIdSize)),Array(o.transferedSwarmIdSize-e.length+1).join(" ").concat(e)},t.packSwarmId=o.packSwarmId,t.concat=o.concat,t.decode=o.decode,t.encode=o.encode}("undefined"==typeof exports?r.core.protocol.BinaryProtocol={}:exports),function(){var e=!1,t=/xyz/.test(function(){})?/\b_super\b/:/.*/;Object.subClass=function(i){function n(){!e&&this.ctor&&this.ctor.apply(this,arguments)}var r=this.prototype;e=!0;var o=new this;e=!1;var s;for(s in i){var a="function"==typeof i[s]&&"function"==typeof r[s]&&t.test(i[s]);o[s]=a?function(e,t){return function(){var i=this._super;this._super=r[e];var n=t.apply(this,arguments);return this._super=i,n}}(s,i[s]):i[s]}for(s in this)this.hasOwnProperty(s)&&"function"!=typeof this[s]&&(n[s]=this[s]);return n.prototype=o,n.constructor=n,n.subClass=arguments.callee,n.addBehavior=function(e,t){if(t=t||{},!e)throw"behaviorAbstractClass must be a vaild behavior class";override(o,t,new e)},n}}(),function(e){var t=t||function(e,t){var i={},n=i.lib={},r=function(){},o=n.Base={extend:function(e){r.prototype=this;var t=new r;return e&&t.mixIn(e),t.hasOwnProperty("init")||(t.init=function(){t.$super.init.apply(this,arguments)}),t.init.prototype=t,t.$super=this,t},create:function(){var e=this.extend();return e.init.apply(e,arguments),e},init:function(){},mixIn:function(e){for(var t in e)e.hasOwnProperty(t)&&(this[t]=e[t]);e.hasOwnProperty("toString")&&(this.toString=e.toString)},clone:function(){return this.init.prototype.extend(this)}},s=n.WordArray=o.extend({init:function(e,i){e=this.words=e||[],this.sigBytes=i!=t?i:4*e.length},toString:function(e){return(e||c).stringify(this)},concat:function(e){var t=this.words,i=e.words,n=this.sigBytes;if(e=e.sigBytes,this.clamp(),n%4)for(var r=0;e>r;r++)t[n+r>>>2]|=(255&i[r>>>2]>>>24-8*(r%4))<<24-8*((n+r)%4);else if(i.length>65535)for(r=0;e>r;r+=4)t[n+r>>>2]=i[r>>>2];else t.push.apply(t,i);return this.sigBytes+=e,this},clamp:function(){var t=this.words,i=this.sigBytes;t[i>>>2]&=4294967295<<32-8*(i%4),t.length=e.ceil(i/4)},clone:function(){var e=o.clone.call(this);return e.words=this.words.slice(0),e},random:function(t){for(var i=[],n=0;t>n;n+=4)i.push(0|4294967296*e.random());return new s.init(i,t)}}),a=i.enc={},c=a.Hex={stringify:function(e){var t=e.words;e=e.sigBytes;for(var i=[],n=0;e>n;n++){var r=255&t[n>>>2]>>>24-8*(n%4);i.push((r>>>4).toString(16)),i.push((15&r).toString(16))}return i.join("")},parse:function(e){for(var t=e.length,i=[],n=0;t>n;n+=2)i[n>>>3]|=parseInt(e.substr(n,2),16)<<24-4*(n%8);return new s.init(i,t/2)}},l=a.Latin1={stringify:function(e){var t=e.words;e=e.sigBytes;for(var i=[],n=0;e>n;n++)i.push(String.fromCharCode(255&t[n>>>2]>>>24-8*(n%4)));return i.join("")},parse:function(e){for(var t=e.length,i=[],n=0;t>n;n++)i[n>>>2]|=(255&e.charCodeAt(n))<<24-8*(n%4);return new s.init(i,t)}},d=a.Utf8={stringify:function(e){try{return decodeURIComponent(escape(l.stringify(e)))}catch(t){throw Error("Malformed UTF-8 data")}},parse:function(e){return l.parse(unescape(encodeURIComponent(e)))}},u=n.BufferedBlockAlgorithm=o.extend({reset:function(){this._data=new s.init,this._nDataBytes=0},_append:function(e){"string"==typeof e&&(e=d.parse(e)),this._data.concat(e),this._nDataBytes+=e.sigBytes},_process:function(t){var i=this._data,n=i.words,r=i.sigBytes,o=this.blockSize,a=r/(4*o),a=t?e.ceil(a):e.max((0|a)-this._minBufferSize,0);if(t=a*o,r=e.min(4*t,r),t){for(var c=0;t>c;c+=o)this._doProcessBlock(n,c);c=n.splice(0,t),i.sigBytes-=r}return new s.init(c,r)},clone:function(){var e=o.clone.call(this);return e._data=this._data.clone(),e},_minBufferSize:0});n.Hasher=u.extend({cfg:o.extend(),init:function(e){this.cfg=this.cfg.extend(e),this.reset()},reset:function(){u.reset.call(this),this._doReset()},update:function(e){return this._append(e),this._process(),this},finalize:function(e){return e&&this._append(e),this._doFinalize()},blockSize:16,_createHelper:function(e){return function(t,i){return new e.init(i).finalize(t)}},_createHmacHelper:function(e){return function(t,i){return new h.HMAC.init(e,i).finalize(t)}}});var h=i.algo={};return i}(Math);(function(){var e=t,i=e.lib,n=i.WordArray,r=i.Hasher,o=[],i=e.algo.SHA1=r.extend({_doReset:function(){this._hash=new n.init([1732584193,4023233417,2562383102,271733878,3285377520])},_doProcessBlock:function(e,t){for(var i=this._hash.words,n=i[0],r=i[1],s=i[2],a=i[3],c=i[4],l=0;80>l;l++){if(16>l)o[l]=0|e[t+l];else{var d=o[l-3]^o[l-8]^o[l-14]^o[l-16];o[l]=d<<1|d>>>31}d=(n<<5|n>>>27)+c+o[l],d=20>l?d+((r&s|~r&a)+1518500249):40>l?d+((r^s^a)+1859775393):60>l?d+((r&s|r&a|s&a)-1894007588):d+((r^s^a)-899497514),c=a,a=s,s=r<<30|r>>>2,r=n,n=d}i[0]=0|i[0]+n,i[1]=0|i[1]+r,i[2]=0|i[2]+s,i[3]=0|i[3]+a,i[4]=0|i[4]+c},_doFinalize:function(){var e=this._data,t=e.words,i=8*this._nDataBytes,n=8*e.sigBytes;return t[n>>>5]|=128<<24-n%32,t[(n+64>>>9<<4)+14]=Math.floor(i/4294967296),t[(n+64>>>9<<4)+15]=i,e.sigBytes=4*t.length,this._process(),this._hash},clone:function(){var e=r.clone.call(this);return e._hash=this._hash.clone(),e}});e.SHA1=r._createHelper(i),e.HmacSHA1=r._createHmacHelper(i)})(),e.CryptoJS=t}("undefined"==typeof exports?r:exports),function(e){var t=function(e,t){return 4294967295&e+t},i=function(e,i,n,r,o,s){return i=t(t(i,e),t(r,s)),t(i<<o|i>>>32-o,n)},n=function(e,t,n,r,o,s,a){return i(t&n|~t&r,e,t,o,s,a)},r=function(e,t,n,r,o,s,a){return i(t&r|n&~r,e,t,o,s,a)},o=function(e,t,n,r,o,s,a){return i(t^n^r,e,t,o,s,a)},s=function(e,t,n,r,o,s,a){return i(n^(t|~r),e,t,o,s,a)},a=function(e,i){var a=e[0],c=e[1],l=e[2],d=e[3];a=n(a,c,l,d,i[0],7,-680876936),d=n(d,a,c,l,i[1],12,-389564586),l=n(l,d,a,c,i[2],17,606105819),c=n(c,l,d,a,i[3],22,-1044525330),a=n(a,c,l,d,i[4],7,-176418897),d=n(d,a,c,l,i[5],12,1200080426),l=n(l,d,a,c,i[6],17,-1473231341),c=n(c,l,d,a,i[7],22,-45705983),a=n(a,c,l,d,i[8],7,1770035416),d=n(d,a,c,l,i[9],12,-1958414417),l=n(l,d,a,c,i[10],17,-42063),c=n(c,l,d,a,i[11],22,-1990404162),a=n(a,c,l,d,i[12],7,1804603682),d=n(d,a,c,l,i[13],12,-40341101),l=n(l,d,a,c,i[14],17,-1502002290),c=n(c,l,d,a,i[15],22,1236535329),a=r(a,c,l,d,i[1],5,-165796510),d=r(d,a,c,l,i[6],9,-1069501632),l=r(l,d,a,c,i[11],14,643717713),c=r(c,l,d,a,i[0],20,-373897302),a=r(a,c,l,d,i[5],5,-701558691),d=r(d,a,c,l,i[10],9,38016083),l=r(l,d,a,c,i[15],14,-660478335),c=r(c,l,d,a,i[4],20,-405537848),a=r(a,c,l,d,i[9],5,568446438),d=r(d,a,c,l,i[14],9,-1019803690),l=r(l,d,a,c,i[3],14,-187363961),c=r(c,l,d,a,i[8],20,1163531501),a=r(a,c,l,d,i[13],5,-1444681467),d=r(d,a,c,l,i[2],9,-51403784),l=r(l,d,a,c,i[7],14,1735328473),c=r(c,l,d,a,i[12],20,-1926607734),a=o(a,c,l,d,i[5],4,-378558),d=o(d,a,c,l,i[8],11,-2022574463),l=o(l,d,a,c,i[11],16,1839030562),c=o(c,l,d,a,i[14],23,-35309556),a=o(a,c,l,d,i[1],4,-1530992060),d=o(d,a,c,l,i[4],11,1272893353),l=o(l,d,a,c,i[7],16,-155497632),c=o(c,l,d,a,i[10],23,-1094730640),a=o(a,c,l,d,i[13],4,681279174),d=o(d,a,c,l,i[0],11,-358537222),l=o(l,d,a,c,i[3],16,-722521979),c=o(c,l,d,a,i[6],23,76029189),a=o(a,c,l,d,i[9],4,-640364487),d=o(d,a,c,l,i[12],11,-421815835),l=o(l,d,a,c,i[15],16,530742520),c=o(c,l,d,a,i[2],23,-995338651),a=s(a,c,l,d,i[0],6,-198630844),d=s(d,a,c,l,i[7],10,1126891415),l=s(l,d,a,c,i[14],15,-1416354905),c=s(c,l,d,a,i[5],21,-57434055),a=s(a,c,l,d,i[12],6,1700485571),d=s(d,a,c,l,i[3],10,-1894986606),l=s(l,d,a,c,i[10],15,-1051523),c=s(c,l,d,a,i[1],21,-2054922799),a=s(a,c,l,d,i[8],6,1873313359),d=s(d,a,c,l,i[15],10,-30611744),l=s(l,d,a,c,i[6],15,-1560198380),c=s(c,l,d,a,i[13],21,1309151649),a=s(a,c,l,d,i[4],6,-145523070),d=s(d,a,c,l,i[11],10,-1120210379),l=s(l,d,a,c,i[2],15,718787259),c=s(c,l,d,a,i[9],21,-343485551),e[0]=t(a,e[0]),e[1]=t(c,e[1]),e[2]=t(l,e[2]),e[3]=t(d,e[3])},c=function(e){var t,i=[];for(t=0;64>t;t+=4)i[t>>2]=e.charCodeAt(t)+(e.charCodeAt(t+1)<<8)+(e.charCodeAt(t+2)<<16)+(e.charCodeAt(t+3)<<24);return i},l=function(e){var t,i=[];for(t=0;64>t;t+=4)i[t>>2]=e[t]+(e[t+1]<<8)+(e[t+2]<<16)+(e[t+3]<<24);return i},d=function(e){var t,i,n,r,o,s,l=e.length,d=[1732584193,-271733879,-1732584194,271733878];for(t=64;l>=t;t+=64)a(d,c(e.substring(t-64,t)));for(e=e.substring(t-64),i=e.length,n=[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0],t=0;i>t;t+=1)n[t>>2]|=e.charCodeAt(t)<<(t%4<<3);if(n[t>>2]|=128<<(t%4<<3),t>55)for(a(d,n),t=0;16>t;t+=1)n[t]=0;return r=8*l,r=r.toString(16).match(/(.*?)(.{0,8})$/),o=parseInt(r[2],16),s=parseInt(r[1],16)||0,n[14]=o,n[15]=s,a(d,n),d},u=function(e){var t,i,n,r,o,s,c=e.length,d=[1732584193,-271733879,-1732584194,271733878];for(t=64;c>=t;t+=64)a(d,l(e.subarray(t-64,t)));for(e=c>t-64?e.subarray(t-64):new Uint8Array(0),i=e.length,n=[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0],t=0;i>t;t+=1)n[t>>2]|=e[t]<<(t%4<<3);if(n[t>>2]|=128<<(t%4<<3),t>55)for(a(d,n),t=0;16>t;t+=1)n[t]=0;return r=8*c,r=r.toString(16).match(/(.*?)(.{0,8})$/),o=parseInt(r[2],16),s=parseInt(r[1],16)||0,n[14]=o,n[15]=s,a(d,n),d},h=["0","1","2","3","4","5","6","7","8","9","a","b","c","d","e","f"],f=function(e){var t,i="";for(t=0;4>t;t+=1)i+=h[15&e>>8*t+4]+h[15&e>>8*t];return i},p=function(e){var t;for(t=0;e.length>t;t+=1)e[t]=f(e[t]);return e.join("")},g=function(e){return p(d(e))},v=function(){this.reset()};"5d41402abc4b2a76b9719d911017c592"!==g("hello")&&(t=function(e,t){var i=(65535&e)+(65535&t),n=(e>>16)+(t>>16)+(i>>16);return n<<16|65535&i}),v.prototype.append=function(e){return/[\u0080-\uFFFF]/.test(e)&&(e=unescape(encodeURIComponent(e))),this.appendBinary(e),this},v.prototype.appendBinary=function(e){this._buff+=e,this._length+=e.length;var t,i=this._buff.length;for(t=64;i>=t;t+=64)a(this._state,c(this._buff.substring(t-64,t)));return this._buff=this._buff.substr(t-64),this},v.prototype.end=function(e){var t,i,n=this._buff,r=n.length,o=[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0];for(t=0;r>t;t+=1)o[t>>2]|=n.charCodeAt(t)<<(t%4<<3);return this._finish(o,r),i=e?this._state:p(this._state),this.reset(),i},v.prototype._finish=function(e,t){var i,n,r,o=t;if(e[o>>2]|=128<<(o%4<<3),o>55)for(a(this._state,e),o=0;16>o;o+=1)e[o]=0;i=8*this._length,i=i.toString(16).match(/(.*?)(.{0,8})$/),n=parseInt(i[2],16),r=parseInt(i[1],16)||0,e[14]=n,e[15]=r,a(this._state,e)},v.prototype.reset=function(){return this._buff="",this._length=0,this._state=[1732584193,-271733879,-1732584194,271733878],this},v.prototype.destroy=function(){delete this._state,delete this._buff,delete this._length},v.hash=function(e,t){/[\u0080-\uFFFF]/.test(e)&&(e=unescape(encodeURIComponent(e)));var i=d(e);return t?i:p(i)},v.hashBinary=function(e,t){var i=d(e);return t?i:p(i)},v.ArrayBuffer=function(){this.reset()},v.ArrayBuffer.prototype.append=function(e){var t,i=this._concatArrayBuffer(this._buff,e),n=i.length;for(this._length+=e.byteLength,t=64;n>=t;t+=64)a(this._state,l(i.subarray(t-64,t)));return this._buff=n>t-64?i.subarray(t-64):new Uint8Array(0),this},v.ArrayBuffer.prototype.end=function(e){var t,i,n=this._buff,r=n.length,o=[0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0];for(t=0;r>t;t+=1)o[t>>2]|=n[t]<<(t%4<<3);return this._finish(o,r),i=e?this._state:p(this._state),this.reset(),i},v.ArrayBuffer.prototype._finish=v.prototype._finish,v.ArrayBuffer.prototype.reset=function(){return this._buff=new Uint8Array(0),this._length=0,this._state=[1732584193,-271733879,-1732584194,271733878],this},v.ArrayBuffer.prototype.destroy=v.prototype.destroy,v.ArrayBuffer.prototype._concatArrayBuffer=function(e,t){var i=e.length,n=new Uint8Array(i+t.byteLength);return n.set(e),n.set(new Uint8Array(t),i),n},v.ArrayBuffer.hash=function(e,t){var i=u(new Uint8Array(e));return t?i:p(i)},e.MD5=v}("undefined"==typeof exports?r.core.util:exports),function(e){var t={readFileInSlices:function(e,t,i,n){var o,s=new FileReader,a=0;s.onloadend=function(c){c.target.readyState==FileReader.DONE&&(r.log("onload returned: "+s.readyState),n(e,c.target.result,function(){a++,t.size>(a+1)*i?(o=t.slice(a*i,(a+1)*i),1==s.readyState,r.log("before reading: "+s.readyState),s.readAsArrayBuffer(o)):t.size>a*i?(o=t.slice(a*i,t.size),s.readAsArrayBuffer(o)):(r.debug("Finished reading file "+e),n(e))}))},o=t.slice(a*i,(a+1)*i),s.readAsArrayBuffer(o)}};e.fileHandler=t}("undefined"==typeof exports?r.core.util:exports),function(e){e.randomKFromN=function(e,t){var i=[];if(e>t){for(var n=0;t>=n;n++)i.push(n);return i}for(;e>i.length;){for(var r=Math.ceil(Math.random()*(t+1))-1,o=!1,n=0;i.length>n;n++)if(i[n]==r){o=!0;break}o||i.push(r)}return i},e.randSample=function(t,i){if(0==t.length)return t;var n=e.randomKFromN(i,t.length-1);return e.sampleIndexes(t,n)},e.sampleIndexes=function(e,t){sampledArr=[];for(var i=0;t.length>i;i++)sampledArr.push(e[t[i]]);return sampledArr},e.shuffle=function(e){var t,i,n=e.length;if(n)for(;--n;)i=Math.floor(Math.random()*(n+1)),t=e[i],e[i]=e[n],e[n]=t;return e}}("undefined"==typeof exports?r.core.util:exports),window=window||self,function(e){e.loadScript=function(e,t){var i=document.getElementsByTagName("head")[0],n=document.createElement("script");n.type="text/javascript",n.src=e,n.onreadystatechange=t,n.onload=t,i.appendChild(n)},e.isObjectEmpty=function(e){for(var t in e)if(e.hasOwnProperty(t))return!1;return!0},e.envokeCallback=function(e,t,i){i=i||window,e&&"function"==typeof e?e.apply(i,t):r.log("couldn't envoke the callback: "+e)},e.executeFunctionByName=function(e,t,i){for(var n=e.split("."),r=n.pop(),o=0;n.length>o;o++)t=t[n[o]];return t[r].apply(t,i)},e.overrideNative=function(){floor=Math.floor,Math.floor=function(e){var t=e;return isNaN(t)?(console.log("bad: "+t),void 0):floor(e)},ceil=Math.ceil,Math.ceil=function(e){var t=e;return isNaN(t)?(console.log("bad: "+t),void 0):ceil(e)},round=Math.round,Math.round=function(e){var t=e;return isNaN(t)?(console.log("bad: "+t),void 0):round(e)}},r.core.util.overrideNative()}("undefined"==typeof exports?r.core.util:exports),e("../util/lang_ext.js"),function(e){e.AvailabilityMapBase=Object.subClass({name:"peer5.core.dataStructures.AvailabilityMapBase",ctor:function(){},has:function(){throw"unimplemented method"},set:function(){throw"unimplemented method"},isFull:function(){throw"unimplemented method"},serialize:function(){throw"unimplemented method"},deserializeAndCopy:function(){throw"unimplemented method"},deserializeAndUpdate:function(){throw"unimplemented method"}})}("undefined"==typeof exports?r.core.dataStructures:exports),function(t){var i=(e("./AvailabilityMapBase.js")||r.core.dataStructures).AvailabilityMapBase;t.AvailabilityMap=i.subClass({name:"peer5.core.dataStructures.AvailabilityMap",ctor:function(e,t){if(this._super(e),this.seeder=t,this.size=e,this.length=Math.ceil(this.size/8),this.bitArray=new Uint8Array(this.length),t)for(var i=0;this.length>i;i++)this.bitArray[i]=255;this.numOfOnBits=0,this.bitMask=[1,2,4,8,16,32,64,128]},has:function(e){if(this.isFull())return!0;var t=this.getOffsets(e);return this.bitArray[t.index]&this.bitMask[t.bit]},set:function(e){if(!this.has(e)){var t=this.getOffsets(e);this.bitArray[t.index]=this.bitArray[t.index]|this.bitMask[t.bit],this.numOfOnBits++}},setSeeder:function(){this.numOfOnBits=this.size},isFull:function(){return this.numOfOnBits==this.size},serialize:function(){return this.bitArray},deserializeAndCopy:function(e){this.bitArray=e;for(var t=0,i=0;e.length>i;++i)if(0!=e[i])for(var n=0;this.bitMask.length>n;++n)this.bitArray[i]&this.bitMask[n]&&t++;this.numOfOnBits=t},deserializeAndUpdate:function(e){for(var t=0;e>t;++t)this.set(e[t]);this.numOfOnBits+=e.length},getOffsets:function(e){var t={};return t.index=Math.floor(e/8),t.bit=e%8,t}})}("undefined"==typeof exports?r.core.dataStructures:exports),function(t){var i=(e("./AvailabilityMap.js")||r.core.dataStructures).AvailabilityMap;t.AvailabilityMapFS=i.subClass({name:"peer5.core.dataStructures.AvailabilityMap",ctor:function(e,t,i,n){this._super(e,!1),this.numOfOnFSBits=0,this.resourceId=t,this.metadataFile=t+".fi",this._initiateFromFilesystem(i,n),this.fsBitArray=new Uint8Array(this.length)},setFS:function(e,t){if(!this.has(e)||this.hasFS(e))return t(!1),void 0;var i=this.getOffsets(e),n=new Uint8Array([this.fsBitArray[i.index]|this.bitMask[i.bit]]);
  2. this.fsBitArray[i.index]=this.fsBitArray[i.index]|this.bitMask[i.bit],this.numOfOnFSBits++;var o=this;r.core.data.FSio.write(this.metadataFile,n,i.index,function(e,i){return e?(t(!0),void 0):(r.warn("couldn't write index to metadata file "+o.metadataFile),"space"===i?o._handleOutOfSpaceError():o._handleWriteError(),t(error),void 0)})},setFSFull:function(e){var t=this;r.core.data.FSio.write(this.metadataFile,this.bitarray,0,function(i){return i?(e(!0),void 0):(t._handleWriteError(),e(!1),void 0)})},hasFS:function(e){if(this.isFullFS())return!0;var t=this.getOffsets(e);return this.fsBitArray[t.index]&this.bitMask[t.bit]},isFullFS:function(){return this.numOfOnFSBits===this.size},deserializeAndCopy:function(e){this.fsBitArray=e;for(var t=0,i=0;e.length>i;++i)if(0!=e[i])for(var n=0;this.bitMask.length>n;++n)this.fsBitArray[i]&this.bitMask[n]&&t++;this.numOfOnFSBits=t},removeBlock:function(e,t){if(this.has(e)){var i=this.getOffsets(e),n=this.bitArray[i.index]&~this.bitMask[i.bit],o=this;r.core.data.FSio.write(this.metadataFile,n,i.index,function(e,s){e?(o.bitArray[i.index]=n,t(!0)):(r.warn("couldn't write index to metadata file "+o.metadataFile),"space"===s?o._handleOutOfSpaceError():o._handleWriteError(),t(!1))})}else t(!0)},removeBlocksFrom:function(e,t){if(e>this.size-1)return t(!0),void 0;var i=this;this.removeBlock(e,function(n){return n?(i.removeBlocksFrom(e+1,t),void 0):(t(!1),void 0)})},reset:function(e){this.removeBlocksFrom(0,e)},renameResource:function(e,t){var i=e+".fi",n=this;r.core.data.FSio.renameResource(this.metadataFile,i,function(e){e&&(n.metadataFile=i),t(e)})},_initiateFromFilesystem:function(e,t){var i=this;r.core.data.FSio.isExist(this.metadataFile,function(n){n?(r.info("metadata file "+i.metadataFile+" exists"),r.core.data.FSio.read(i.metadataFile,0,i.length,function(e,n){e?(i.deserializeAndCopy(n),r.info("finished initiating AvailabilityMap from FS"),t(!0)):(r.warn("error reading metadataFile "+i.metadataFile),t(!1))})):(r.info("metadata file "+i.metadataFile+" doesn't exist, creating a new one"),e>i.length?r.core.data.FSio.createResource(i.metadataFile,function(e){e?(r.log("created metadata file, initiating its length"),r.core.data.FSio.write(i.metadataFile,new Uint8Array([]),i.length-1,function(e,n){e?t(!0):("space"===n?i._handleOutOfSpaceError():i._handleWriteError(),t(!1))})):t(!1)}):(r.warn("not enough space to create metadata file: "+i.metadatFile+", removing root dir"),r.core.data.FSio.removeRootDir(function(){r.core.data.FSio.createResource(i.metadataFile,function(e){e?(r.log("created metadata file, initiating its length"),r.core.data.FSio.write(i.metadataFile,new Uint8Array([]),i.length-1,function(e,n){e?t(!0):("space"===n?i._handleOutOfSpaceError():i._handleWriteError(),t(!1))})):t(!1)})})))})},_handleOutOfSpaceError:function(){r.error("Out of space error"),r.core.data.FSio.removeAll(function(e){e||r.warn("couldn't remove files from offline storage")}),radio("removeResource").broadcast(this.resourceId,r.Request.OUT_OF_SPACE_ERR,"out of space")},_handleWriteError:function(){r.error("offline storage write error"),radio("removeResource").broadcast(this.resourceId,r.Request.WRITE_ERR,"offline storage write error")}})}("undefined"==typeof exports?r.core.dataStructures:exports),function(){r.core.dataStructures.DoublyLinkedList=Object.subClass({name:"peer5.core.dataStructures.DoublyLinkedList",ctor:function(){this.length=0,this.tail=null,this.head=null},insert:function(e){var t={prev:this.tail,next:null,value:e};this.tail&&(this.tail.next=t),this.tail=t,0==this.length&&(this.head=t),this.length++},remove:function(e){e.prev&&(e.prev.next=e.next),e.next&&(e.next.prev=e.prev),this.tail==e&&(this.tail=e.prev),this.head==e&&(this.head=e.next),!this.head,this.length--},toString:function(){for(var e=this.head;e;)r.log(e.value),e=e.next}})}(),function(){r.core.dataStructures.LRU=Object.subClass({name:"peer5.core.dataStructures.LRU",ctor:function(e,t){this.max=e,this.dict={},this.list=new r.core.dataStructures.DoublyLinkedList,this.deleteCB=t},set:function(e,t){if(r.debug("LRU.set with key: "+e),this.dict[e]&&this._delete(e),this.list.insert(e),this.dict[e]={value:t,p:this.list.tail},this.list.length>this.max){var i=this.list.head;this._delete(i.value,this.deleteCB)}},get:function(e){if(r.debug("LRU.get with key: "+e),this.dict[e]){var t=this.dict[e].p;return t==this.list.tail?this.dict[e].value:(this.list.remove(t),this.list.insert(e),this.dict[e].p=this.list.tail,this.dict[e].value)}return!1},_delete:function(e,t){r.debug("removing key "+e+" from lru");var i=this.dict[e];this.list.remove(i.p),delete this.dict[e],t&&t(e,i.value)}})}(),function(){r.core.transport.AbstractPeerConnection=Object.subClass({name:"peer5.core.transport.AbstractPeerConnection",ctor:function(e,t,i){this.peerConnection,this.dataChannel,this.label=i?e+t:t+e,this.originId=e,this.targetId=t,this.createAnswerConstraints={},this.createOfferConstraints={},this.startTime,this.ready=!1,this.requestDropped=0,this.numOfRequestedChunks=0,this.numOfExpiredChunks=0,this.numOfPendingChunks=0,this.maxNumOfPendingChunks=r.config.MAX_PENDING_CHUNKS/2,this.minLatencyForChunk=null,this.maxLatencyForChunk=null,this.avgLatencyForChunk=null,this.connectingDuration=null,this.numOfChunksArrived=0,this.failure=!1},setupCall:function(){throw"unimplemented method"},handleMessage:function(){throw"unimplemented method"},send:function(){throw"unimplemented method"}})}(),function(){r.core.transport.PeerConnectionImpl=r.core.transport.AbstractPeerConnection.subClass({name:"peer5.core.transport.PeerConnectionImpl",ctor:function(e,t,i){this._super(e,t,i),this.reliable=!1,window.webkitRTCPeerConnection?(this.RTCPeerConnection=webkitRTCPeerConnection,this.RTCSessionDescription=RTCSessionDescription):window.mozRTCPeerConnection&&(r.config.TURN_SERVERS=[],this.RTCPeerConnection=mozRTCPeerConnection,this.RTCSessionDescription=mozRTCSessionDescription,RTCIceCandidate=mozRTCIceCandidate),this.useBase64=!1,this.dataChannelOptions=this.reliable?{}:{ordered:!1,maxRetransmits:0},this.initiatePeerConnection(i)},setupCall:function(){this.startTime=Date.now(),r.debug("createOffer with constraints: "+JSON.stringify(this.createOfferConstraints,null," ")),this.peerConnection.createOffer(this.setLocalAndSendMessage_,function(e){r.debug("createOffer(): failed, "+e)},this.createOfferConstraints)},handleMessage:function(e){if(parsed_msg=e.sdpMessage,r.info("handling message "+e),parsed_msg.type){var t=new this.RTCSessionDescription(parsed_msg),i=this;if(!this.peerConnectionStateValid())return;return this.peerConnection.setRemoteDescription(t,function(){if(r.debug("setRemoteDescription(): success."),"offer"==t.type){if(r.debug("createAnswer with constraints: "+JSON.stringify(this.createAnswerConstraints,null," ")),!i.peerConnectionStateValid())return;i.peerConnection.createAnswer(i.setLocalAndSendMessage_,function(e){r.debug("createAnswer(): failed, "+e)},i.createAnswerConstraints)}},function(e){r.debug("setRemoteDescription(): failed, "+e)}),void 0}if(parsed_msg.candidate){if(JSON.stringify(parsed_msg)in this.peerConnection.candidates)return r.warn("candidate was already added"),void 0;if(!this.peerConnectionStateValid())return;var n=new RTCIceCandidate(parsed_msg);return this.peerConnection.addIceCandidate(n),this.peerConnection.candidates[JSON.stringify(parsed_msg)]=Date.now(),void 0}r.log("unknown message received")},send:function(e){var t=this.dataChannel.bufferedAmount;0!=t&&console.log("yay! sctp enabled? buffered amount is: "+t);var i=this.useBase64?r.core.util.base64.encode(e):e.buffer,n=this;if("open"==n.dataChannel.readyState.toLowerCase()){r.debug("sending data on dataChannel");try{n.dataChannel.send(i)}catch(o){r.warn("Caught dc error: "+o)}}else r.info("dataChannel was not ready, setting timeout"),setTimeout(function(e,t){n.send(e,t)},r.config.PC_RESEND_INTERVAL,n.dataChannel,i)},close:function(){this.ready=!1,this.dataChannel.close(),this.peerConnection.close()},initiatePeerConnection:function(e){this.initiatePeerConnectionCallbacks(),this.createPeerConnection(),e&&this.ensureHasDataChannel(),setTimeout(function(e){e.ready||(r.info("ready state of PCImpl to "+e.targetId+" = "+e.ready),e.failure=!0,r.warn("couldn't connect to "+e.targetId),e.handlePeerDisconnection(e.targetId))},r.config.PC_FAIL_TIMEOUT,this)},initiatePeerConnectionCallbacks:function(){this.registerEvents()},registerEvents:function(){var e=this;this.setLocalAndSendMessage_=function(t){t.sdp=e.transformOutgoingSdp(t.sdp),e.peerConnection.setLocalDescription(t,function(){r.debug("setLocalDescription(): success.")},function(e){r.debug("setLocalDescription(): failed"+e)}),r.debug("Sending SDP message:\n"+t.sdp);var i=new r.core.protocol.Sdp(e.originId,e.targetId,t),n=r.core.protocol.BinaryProtocol.encode([i]);radio("websocketsSendData").broadcast(n)},this.iceCallback_=function(t){if(t.candidate&&"disconnected"!=t.target.iceConnectionState){var i=new r.core.protocol.Sdp(e.originId,e.targetId,t.candidate),n=r.core.protocol.BinaryProtocol.encode([i]);radio("websocketsSendData").broadcast(n)}},this.iceStateChangedCallback_=function(t){t.target&&"disconnected"===t.target.iceConnectionState&&(r.info("iceStateChanged to disconnected"),e.handlePeerDisconnection())},this.signalingStateChangeCallback_=function(t){t.target&&"closed"==t.target.signalingState&&(r.info("signalingStateChanged to closed"),e.handlePeerDisconnection())},this.onCreateDataChannelCallback_=function(t){null!=e.dataChannel&&"closed"!=e.dataChannel.readyState&&r.warn("Received DataChannel, but we already have one."),e.dataChannel=t.channel,r.debug("DataChannel with label "+e.dataChannel.label+" initiated by remote peer."),e.hookupDataChannelEvents()},this.onDataChannelReadyStateChange_=function(t){var i=t.target.readyState;r.info("DataChannel to "+e.targetId+" state:"+i),"open"==i.toLowerCase()&&(e.ready=!0,e.connectingDuration=Date.now()-e.startTime,radio("connectionReady").broadcast(e.targetId))},this.onDataChannelClose_=function(){r.info("data channel was closed"),e.handlePeerDisconnection()},this.onMessageCallback_=function(t){r.debug("receiving data on dataChannel");var i=e.useBase64?r.core.util.base64.decode(t.data):new Uint8Array(t.data);radio("dataReceivedEvent").broadcast(i,e.targetId)}},ensureHasDataChannel:function(){null==this.peerConnection&&r.warn("Tried to create data channel, but have no peer connection."),null!=this.dataChannel&&"closed"!=this.dataChannel&&r.warn("Creating DataChannel, but we already have one."),this.createDataChannel()},createPeerConnection:function(){for(var e=r.config.STUN_SERVERS,t=r.config.TURN_SERVERS?r.config.TURN_SERVERS:[],i=r.config.TURN_CREDENTIALS,n={iceServers:[]},o=0;e.length>o;++o)n.iceServers.push({url:"stun:"+e[o]});for(var s=0;t.length>s;++s)n.iceServers.push({url:"turn:"+t[s],credential:i[s]});try{r.info("webkitRTCPeerConnection"),this.peerConnection=window.mozRTCPeerConnection?new this.RTCPeerConnection:new this.RTCPeerConnection(n),this.peerConnection.candidates={}}catch(a){r.warn("Failed to create peer connection: "+a)}this.peerConnection.onaddstream=this.addStreamCallback_,this.peerConnection.onremovestream=this.removeStreamCallback_,this.peerConnection.onicecandidate=this.iceCallback_,this.peerConnection.oniceconnectionstatechange=this.iceStateChangedCallback_,this.peerConnection.onicechange=this.iceStateChangedCallback_,this.peerConnection.onsignalingstatechange=this.signalingStateChangeCallback_,this.peerConnection.ondatachannel=this.onCreateDataChannelCallback_},createDataChannel:function(){r.info("createDataChannel"),this.dataChannel=this.peerConnection.createDataChannel(this.label,this.dataChannelOptions),r.debug("DataChannel with label "+this.dataChannel.label+" initiated locally."),this.hookupDataChannelEvents()},closeDataChannel:function(){null==this.dataChannel&&r.warn("Closing DataChannel, but none exists."),r.debug("DataChannel with label "+this.dataChannel.label+" is being closed."),this.dataChannel.close()},hookupDataChannelEvents:function(){this.dataChannel.binaryType="arraybuffer",this.dataChannel.onmessage=this.onMessageCallback_,this.dataChannel.onopen=this.onDataChannelReadyStateChange_,this.dataChannel.onclose=this.onDataChannelClose_,r.info("data-channel-status: "+this.dataChannel.readyState)},transformOutgoingSdp:function(e){var t=e.split("b=AS:30");if(t.length>1)var i=t[0]+"b=AS:1638400"+t[1];else i=e;return i},addStreamCallback_:function(e){r.debug("Receiving remote stream...");var t=document.getElementById("remote-view");t.src=webkitURL.createObjectURL(e.stream),setTimeout(function(){updateVideoTagSize_("remote-view")},500)},removeStreamCallback_:function(){r.debug("Call ended."),document.getElementById("remote-view").src=""},handlePeerDisconnection:function(){this.dataChannel&&"closed"!=this.dataChannel.readyState&&(r.info("handling peer disconnection: closing the datachannel"),this.dataChannel.close()),"closed"!=this.peerConnection.signalingState&&(r.info("handling peer disconnection: closing the peerconnection"),this.peerConnection.close()),radio("connectionFailed").broadcast(this.targetId)},peerConnectionStateValid:function(){return"closed"!=this.peerConnection.iceConnectionState&&"closed"!=this.peerConnection.signalingState?!0:(r.warn("peerConnection state to "+this.targetId+" is invalid - 'not usable'"),!1)}})}(),function(){r.core.stats.StatsCalculator=Object.subClass({name:"peer5.core.stats.StatsCalculator",ctor:function(e,t,i,n){this.swarmId=n,this.url=i,this.resourceId=t,this.size=e,this.transferFinished=!1,this.Report_Created_Timestamp=Date.now(),this.Report_Timestamp=0,this.Stats_Timestamp=Date.now(),this.Total_Recv_No_Waste=0,this.Total_Recv=0,this.Total_Sent=0,this.Total_Sent_P2P=0,this.Total_Recv_P2P=0,this.Total_Recv_HTTP=0,this.Total_Waste_P2P=0,this.Total_Waste_HTTP=0,this.Total_loaded_FS=0,this.numOfSenders=0,this.Total_Avg_Download=0,this.Prev_Report_Timestamp=Date.now(),this.Prev_Total_Recv=0,this.Prev_Total_Sent=0,this.Prev_Total_Sent_P2P=0,this.Prev_Total_Recv_P2P=0,this.Prev_Total_Waste_P2P=0,this.Prev_Total_Waste_HTTP=0,this.Prev_Total_Recv_HTTP=0,this.Prev_Total_loaded_FS=0,this.Avg_Sent=0,this.Avg_Recv=0,this.Avg_Sent_P2P=0,this.Avg_Recv_P2P=0,this.Avg_Loaded_FS=0,this.Avg_Waste_P2P=0,this.Avg_Waste_HTTP=0,this.Avg_Recv_HTTP=0,this.Size_Uploaded_To_Memory=0,this.Total_Avg_Download=0,this.numOfHttpCompletedChunks=0,this.numOfHttpWasteChunks=0,this.numOfP2PCompletedChunks=0,this.numOfP2PWasteChunks=0,this.statsTimestamp=0,this.startTime=Date.now(),this.b1=!1,this.p1=!1,this.p5=!1,this.p10=!1,this.q1=!1,this.q2=!1,this.q3=!1,this.q4=!1,this.registerEvents(),this.calc_avg()},addP2PRecv:function(){this.Total_Recv_P2P+=r.config.CHUNK_SIZE},addP2PWaste:function(){this.numOfP2PWasteChunks++,this.Total_Waste_P2P+=r.config.CHUNK_SIZE},addP2PSent:function(){this.Total_Sent_P2P+=r.config.CHUNK_SIZE},addHTTP:function(){this.Total_Recv_HTTP+=r.config.CHUNK_SIZE},calc_avg:function(){var e=Date.now()-this.statsTimestamp;return 0==this.statsTimestamp?(radio("peer5_state_updated").broadcast(this,this.url),this.statsTimestamp+=e,void 0):(this.statsTimestamp+=e,e/=1e3,this.Total_Recv=this.Total_Recv_HTTP+this.Total_Recv_P2P+this.Total_loaded_FS,this.Total_Recv_No_Waste=this.Total_Recv-this.Total_Waste_HTTP-this.Total_Waste_P2P,this.Total_Sent=this.Total_Sent_P2P,this.Total_Avg_Download=(this.Total_Recv_HTTP+this.Total_Recv_P2P)/((Date.now()-this.startTime)/1e3),this.Avg_Recv=(this.Total_Recv-this.Prev_Total_Recv)/e,this.Avg_Sent=(this.Total_Sent-this.Prev_Total_Sent)/e,this.Avg_Loaded_FS=(this.Total_loaded_FS-this.Prev_Total_loaded_FS)/e,this.Avg_Sent_P2P=(this.Total_Sent_P2P-this.Prev_Total_Sent_P2P)/e,this.Avg_Recv_P2P=(this.Total_Recv_P2P-this.Prev_Total_Recv_P2P)/e,this.Avg_Waste_P2P=(this.Total_Waste_P2P-this.Prev_Total_Waste_P2P)/e,this.Avg_Waste_HTTP=(this.Total_Waste_HTTP-this.Prev_Total_Waste_HTTP)/e,this.Avg_Recv_HTTP=(this.Total_Recv_HTTP-this.Prev_Total_Recv_HTTP)/e,this.Avg_Recv_WS=(this.Total_Recv_WS-this.Prev_Total_Recv_WS)/e,this.Avg_Sent_WS=(this.Total_Sent_WS-this.Prev_Total_Sent_WS)/e,this.Offloading=this.Total_Recv_P2P/(this.Total_Recv_HTTP+this.Total_Recv_P2P),this.Prev_Total_Recv=this.Total_Recv,this.Prev_Total_Sent=this.Total_Sent,this.Prev_Total_Sent_P2P=this.Total_Sent_P2P,this.Prev_Total_Recv_P2P=this.Total_Recv_P2P,this.Prev_Total_Waste_P2P=this.Total_Waste_P2P,this.Prev_Total_Waste_HTTP=this.Total_Waste_HTTP,this.Prev_Total_Recv_HTTP=this.Total_Recv_HTTP,this.Prev_Total_loaded_FS=this.Total_loaded_FS,radio("peer5_state_updated").broadcast(this,this.url),void 0)},registerEvents:function(){var e=this;radio("blockReceivedEvent").subscribe([function(t){if(!(!t||t.swarmId!==this.swarmId&&t.url!==this.resourceId||this.Total_loaded_FS>=this.Total_Recv)){var i=this.resourceId||this.swarmId,n=r.core.data.BlockCache.get(i),o=n.getCompletionRate();!this.b1&&o>0&&(this.b1=!0,radio("peer5_b1_finished").broadcast(Date.now()-this.startTime)),!this.p1&&o>=.01&&(this.p1=!0,radio("peer5_p1_finished").broadcast(this.Total_Avg_Download)),!e.p5&&o>=.05&&(e.p5=!0,radio("peer5_p5_finished").broadcast(this.Total_Avg_Download)),!e.p10&&o>=.1&&(e.p10=!0,radio("peer5_p10_finished").broadcast(this.Total_Avg_Download)),!e.q1&&o>=.25&&(e.q1=!0,radio("peer5_q1_finished").broadcast(this.Total_Avg_Download)),!e.q2&&o>=.5&&(e.q2=!0,radio("peer5_q2_finished").broadcast(this.Total_Avg_Download)),!e.q3&&o>=.75&&(e.q3=!0,radio("peer5_q3_finished").broadcast(this.Total_Avg_Download)),!e.q4&&o>=1&&(e.q4=!0,radio("peer5_q4_finished").broadcast(this.Total_Avg_Download))}},this]),radio("peer5_received_fs_chunk").subscribe([function(e,t){(this.resourceId===t||this.swarmId===t)&&(this.Total_loaded_FS+=r.config.CHUNK_SIZE)},this]),radio("peer5_received_http_chunk").subscribe([function(e,t){this.resourceId!==t&&this.swarmId!==t},this]),radio("peer5_waste_http_chunk").subscribe([function(t,i){(this.resourceId===swarmId||this.url===i)&&(e.Total_Waste_HTTP+=r.config.CHUNK_SIZE)},this]),radio("peer5_new_p2p_chunk").subscribe([function(t,i){(this.resourceId===i||this.swarmId===i)&&(e.Total_Recv_P2P+=r.config.CHUNK_SIZE)},this]),radio("peer5_waste_p2p_chunk").subscribe([function(t,i){(this.resourceId===i||this.swarmId===i)&&(e.numOfP2PWasteChunks++,e.Total_Waste_P2P+=r.config.CHUNK_SIZE)},this]),radio("chunkAddedToBlockMap").subscribe([function(){e.Size_Uploaded_To_Memory+=r.config.CHUNK_SIZE},this]),radio("chunkSentEvent").subscribe([function(t){(this.resourceId===t||this.swarmId===t)&&(e.Total_Sent_P2P+=r.config.CHUNK_SIZE)},this]),radio("xhrBytesReceived").subscribe([function(t,i){this.url===i&&(e.Total_Recv_HTTP+=t)},this]),radio("transferFinishedEvent").subscribe([function(t){t&&t&&t.swarmId===this.swarmId&&(e.transferFinished=!0,e.Total_Avg_Download=e.size/((Date.now()-e.startTime)/1e3))},this]),radio("beforeUnload").subscribe([function(){var e=this.resourceId||this.swarmId,t=r.core.data.BlockCache.get(e),i=t.getCompletionRate();radio("exitPage").broadcast(i,this.Avg_Recv,this.Total_Avg_Download)},this])}})}(),function(){r.core.controllers.IController=Object.subClass({download:function(){throw"unimplemented method"},stopResource:function(){throw"unimplemented method"},removeResource:function(){throw"unimplemented method"},init:function(){throw"unimplemented method"},isPendingBlock:function(){throw"unimplemented method"},getConnectionStats:function(){throw"unimplemented method"}})}(),function(){r.core.controllers.AbstractController=r.core.controllers.IController.subClass({ctor:function(){this.resourceState={},this.pendingBlocks={}},init:function(e,t){(t||!this.resourceState.hasOwnProperty(e))&&(this.resourceState[e]=!0,(t||!this.pendingBlocks[e])&&(this.pendingBlocks[e]={}))},removeResource:function(e){this.resourceState[e]=!1,delete this.resourceState[e],this.pendingBlocks[e]={},delete this.pendingBlocks[e]},stopResource:function(e){this.resourceState[e]=!1,this.pendingBlocks[e]={},delete this.pendingBlocks[e]},isPendingBlock:function(e,t){return this.pendingBlocks[e][t]?r.core.util.isObjectEmpty(this.pendingBlocks[e][t])?(delete this.pendingBlocks[e][t],!1):!0:!1},removeFromPendingBlocks:function(e,t){var i=r.core.data.BlockCache.get(e);if(i){var n=i.getBlockIdOfChunk(t);this.pendingBlocks[e][n]?delete this.pendingBlocks[e][n][t]:r.warn("trying to remove a pending chunk from a non pending block")}},addToPendingBlocks:function(e,t){var i=r.core.data.BlockCache.get(e),n=i.getBlockIdOfChunk(t);this.pendingBlocks[e][n]||(this.pendingBlocks[e][n]={}),this.pendingBlocks[e][n][t]=Date.now()},addChunk:function(e,t,i){var n=r.core.data.BlockCache.get(e);n.setChunk(i,t)},getRarestBlocks:function(e,t,i){for(var n,o,s=r.core.data.BlockCache.get(e),a=[],c=[],l=this.P2PController||this,d=0,u=s.getNumOfBlocks();u>d;d++)if(o=0,i(d)){for(var h in l.remoteAvailabilityMaps[swarmId])l.remoteAvailabilityMaps[swarmId][h].has(d)&&o++;0==c.length?(a.push(d),n=o):o===n?a.push(d):n>o&&(a=[d],n=o)}var f=r.core.util.randSample(a,t);return f},getSeqBlocks:function(e,t,i){for(var n=r.core.data.BlockCache.get(e),o=[],s=n.getFirstMissingBlock(),a=n.getNumOfBlocks()-1,c=s;a>=c&&t>o.length;c++)if(i(c))o.push(c);else if(o.length)break;return o}})}(),function(){r.core.controllers.P2PController=r.core.controllers.AbstractController.subClass({ctor:function(e){this._super(),this.clientId=e,this.peerConnections={},this.initPeerConnections={},this.droppedConnections={},this.inited=!1,this.remoteAvailabilityMaps={},this.p2pPendingChunks={},this.peerSwarms={},this.peerConnectionImpl=null,this.prefetchFlag={},this.resourceState={},this.configureBrowserSpecific(),this.availableTimeStamp=0,this.requestNum=0,this.pendingRequests={},this.registerEvents()},init:function(e,t,i){this._super(e,i),(i||!this.p2pPendingChunks[e])&&(this.p2pPendingChunks[e]={}),this.remoteAvailabilityMaps[e]||(this.remoteAvailabilityMaps[e]={}),this.prefetchFlag[e]=t,this.sendHaveRequestToAll(e)},download:function(e,t,i){if(!t)for(var t in this.peerConnections)this.isPeerAvailable(t)&&this.download(e,t,i);i||(i=function(i){return!o.has(i)&&h.remoteAvailabilityMaps[e][t].has(i)&&!h.isPendingEntireBlock(e,i)});var n=this.peerConnections[t].maxNumOfPendingChunks-this.peerConnections[t].numOfPendingChunks;r.log("allocating "+n+" chunks");var o=r.core.data.BlockCache.get(e);if(this.isAvailable(e)){var s,a,c=[];if((this.lastBlockRequestedInP2P||0===this.lastBlockRequestedInP2P)&&!o.has(this.lastBlockRequestedInP2P)){a=this.lastBlockRequestedInP2P,s=o.getChunkIdsOfBlock(a);for(var l=0;s.length>l&&n>c.length;++l)o.hasChunk(s[l])||this.isPendingChunk(e,s[l])||c.push(s[l])}var d=this.peerConnections[t].maxNumOfPendingChunks-this.peerConnections[t].numOfPendingChunks-c.length;if(d>0)for(var u=Math.ceil(d/(12e5/r.config.CHUNK_SIZE)),h=this,f=this.getRarestBlocks(e,u,i),l=0;f.length>l;l++)if(f[l]!==a){s=[],s=o.getChunkIdsOfBlock(f[l]);for(var p=0;s.length>p&&n>=c.length;++p)o.hasChunk(s[p])||this.p2pPendingChunks.hasOwnProperty(e)&&this.p2pPendingChunks[e].hasOwnProperty(s[p])||c.push(s[p]);this.lastBlockRequestedInP2P=f[l]}return r.log("finished allocating "+c.length+" chunks"+performance.now()),this.distributeChunksAmongSources(e,c,t),c.length}},isPendingEntireBlock:function(e,t){for(var i=r.core.data.BlockCache.get(e),n=i.getChunkIdsOfBlock(t),o=0;n.length>o;o++)if(!this.p2pPendingChunks[e].hasOwnProperty(n[o])&&!i.hasChunk(n[o]))return!1;return!0},isPendingChunk:function(e,t){return this.p2pPendingChunks.hasOwnProperty(e)&&this.p2pPendingChunks[e].hasOwnProperty(t)},isAvailable:function(e){if(!this.resourceState[e])return!1;var t=Date.now();r.core.data.BlockCache.get(e);for(var i in this.peerConnections)if(this.remoteAvailabilityMaps[e][i]&&this.isPeerAvailable(i))return this.availableTimeStamp=t,!0;return this.availableTimeStamp=t,!1},isPeerAvailable:function(e){if(!this.peerConnections[e])return!1;if(r.log("peerAvailability: "+this.peerConnections[e].numOfPendingChunks+"/"+this.peerConnections[e].maxNumOfPendingChunks),!(this.peerConnections[e].numOfPendingChunks<.9*this.peerConnections[e].maxNumOfPendingChunks))return!1;var t=[];for(var i in this.peerSwarms[e])t.push(i);return 0===t.length?!1:t},getConnectionStats:function(){var e={};for(key in this.peerConnections)e[key]=new r.core.protocol.Connection(null,null,null,null,this.peerConnections[key].numOfExpiredChunks,this.peerConnections[key].numOfRequestedChunks,this.peerConnections[key].minLatencyForChunk,this.peerConnections[key].ready,this.peerConnections[key].connectingDuration,this.peerConnections[key].failure);for(key in this.droppedConnections)e[key]=new r.core.protocol.Connection(null,null,null,null,this.droppedConnections[key].numOfExpiredChunks,this.droppedConnections[key].numOfRequestedChunks,this.droppedConnections[key].minLatencyForChunk,this.droppedConnections[key].ready,this.droppedConnections[key].connectingDuration,this.droppedConnections[key].failure);return e},getAvailableNumOfChunksToSend:function(){var e=0;for(var t in this.peerConnections)e+=this.peerConnections[t].maxNumOfPendingChunks-this.peerConnections[t].numOfPendingChunks;return e},removeResource:function(e){r.info("removed p2p resource "+e);for(var t in this.pendingRequests)this.pendingRequests[t][1]===e&&(clearTimeout(this.pendingRequests[t][0]),this.expireChunks(this.pendingRequests[t][1],this.pendingRequests[t][2],this.pendingRequests[t][3],t,!0),delete this.pendingRequests[t]);this.remoteAvailabilityMaps[e]={},delete this.remoteAvailabilityMaps[e],this.p2pPendingChunks[e]={},delete this.p2pPendingChunks[e],this._super(e)},stopResource:function(e){r.info("stopped p2p resource "+e);for(var t in this.pendingRequests)this.pendingRequests[t][1]===e&&(clearTimeout(this.pendingRequests[t][0]),this.expireChunks(this.pendingRequests[t][1],this.pendingRequests[t][2],this.pendingRequests[t][3],t,!0),delete this.pendingRequests[t]);0!==Object.keys(this.p2pPendingChunks[e]).length&&r.error("stopping resource didn't clear all pendingChunks"),this.p2pPendingChunks[e]={},delete this.p2pPendingChunks[e],this._super(e)},registerEvents:function(){var e=this;this.expireChunks=function(t,i,n,o,s){e.pendingRequests[o]&&delete e.pendingRequests[o];for(var a=[],c=0,l=r.core.data.BlockCache.get(t),d=0;i.length>d;d++){var u=i[d];e.p2pPendingChunks.hasOwnProperty(t)&&e.p2pPendingChunks[t].hasOwnProperty(u)&&(r.debug("expiring chunk "+u),delete e.p2pPendingChunks[t][u],e.removeFromPendingBlocks(t,u),c++,e.peerConnections[n]&&(e.peerConnections[n].numOfExpiredChunks++,e.peerConnections[n].numOfPendingChunks--),l.hasChunk(u)||a.push(u))}if(!s)if(c==i.length?e.peerConnections[n]&&(e.peerConnections[n].requestDropped?e.peerConnections[n].requestDropped++:e.peerConnections[n].requestDropped=1,e.peerConnections[n].requestDropped>=r.config.REQUEST_DROPPED_FAIL&&e.closeConnection(n)):e.peerConnections[n]&&(e.peerConnections[n].requestDropped=0),e.peerConnections[n]&&r.log("num of requests dropped from "+n+" is "+e.peerConnections[n].requestDropped),a.length){e.peerConnections[n]&&(e.peerConnections[n].maxNumOfPendingChunks=Math.ceil(Math.max(e.peerConnections[n].maxNumOfPendingChunks/2,e.peerConnections[n].maxNumOfPendingChunks-2*c)),r.log("expiring chunks, windows decreased to "+e.peerConnections[n].maxNumOfPendingChunks));var h;e.peerConnections[n]&&(h=e.isPeerAvailable(n))&&radio("P2PAvailableEvent").broadcast(h,n)}else e.peerConnections[n]&&(e.peerConnections[n].maxNumOfPendingChunks=Math.min(r.config.MAX_PENDING_CHUNKS,e.peerConnections[n].maxNumOfPendingChunks+1),r.log("no chunks expired, windows increased to "+e.peerConnections[n].maxNumOfPendingChunks))},radio("P2PAvailableEvent").subscribe([function(e,t){this.prefetch(e,t)},this]),radio("blockReceivedEvent").subscribe([function(e){e.swarmId&&this.sendHaveToAll(e.swarmId)},this]),radio("dataReceivedEvent").subscribe([function(e,t){var i=r.core.protocol.BinaryProtocol.decode(new Uint8Array(e));if(!this.peerConnections[t])return r.info("got dataReceivedEvent from peerId "+t+"which was not found in peerConnections"),void 0;for(var n=0;i.length>n;++n)if(this.resourceState.hasOwnProperty(i[n].swarmId))switch(i[n].tag){case r.core.protocol.P2P_HAVE:this.receiveHaveMessage(i[n],t);var o;(o=this.isPeerAvailable(t))&&radio("P2PAvailableEvent").broadcast(o,t);break;case r.core.protocol.P2P_HAVE_REQUEST:if(!this.resourceState[i[n].swarmId])return;var s=this.createHaveMessage(i[n].swarmId),a=r.core.protocol.BinaryProtocol.encode([s]);this.peerConnections[t].ready&&this.peerConnections[t].send(a);break;case r.core.protocol.P2P_REQUEST:this.receiveRequestMessage(i[n],t);break;case r.core.protocol.P2P_DATA:this.receiveDataMessage(i[n],t);var o;(o=this.isPeerAvailable(t))&&radio("P2PAvailableEvent").broadcast(o,t);break;case r.core.protocol.P2P_CANCEL:}},this]),radio("connectionReady").subscribe([function(t){this.peerConnections[t]?r.warn("peerConnection to "+t+" was initialized, but we already have a connection to him"):(this.peerConnections[t]=this.initPeerConnections[t],delete this.initPeerConnections[t]),this.peerSwarms[t]={},radio("activePeerConnectionsNumberChanged").broadcast(Object.keys(this.peerConnections).length),r.core.data.BlockCache.forEach(function(i,n){var r=n.metadata;if(r&&e.resourceState[r.swarmId]){var o=r.swarmId;e.sendHaveToNewConnection(o,t)}})},this]),radio("connectionFailed").subscribe([function(e){r.warn("onConnectionFailed: closing connection with "+e),this.peerConnections[e]?delete this.peerConnections[e]:this.initPeerConnections[e]&&delete this.initPeerConnections[e],this.peerSwarms[e]&&delete this.peerSwarms[e],radio("activePeerConnectionsNumberChanged").broadcast(Object.keys(this.peerConnections).length)},this]),radio("receivedMatchEvent").subscribe([function(e){r.info("peer "+this.clientId+" receivedMatch with peer "+e.peerId);var t=e.peerId;this.ensurePeerConnectionInitialized(t,!0)},this]),radio("receivedSDP").subscribe([function(e){this.ensurePeerConnectionInitialized(e.originId,!1),this.initPeerConnections[e.originId]?this.initPeerConnections[e.originId].handleMessage(e):r.log("receivedSDP: this.initPeerConnections ["+e.originId+" ] undefined")},this])},prefetch:function(e,t){var i=e.slice(0);do{var n=i[0];if(this.prefetchFlag[n])var r=this.download(n,t);i.splice(0,1)}while(!r&&0!==i.length)},getSwarmPriority:function(e){for(var t=e[0];r.core.data.BlockCache.get(t).isFull();)e.splice(0,1),t=e[0]},receiveRequestMessage:function(e,t){r.log("received a request for "+e.chunkIds.length+" chunks"),this.sendData(e.swarmId,t,e.chunkIds,0),radio("requestChunks").broadcast(e.swarmId,t,e.chunkIds)},receiveDataMessage:function(e,t){this.receiveP2PChunk(e.swarmId,t,e.chunkId,e.payload)},configureBrowserSpecific:function(){window.mozRTCPeerConnection?(this.peerConnectionImpl=r.core.transport.PeerConnectionImpl,r.config.MAX_PENDING_CHUNKS=r.config.MOZ_MAX_PENDING_CHUNKS):window.webkitRTCPeerConnection&&(this.peerConnectionImpl=r.core.transport.PeerConnectionImpl)},distributeChunksAmongSources:function(e,t,i){var n,o=this;r.debug("chunks to distribute "+t.length),n=i?[i]:Object.keys(this.peerConnections).sort(function(e,t){return o.peerConnections[e].numOfPendingChunks>o.peerConnections[t].numOfPendingChunks});for(var s={},a=0;t.length>a;++a)for(var c=0;n.length>c;++c){var l=Math.floor(t[a]/(12e5/r.config.CHUNK_SIZE));if(this.remoteAvailabilityMaps.hasOwnProperty(e)&&this.remoteAvailabilityMaps[e][n[c]]&&this.remoteAvailabilityMaps[e][n[c]].has(l)&&this.peerConnections[n[c]].numOfPendingChunks<o.peerConnections[n[c]].maxNumOfPendingChunks){s[n[c]]||(s[n[c]]=[]),s[n[c]].push(t[a]),this.peerConnections[n[c]].numOfPendingChunks++;break}}for(var d=0;n.length>d;++d)if(s[n[d]]){var u=n[d],t=s[u];this.addToPendingChunks(e,t,u),this.peerConnections[n[d]].numOfRequestedChunks+=t.length;var h=new r.core.protocol.Request(e,t),f=r.core.protocol.BinaryProtocol.encode([h]);r.log("sending request for "+t.length+" chunks"),this.peerConnections[n[d]].send(f)}},sendToAll:function(e){var t=r.core.protocol.BinaryProtocol.encode([e]);for(var i in this.peerConnections)this.peerConnections[i].ready&&this.peerConnections[i].send(t)
  3. },ensurePeerConnectionInitialized:function(e,t){this.peerConnections[e]||this.initPeerConnections[e]||(this.initPeerConnections[e]=new this.peerConnectionImpl(this.clientId,e,t),t&&this.initPeerConnections[e].setupCall())},sendData:function(e,t,i,n){if(this.canUpload(e)&&!(r.config.EMULATE_LOSS&&Math.random()<r.config.EMULATE_LOSS_PERCENTAGE)){var o=i[n];n++;var s=this;r.core.data.BlockCache.get(e).getChunk(o,function(a,c){var l=new r.core.protocol.Data(e,o,c),d=r.core.protocol.BinaryProtocol.encode([l]);s.peerConnections[t].send(d),radio("chunkSentEvent").broadcast(e),i.length>n&&s.sendData(e,t,i,n)})}},sendHaveToNewConnection:function(e,t){var i=r.core.data.BlockCache.get(e);if(i)if(this.peerConnections[t].ready){var n=this.createHaveMessage(e),o=r.core.protocol.BinaryProtocol.encode([n]);this.peerConnections[t].send(o)}else r.log("connection is not ready yet")},receiveHaveMessage:function(e,t){var i=e.swarmId;if(this.remoteAvailabilityMaps[i]){if(!this.remoteAvailabilityMaps[i][t]){r.info("got a have message from a peer with a non initialized availabilityMap");var n=r.core.data.BlockCache.get(e.swarmId);this.remoteAvailabilityMaps[i][t]=new r.core.dataStructures.AvailabilityMap(n.getNumOfBlocks())}e.availabilityMap?this.remoteAvailabilityMaps[i][t].deserializeAndCopy(e.availabilityMap):e.seeder?this.remoteAvailabilityMaps[i][t].setSeeder():this.remoteAvailabilityMaps[i][t].deserializeAndUpdate(e.chunkIds),this.peerSwarms[t]||(this.peerSwarms[t]={}),this.peerSwarms[t][i]=!0}},sendHaveRequestToAll:function(e){var t=new r.core.protocol.HaveRequest(e);this.sendToAll(t)},sendHaveToAll:function(e){var t=this.createHaveMessage(e);this.sendToAll(t)},receiveP2PChunk:function(e,t,i,n){r.debug("receiving chunk "+i);var o=r.core.data.BlockCache.get(e);if(o.hasChunk(i)?(r.log("DOH! I already got chunk: "+i+"!"),radio("peer5_waste_p2p_chunk").broadcast(i,e,t)):(this.addChunk(e,n,i),radio("peer5_new_p2p_chunk").broadcast(i,e,t)),this.p2pPendingChunks.hasOwnProperty(e)&&this.p2pPendingChunks[e].hasOwnProperty(i)){var s=Date.now()-this.p2pPendingChunks[e][i];this.peerConnections[t].minLatencyForChunk?(this.peerConnections[t].minLatencyForChunk=Math.min(this.peerConnections[t].minLatencyForChunk,s),this.peerConnections[t].maxLatencyForChunk=Math.max(this.peerConnections[t].maxLatencyForChunk,s),this.peerConnections[t].avgLatencyForChunk=(this.peerConnections[t].avgLatencyForChunk*this.peerConnections[t].numOfChunksArrived+s)/(1+this.peerConnections[t].numOfChunksArrived)):(this.peerConnections[t].minLatencyForChunk=s,this.peerConnections[t].maxLatencyForChunk=s,this.peerConnections[t].avgLatencyForChunk=s),this.peerConnections[t].numOfChunksArrived++,this.peerConnections[t].numOfPendingChunks--,delete this.p2pPendingChunks[e][i],this.removeFromPendingBlocks(e,i)}else r.log("we already expired chunk: "+i)},addToPendingChunks:function(e,t,i){if(this.peerConnections[i].avgLatencyForChunk&&this.peerConnections[i].numOfChunksArrived>5*this.peerConnections[i].maxNumOfPendingChunks)var n=(r.config.CHUNK_EXPIRATION_TIMEOUT+2*this.peerConnections[i].avgLatencyForChunk)/2;else var n=r.config.CHUNK_EXPIRATION_TIMEOUT;for(var o=0;t.length>o;++o){var s=t[o];this.p2pPendingChunks[e][s]=Date.now(),this.addToPendingBlocks(e,s),radio("peer5_p2p_pending_chunk").broadcast(s,e,i)}if(0!=t.length){this.requestNum++;var a=setTimeout(this.expireChunks,n,e,t,i,this.requestNum);this.pendingRequests[this.requestNum]=[a,e,t,i]}},restoreConnection:function(e){!this.peerConnections[e]&&this.droppedConnections[e]&&(r.warn("connection with "+e+" was restored"),this.peerConnections[e]=this.droppedConnections[e],this.peerConnections[e].ready=!0,delete this.droppedConnections[e],this.sendHaveToNewConnection(e))},createHaveMessage:function(e){var t,i=r.core.data.BlockCache.get(e);return t=i.isFull()?new r.core.protocol.Have(e,!0):new r.core.protocol.Have(e,!1,i.getSerializedMap(),null)},closeConnection:function(e){r.warn("closing connection with "+e+" due to high packet loss"),this.peerConnections[e]&&(r.info(this.peerConnections[e]),this.peerConnections[e].close(),delete this.peerConnections[e])},canUpload:function(){return!0}})}(),function(){var e=function(e){var t={};if(!e)return t;for(var i=e.split("\r\n"),n=0;i.length>n;n++){var r=i[n],o=r.indexOf(": ");if(o>0){var s=r.substring(0,o).toLocaleLowerCase(),a=r.substring(o+2);t[s]=a}}return t},t=function(e,t){return e&&2==e.split("/").length?parseInt(e.split("/")[1]):t?parseInt(t):void 0};r.client.HTTPDownloader=Object.subClass({name:"peer5.client.HTTPDownloader",ctor:function(e){if(this.url=e,this.httpRequestTime=0,this.firstRequest=!0,this.xhr=window._XMLHttpRequest?new _XMLHttpRequest:new XMLHttpRequest,!this.xhr)throw"Cannot instantiate XHR";this.registerEvents()},isHTTPBusy:function(){return this.xhr.busy},cleanHTTP:function(){this.xhr.busy=!1,this.httpRequestTime=0},isHTTPOld:function(){return this.httpRequestTime>0&&this.httpRequestTime+r.config.XHR_TIMEOUT<Date.now()},stop:function(){r.info("aborting XHR"),this.xhr.abort(),this.cleanHTTP(),clearTimeout(this.timerId)},headGET:function(){},head:function(){this.xhr.url=this.url,this.xhr.open("HEAD",this.url),this.xhr.busy=!0;var i=this;this.xhr.onload=function(){if(200!=this.status)return r.warn("Expecting status code 200 from HEAD request. Got "+this.status),this.busy=!1,radio("removeResource").broadcast(this.url,this.status,"head request failed"),void 0;this.busy=!1;var n=this.getAllResponseHeaders(),o=e(n),s=t(o["content-range"],o["content-length"]);if(s){if(r.config.CHUNKY_HEAD)return i.download(0,r.config.CHUNKY_HEAD_LENGTH,!1,!0,s),void 0;this.hash=o["content-md5"],radio("HTTPHeadersReceived").broadcast(this.url,n,o),radio("XHRMetaFetched").broadcast({url:this.url,fileSize:s,hash:null})}else i.download(0,1,!1,!0)},this.xhr.onerror=function(){this.busy=!1,radio("removeResource").broadcast(this.url,this.status,"head request failed")},this.xhr.send(null)},resetTimer:function(e){this.timerId&&(clearTimeout(this.timerId),r.debug("resetTimer clearTimeout of "+this.timerId)),this.timerId=setTimeout(this.expireRequest,r.config.XHR_TIMEOUT,e),r.debug("resetTimer setTimeout returned "+this.timerId)},clearTimer:function(){this.timerId&&(clearTimeout(this.timerId),this.timerId=null)},download:function(i,n,o,s,a){r.debug(i+" - "+n);var c=this;this.httpRequestTime=Date.now(),this.xhr.lastModified=this.httpRequestTime,this.xhr.url=this.url,(!this.xhr.lastTotalLoaded||i>this.xhr.lastTotalLoaded||this.xhr.lastTotalLoaded>n)&&(this.xhr.lastTotalLoaded=i),this.xhr.open("GET",this.url,!0),this.xhr.busy=!0,this.xhr.startRange=i,this.xhr.endRange=n,n?this.xhr.setRequestHeader("Range","bytes="+i+"-"+n):i&&i>0?this.xhr.setRequestHeader("Range","bytes="+i):i=0,this.xhr.onloadend=function(){r.debug("xhr onloadend start: "+this.startRange+" end: "+this.endRange)},this.xhr.onabort=function(){r.debug("xhr onabort")},this.xhr.onerror=function(e){this.busy=!1,r.warn("xhr onerror!"),r.warn(e),radio("xhrFailed"+this.url).broadcast(this)},this.xhr.responseType="arraybuffer",this.xhr.onload=function(){if(r.log("onload xhr"),this.busy=!1,c.firstRequest&&(c.firstRequest=!1),s){var i=this.getAllResponseHeaders(),n=e(i),o=a||t(n["content-range"]);if(o){var l=new r.core.util.MD5.ArrayBuffer,d=l.end();radio("HTTPHeadersReceived").broadcast(this.url,i,n),radio("XHRMetaFetched").broadcast({url:this.url,fileSize:o,hash:d})}}c.httpRequestTime=0,300>this.status&&this.status>=200&&this.response?(r.info("onload"),radio("bytesReceivedEvent"+this.url).broadcast({url:this.url,offset:this.startRange,dataArray:new Uint8Array(this.response)})):(r.warn("could not determine file size from HTTP"),radio("xhrFailed"+this.url).broadcast(this))},this.xhr.onprogress=function(e){var t=Date.now()-this.lastModified;t>r.config.XHR_TIMEOUT/2&&r.info("onprogress last part arrived in "+t+"ms"),this.lastModified=Date.now(),c.resetTimer(this.lastModified);var i=e.loaded+e.target.startRange-e.target.lastTotalLoaded;r.debug("onprogress size"+i),i>0&&(radio("xhrBytesReceived"+this.url).broadcast(i,this.url),e.target.lastTotalLoaded=e.loaded+e.target.startRange,radio("onprogressEvent "+this.url).broadcast())},r.debug("before sending xhr start: "+i+" end: "+n),this.resetTimer(this.xhr.lastModified);try{this.xhr.send(null)}catch(l){console.log("xhr native error")}r.debug("after sending xhr start: "+i+" end: "+n)},registerEvents:function(){var e=this;this.expireRequest=function(t){e.xhr.lastModified==t&&(r.warn("expiring xhr requested on: "+t),radio("expireHttpRequest").broadcast(r.config.XHR_TIMEOUT),e.stop(),e.xhr.busy=!1,radio("xhrTimeout"+e.url).broadcast(e.xhr))}}})}(),function(){r.client.MultiSlotManager=Object.subClass({name:"peer5.client.MultiSlotManager",ctor:function(e){this.url=e,this.xhrs=[],this.rampup=!0,this.createNewSlot(this.url),this.firstRequest=!0,window.setInterval(this.cron,r.config.XHR_SLOT_PROBE_INTERVAL,this)},createNewSlot:function(e){var t=r.core.util.generate_uuid(),i=e.indexOf("?")>-1?"&":"?",n=e+i+t,o=new r.client.HTTPDownloader(n);this.xhrs.push(o),r.info("created new slot "+n),this.registerNewSlotEvents(n)},isHTTPBusy:function(){for(var e=0;this.xhrs.length>e;++e)if(!this.xhrs[e].isHTTPBusy())return!1;return!0},isHTTPOld:function(){for(var e=0;this.xhrs.length>e;++e)if(!this.xhrs[e].isHTTPOld())return!1;return!0},download:function(e,t,i){for(var n,o=0;this.xhrs.length>o;++o)if(!this.xhrs[o].isHTTPBusy()){n=this.xhrs[o];break}r.debug("downloading "+this.url+" "+e+":"+t),n.download(e,t,i),this.isHTTPBusy()||radio("HTTPAvailableEvent").broadcast(this.url)},stop:function(){for(var e=0;this.xhrs.length>e;++e)this.xhrs[e].stop()},registerNewSlotEvents:function(e){radio("stopResource"+e).subscribe([function(e,t,i){radio("stopResource").broadcast(this.url,t,i),this.rampup=!1},this]),radio("removeResource"+e).subscribe([function(e,t,i){radio("removeResource").broadcast(this.url,t,i),this.rampup=!1},this]),radio("bytesReceivedEvent"+e).subscribe([function(e){r.debug("finished xhr: "+this.url+" "+e.offset),this.firstRequest=!1,e.url=this.url,radio("bytesReceivedEvent").broadcast(e)},this]),radio("xhrFailed"+e).subscribe([function(t){r.debug("expiring xhr: "+this.url+" "+t.startRange+":"+t.endRange),this.xhrs[0].url===e&&this.firstRequest&&radio("removeResource"+e).broadcast(e,t.status,"First xhr failed"),this.rampup=!1;for(var i=0;this.xhrs.length>i;++i)if(this.xhrs[i].url===e){var n=this.xhrs.splice(i,1)[0];n.stop(),r.info("removed slot "+e);break}radio("xhrFailed"+this.url).broadcast(t)},this]),radio("xhrTimeout"+e).subscribe([function(e){radio("xhrFailed"+this.url).broadcast(e)},this]),radio("xhrBytesReceived"+e).subscribe([function(e){radio("xhrBytesReceived").broadcast(e,this.url)},this]);var t=!1;radio("onprogressEvent "+e).subscribe([function(){!t&&this.rampup&&this.xhrs.length<r.config.XHR_CONCURRENT&&(this.createNewSlot(this.url),t=!0,radio("HTTPAvailableEvent").broadcast(this.url))},this])},cron:function(e){e.xhrs.length<r.config.XHR_CONCURRENT&&(e.createNewSlot(e.url),radio("HTTPAvailableEvent").broadcast(this.url))}})}(),function(){r.client.HTTPController=r.core.controllers.AbstractController.subClass({ctor:function(){this._super(),this.Total_Waste_HTTP=0,this.numOfHTTPWasteChunks=0,this.downloadedBytes=0,this.lastFailedStartBlock={},this.httpPendingChunks={},this.xhrs={},this.resourceState={},this.registerEvents()},isAvailable:function(e){return this.resourceState[e]?!this.xhrs[e].isHTTPBusy():!1},removeResource:function(e){r.info("removed http resource "+e),this.stop(e),this.httpPendingChunks[e]={},delete this.httpPendingChunks[e],this._super(e)},stopResource:function(e){r.info("stopped http resource "+e),this.stop(e),this.httpPendingChunks[e]={},delete this.httpPendingChunks[e],this._super(e)},init:function(e,t){if(this._super(e,t),!this.xhrs[e]){var i=new r.client.MultiSlotManager(e);radio("xhrFailed"+e).subscribe([function(t){if(this.resourceState[e]){for(var i=t.startRange/r.config.CHUNK_SIZE,n=Math.ceil((t.endRange+1)/r.config.CHUNK_SIZE)-1,o=i;n>=o;o++)delete this.httpPendingChunks[e][o],this.removeFromPendingBlocks(e,o);this.lastFailedStartBlock[e]=t.startRange/12e5,radio("HTTPAvailableEvent").broadcast(e)}},this]),this.xhrs[e]=i}(t||!this.httpPendingChunks[e])&&(this.httpPendingChunks[e]={})},download:function(e,t,i){if(this.isAvailable(e)){var n=r.core.data.BlockCache.get(e);this.xhrs[e]||(this.xhrs[e]=new r.client.HTTPDownloader(e),this.httpPendingChunks[e]={});var o=this.xhrs[e],s=this.httpPendingChunks[e];if(o.isHTTPBusy())return o.isHTTPOld()?(r.warn("http timeout"),this.stop(),0):(r.debug("http busy"),0);!this.lastFailedStartBlock[e]||n.has(this.lastFailedStartBlock[e])||this.isPendingBlock(e,this.lastFailedStartBlock[e])||(t=this.lastFailedStartBlock[e],i=this.lastFailedStartBlock[e]);for(var a=i-t+1,c=t;i>=c;c++){var l=n.getChunkIdsOfBlock(c);for(var d in l)s[l[d]]=Date.now(),this.addToPendingBlocks(e,l[d]),radio("peer5_pending_http_chunk").broadcast(l[d],e,"#000000",2)}this.httpPendingChunks[e]=s;var u=!1;r.log("requesting "+a+" blocks in HTTP");var h=12e5*t,f=Math.min(12e5*(i+1)-1,n.fileSize-1);return o.download(h,f,u),a}},getConnectionStats:function(){},getFirstPendingBlock:function(e){var t=parseInt(Object.keys(this.httpPendingChunks[e])[0]);if(isNaN(t))return-1;var i=r.core.data.BlockCache.get(e).getBlockIdOfChunk(t);return i},addHTTPBytesToChunks:function(e,t,i){for(var n=i.length,o=0,s=r.core.data.BlockCache.get(e);n>0;){var a=Math.floor((t+o)/r.config.CHUNK_SIZE),c=Math.min(r.config.CHUNK_SIZE,n);if(s.hasChunk(a))this.Total_Waste_HTTP+=c,this.numOfHTTPWasteChunks++,r.log("DOH, got bytes for a completed chunk"+a),radio("peer5_waste_http_chunk").broadcast(a,e,"#000000");else{var l=i.subarray(o,o+c);this.addChunk(e,l,a),radio("peer5_received_http_chunk").broadcast(a,e),radio("peer5_new_http_chunk").broadcast(a,e,"#000000")}delete this.httpPendingChunks[e][a],this.removeFromPendingBlocks(e,a),o+=c,n-=c}},registerEvents:function(){radio("XHRMetaFetched").subscribe(function(e){radio("HTTPInited").broadcast(e)}),radio("bytesReceivedEvent").subscribe([function(e){this.addHTTPBytesToChunks(e.url,e.offset,e.dataArray),radio("HTTPAvailableEvent").broadcast(e.url)},this])},stop:function(e){var t=this.xhrs[e];t&&(t.stop(),this.httpPendingChunks[e]={},this.pendingBlocks[e]={})}})}(),function(){r.client.HybridController=r.core.controllers.AbstractController.subClass({ctor:function(e){this.P2PController=new r.core.controllers.P2PController(e),this.httpController=new r.client.HTTPController,this.urlToId={},this.urgent={},this.prefetch={},this.resourceState={},this.registerEvents(),this.lastBlockRequestedInP2P},registerEvents:function(){radio("HTTPInited").subscribe(function(){}),radio("P2PAvailableEvent").subscribe([function(e,t){r.log("P2PAvailableEvent");var i=e.slice(0);do{var n=i[0];if(this.resourceState[n]&&2==this.resourceState[n])return;if(this.prefetch[r.core.data.BlockCache.get(n).getMetadata().url])if(r.config.SEQUENTIAL_DOWNLOAD)var o=this.relaxedP2PDownload(r.core.data.BlockCache.get(n).getMetadata().url,null,null,t);else var o=this.relaxedP2PDownloadRandomly(r.core.data.BlockCache.get(n).getMetadata().url,null,null,t);i.splice(0,1)}while(!o&&0!==i.length)},this]),radio("HTTPAvailableEvent").subscribe([function(e){if(r.debug("http available"),this.httpController.isAvailable(e)&&this.prefetch[e]){var t=r.core.data.BlockCache.get(e);if(t.isFull())return r.info("HTTP Available but already have everything"),this.httpController.stop(e),void 0;var i;i=r.config.SEQUENTIAL_DOWNLOAD?this.relaxedHTTPDownload(e):this.relaxedHTTPDownloadRandomly(e),0===i&&(this.urgent[e]=!0,r.config.SEQUENTIAL_DOWNLOAD?this.aggressiveHTTPDownload(e):this.aggressiveHTTPDownloadRandomly(e))}},this])},removeResource:function(e){this.resourceState[e]=!1,this.P2PController.removeResource(this.urlToId[e]),this.httpController.removeResource(e),delete this.resourceState[e]},stopResource:function(e){this.resourceState[e]=!1,this.P2PController.stopResource(this.urlToId[e]),this.httpController.stopResource(e)},download:function(e,t,i,n){if(this.isAvailable(e)){var o=r.core.data.BlockCache.get(e);if(!o.isFull()){if(t||(t=o.getMissingBlock()),i||(i=o.getNumOfBlocks()-1),n||(n=r.config.HYBRID_REQUEST_THRESHOLD),n>r.config.HYBRID_REQUEST_THRESHOLD&&(this.urgent[e]=!1),t>o.getNumOfBlocks()-1||i>o.getNumOfBlocks()-1)return r.warn("out of range"),void 0;var s=t;t=o.getMissingBlock(),t>s&&radio("blockReceivedEvent").broadcast(o.getMetadata()),(r.config.HTTP_REQUEST_THRESHOLD>n||this.urgent[e])&&(r.config.HTTP_REQUEST_THRESHOLD>n&&(this.urgent[e]=!0),r.debug("urgency is: "+n+" downloading from HTTP"),r.config.SEQUENTIAL_DOWNLOAD?this.aggressiveHTTPDownload(e,t,i):this.aggressiveHTTPDownloadRandomly(e,t,i)),(r.config.P2P_ALWAYS_DOWNLOAD||n>=r.config.P2P_REQUEST_BEGIN_THRESHOLD&&r.config.P2P_REQUEST_END_THRESHOLD>n&&this.P2PController.isAvailable(this.urlToId[e]))&&(r.debug("urgency is: "+n+" downloading from P2P"),r.config.SEQUENTIAL_DOWNLOAD?this.relaxedP2PDownload(e,t,i):this.relaxedP2PDownloadRandomly(e,t,i)),(r.config.HTTP_ALWAYS_DOWNLOAD||n>=r.config.HTTP_REQUEST_THRESHOLD&&r.config.HYBRID_REQUEST_THRESHOLD>=n&&this.httpController.isAvailable(e))&&(r.config.SEQUENTIAL_DOWNLOAD?this.relaxedHTTPDownload(e,t,i):this.relaxedHTTPDownloadRandomly(e,t,i))}}},relaxedHTTPDownload:function(e,t,i){var n=r.core.data.BlockCache.get(e);t||(t=n.getFirstMissingBlock()),i||(i=n.getNumOfBlocks()-1);var o=this,s=this.getSeqBlocks(e,r.config.XHR_MAX_GET,function(r){return r>=t&&i>=r&&n.isEmpty(r)&&!o.httpController.isPendingBlock(e,r)&&!o.P2PController.isPendingBlock(o.urlToId[e],r)});return 0===s.length?0:(this.httpController.download(e,s[0],s[s.length-1]),s[s.length-1]-s[0]+1)},aggressiveHTTPDownload:function(e,t,i){var n=r.core.data.BlockCache.get(e);t||(t=n.getFirstMissingBlock()),i||(i=n.getNumOfBlocks()-1);var o=this,s=this.getSeqBlocks(e,r.config.XHR_MAX_GET,function(n){return n>=t&&i>=n&&!o.httpController.isPendingBlock(e,n)});return 0===s.length?0:(this.httpController.download(e,s[0],s[s.length-1]),s[s.length-1]-s[0]+1)},relaxedHTTPDownloadRandomly:function(e,t,i){var n=r.core.data.BlockCache.get(e);t||(t=n.getFirstMissingBlock()),i||(i=n.getNumOfBlocks()-1);var o=this,s=this.getRarestBlocks(e,r.config.XHR_MAX_GET,function(r){return r>=t&&i>=r&&n.isEmpty(r)&&!o.httpController.isPendingBlock(e,r)&&!o.P2PController.isPendingBlock(swarmId,r)});return t=s[0],i=s[s.length-1],s.length>0&&this.httpController.download(e,t,i),s.length},aggressiveHTTPDownloadRandomly:function(e,t,i){var n=r.core.data.BlockCache.get(e);t||(t=n.getFirstMissingBlock()),i||(i=n.getNumOfBlocks()-1);var o=this,s=this.getRarestBlocks(e,r.config.XHR_MAX_GET,function(r){return r>=t&&i>=r&&!n.has(r)&&!o.httpController.isPendingBlock(e,r)}),t=s[0],i=s[s.length-1];return s.length>0&&this.httpController.download(e,t,i),s.length},relaxedP2PDownload:function(e,t,i,n){var o=r.core.data.BlockCache.get(e),s=this.urlToId[e];if(this.P2PController.isAvailable(s)){if(t||(t=o.getFirstMissingBlock()),i||(i=o.getNumOfBlocks()-1),t>o.getNumOfBlocks()-1||i>o.getNumOfBlocks()-1)return r.warn("out of range"),void 0;var a=t;for(t=this.lastBlockRequestedInP2P&&!o.has(this.lastBlockRequestedInP2P)?this.lastBlockRequestedInP2P:o.getFirstMissingBlock(),t>a&&radio("blockReceivedEvent").broadcast(o.getMetadata()),this.httpController.getFirstPendingBlock(e);i>=t&&(this.httpController.isPendingBlock(e,t)||this.P2PController.isPendingEntireBlock(s,t));)t++;for(var c,l=[],d=t;i>=d&&o.getNumOfBlocks()>d&&l.length<this.P2PController.getAvailableNumOfChunksToSend();++d)if(!this.httpController.isPendingBlock(e,d)&&!this.P2PController.isPendingEntireBlock(s,d)){c=[],c=o.getChunkIdsOfBlock(d);for(var u=0;c.length>u;++u)o.hasChunk(c[u])||this.P2PController.isPendingChunk(s,c[u])||l.push(c[u]);this.lastBlockRequestedInP2P=d}return this.P2PController.distributeChunksAmongSources(s,l,n),l.length}},relaxedP2PDownloadRandomly:function(e,t,i,n){if(!n)for(var n in this.P2PController.peerConnections)this.P2PController.isPeerAvailable(n)&&this.download(e,t,i,n);var o=r.core.data.BlockCache.get(e);t||(t=o.getFirstMissingBlock()),i||(i=o.getNumOfBlocks()-1);var s=this.urlToId[e],a=this,c=this.P2PController.download(s,n,function(r){return r>=t&&i>=r&&!o.has(r)&&!a.httpController.isPendingBlock(e,r)&&a.P2PController.remoteAvailabilityMaps[s][n].has(r)&&!a.P2PController.isPendingEntireBlock(s,r)});return c},init:function(e,t,i){if(1==i){if(this.resourceState.hasOwnProperty(e.url))return this.resourceState[e.url]=!0,this.httpController.init(e.url,!0),this.P2PController.init(e.swarmId,!1,!0),void 0;this.resourceState[e.url]=i,this.prefetch[e.url]=t,this.urlToId[e.url]=e.swarmId,this.httpController.init(e.url),this.P2PController.init(e.swarmId,!1),this.prefetch&&(this.urgent[e.url]=!1)}else if(2==i){if(this.urlToId[e.swarmId]=e.swarmId,this.resourceState[e.swarmId]=i,this.resourceState.hasOwnProperty(e.swarmId))return this.P2PController.init(e.swarmId,!0,!0),void 0;this.P2PController.init(e.swarmId,!0),this.prefetch&&(this.urgent[e.swarmId]=!1),e.url&&(this.urlToId[e.url]=e.swarmId,this.prefetch[e.url]=t)}},isAvailable:function(e){return(this.P2PController.isAvailable(this.urlToId[e])||this.httpController.isAvailable(e))&&this.resourceState[e]},getConnectionStats:function(){return{http:this.httpController.getConnectionStats(),p2p:this.P2PController.getConnectionStats()}},downloadPeriodicTest:function(e){this.resourceState[e]&&this.httpController.isAvailable(e)&&radio("HTTPAvailableEvent").broadcast(e)},stopHttp:function(e){this.httpController.stop(e)}})}(),function(){r.core.transport.WsConnection=Object.subClass({name:"peer5.core.transport.WsConnection",ctor:function(e,t){this.state={connectionOpenTime:0},this.clientId=t,this.wsSeverUrl=e,this.lastPongTimeStamp,this.socketInitating=!0,this.intentionalClose=!1,this.socket,this.initiateWebSocket(this.wsSeverUrl,this.clientId)},initiateWebSocket:function(e,t){var i=this;this.intentionalClose=!1,this.start=Date.now(),this.socket=new WebSocket(e+"?id="+t+"&token="+"z142i5n5qypq4cxr"),r.log("trying to connect to a new websocket"),this.socket.sessionid=t,this.socket.binaryType="arraybuffer",this.socket.onclose=function(e){radio("wsError").broadcast("websocket closed"),r.warn("WebSocket closed with error"),r.warn(e),i.socket=null,i.intentionalClose||(r.info("Peer "+this.sessionid+" is trying to reconnect to the server"),setTimeout(function(){i.initiateWebSocket(i.wsSeverUrl,i.clientId)},r.config.SOCKET_RECONNECTION_INTERVAL))},this.socket.onerror=function(e){r.error("peer with Id "+this.sessionid+" had socket error : "),r.error(e)},this.socket.onopen=function(){var e=Date.now();i.state.connectionOpenTime=e-i.start,i.socketInitating=!1,i.lastPongTimeStamp=e,r.log("websocket took: "+i.state.connectionOpenTime+" to open"),i.socketInit=!0,i.registerServerNotifications(),radio("webSocketInit").broadcast()},radio("websocketsSendData").subscribe([function(e){this.sendData(e)},this])},close:function(){this.intentionalClose=!0,this.socket.close()},registerServerNotifications:function(){var e=this;this.socket.onmessage=function(t){if(e.lastPongTimeStamp=Date.now(),"string"!=typeof t.data)for(var i=r.core.protocol.BinaryProtocol.decode(new Uint8Array(t.data)),n=0;i.length>n;++n)switch(i[n].tag){case r.core.protocol.MATCH:radio("receivedMatchEvent").broadcast(i[n]);break;case r.core.protocol.FILE_INFO:radio("receivedFileInfo").broadcast(i[n]);break;case r.core.protocol.SDP:radio("receivedSDP").broadcast(i[n]);break;case r.core.protocol.SWARM_HEALTH:radio("swarmHealth").broadcast(i[n]);break;case r.core.protocol.SWARM_ERROR:radio("swarmError").broadcast(i[n])}else r.warn("received a string message from server - not supported")}},socketReadyToSend:function(){return this.socket&&this.socketInit&&this.socket.readyState==this.socket.OPEN},sendMessage:function(e){var t=r.core.protocol.BinaryProtocol.encode([e]);this.sendData(t)},sendData:function(e){this.socketReadyToSend()?(r.log("sending data on websockets, at time: "+Date.now()),this.socket.send(e)):r.warn("cant send data - socket is not defined")}})}(),function(){r.core.apiValidators.ApiValidatorBase=Object.subClass({name:"peer5.core.apiValidators.ApiValidatorBase",ctor:function(){this.status=!1},detectBrowser:function(){var e,t=navigator.appName,i=navigator.userAgent,n=i.match(/(opera|chrome|safari|firefox|msie)\/?\s*(\.?\d+(\.\d+)*)/i);return n&&null!=(e=i.match(/version\/([\.\d]+)/i))&&(n[2]=e[1]),n=n?[n[1],n[2]]:[t,navigator.appVersion,"-?"]},getMajorVersionNumber:function(e){var t=e.split("."),i=parseInt(t[0]);return i},validate:function(){throw"unimplemented method"}})}(),function(){r.core.apiValidators.ApiValidator=Object.subClass({name:"peer5.core.apiValidators.ApiValidator",ctor:function(e){var t=this.detectBrowser();this.browserName=t[0].toLowerCase(),this.browserVersion=t[1],this.validators={},this.validity={};for(var i in e)this.validators[i]=new e[i](this.browserName,this.browserVersion),this.validity[i]=!1},detectBrowser:function(){var e,t=navigator.appName,i=navigator.userAgent,n=i.match(/(opera|chrome|safari|firefox|msie)\/?\s*(\.?\d+(\.\d+)*)/i);return n&&null!=(e=i.match(/version\/([\.\d]+)/i))&&(n[2]=e[1]),n=n?[n[1],n[2]]:[t,navigator.appVersion,"-?"]},validate:function(){var e=!0;switch(this.browserName){case"chrome":if(r.config.DISABLE_CHROME)return!1;break;case"firefox":if(r.config.DISABLE_FIREFOX)return!1}for(var t in this.validators)e=e&&this.validators[t].validate();return e},getBrowser:function(){return{name:this.browserName,version:this.browserVersion}},getStatus:function(){var e={};for(var t in this.validators)e[t]=this.validators[t].status;return e}})}(),function(){r.core.apiValidators.DataChannelsApiValidator=r.core.apiValidators.ApiValidatorBase.subClass({name:"peer5.core.apiValidators.DataChannelsApiValidator",ctor:function(e,t){this._super(),this.browserName=e,this.browserVersion=t,this.browserVersionSupprot={chrome:31,firefox:26,msie:11,opera:12,safari:1e3}},validate:function(){var e=!0;"chrome"==this.browserName&&31>this.getMajorVersionNumber(this.browserVersion)&&(e=!1);var t;try{var i;if(window.webkitRTCPeerConnection){i=window.webkitRTCPeerConnection;var n="stun:stun.l.google.com:19302";servers={iceServers:[{url:"stun:"+n}]},t=new i(servers),t.createDataChannel("test_data_channels",{outOfOrderAllowed:!0,maxRetransmitNum:0})}else window.mozRTCPeerConnection?(i=window.mozRTCPeerConnection,t=new i,t.createDataChannel("test_data_channels",{outOfOrderAllowed:!0,maxRetransmitNum:0})):e=!1}catch(r){e=!1}return t&&(t.close(),delete t),e||radio("browserUnsupported").broadcast(this.browserName,this.browserVersion,"data channels"),this.status=e,e}})}(),function(){r.core.apiValidators.FileSystemApiValidator=r.core.apiValidators.ApiValidatorBase.subClass({name:"peer5.core.apiValidators.FileSystemApiValidator",ctor:function(e,t){this._super(),this.browserName=e,this.browserVersion=t,this.browserVersionSupprot={chrome:26,firefox:19,msie:11,opera:12,safari:1e3}},validate:function(){if(0==r.config.USE_FS)return!0;if("firefox"==this.browserName)r.config.ALLOWED_FILE_SIZE=r.config.ALLOWED_FILE_SIZE_FF,r.core.data.FSio=new r.core.data.FSioFireFox,r.config.IS_FIREFOX=!0,r.config.USE_PERSISTENT||(r.config.USE_FS=!1),window.indexedDB.open||(r.config.USE_FS=!1);else if(window.webkitRequestFileSystem&&navigator.webkitTemporaryStorage){var e=this;r.core.data.FSio.requestTempQuota(100,function(t){t||(r.info("changing USE_FS to false"),e.status=!1,r.config.USE_FS=!1)})}else r.config.USE_FS=!1;return this.status=r.config.USE_FS,!0}})}(),function(){r.overrideXHR=function(){if(window.XMLHttpRequest)window._XMLHttpRequest=window.XMLHttpRequest,window.XMLHttpRequest=r.Request;else{if(!window._XMLHttpRequest)throw"Cannot find XMLHTTPRequest";r.warn("XMLHTTPRequest is already peer5.Request")}},r.revertXHR=function(){window._XMLHttpRequest?(window.XMLHttpRequest=window._XMLHttpRequest,window._XMLHttpRequest=null):r.warn("_XMLHTTPRequest not found")},r.Request=Object.subClass({ctor:function(e){this.readyState=0,this.response,this._responseHeaders,this.responseType="",this.timeout="unimplemented",this.status,this._range,this._get=!1,this._post=!1,this._id,this._swarmState={numOfPeers:0,uploaded:0},this.fileInfo,e=this.sanitizeCtorArgs(e),this.downloadMode=e.downloadMode,this.onloadstart,this.onprogress,this.onabort,this.onerror,this.onload,this.ontimeout="unimplemented",this.onloadend,this.onreadystatechange,this.onswarmstatechange},open:function(e,t){if(!e)return!1;if("GET"==e.toUpperCase()&&t)this._get=!0,this._id=t;else{if("POST"!=e.toUpperCase())return!1;this._post=!0,this._id=r.core.util.generate_uuid()}this.changeReadyState(1),this.registerEvents()},setRequestHeader:function(){},send:function(e){radio("requestSent").broadcast();var t=this;r.clientInstance.isValidated(function(i){return i?(!e&&t._get&&1==t.readyState&&r.clientInstance.addResource(t._id,t.downloadMode),e&&t._post&&1==t.readyState&&e instanceof Blob&&t.changeReadyState(2)&&r.clientInstance.readBlobData(t._id,e),void 0):(r.getCompatibilityStatus(function(e){t.handleRequestError(e[0])}),void 0)})},getResponseHeader:function(e){if(2>this.readyState)throw"Response headers are available only when readystate >=2";var t=this._responseMap[e];if(t)return t;throw e+" is not present in the response headers"},getAllResponseHeaders:function(){return this._responseHeaders},getFileInfo:function(){return this.readyState>=2?this.fileInfo:void 0},abort:function(e){if(this.readyState>=1&&3>this.readyState)return this.queuedCommand=["abort",e],void 0;var t=this;this.createProgressEvent(this.fileInfo,function(i){e&&e.leaveSwarm?r.clientInstance.removeResource(t._id):r.clientInstance.stopResource(t._id),t.unregisterEvents(),r.core.util.envokeCallback(t.onabort,[i],t),r.core.util.envokeCallback(t.onloadend,[i],t)})},registerEvents:function(){radio("HTTPHeadersReceived").subscribe([this.HTTPHeadersReceivedEvent,this]),radio("fileInfoReceived").subscribe([this.fileInfoReceivedEvent,this]),radio("resourceReady").subscribe([this.resourceReadyEvent,this]),radio("blockReceivedEvent").subscribe([this.blockReceivedEvent,this]),radio("transferLoadedEvent").subscribe([this.transferLoadedEvent,this]),radio("requestError").subscribe([this.requestErrorEvent,this]),radio("activePeerConnectionsNumberChanged").subscribe([this.activePeerConnectionsNumberChangedEvent,this]),radio("chunkSentEvent").subscribe([this.chunkSentEvent,this])},unregisterEvents:function(){radio("HTTPHeadersReceived").unsubscribe([this.HTTPHeadersReceivedEvent,this]),radio("fileInfoReceived").unsubscribe([this.fileInfoReceivedEvent,this]),radio("resourceReady").unsubscribe([this.resourceReadyEvent,this]),radio("blockReceivedEvent").unsubscribe([this.blockReceivedEvent,this]),radio("transferLoadedEvent").unsubscribe([this.transferLoadedEvent,this]),radio("requestError").unsubscribe([this.requestErrorEvent,this]),radio("activePeerConnectionsNumberChanged").unsubscribe([this.activePeerConnectionsNumberChangedEvent,this]),radio("chunkSentEvent").unsubscribe([this.chunkSentEvent,this])},HTTPHeadersReceivedEvent:function(e,t,i){e==this._id&&(this._responseHeaders=t,this._responseMap=i)},fileInfoReceivedEvent:function(e){var t=this;r.clientInstance.getSwarmId(this._id,function(i){i==e.swarmId&&t._get&&(t.fileInfo=e,t.changeReadyState(2))})},resourceReadyEvent:function(e){var t=this;r.clientInstance.getSwarmId(this._id,function(i){if(i==e.swarmId)if(t.fileInfo=e,t._get){if(!t.changeReadyState(3))return;if(t.range)var n=range[0],o=range[1];t.createProgressEvent(e,function(e){r.core.util.envokeCallback(t.onloadstart,[e],t)}),r.clientInstance.isFull(i,function(i){i?t.handleTransferLoaded(e):(urgent=null,stop_prev=null,radio("needByteRangeEvent").broadcast(t._id,n,o,urgent,stop_prev))})}else if(t._post){if(t._id=e.swarmId,!t.changeReadyState(4))return;t._getUrlAndTriggerOnLoad(e)}}),e.swarmId!=swarmId},blockReceivedEvent:function(e){if(e&&(e.url==this._id||e.swarmId==this._id)){var t=this;t.createProgressEvent(e,function(e){r.core.util.envokeCallback(t.onprogress,[e],t)
  4. })}},transferLoadedEvent:function(e){this.handleTransferLoaded(e)},requestErrorEvent:function(e,t,i){var n=this;r.clientInstance.getResourceId(this._id,function(r){(n._id==e||r==e)&&n.handleRequestError(t,i)})},activePeerConnectionsNumberChangedEvent:function(e){this._swarmState.numOfPeers=e;var t=this.createSwarmStateEvent();r.core.util.envokeCallback(this.onswarmstatechange,[t],this)},chunkSentEvent:function(e){if(this.fileInfo&&this.fileInfo.swarmId==e){var t=this;r.clientInstance.getUploadedStats(e,function(e){for(stat in e)t._swarmState[stat]=e[stat];var i=t.createSwarmStateEvent();r.core.util.envokeCallback(t.onswarmstatechange,[i],t)})}},sanitizeCtorArgs:function(e){switch(e||(e={}),e.downloadMode){case"p2p":e.downloadMode=2;break;case"http":e.downloadMode=3;break;default:e.downloadMode=1}return e},createProgressEvent:function(e,t){var i=this.createEvent(),n=this;return e?(r.clientInstance.getNumOfVerifiedBytes(this._id,function(o){o||0==o?(i.loaded=o,i.lengthComputable=!0,i.total=e.size,r.clientInstance.getLoadedStats(n._id,function(e){for(stat in e)i[stat]=e[stat];t(i)})):(i.loaded=0,i.loadedHTTP=0,i.loadedP2P=0,i.loadedFS=0,i.lengthComputable=!1,t(i))}),void 0):(i.loaded=0,i.loadedHTTP=0,i.loadedP2P=0,i.loadedFS=0,i.lengthComputable=!1,t(i),void 0)},createSwarmStateEvent:function(){var e=this.createEvent();for(var t in this._swarmState)e[t]=this._swarmState[t];return e},createEvent:function(){var e={};return e.currentTarget=this,e},changeReadyState:function(e){if(this.readyState!=e-1)return r.info("ready state has jumped a stage"),!1;this.readyState=e,3==this.readyState&&(this.queuedCommand&&r.core.util.executeFunctionByName(this.queuedCommand[0],this,[this.queuedCommand[1]]),this._get&&radio("startedDownloading").broadcast(this.fileInfo.size));var t=this;if(this.fileInfo)this.createProgressEvent(this.fileInfo,function(e){r.core.util.envokeCallback(t.onreadystatechange,[e],t)});else{var i=this.createEvent();r.core.util.envokeCallback(this.onreadystatechange,[i],this)}return!0},handleTransferLoaded:function(e){if(e&&(e.url==this._id||e.swarmId==this._id))if(this._get){if(!this.changeReadyState(4))return;this._getUrlAndTriggerOnLoad(e)}else this._post&&this.changeReadyState(3)},handleRequestError:function(e,t){this.status=e,this.description=t,this.unregisterEvents();var i=this;this.createProgressEvent(this.fileInfo,function(e){r.core.util.envokeCallback(i.onerror,[e],i)})},_getUrlAndTriggerOnLoad:function(e){var t=this;switch(this.status=200,this.responseType){case"arraybuffer":throw"arraybuffer not supported, use blob instead";case"blob":r.clientInstance.getBlob(e.swarmId,function(i,n){i?(t.response=n,t.createProgressEvent(e,function(e){r.core.util.envokeCallback(t.onload,[e],t)})):r.error("couldn't receive blob")});break;case"document":r.error("document responseType isn't supported"),t.handleRequestError(this.INVALID_RESPONSETYPE,"document is not implemented");break;case"json":r.error("json responseType isn't supported"),t.handleRequestError(this.INVALID_RESPONSETYPE,"json is not implemented");break;case"text":r.error("text responseType isn't supported"),t.handleRequestError(this.INVALID_RESPONSETYPE,"text is not implemented");break;default:r.clientInstance.getBlobUrl(e.swarmId,function(i,n){i?(t.response=n,t.createProgressEvent(e,function(e){r.core.util.envokeCallback(t.onload,[e],t)})):r.error("couldn't receive blobUrl")})}}}),r.Request.INVALID_RESPONSETYPE=644,r.Request.SWARMID_NOT_FOUND_ERR=650,r.Request.FILE_SIZE_ERR=640,r.Request.FIREFOX_ONLY_SWARM_ERR=641,r.Request.CHROME_ONLY_SWARM_ERR=642,r.Request.BROWSER_SWARM_COMPAT_ERR=643,r.Request.OUT_OF_SPACE_ERR=644,r.Request.WRITE_ERR=645,r.DATACHANNELS_ERROR=700,r.WEBSOCKETS_ERROR=701,r.FILESYSTEM_ERROR=702,r.getCompatibilityStatus=function(e){r.clientInstance.getCompatibilityStatus(function(t,i){var n=[];for(type in t)if(!t[type])switch(type){case"dataChannels":n.push(r.DATACHANNELS_ERROR);break;case"Websockets":n.push(r.WEBSOCKETS_ERROR);break;case"fileSystem":n.push(r.FILESYSTEM_ERROR)}e(n,i.name,i.version)})}}(),function(){r.core.Block=Object.subClass({name:"peer5.core.Block",ctor:function(e,t,i){this.blockSize=e,this.length=Math.ceil(this.blockSize/r.config.CHUNK_SIZE),this.buffer=t?t:null,this.verified=i?i:!1,this.hash=null,this.chunkMap=[];for(var n=0;this.length>n;++n)this.chunkMap[n]=this.verified},getBlock:function(){return this.verified&&this.buffer?this.buffer:!1},setBlock:function(e){this.verified&&e.length==this.blockSize&&(this.buffer=e)},getChunk:function(e){if(this.verified){if(this.buffer){var t=e*r.config.CHUNK_SIZE,i=(1+e)*r.config.CHUNK_SIZE;return this.buffer.subarray(t,i)}return!0}return!1},hasChunk:function(e){return this.chunkMap[e]},setChunk:function(e,t){this.buffer||(this.buffer=new Uint8Array(this.blockSize),this.chunkMap=[]);var i=new Uint8Array(t),n=e*r.config.CHUNK_SIZE;this.buffer.set(i,n),this.chunkMap[e]=!0},setChunkOn:function(e){this.chunkMap||(this.chunkMap=[]),this.chunkMap[e]=!0},getNumOfChunks:function(){return this.length},removeBlockData:function(){delete this.buffer},verifyBlock:function(){if(this.verified)return 0;for(var e=0;this.length>e;++e)if(!this.chunkMap[e])return 0;return this.verified=!0,1}})}(),function(){r.core.dataStructures.BlockMap=Object.subClass({name:"peer5.core.dataStructures.BlockMap",ctor:function(e,t,i){this.init=!1,this.resourceId=t,this.hash=i,this.metadata=new r.core.protocol.FileInfo(null,e,null,null,12e5,null,null,null,null),this.metadata.url=t,this.privateBlockMap={},this.numOfChunksInBlock=12e5/r.config.CHUNK_SIZE,this.fileSize=e,this.numOfBlocks=Math.ceil(this.fileSize/12e5),this.numOfChunks=Math.ceil(this.fileSize/r.config.CHUNK_SIZE),this.numOfVerifiedBlocks=0,this.firstMissingBlock=0,this.sizeOfLastBlock=e%12e5,0==this.sizeOfLastBlock&&(this.sizeOfLastBlock=12e5),this.availabilityMap,this.fs=!0,this._registerEvents(),r.config.USE_FS?(this.lruMap=new r.core.dataStructures.LRU(Math.floor(r.config.CACHE_SIZE/12e5),this._lruRemoveCb),this._initiateFileSystem()):(this.fs=!1,this.availabilityMap=new r.core.dataStructures.AvailabilityMap(this.numOfBlocks))},getSerializedMap:function(){return this.availabilityMap.serialize()},isFull:function(){return this.numOfBlocks==this.numOfVerifiedBlocks},getCompletionRate:function(){return this.numOfVerifiedBlocks/this.numOfBlocks},has:function(e){return this.privateBlockMap[e]&&this.privateBlockMap[e].verified},hasChunk:function(e){var t=this.calcBlockIdChunkOffset(e);return this.privateBlockMap[t.block]?this.privateBlockMap[t.block].hasChunk(t.chunk):!1},getNumOfBlocks:function(){return this.numOfBlocks},getNumOfVerifiedBytes:function(){return this.numOfVerifiedBlocks==this.numOfBlocks?this.fileSize:12e5*this.numOfVerifiedBlocks},getNumOfChunks:function(){return this.getNumOfChunks},getBlock:function(e){return this.privateBlockMap[e]?this.privateBlockMap[e].getBlock():!1},getChunkIdsOfBlock:function(e){if(e>=this.numOfBlocks)return[];for(var t=e==this.numOfBlocks-1?Math.ceil(this.sizeOfLastBlock/r.config.CHUNK_SIZE):this.numOfChunksInBlock,i=[],n=e*this.numOfChunksInBlock,o=n;n+t>o;++o)i.push(o);return i},getBlockIdOfChunk:function(e){if(e>=this.numOfChunks)return-1;var t=this.calcBlockIdChunkOffset(e);return t.block},getChunk:function(e,t){var i=this,n=this.calcBlockIdChunkOffset(e);if(this.privateBlockMap[n.block]){var o=this.privateBlockMap[n.block].getChunk(n.chunk);if(this.fs){if(!o)return!1;if(1==o){var s=12e5*n.block;r.core.data.FSio.read(this.resourceId,s,s+12e5,function(r,o){if(r){var s=i.privateBlockMap[n.block];s.setBlock(o),i.lruMap.set(n.block,s),i.getChunk(e,t)}})}else this.lruMap.get(n.block),t(!0,o)}else t(!0,o)}},setChunk:function(e,t){var i=this.calcBlockIdChunkOffset(e);if(!this.privateBlockMap[i.block]){var n=i.block==this.numOfBlocks-1?this.sizeOfLastBlock:12e5;this.privateBlockMap[i.block]=new r.core.Block(n)}return this.privateBlockMap[i.block].setChunk(i.chunk,t),this.verifyBlock(i.block),i.block},isEmpty:function(e){return!this.privateBlockMap[e]},getBlockIndex:function(e){return Math.ceil(e/12e5)},getBlockIds:function(){return Object.keys(this.privateBlockMap)},getMissingBlock:function(e){return e?this.getRandomMissingBlock():this.getFirstMissingBlock()},getFirstMissingBlock:function(){return this.firstMissingBlock},getRandomMissingBlock:function(){for(var e=0;1e3>e;e++){var t=this.numOfBlocks-this.firstMissingBlock,i=this.firstMissingBlock+Math.floor(Math.random()*t);if(!(i in this.privateBlockMap&&this.privateBlockMap[i].verified))return i}return this.firstMissingBlock},getConsecutiveBuffer:function(e){for(var t=e;this.has(t);)t++;for(var i=t-e,n=new Uint8Array(12e5*i),r=0;i>r;++r)n.set(this.getBlock(r),12e5*r);return n},verifyBlock:function(e){if(this.privateBlockMap[e]){if(1==this.privateBlockMap[e].verifyBlock()){for(this.numOfVerifiedBlocks++;this.has(this.firstMissingBlock);)this.firstMissingBlock++;radio("blockReceivedEvent").broadcast(this.metadata),this.isFull()&&radio("transferFinishedEvent").broadcast(this.metadata);var t=this;this.fs?r.core.data.FSio.write(t.resourceId,t.getBlock(e),12e5*e,function(i,n){i?(t.lruMap.set(e,t.privateBlockMap[e]),r.debug("successfully wrote block "+e+" to filesystem "),t.availabilityMap.setFS(e,function(i){i&&r.debug("successfully added block "+e+" to metadata file"),t.availabilityMap.isFullFS()&&radio("transferLoadedEvent").broadcast(t.metadata)})):(r.warn("couldn't write block "+e+" to filesystem"),"space"===n?t._handleOutOfSpaceError():t._handleWriteError())}):this.isFull()&&radio("transferLoadedEvent").broadcast(this.metadata)}if(this.privateBlockMap[e].verified)return this.availabilityMap.set(e),!0}return!1},addMetadata:function(e){this.metadata=e,this.init=!0},getMetadata:function(){return this.metadata},initiateFromLocalData:function(e,t,i){var n=this;t||(t=0),i||0==i?n.availabilityMap.hasFS(t)?r.core.data.FSio.read(n.resourceId,12e5*t,12e5*(t+1),function(o,s){o?(n.initiateBlockFromLocalData(t,s)?(radio("blockReceivedEvent").broadcast(n.metadata),r.log("successfully initiated block "+t+" from filesystem "+Date.now())):r.log("couldnt verify block "+t+" from filesystem "+Date.now()),i>t?(t++,n.initiateFromLocalData(e,t,i)):(r.info("finished initiating from filesystem"),radio("resumeEnded").broadcast(),e(!0))):r.warn("couldn't initiate block "+t+" from filesystem")}):(r.debug("blockId "+t+" was not in availabilityMap, skipping to next block"),i>t?(t++,n.initiateFromLocalData(e,t,i)):(r.info("finished initiating from filesystem"),radio("resumeEnded").broadcast(),e(!0))):r.core.data.FSio.getResourceDetails(this.resourceId,function(i,o){var s=Math.floor(o.size/12e5);n.availabilityMap.removeBlocksFrom(s+1,function(i){i?n.initiateFromLocalData(e,t,s):r.error("couldn't remove blocks from availability map")})})},initiateBlockFromLocalData:function(e,t){var i=e==this.numOfBlocks-1?this.sizeOfLastBlock:12e5;this.privateBlockMap[e]=new r.core.Block(i);for(var n=0;Math.ceil(t.length/r.config.CHUNK_SIZE)>n;++n)this.privateBlockMap[e].setChunkOn(n);if(this.privateBlockMap[e].verifyBlock(t)){for(this.numOfVerifiedBlocks++;this.has(this.firstMissingBlock);)this.firstMissingBlock++;for(var n=0;Math.ceil(t.length/r.config.CHUNK_SIZE)>n;++n)radio("peer5_received_fs_chunk").broadcast(e*this.numOfChunksInBlock+n,this.resourceId);if(this.availabilityMap.set(e),this.isFull()){var o=this;this.availabilityMap.setFSFull(function(){radio("transferLoadedEvent").broadcast(o.metadata)})}return!0}return delete this.privateBlockMap[e],!1},saveLocally:function(){this.fs?(r.info("saving file via file system api "),this._saveLocallyUsingFSio()):(this._saveLocally(),r.info("saving file without file system api "))},changeResourceId:function(e,t){if(this.fs){var i=this;r.core.data.FSio.renameResource(this.resourceId,e,function(n){n?(i.resourceId=e,i.availabilityMap.renameResource(e,function(e){t(e)})):t(n)})}else this.resourceId=e,t(!0)},getData:function(){for(var e=[],t=0;this.getNumOfBlocks()>t;++t)e.push(this.getBlock(t));var i=new Blob(e,{type:"application/octet-binary"});return i},getBlobUrl:function(e){var t=this;if(this.fs)r.core.data.FSio.createObjectURL(this.resourceId,function(t,i){return t?(e(t,i),void 0):(e(!1),void 0)});else{var i=function(){try{var n=t.getData()}catch(r){"NS_ERROR_OUT_OF_MEMORY"===r.name&&(setTimeout(i,1e4),r.result,radio("outOfMemoryError").broadcast(r.result))}var o=window.URL.createObjectURL(n);e(!0,o)};i()}},getBlob:function(e){this.fs?r.core.data.FSio.getBlob(this.resourceId,0,this.fileSize,e):e(!0,this.getData())},getFileSize:function(){return this.fileSize},allocateFileSize:function(e){var t=this;r.core.data.FSio.write(this.resourceId,new Uint8Array([]),this.fileSize,function(i){i||t._handleOutOfSpaceError(),e(i)})},_registerEvents:function(){var e=this;this._lruRemoveCb=function(t){e._removeBlockData(t)}},_initiateFileSystemDeprecated:function(){var e=this,t=this.resourceId;r.core.data.FSio.requestTempQuota(this.fileSize,function(i,n){i?e.availabilityMap=new r.core.dataStructures.AvailabilityMapFS(e.numOfBlocks,e.resourceId,n,function(i){i?e.availabilityMap.numOfOnFSBits>0?r.core.data.FSio.isExist(t,function(i){i?(r.info("Resource "+t+" exists already in the filesystem."),radio("resumeStarted").broadcast(),e.initiateFromLocalData(function(i){if(i){var o=12e5*(e.numOfBlocks-e.numOfVerifiedBlocks);0==o||n>=o?e._resourceInitedWithFS():(r.info("not enough space, requesting a bigger quota"),r.core.data.FSio.queryTempQuota(function(i,n,s){i?r.core.data.FSio.requestTempQuota(s+e.fileSize,function(i,n){n>=o?e._resourceInitedWithFS():r.config.USE_PERSISTENT?(r.warn("not enough space, trying persistent"),r.core.data.FSio.requestPersQuota(r.config.PERSISTENT_FS_SIZE,function(i,n){i?n>=e.fileSize&&r.core.data.FSio.createResource(t,function(t){t?e._resourceInitedWithFS():(r.warn("failed to create resource in filesystem"),e._fallbackToNoFS())}):(r.warn("failed to alllocate persistent quota"),e._fallbackToNoFS())},e.fileSize)):(r.warn("not enough space in filesystem"),e._fallbackToNoFS())}):(r.warn("couldn't request more quota"),e._fallbackToNoFS())}))}else r.warn("There was a problem initiating from filesystem"),e._fallbackToNoFS()},0)):e.availabilityMap.reset(function(t){t?e._fileNonExistInitiateFS(n):(r.error("couldn't reset the availability map"),e._fallbackToNoFS())})}):e._fileNonExistInitiateFS(n):(r.warn("failed to initiate metadata file"),e._fallbackToNoFS())}):(r.warn("failed to create the filesystem"),e._fallbackToNoFS())})},_fileNonExistInitiateFSDeprecated:function(e){var t=this,i=this.resourceId;r.info("Resource "+i+" doesn't exist in the filesystem."),e>t.fileSize?r.core.data.FSio.createResource(i,function(e){e?t._resourceInitedWithFS():(r.warn("failed to create resource in filesystem"),t._fallbackToNoFS())}):r.core.data.FSio.removeRootDir(function(){r.core.data.FSio.queryTempQuota(function(e,n,o){o-n>t.fileSize?t.availabilityMap=r.core.dataStructures.AvailabilityMapFS(t.numOfBlocks,i,function(e){e?r.core.data.FSio.createResource(i,function(e){e?t._resourceInitedWithFS():(r.warn("failed to create resource in filesystem"),t._fallbackToNoFS())}):(r.warn("failed to initiate metadata file"),t._fallbackToNoFS())}):r.core.data.FSio.requestTempQuota(t.fileSize+n,function(e,n){e&&(n>t.fileSize?t.availabilityMap=new r.core.dataStructures.AvailabilityMapFS(t.numOfBlocks,i,n,function(e){e?r.core.data.FSio.createResource(i,function(e){e?t._resourceInitedWithFS():(r.warn("failed to create resource in filesystem"),t._fallbackToNoFS())}):(r.warn("failed to initiate metadata file"),t._fallbackToNoFS())}):r.config.USE_PERSISTENT?t.availabilityMap=new r.core.dataStructures.AvailabilityMapFS(t.numOfBlocks,i,n,function(e){e?(r.warn("not enough space, trying persistent"),r.core.data.FSio.requestPersQuota(r.config.PERSISTENT_FS_SIZE,function(e,n){e?n>=t.fileSize&&r.core.data.FSio.createResource(i,function(e){e?t._resourceInitedWithFS():(r.warn("failed to create resource in filesystem"),t._fallbackToNoFS())}):(r.warn("failed to alllocate persistent quota"),t._fallbackToNoFS())},t.fileSize)):(r.warn("failed to initiate metadata file"),t._fallbackToNoFS())}):(r.warn("not enough space for the file"),t._fallbackToNoFS()))})})})},_initiateFileSystem:function(){var e=this;r.config.USE_PERSISTENT?r.core.data.FSio.queryPersQuota(function(t,i,n){0!=n?r.core.data.FSio.requestPersQuota(n,function(t,i){t?e._createOrResumeResource(i):(r.warn("couldn't initiate filesystem"),e._fallbackToNoFS())},e.fileSize):e._initiateTempFileSystem()}):this._initiateTempFileSystem()},_initiateTempFileSystem:function(){var e=this;r.core.data.FSio.queryTempQuota(function(t,i,n){e.fileSize>n?r.config.USE_PERSISTENT?r.core.data.FSio.requestPersQuota(r.config.PERSISTENT_FS_SIZE,function(t,i){t?e.availabilityMap=new r.core.dataStructures.AvailabilityMapFS(e.numOfBlocks,e.resourceId,i,function(t){t?r.core.data.FSio.createResource(e.resourceId,function(t){t?e._resourceInitedWithFS():(r.warn("failed to create resource in filesystem"),e._fallbackToNoFS())}):(r.warn("couldn't initiate metadata file"),e._fallbackToNoFS())}):(r.warn("couldn't initiate persistent filesystem"),e._fallbackToNoFS())},e.fileSize):(r.warn("not enough space in temporary storage"),e._fallbackToNoFS()):n-i>e.fileSize?e._createOrResumeResource(n-i):e.fileSize>n-i&&r.core.data.FSio.requestTempQuota(n,function(t,i){t?e.availabilityMap=new r.core.dataStructures.AvailabilityMapFS(e.numOfBlocks,e.resourceId,i,function(t){t&&(e.availabilityMap.numOfOnFSBits>0?r.core.data.FSio.isExist(e.resourceId,function(t){t?(r.info("Resource "+e.resourceId+" exists already in the filesystem."),radio("resumeStarted").broadcast(),e.initiateFromLocalData(function(t){if(t){var n=12e5*(e.numOfBlocks-e.numOfVerifiedBlocks);0==n||i>=n?e._resourceInitedWithFS():r.core.data.FSio.removeAllButThis(e.resourceId,e.availabilityMap.metadataFile,function(t){t?(r.info("succesfully removed all other files in filesystem"),e._resourceInitedWithFS()):(r.warn("couldn't remove files from filesystem"),e._fallbackToNoFS())})}else r.warn("there was a problem resuming the resource"),e._fallbackToNoFS()},0)):e._clearFSAndCreateNewResource()}):e._clearFSAndCreateNewResource())}):(r.warn("couldn't initiate temporary filesystem"),e._fallbackToNoFS())})})},_clearFSAndCreateNewResource:function(){var e=this;r.core.data.FSio.removeRootDir(function(){r.core.data.FSio.queryTempQuota(function(t,i,n){t?n-i>e.fileSize?e.availabilityMap=new r.core.dataStructures.AvailabilityMapFS(e.numOfBlocks,e.resourceId,n-i,function(t){t?r.core.data.FSio.createResource(e.resourceId,function(t){t?e._resourceInitedWithFS():(r.warn("failed to create resource in filesystem"),e._fallbackToNoFS())}):(r.warn("failed to initiate metadata file"),e._fallbackToNoFS())}):(r.warn("not enough space in the filesystem after clearing"),e._fallbackToNoFS()):(r.warn("couldn't query temporary quota"),e._fallbackToNoFS())})})},_createOrResumeResource:function(e){var t=this;t.availabilityMap=new r.core.dataStructures.AvailabilityMapFS(t.numOfBlocks,t.resourceId,e,function(e){e?t.availabilityMap.numOfOnFSBits>0?r.core.data.FSio.isExist(t.resourceId,function(e){e?(r.info("Resource "+t.resourceId+" exists already in the filesystem."),radio("resumeStarted").broadcast(),t.initiateFromLocalData(function(e){e?t._resourceInitedWithFS():(r.warn("there was a problem resuming the resource"),t._fallbackToNoFS())})):t.availabilityMap.reset(function(e){e?r.core.data.FSio.createResource(t.resourceId,function(e){e?t._resourceInitedWithFS():(r.warn("failed to create resource in filesystem"),t._fallbackToNoFS())}):(r.error("couldn't reset the availability map"),t._fallbackToNoFS())})}):r.core.data.FSio.createResource(t.resourceId,function(e){e?t._resourceInitedWithFS():(r.warn("failed to create resource in filesystem"),t._fallbackToNoFS())}):(r.warn("couldn't initiate metadata file"),t._fallbackToNoFS())})},_resourceInitedWithFS:function(){this.fs=!0,radio("filesystemInitiated"+this.resourceId).broadcast(),this.init&&radio("resourceInit").broadcast(this.metadata)},_fallbackToNoFS:function(){this.fs=!1,this.availabilityMap=new r.core.dataStructures.AvailabilityMap(this.numOfBlocks),this.init&&radio("resourceInit").broadcast(this.metadata),radio("filesystemInitiated"+this.resourceId).broadcast()},_removeBlockData:function(e){this.privateBlockMap[e]&&this.privateBlockMap[e].removeBlockData()},_saveLocallyUsingFSio:function(){r.debug("saveLocally called");var e=this;r.core.data.FSio.createObjectURL(this.resourceId,function(t,i){if(t){var n=document.createElement("a");n.setAttribute("download",e.metadata.name),n.setAttribute("href",i),document.body.appendChild(n),n.click()}})},_saveLocally:function(){for(var e=[],t=0;this.getNumOfBlocks()>t;++t)e.push(this.getBlock(t));var i=new Blob(e,{type:"application/octet-binary"});!window.URL&&window.webkitURL&&(window.URL=window.webkitURL);var n=document.createElement("a");n.setAttribute("download",this.metadata.name),n.setAttribute("href",window.URL.createObjectURL(i)),document.body.appendChild(n),n.click()},_handleOutOfSpaceError:function(){r.error("Out of space error"),r.core.data.FSio.removeAll(function(e){e||r.warn("couldn't remove files from offline storage")}),radio("removeResource").broadcast(this.resourceId,r.Request.OUT_OF_SPACE_ERR,"out of space")},_handleWriteError:function(){r.error("offline storage write error"),radio("removeResource").broadcast(this.resourceId,r.Request.WRITE_ERR,"offline storage write error")},calcBlockIdChunkOffset:function(e){var t=Math.floor(e/this.numOfChunksInBlock),i=e%this.numOfChunksInBlock;return{block:t,chunk:i}}})}(),function(){r.core.data.BlockMaps=Object.subClass({ctor:function(){this._blockMaps={},this._keys={}},getRealKeyName:function(e){return this._blockMaps.hasOwnProperty(e)?e:this._keys.hasOwnProperty(e)?this.getRealKeyName(this._keys[e]):!1},alias:function(e,t){this._keys[e]=t},add:function(e,t){this._blockMaps[e]=t},get:function(e){return e=this.getRealKeyName(e),this._blockMaps[e]},remove:function(e){e=this.getRealKeyName(e),delete this._blockMaps[e]},forEach:function(e){for(var t in this._blockMaps)e(t,this._blockMaps[t])}}),r.core.data.BlockCache=new r.core.data.BlockMaps}(),function(){r.core.data.FSio=Object.subClass({ctor:function(){this.writeQueue=new n,this.registerEvents(),this.pendingObjectUrlCb={},this.finishWriteCbs=[]},createResource:function(e,t){r.info("Adding resource "+e+" to the filesystem.");var i=this;this.fs.root.getFile(r.config.FS_ROOT_DIR+e,{create:!0},function(){t&&t(!0)},function(e){i.errorHandler(e,t)})},removeResource:function(e,t){r.log("Removing resource "+e+" from the filesystem.");var i=this;this.fs.root.getFile(r.config.FS_ROOT_DIR+e,{create:!1},function(e){e.remove(function(){t&&t(!0)},function(e){i.errorHandler(e,t)})},function(e){i.errorHandler(e,t)})},renameResource:function(e,t,i){r.info("changing resource name from "+e+" to "+t);var n=this;this.fs.root.getDirectory(r.config.FS_ROOT_DIR,{create:!1},function(o){o.getFile(e,{create:!1},function(e){e.moveTo(o,t,function(e){e&&r.info("succesfully renamed"),i&&i(!0)},function(e){n.errorHandler(e,i)})},function(e){n.errorHandler(e,i)})},function(e){n.errorHandler(e,i)})},write:function(e,t,i,n){t=new Blob([t]),r.debug("Writing to resource "+e),this._writeAvailable()?(this._addWriteCommand(e,t,i,n),this._write(e,t,i,n)):this._addWriteCommand(e,t,i,n)},read:function(e,t,i,n){var o=this;this.fs.root.getFile(r.config.FS_ROOT_DIR+e,{},function(e){e.file(function(e){var r=new FileReader;r.onloadend=function(e){e.target.readyState!=FileReader.DONE||e.target.error||n&&n(!0,new Uint8Array(e.target.result))},r.onerror=function(e){o.errorHandler(e,n)};var s=e.slice(t,i);r.readAsArrayBuffer(s)},function(e){o.errorHandler(e,n)})},function(e){o.errorHandler(e,n)})},getBlob:function(e,t,i,n){var o=this;this.fs.root.getFile(r.config.FS_ROOT_DIR+e,{},function(e){e.file(function(e){var r=e.slice(t,i);n(!0,r)},function(e){o.errorHandler(e,n)})},function(e){o.errorHandler(e,n)})},getResourceDetails:function(e,t){var i=this;this.fs.root.getFile(r.config.FS_ROOT_DIR+e,{},function(e){e.file(function(e){t(!0,{size:e.size})},function(e){i.errorHandler(e,t)})},function(e){i.errorHandler(e,t)})},createObjectURL:function(e,t){var i=this;this.fs.root.getFile(r.config.FS_ROOT_DIR+e,{},function(e){t&&t(!0,e.toURL())},function(e){i.errorHandler(e,t)})},notifyFinishWrite:function(e){0>=this.writeQueue.getLength()?e():this.finishWriteCbs.push(e)},isExist:function(e,t){r.log("Checking if resource "+e+" exists in the filesystem.");var i=this;this.fs.root.getFile(r.config.FS_ROOT_DIR+e,{create:!1},function(){t&&t(!0)},function(e){i.errorHandler(e,t)})},listFiles:function(e){var t=this,i=this.fs.root.createReader();i.readEntries(function(t){t.length?r.debug("Filesystem files: "+t):r.debug("Filesystem is empty"),e(!0,t)},function(i){t.errorHandler(i,e)})},removeAll:function(e){r.warn("removing all files in filesystem");var t=this,i=this.fs.root.createReader();i.readEntries(function(i){for(var n,o=0;n=i[o];++o)n.isDirectory?n.removeRecursively(function(){e&&e(!0)},function(i){t.errorHandler(i,e)}):n.remove(function(){e&&e(!0)},function(i){t.errorHandler(i,e)});r.debug("Directory emptied.")},function(i){t.errorHandler(i,e)})},removeRootDir:function(e){r.warn("removing all files in filesystem under "+r.config.FS_ROOT_DIR);var t=this,i=this.fs.root.createReader();i.readEntries(function(i){for(var n,o=0;n=i[o];++o)n.isDirectory&&n.name+"/"==r.config.FS_ROOT_DIR&&n.removeRecursively(function(){t.fs.root.getDirectory(r.config.FS_ROOT_DIR,{create:!0},function(){e(!0)},function(i){t.errorHandler(i,e)})},function(i){t.errorHandler(i,e)});r.debug("Directory emptied.")},function(i){t.errorHandler(i,e)})},removeAllButThis:function(e,t,i){r.info("removing all files in filesystem under "+r.config.FS_ROOT_DIR+" besides "+e+","+t);var n=this;this.fs.root.getDirectory(r.config.FS_ROOT_DIR,{},function(r){var o=r.createReader();o.readEntries(function(r){for(var o,s=r.length,a=0;o=r[a];++a)o.name!=e&&o.name!=t?o.isDirectory?o.removeRecursively(function(){s--,0===s&&i(!0)},function(e){n.errorHandler(e,i)}):o.remove(function(){s--,0===s&&i(!0)},function(e){n.errorHandler(e,i)}):s--})},function(e){n.errorHandler(e,i)});var n=this,o=this.fs.root.createReader();o.readEntries(function(e){for(var t,o=0;t=e[o];++o)t.isDirectory&&t.name+"/"==r.config.FS_ROOT_DIR&&t.removeRecursively(function(){n.fs.root.getDirectory(r.config.FS_ROOT_DIR,{create:!0},function(){i(!0)},function(e){n.errorHandler(e,i)})},function(e){n.errorHandler(e,i)});r.debug("Directory emptied.")},function(e){n.errorHandler(e,i)})},requestTempQuota:function(e,t){r.info("requesting quota size = "+e);var i=this,n=1.1*e;window.webkitRequestFileSystem(window.TEMPORARY,n,function(e){i.onInitFs(e),i.queryTempQuota(function(e,i,n){t(!0,n-i)})},function(e){i.errorHandler(e,t)})},requestPersQuota:function(e,t){r.info("requesting perma quota size = "+e);var i=this,n=e,o=!1;radio("requestedPersQuota").broadcast(),navigator.webkitPersistentStorage.requestQuota(n,function(e){if(!o){if(o=!0,0===e)return radio("persQuotaAnswer").broadcast(!1),t&&t(!1),void 0;window.webkitRequestFileSystem(window.PERSISTENT,e,function(e){radio("persQuotaAnswer").broadcast(!0),i.onInitFs(e),i.queryPersQuota(function(e,i,n){t(!0,n-i)})},function(e){i.errorHandler(e,t),radio("persQuotaAnswer").broadcast(!1)})}},function(e){i.errorHandler(e,t),radio("persQuotaAnswer").broadcast(!1)}),window.setTimeout(function(){o||(o=!0,t(!1),radio("persQuotaTimeout").broadcast())},r.config.PROMPT_TIMEOUT)},queryTempQuota:function(e){navigator.webkitTemporaryStorage.queryUsageAndQuota(function(t,i){r.info("Using: "+100*(t/i)+"% of temporary storage"),e&&e(!0,t,i)},function(t){r.error("Error",t),e&&e(!1)})},queryPersQuota:function(e){navigator.webkitPersistentStorage.queryUsageAndQuota(function(t,i){r.info("Using: "+100*(t/i)+"% of temporary storage"),e&&e(!0,t,i)},function(t){r.error("Error",t),e&&e(!1)})},_writeAvailable:function(){return this.writeQueue.isEmpty()},_write:function(e,t,i,n){var o=this;this.fs.root.getFile(r.config.FS_ROOT_DIR+e,{create:!1},function(s){s.createWriter(function(s){i>s.length?(r.debug("truncating: filewriter length = "+s.length+" position = "+i),s.truncate(i),o._write(e,t,i,n)):(s.onwriteend=function(t){if(t.currentTarget.error)return o.errorHandler(t.currentTarget.error,n),void 0;if(o.writeQueue.dequeue(),r.debug("onwriteend( "+e+"): writeQueue length = "+o.writeQueue.getLength()),o.writeQueue.isEmpty()){n&&n(!0),r.debug("finished writing all the commands in command queue"),r.debug("writeQueue is empty, pendingObjectUrlCb = "+o.pendingObjectUrlCb[e]),o.pendingObjectUrlCb[e]&&(o.createObjectURL(e,o.pendingObjectUrlCb[e]),delete o.pendingObjectUrlCb[e]);for(var i=0;o.finishWriteCbs.length>i;++i)o.finishWriteCbs[i](e);o.finishWriteCbs=[]}else{n&&n(!0);var s=o.writeQueue.peek();o._write(s.resourceId,s.data,s.position,s.cb)}},s.onerror=function(e){o.errorHandler(e.currentTarget.error)},r.debug("data size = "+t.size+" fileWriter.length = "+s.length+" position = "+i),s.seek(i),s.write(t))},function(e){o.errorHandler(e,n)})},function(e){o.errorHandler(e,n)})},_addWriteCommand:function(e,t,i,n){var r={resourceId:e,data:t,position:i,cb:n};this.writeQueue.enqueue(r)},registerEvents:function(){var e=this;this.onInitFs=function(t){e.fs=t,t.root.getDirectory(r.config.FS_ROOT_DIR,{create:!0},function(){r.info("initiated filesystem")},function(t){e.errorHandler(t),r.warn("failed to create peer5 directory")})},this.errorHandler=function(e,t){var i="";switch(e.name){case"QuotaExceededError":i="QuotaExceededError",t&&t(!1,"space");break;case"NotFoundError":i="NotFoundError",t&&t(!1);break;case"SecurityError":i="SecurityError",t&&t(!1);break;case"InvalidModificationError":i="InvalidModificationError",t&&t(!1);break;case"InvalidStateError":i="InvalidStateError",t&&t(!1);break;default:i="Unknown Error",t&&t(!1)}radio("offlineStorageError").broadcast(i),r.warn("File system error: "+i)}}}),r.core.data.FSio=new r.core.data.FSio}(),function(){r.core.data.FSioFireFox=Object.subClass({ctor:function(){this.writeQueue=new n,this.registerEvents(),this.pendingObjectUrlCb={},this.finishWriteCbs=[],this.db,this.filesObjectStore="files",this.filesMetaData={},this.flushSize=67108864,this.createMainDB(function(e){e?console.log("mainDB created successfuly"):console.log("mainDB creation had error")})},createMainDB:function(e){var t=this,i=window.indexedDB.open(r.config.FS_ROOT_DIR,3);i.onerror=function(i){t.errorHandler(i),e&&e(!1)},i.onupgradeneeded=function(e){e.target.result.createObjectStore(t.filesObjectStore)},i.onsuccess=function(i){t.db=i.target.result,e&&e(!0)}},createResource:function(e,t){r.info("Adding resource "+e+" to the indexedDB.");var i=this,n=i.db.mozCreateFileHandle(e);n.onsuccess=function(){var n=this.result;n.open("readwrite");var r=i.db.transaction([i.filesObjectStore],"readwrite").objectStore(i.filesObjectStore),o=r.add(n,e);o.onsuccess=function(){i.filesMetaData[e]={fileLength:0,appendedSinceLastFlush:0},t&&t(!0)},o.onerror=function(e){i.errorHandler(e),t&&t(!0)}},n.onerror=function(e){i.errorHandler(e),t&&t(!1)}},removeResource:function(e,t){r.log("Removing resource "+e+" from the filesystem.");var i=this,n=i.db.transaction([i.filesObjectStore],"readwrite").objectStore(i.filesObjectStore),o=n["delete"](e);o.onsuccess=function(){delete i.filesMetaData[e],t&&t(!0)},o.onerror=function(e){i.errorHandler(e),t&&t(!1)}},renameResource:function(e,t,i){r.info("changing resource name from "+e+" to "+t);var n=this,o=n.db.transaction([n.filesObjectStore],"readwrite").objectStore(n.filesObjectStore),s=o.get(e);s.onsuccess=function(a){if(!a.target.result)return n.errorHandler({code:"record was not found for key"+e}),i&&i(!1),void 0;var c=s.result;n.db.transaction([n.filesObjectStore],"readwrite").objectStore(n.filesObjectStore);var l=o.add(c,t);n.filesMetaData[t]=n.filesMetaData[e],l.onsuccess=function(){var t=n.db.transaction([n.filesObjectStore],"readwrite").objectStore(n.filesObjectStore),o=t["delete"](e);o.onsuccess=function(){delete n.filesMetaData[e],r.info("succesfully renamed"),i&&i(!0)
  5. },o.onerror=function(e){n.errorHandler(e),i&&i(!1)}},l.onerror=function(e){n.errorHandler(e),i&&i(!1)}},s.onerror=function(e){n.errorHandler(e),i&&i(!1)}},write:function(e,t,i,n){r.debug("Writing to resource "+e),this._writeAvailable()?(this._addWriteCommand(e,t,i,n),this._write(e,t,i,n)):this._addWriteCommand(e,t,i,n)},read:function(e,t,i,n){var r=this,o=r.db.transaction(["files"]),s=o.objectStore("files"),a=s.get(e);a.onsuccess=function(e){if(!e.target.result)return r.errorHandler({code:"record was not found for key"+oldResourceId}),n&&n(!1),void 0;var o=a.result,s=o.open("readwrite");s.location=t;var c=s.readAsArrayBuffer(i-t);c.onsuccess=function(e){n&&n(!0,new Uint8Array(e.target.result))},c.onerror=function(e){r.errorHandler(e),n&&n(!1)}},a.onerror=function(e){r.errorHandler(e),n&&n(!1)}},getBlob:function(){},getResourceDetails:function(e,t){var i=this,n=i.db.transaction([i.filesObjectStore],"readwrite").objectStore(i.filesObjectStore),r=n.get(e);r.onsuccess=function(e){if(!e.target.result)return i.errorHandler({code:"record was not found for key"+oldResourceId}),t&&t(!1),void 0;var n=r.result,o=n.open("readwrite"),s=o.getMetadata();s.onsuccess=function(e){t(!0,{size:e.target.result.size})},s.onerror=function(e){i.errorHandler(e),t&&t(!1)}},r.onerror=function(e){i.errorHandler(e),t&&t(!1)}},createObjectURL:function(e,t){var i=this,n=i.db.transaction([i.filesObjectStore],"readwrite").objectStore(i.filesObjectStore),r=n.get(e);r.onsuccess=function(n){if(!n.target.result)return i.errorHandler({code:"record was not found for key"+oldResourceId}),t&&t(!1),void 0;var o=r.result,s=o.open("readwrite");i.checkAndFlush(s,i,e,function(){s.name;var e=o.getFile();e.onsuccess=function(e){var i=e.target.result;!window.URL&&window.webkitURL&&(window.URL=window.webkitURL),t&&t(!0,URL.createObjectURL(i))},e.onerror=function(e){i.errorHandler(e),t&&t(!1)}},!0)},r.onerror=function(e){i.errorHandler(e),t&&t(!1)}},notifyFinishWrite:function(e){0>=this.writeQueue.getLength()?e():this.finishWriteCbs.push(e)},isExist:function(e,t){r.log("Checking if resource "+e+" exists in the filesystem.");var i=this;try{var n=i.db.transaction([i.filesObjectStore],"readwrite").objectStore(i.filesObjectStore)}catch(o){}if(!n)return t&&t(!1),void 0;var s=n.get(e);s.onsuccess=function(n){if(!n.target.result)return t&&t(!1),void 0;var r=n.target.result,o=r.open("readwrite"),s=o.getMetadata();s.onsuccess=function(n){i.filesMetaData[e]={fileLength:n.target.result.size,appendedSinceLastFlush:0},t&&t(!0)},s.onerror=function(e){i.errorHandler(e),t&&t(!1)}},s.onerror=function(e){i.errorHandler(e),t&&t(!1)}},listFiles:function(e){var t=this,i=t.db.transaction([t.filesObjectStore],"readwrite").objectStore(t.filesObjectStore),n=!0;i.openCursor().onsuccess=function(t){var i=[],o=t.target.result;n&&!o&&r.debug("Filesystem is empty"),o?(n=!1,i.push(o.key),o["continue"]()):(e(!0,i),alert("No more entries!"))}},removeAll:function(e){this.db.close(),window.indexedDB.deleteDatabase(r.config.FS_ROOT_DIR),this.createMainDB(function(t){t?e&&e(!0):e&&e(!1)})},removeAllNew:function(){var e=this,t=e.db.transaction([e.filesObjectStore],"readwrite"),i=t.objectStore(e.filesObjectStore).clear();i.onsuccess=function(){console.log("Filesystem is empty")},i.onerror=function(){console.log("removeAll() failed")}},removeDep:function(e){r.warn("removing all files in filesystem");var t=this,i=t.db.transaction([t.filesObjectStore],"readwrite").objectStore(t.filesObjectStore),n=!0;i.openCursor().onsuccess=function(o){var s=o.target.result;if(n&&!s&&r.debug("Filesystem is empty"),s){n=!1;var a=i["delete"](s.key);a.onsuccess=function(){t.filesMetaData[s.key]&&delete t.filesMetaData[s.key],s["continue"]()},a.onerror=function(){e&&e(!1)}}else r.debug("Directory emptied."),e&&e(!0)}},removeRootDir:function(e){this.removeAll(e)},requestPersQuota:function(e,t,i){var n=this;n.isExist("confirmed_persistent",function(e){if(e)return t(!0,r.config.PERSISTENT_FS_SIZE),void 0;if(r.config.ALLOWED_FILE_SIZE>=i)return t(!1,0),void 0;radio("requestedPersQuota").broadcast();var o,s=(new Date).getTime()+100,a=window.indexedDB.open(s,1),c=!1;a.onerror=function(){console.log("Error obtaining quota, retrying..."),t(!1,0)},a.onsuccess=function(){o=a.result,a.getquota()},a.onupgradeneeded=function(e){e.target.result.createObjectStore(s)},a.getquota=function(){var e=o.transaction(s,"readwrite");e.oncomplete=function(){o.close(),window.indexedDB.deleteDatabase(s),n.createResource("confirmed_persistent",function(e){if(!c){if(c=!0,!e)return t(!1,0),void 0;radio("persQuotaAnswer").broadcast(!0),t(!0,r.config.PERSISTENT_FS_SIZE)}},!0)},e.onerror=function(){return c?void 0:(c=!0,radio("persQuotaAnswer").broadcast(!1),o.close(),window.indexedDB.deleteDatabase(s),t(!1,0),void 0)},e.objectStore(s).put(new Blob([new ArrayBuffer(62914560)]),"quota"),window.setTimeout(function(){c||(e.oncomplete=function(){},e.onerror=function(){},radio("persQuotaTimeout").broadcast(),o.close(),window.indexedDB.deleteDatabase(s),t(!1,0))},r.config.PROMPT_TIMEOUT)}})},requestTempQuota:function(){r.warn("requestTempQuota shouldn't be called in firefox")},queryPersQuota:function(e){this.isExist("confirmed_persistent",function(t){return t?(e(!0,0,r.config.PERSISTENT_FS_SIZE),void 0):(e(!1,0,0),void 0)})},queryTempQuota:function(e){e(!1,0,0)},_writeAvailable:function(){return this.writeQueue.isEmpty()},_write_dep:function(e,t,i,n){var o=this,s=window.indexedDB.open(r.config.FS_ROOT_DIR,3);s.onerror=function(e){o.errorHandler(e),n&&n(!1)},s.onsuccess=function(){o.db=s.result;var a=o.db.transaction([o.filesObjectStore],"readwrite").objectStore(o.filesObjectStore),c=a.get(e);c.onsuccess=function(s){if(!s.target.result)return o.errorHandler({code:"record was not found for key"+oldResourceId}),n&&n(!1),void 0;var a=c.result,l=a.open("readwrite"),d=l.getMetadata();d.onsuccess=function(s){var c=s.target.result.size;if(i>c){r.debug("truncating: filewriter length = "+s.target.result.size+" position = "+i);var l=new FileReader;l.onload=function(t){var s=t.target.result,l=a.open("readwrite");l.oncomplete=function(){if(o.writeQueue.dequeue(),r.debug("onwriteend( "+e+"): writeQueue length = "+o.writeQueue.getLength()),o.writeQueue.isEmpty()){n&&n(!0),r.debug("finished writing all the commands in command queue"),r.debug("writeQueue is empty, pendingObjectUrlCb = "+o.pendingObjectUrlCb[e]),o.pendingObjectUrlCb[e]&&(o.createObjectURL(e,o.pendingObjectUrlCb[e]),delete o.pendingObjectUrlCb[e]);for(var t=0;o.finishWriteCbs.length>t;++t)o.finishWriteCbs[t](e);o.finishWriteCbs=[]}else{n&&n(!0);var i=o.writeQueue.peek();o._write(i.resourceId,i.data,i.position,i.cb)}};for(var d=i-c,u=0,h=new ArrayBuffer(1048576);d>u;)1048576>d-u&&(h=new ArrayBuffer(d-u)),u+=1048576,l.append(h);var f=l.append(s);f.onerror=function(e){o.errorHandler(e),n&&n(!1)}},l.readAsArrayBuffer(t)}else{var l=new FileReader;l.onload=function(t){var s=t.target.result,c=a.open("readwrite");c.location=i;var l=c.write(s);if(l||0!=i||0!=s.byteLength)l.onsuccess=function(){var t=c.flush();t.onsuccess=function(){if(o.writeQueue.dequeue(),r.debug("onwriteend( "+e+"): writeQueue length = "+o.writeQueue.getLength()),o.writeQueue.isEmpty()){n&&n(!0),r.debug("finished writing all the commands in command queue"),r.debug("writeQueue is empty, pendingObjectUrlCb = "+o.pendingObjectUrlCb[e]),o.pendingObjectUrlCb[e]&&(o.createObjectURL(e,o.pendingObjectUrlCb[e]),delete o.pendingObjectUrlCb[e]);for(var t=0;o.finishWriteCbs.length>t;++t)o.finishWriteCbs[t](e);o.finishWriteCbs=[]}else{n&&n(!0),r.debug("onwriteend: writeQueue is not empty, writing another command");var i=o.writeQueue.peek();o._write(i.resourceId,i.data,i.position,i.cb)}},t.onerror=function(e){o.errorHandler(e),n&&n(!1)}},l.onerror=function(e){o.errorHandler(e),n&&n(!1)};else if(o.writeQueue.dequeue(),r.debug("onwriteend( "+e+"): writeQueue length = "+o.writeQueue.getLength()),n&&n(!0),o.writeQueue.isEmpty()){r.debug("finished writing all the commands in command queue"),r.debug("writeQueue is empty, pendingObjectUrlCb = "+o.pendingObjectUrlCb[e]),o.pendingObjectUrlCb[e]&&(o.createObjectURL(e,o.pendingObjectUrlCb[e]),delete o.pendingObjectUrlCb[e]);for(var d=0;o.finishWriteCbs.length>d;++d)o.finishWriteCbs[d](e);o.finishWriteCbs=[]}else{var u=o.writeQueue.peek();o._write(u.resourceId,u.data,u.position,u.cb)}},l.readAsArrayBuffer(t)}},d.onerror=function(e){o.errorHandler(e),n&&n(!1)}},c.onerror=function(e){o.errorHandler(e),n&&n(!1)}}},_write_no_flush:function(e,t,i,n){var o=this,s=window.indexedDB.open(r.config.FS_ROOT_DIR,3);s.onerror=function(e){o.errorHandler(e),n&&n(!1)},s.onsuccess=function(){o.db=s.result;var a=o.db.transaction([o.filesObjectStore],"readwrite").objectStore(o.filesObjectStore),c=a.get(e);c.onsuccess=function(s){if(!s.target.result)return o.errorHandler({code:"record was not found for key"+oldResourceId}),n&&n(!1),void 0;var a=c.result,l=a.open("readwrite"),d=l.getMetadata();d.onsuccess=function(s){var c=s.target.result.size;if(i>c){r.debug("truncating: filewriter length = "+s.target.result.size+" position = "+i);var l=a.open("readwrite"),d=i-c;o.appendZerosBeforeRealData(l,e,d,t.buffer,!1,n,function(){o.performAfterWriteOperations(e,n)})}else{var l=a.open("readwrite");l.location=i;var u=l.write(t.buffer);if(!u&&0==i&&0==t.buffer.byteLength)return o.performAfterWriteOperations(e,n),void 0;u.onsuccess=function(){o.performAfterWriteOperations(e,n)},u.onerror=function(e){o.errorHandler(e),n&&n(!1)}}},d.onerror=function(e){o.errorHandler(e),n&&n(!1)}},c.onerror=function(e){o.errorHandler(e),n&&n(!1)}}},_write:function(e,t,i,n){var o=this,s=o.db.transaction([o.filesObjectStore],"readwrite").objectStore(o.filesObjectStore),a=s.get(e);a.onsuccess=function(s){if(!s.target.result)return o.errorHandler({code:"record was not found for key"+oldResourceId}),n&&n(!1),void 0;var c=a.result,l=c.open("readwrite");if(o.filesMetaData[e]){var d=o.filesMetaData[e].fileLength;if(o.filesMetaData[e].fileLength=Math.max(d,i+t.buffer.byteLength),i>d){r.debug("truncating: filewriter length = "+s.target.result.size+" position = "+i);var l=c.open("readwrite"),u=i-d;o.appendZerosBeforeRealData(l,e,u,t.buffer,!1,n,function(){o.performAfterWriteOperations(e,n)})}else{var l=c.open("readwrite");l.location=i;var h=l.write(t.buffer);if(!h&&0==t.buffer.byteLength)return o.performAfterWriteOperations(e,n),void 0;h.onsuccess=function(){o.filesMetaData[e].appendedSinceLastFlush+=t.buffer.byteLength,o.performAfterWriteOperations(e,n),o.checkAndFlush(l,o,e,function(e){e||console.log("checkAndFlush error")},!1)},h.onerror=function(e){o.errorHandler(e),n&&n(!1)}}}else;},a.onerror=function(e){o.errorHandler(e),n&&n(!1)}},performAfterWriteOperations:function(e,t){var i=this;if(i.writeQueue.dequeue(),r.debug("onwriteend( "+e+"): writeQueue length = "+i.writeQueue.getLength()),i.writeQueue.isEmpty()){t&&t(!0),r.debug("finished writing all the commands in command queue"),r.debug("writeQueue is empty, pendingObjectUrlCb = "+i.pendingObjectUrlCb[e]),i.pendingObjectUrlCb[e]&&(i.createObjectURL(e,i.pendingObjectUrlCb[e]),delete i.pendingObjectUrlCb[e]);for(var n=0;i.finishWriteCbs.length>n;++n)i.finishWriteCbs[n](e);i.finishWriteCbs=[]}else{t&&t(!0),r.debug("onwriteend: writeQueue is not empty, writing another command");var o=i.writeQueue.peek();i._write(o.resourceId,o.data,o.position,o.cb)}},_addWriteCommand:function(e,t,i,n){var r={resourceId:e,data:t,position:i,cb:n};this.writeQueue.enqueue(r)},appendZerosBeforeRealData:function(e,t,i,n,r,o,s){var a=this;if(r)if(n.byteLength>0){var c=e.append(n);c.onsuccess=function(){a.filesMetaData[t].appendedSinceLastFlush+=n.byteLength,s&&s()},c.onerror=function(){o&&o(!1)}}else s&&s();else if(i>=67108864){var l=e.append(new ArrayBuffer(67108864));l.onsuccess=function(){var r=e.flush();r.onsuccess=function(){a.appendZerosBeforeRealData(e,t,i-67108864,n,!1,o,s)},r.onerror=function(){}},l.onerror=function(e){"The operation failed for reasons unrelated to the file storage itself and not covered by any other error code."==e.target.error.message&&"UnknownError"==e.target.error.name?o&&o(!1,"space"):o&&o(!1)}}else if(i>0){var d=e.append(new ArrayBuffer(i));d.onsuccess=function(){if(a.filesMetaData[t].appendedSinceLastFlush+=i,a.filesMetaData[t].appendedSinceLastFlush>a.flushSize){var r=e.flush();r.onsuccess=function(){a.appendZerosBeforeRealData(e,t,0,n,!0,o,s)},r.onerror=function(){}}else a.appendZerosBeforeRealData(e,t,0,n,!0,o,s)},d.onerror=function(){o&&o(!1)}}else a.appendZerosBeforeRealData(e,t,0,n,!0,o,s)},checkAndFlush:function(e,t,i,n,r){if(t.filesMetaData[i].appendedSinceLastFlush>t.flushSize||r){var o=e.flush();o.onsuccess=function(){t.filesMetaData[i].appendedSinceLastFlush=0,n&&n(!0)},o.onerror=function(){console.log("flush error in checkAndFlush function")}}else n&&n(!0)},registerEvents:function(){this.errorHandler=function(e){var t="";switch(e.code){default:t=e}radio("offlineStorageError").broadcast(t),r.warn("File system error: "+t)}}})}(),function(){function e(){s+=Math.round(2*Math.random()-1),document.querySelector(".peer5_users_counter").innerText=s}r.download=function(e,i){if(i||(i={}),!e)return r.error("Empty URL"),!1;var n=document.createElement("a");if(n.href=e,e=n.href,i.name=i.name?""+i.name:decodeURI(e.substr(e.lastIndexOf("/")+1).split("?")[0].split("#")[0]),i.onFallback&&"function"!=typeof i.onFallback&&(r.warn("options.onFallback is not a function - ignoring"),i.onFallback=null),i.onDownloadComplete&&"function"!=typeof i.onDownloadComplete&&(r.warn("options.onDownloadComplete is not a function - ignoring"),i.onDownloadComplete=null),i.sig){if("[object String]"!=Object.prototype.toString.call(i.sig))return r.error("options.sig contains invalid characters"),!1}else i.sig=null;var o=t[e];if(o)r.warn(e+" was already existed in the filewrappers"),o.download();else{var s=new r.client.downloader.FileWrapper(e,i);s.download(),t[e]=s}},r.stopDownload=function(e){t[e].stop()},r.exitDownload=function(e){t[e].exit(),delete t[e]};var t={},i=function(){r.core.util.envokeCallback(n,[]),radio("beforeUnload").broadcast();for(var e in t)if(t[e].started&&!t[e].completed&&!t[e].fallback)return"Download in progress. Closing this tab will stop the download."},n=window.onbeforeunload;if(window.onbeforeunload=i,r.client.downloader.FileWrapper=Object.subClass({name:"peer5.client.downloader.FileWrapper",ctor:function(e,t){this.completed=!1,this.started=!1,this.fallback=!1,this.ui=null,this.url=e,this.swarmId=null,t.name&&(this.filename=t.name),this.options=t||{};var i=this.options.container;i||(i=document.body)},download:function(){var e=this;this.isEnabled(function(){e._download()},function(){r.warn("Downloader isEnabled returned false"),e.regularDownload()})},_download:function(){function e(e){var t="attachment; filename=";if(-1==e.indexOf(t))return null;var i=e.replace(t,"");return i.substring(1,i.length-1)}function t(){n.started||(n.started=!0);var e={name:n.options.name,displayOverlayOnLoad:n.options.displayOverlayOnLoad};n.options.container||(e.floating=!0),n.ui||(n.ui=new r.client.downloader.FileUI(n.url,n.options.container),n.ui.enableUI(n.filename,e),n.registerHTTPEvents(),n.registerFSEvents(),n.registerP2PEvents())}function i(e){var t=Math.ceil(e/r.config.CHUNK_SIZE);n.ui.setNumOfChunks(t)}var n=this,o=new r.Request;o.onreadystatechange=function(){if(!n.options.disableUI){if(!n.swarmId&&this.readyState>=2){var t=this.getFileInfo();i(t.size),n.swarmId=t.swarmId;try{var o=e(this.getResponseHeader("content-disposition")),s=decodeURIComponent(o);o&&s&&(n.filename=s)}catch(a){r.info("content-disposition is not found")}}3==this.readyState&&n.ui.createPause()}},o.open("GET",this.url),t(),o.onprogress=function(){},o.onload=function(e){n.completed=!0,n.ui&&(n.ui.displayCompleted(),n.deregisterEvents()),radio("downloadFinished").broadcast(n.url,e.total,e.loadedP2P,e.loadedHTTP,e.loadedFS),setTimeout(function(){radio("seeding").broadcast(5e3),setTimeout(function(){radio("seeding").broadcast(3e4),setTimeout(function(){radio("seeding").broadcast(3e5)},27e4)},25e3)},5e3),!window.URL&&window.webkitURL&&(window.URL=window.webkitURL);var t=document.createElement("a");t.setAttribute("download",n.filename),t.setAttribute("href",this.response),document.body.appendChild(t),t.click(),r.config.IS_FIREFOX&&r.core.data.BlockCache.get(n.url).fs&&alert("Thanks for downloading!"),n.options.onDownloadComplete&&n.options.onDownloadComplete()},o.onerror=function(e){r.error(e),n.ui&&n.ui.showError(),n.options.onFallback?n.options.onFallback():(r.warn("FileWrapper Fallbacking to normal download"),n.regularDownload()),n.fallback=!0,radio("fallback").broadcast(this.status)},o.onswarmstatechange=function(e){e.hasOwnProperty("numOfPeers")&&n.ui.changeNumOfsources(e.numOfPeers)},o.send(),this.request=o},stop:function(){r.warn("download stopped "+this.url),this.request.abort()},isEnabled:function(e,t){r.getCompatibilityStatus(function(i,n){if(i.length>0&&702!=i[0])return t(),void 0;switch(n){case"chrome":if(r.config.DISABLE_CHROME)return t(),void 0;break;case"opera":if(r.config.DISABLE_OPERA)return t(),void 0;break;case"firefox":if(r.config.DISABLE_FIREFOX)return t(),void 0}e()})},exit:function(){r.warn("download exited "+this.url),this.ui&&this.ui.removeUI(),this.request.abort({leaveSwarm:!0}),this.dtor(),radio("exitDownload").broadcast(this.completed)},regularDownload:function(){!window.URL&&window.webkitURL&&(window.URL=window.webkitURL);var e=document.createElement("a");if(e.setAttribute("download",this.options.name),e.setAttribute("href",this.url),document.body.appendChild(e),e.click)e.click();else{var t="hiddenDownloader",i=document.getElementById(t);null===i&&(i=document.createElement("iframe"),i.id=t,i.style.display="none",document.body.appendChild(i)),i.src=this.url}},deregisterEvents:function(){},registerHTTPEvents:function(){var e=this;radio("peer5_received_http_chunk").subscribe(function(t,i){i==e.url&&e.ui.paint_http(t,1)}),radio("peer5_pending_http_chunk").subscribe(function(t,i){i!=e.url}),radio("peer5_waste_http_chunk").subscribe(function(t,i){i!=e.url}),radio("peer5_state_updated").subscribe(function(t,i){i==e.url&&e.ui.updateAvgs(t)}),radio("transferFinishedEvent").subscribe([function(t){(e.url===t.url||e.swarmId===t.swarmId)&&this.ui.displayVerifying()},this])},registerFSEvents:function(){var e=this;radio("peer5_received_fs_chunk").subscribe(function(t,i){i==e.swarmId&&e.ui.paint_fs(t,1)})},registerP2PEvents:function(){var e=this;radio("peer5_new_p2p_chunk").subscribe(function(t,i,n){e.swarmId&&i==e.swarmId&&e.ui.paint_p2p(t,1,n)}),radio("peer5_p2p_pending_chunk").subscribe(function(t,i,n){e.swarmId&&i==e.swarmId&&e.ui.paint_p2p(t,1,n)}),radio("peer5_waste_p2p_chunk").subscribe(function(t,i,n){e.swarmId&&i==e.swarmId&&e.ui.paint_waste_p2p(t,1,n)})},dtor:function(){this.url=null,this.options=null,this.request=null}}),document.querySelector(".peer5_users_counter")){var o=1e3,s=14*o+920;window.setInterval(e,500),e()}}(),function(){var e="#428bca";r.client.downloader.FileUI=Object.subClass({name:"peer5.client.downloader.FileUI",dispSpeed:0,div_left:"",peer5_dl_float:"",helpDisplay:"none",buttonsdiv:"",newDispSpeed:409600+1024*100*Math.random(),ctor:function(t,i){this.url=t,this.container=i,this.container||(this.container=document.body),this.mainDiv=null,this.chunks_area_style="",this.http_color=e,this.fs_color=e,this.waste_color=e,this.opacity=1,this.height=20,this.canvas=null,this.chunks_in_block=12e5/r.config.CHUNK_SIZE,this.p=!1,this.paused=!0,this.colors=[e],this.numOfPeers=0},get_color:function(e){return this.colors[e.charCodeAt(0)%this.colors.length]},setNumOfChunks:function(e){this.num_of_chunks=e},initCanvas:function(){this.canvas&&(this.canvas.getContext("2d"),this.canvas.bg||(this.canvas.bg=!0,this.height?(this.canvas.height=this.height,this.canvas.style.height=this.height+"px"):(this.canvas.height=parseInt(document.defaultView.getComputedStyle(this.canvas).height.replace("px","")),this.height=this.canvas.height),this.canvas.width=this.canvas_width,this.canvas.style.width=this.canvas_width+"px"))},paint_fs:function(e,t){this.paint(e,t,this.fs_color)},paint_http:function(e,t){this.paint(e,t,this.http_color)},paint_p2p:function(e,t,i){this.paint(e,t,i)},paint_waste_p2p:function(e,t){this.paint(e,t,this.waste_color)},paint_waste_http:function(e,t){this.paint(e,t,this.waste_color)},paint:function(e,t,i){var n="#"==i.charAt(0)?i:this.get_color(i);if(this.canvas){var r=this.canvas.getContext("2d"),o=this.num_of_chunks/this.chunks_in_block,s=Math.floor(e/this.chunks_in_block),a=this.canvas_width/o,c=this.height/this.chunks_in_block,l=s,d=e-s*this.chunks_in_block;r.globalAlpha=t,r.fillStyle=n,1>c&&(c=1),r.fillRect(l*a,d*c,a,c)}},enableUI:function(e,t){t||(t={}),t.displayOverlayOnLoad&&(this.helpDisplay="block"),t.floating&&(this.peer5_dl_float=" peer5-dl-float",this.buttonsdiv='<div  class="peer5-dl peer5-control" > <!--<span>?</span>--> <!--<span>_</span>--> <button class="peer5-dl peer5_close_button" url="'+this.url+'" onclick="peer5.exitDownload(this.getAttribute(\'url\'))">X</button></div>'),this.div_left='<div class="peer5-dl peer5-dl-left"> <svg x="0px" y="0px" width="130px" height="130px" viewBox="0 0 512 512" enable-background="new 0 0 512 512" xml:space="preserve"> <path id="download-2-icon" d="M333.816,231.323h66.258L255.998,375.645L111.926,231.323h66.256V50h155.635V231.323z M375.236,346.828V412H136.764v-65.172h-50V462h338.473V346.828H375.236z" /> <animate attributeName="opacity" values="0.85;1;0.85" dur="2s" repeatCount="indefinite" /> </svg></div>',t.chunks_area_style&&(this.chunks_area_style='style="'+t.chunks_area_style+'"'),location.hash.indexOf("visual")>0&&(this.colors=["#3491E3","#2871B0","#1D507D","#62A7E3","#8FBCE3","#4F677D"],this.http_color="#111111",this.fs_color="#555555",this.waste_color="#FFFFFF",this.opacity=1,this.height=100,i=this,radio("peer5_pending_http_chunk").subscribe(function(e){i.paint_http(e,.5)}),radio("peer5_p2p_pending_chunk").subscribe(function(e,t,n){i.paint_p2p(e,.5,n)}));var i=this;r.clientInstance.getClientId(function(t){i.init(t,e),location.hash.indexOf("visual")>0&&(i.percentage_label.style.borderColor=i.get_color(t))})},pauseClicked:function(){radio("pauseClicked").broadcast(),r.stopDownload(this.url),this.createPlay()},playClicked:function(){radio("playClicked").broadcast(),r.download(this.url)},createPlay:function(){this.paused=!0;var e,t=this;this.pauseplayPrevChild?e=this.pauseplayPrevChild:(e=document.createElement("button"),e.setAttribute("class","peer5-dl peer5_play"),e.setAttribute("url",t.url),e.addEventListener("click",function(){t.playClicked()})),this.pauseplayPrevChild=this.pauseplay.childNodes.length?this.pauseplay.removeChild(this.pauseplay.childNodes[0]):null,this.pauseplay.appendChild(e),this.rateDiv_label.textContent=" ",this.metric_label.textContent=" ",this.eta_label.textContent="Paused"},createPause:function(){this.paused=!1;var e,t=this;this.pauseplayPrevChild?e=this.pauseplayPrevChild:(e=document.createElement("button"),e.setAttribute("title","Pause download"),e.setAttribute("class","peer5-dl peer5_pause"),e.setAttribute("url",t.url),e.addEventListener("click",function(){t.pauseClicked()})),this.pauseplayPrevChild=this.pauseplay.childNodes.length?this.pauseplay.removeChild(this.pauseplay.childNodes[0]):null,this.pauseplay.appendChild(e)},init:function(t,i){this.get_color(t);var n=document.createElement("style");n.innerHTML=" .peer5-dl { padding: 0 !important; margin: 0 !important; font-family: Arial, Helvetica, sans-serif !important; } .peer5-dl-float { z-index: 1337; padding: 10px !important; border: solid #ccc 1px; background-color: #FFFFFF; box-shadow: 0 4px 16px rgba(0,0,0,.2); #6C6B6B; width:750px; left: 50%; top: 30%; margin-left: -375px !important; position: fixed; }"+(this.peer5_dl_float?" ":" .peer5-dl-main {position: relative;}")+" .peer5_stats_canvas { height: 5px; border-top: #555 solid 1px; border-radius: 1px; }"+" .peer5_stats { font-family: courier !important; color: green; background: rgba(0,0,0,0.85); }"+" .stat_font { color: #050505; font-size: 16px; } "+" .stat_area { border: 0px #DDDDDD solid; } "+" .peer5_header { overflow: hidden; text-align: right; line-height: 45px !important; }"+" .peer5_header a {text-decoration: none !important; font-size: 13px; color:"+e+"; font-weight: bold; }"+" .peer5_header a:hover { text-decoration: underline !important; }"+" .peer5_logo { display: inline-block; padding-left:13px !important; font-size: 15px; vertical-align: middle; }"+" .peer5_share { display: inline-block; padding-left:15px !important; vertical-align: middle; }"+" .peer5_help_button { display: inline-block; padding-left:15px !important; vertical-align: middle; }"+" .peer5_filename { float: left; text-align: left; font-size: 25px; color: "+e+"; overflow: hidden; text-overflow: ellipsis; white-space:nowrap; vertical-align: middle; }"+" .peer5-dl div { cursor:default } "+" .peer5_info { float:right; display:none }"+" .peer5_info_button { background: no-repeat url(//api.peer5.com/downloader/buttons/i_b.png) 0px 0px ; float:left;   width: 30px; height: 27px;        }"+" .peer5_play { background: no-repeat url(data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAB0AAAAdCAYAAABWk2cPAAAAGXRFWHRTb2Z0d2FyZQBBZG9iZSBJbWFnZVJlYWR5ccllPAAAA2ZpVFh0WE1MOmNvbS5hZG9iZS54bXAAAAAAADw/eHBhY2tldCBiZWdpbj0i77u/IiBpZD0iVzVNME1wQ2VoaUh6cmVTek5UY3prYzlkIj8+IDx4OnhtcG1ldGEgeG1sbnM6eD0iYWRvYmU6bnM6bWV0YS8iIHg6eG1wdGs9IkFkb2JlIFhNUCBDb3JlIDUuMC1jMDYwIDYxLjEzNDc3NywgMjAxMC8wMi8xMi0xNzozMjowMCAgICAgICAgIj4gPHJkZjpSREYgeG1sbnM6cmRmPSJodHRwOi8vd3d3LnczLm9yZy8xOTk5LzAyLzIyLXJkZi1zeW50YXgtbnMjIj4gPHJkZjpEZXNjcmlwdGlvbiByZGY6YWJvdXQ9IiIgeG1sbnM6eG1wTU09Imh0dHA6Ly9ucy5hZG9iZS5jb20veGFwLzEuMC9tbS8iIHhtbG5zOnN0UmVmPSJodHRwOi8vbnMuYWRvYmUuY29tL3hhcC8xLjAvc1R5cGUvUmVzb3VyY2VSZWYjIiB4bWxuczp4bXA9Imh0dHA6Ly9ucy5hZG9iZS5jb20veGFwLzEuMC8iIHhtcE1NOk9yaWdpbmFsRG9jdW1lbnRJRD0ieG1wLmRpZDpENzA2OThCNjA3MjA2ODExOTk0QzgzNzg2NTRFNEFGRSIgeG1wTU06RG9jdW1lbnRJRD0ieG1wLmRpZDoyODY2MzkxRTkwQ0IxMUUzQTkzMEIwNEVCMzZBRkQwOCIgeG1wTU06SW5zdGFuY2VJRD0ieG1wLmlpZDoyODY2MzkxRDkwQ0IxMUUzQTkzMEIwNEVCMzZBRkQwOCIgeG1wOkNyZWF0b3JUb29sPSJBZG9iZSBQaG90b3Nob3AgQ1M1IE1hY2ludG9zaCI+IDx4bXBNTTpEZXJpdmVkRnJvbSBzdFJlZjppbnN0YW5jZUlEPSJ4bXAuaWlkOjYyOTMyODA0MTUyMDY4MTE5QzA3RTc3QjQ2RTREOTMzIiBzdFJlZjpkb2N1bWVudElEPSJ4bXAuZGlkOkQ3MDY5OEI2MDcyMDY4MTE5OTRDODM3ODY1NEU0QUZFIi8+IDwvcmRmOkRlc2NyaXB0aW9uPiA8L3JkZjpSREY+IDwveDp4bXBtZXRhPiA8P3hwYWNrZXQgZW5kPSJyIj8+sDw0VwAAAmVJREFUeNrcl19km1EYxpNswm7S3owuoddVSsm2GmNkUqWRCa3SytXI7GpUu8vOxphlN7sao1e13bQSi1ZLrHpX1YZq6G1pZQthbRkjVPa8POHLyXe+c7LExg4/r7bne57z/33rbzQavr/dAr5/0K7bdHr4bj+IEAdJEAUDIAIqoApKoACKXxfu1E16fq/lhdk1hMfgJY1MTQbwAizD/KpjUxgOInwBo/zVtsyEVDnLCAcTJzH2PQSPYHxqbQpDWcJ1Cu6CD2BFN3KIN79LIzwF9ziwBP5WMh4kfCij36RhHkx4GSrmK+yf5/eb1NPPlAdmj0u6BqYtzdxWaxVhiks95jxg6kyf0VCWNNPlzchQZ5S67cuLkd1AmOePb8B5N46Y2Tl1pC1Sv22mk9yHIu+crn0CfZbGBerdpL6rqbQNg9YMOAIPLCe9oei3mEYd99Gr/QRyh3fAWxA09C8y3nUzHWQ862DrFsEB9mvEo883xoibaXOfLjo8M2K4B+N5zb5eKPotppeM/QYTtwddTmZa85z2K/otphXGsMH0l8vPz8FtTf+wot+S2uSNHObDfWy5tHJInmAJTzz6xBz6bTMtqEfbo9XAHBgHJ4a+SfUqBpT7VHMka137CIbAZ4vkn6RezfngBBynTPYm67gKIY3Wa/DDwjBEHWlZ6rs++O9BGdyX7N/lg79MnTJ13fMp00+CyyFpKecxY+0MQY7f15jI655JnCVGgpk/BbbArKXhLPunHJXDaa9qJHnavoNbvIfd10hKNSjJeKmDavCVnPA/qgYNdW+zCmxWhb2re/+rfyt+CzAAj93Yyv4S+cYAAAAASUVORK5CYII=); 0px 0px ; float:left;   width: 30px; height: 27px;        }"+" .peer5_pause { background: no-repeat url(data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAB0AAAAdCAYAAABWk2cPAAAAGXRFWHRTb2Z0d2FyZQBBZG9iZSBJbWFnZVJlYWR5ccllPAAAA2ZpVFh0WE1MOmNvbS5hZG9iZS54bXAAAAAAADw/eHBhY2tldCBiZWdpbj0i77u/IiBpZD0iVzVNME1wQ2VoaUh6cmVTek5UY3prYzlkIj8+IDx4OnhtcG1ldGEgeG1sbnM6eD0iYWRvYmU6bnM6bWV0YS8iIHg6eG1wdGs9IkFkb2JlIFhNUCBDb3JlIDUuMC1jMDYwIDYxLjEzNDc3NywgMjAxMC8wMi8xMi0xNzozMjowMCAgICAgICAgIj4gPHJkZjpSREYgeG1sbnM6cmRmPSJodHRwOi8vd3d3LnczLm9yZy8xOTk5LzAyLzIyLXJkZi1zeW50YXgtbnMjIj4gPHJkZjpEZXNjcmlwdGlvbiByZGY6YWJvdXQ9IiIgeG1sbnM6eG1wTU09Imh0dHA6Ly9ucy5hZG9iZS5jb20veGFwLzEuMC9tbS8iIHhtbG5zOnN0UmVmPSJodHRwOi8vbnMuYWRvYmUuY29tL3hhcC8xLjAvc1R5cGUvUmVzb3VyY2VSZWYjIiB4bWxuczp4bXA9Imh0dHA6Ly9ucy5hZG9iZS5jb20veGFwLzEuMC8iIHhtcE1NOk9yaWdpbmFsRG9jdW1lbnRJRD0ieG1wLmRpZDpENzA2OThCNjA3MjA2ODExOTk0QzgzNzg2NTRFNEFGRSIgeG1wTU06RG9jdW1lbnRJRD0ieG1wLmRpZDoyODY2MzkxQTkwQ0IxMUUzQTkzMEIwNEVCMzZBRkQwOCIgeG1wTU06SW5zdGFuY2VJRD0ieG1wLmlpZDoyODYyNUUxMjkwQ0IxMUUzQTkzMEIwNEVCMzZBRkQwOCIgeG1wOkNyZWF0b3JUb29sPSJBZG9iZSBQaG90b3Nob3AgQ1M1IE1hY2ludG9zaCI+IDx4bXBNTTpEZXJpdmVkRnJvbSBzdFJlZjppbnN0YW5jZUlEPSJ4bXAuaWlkOjYyOTMyODA0MTUyMDY4MTE5QzA3RTc3QjQ2RTREOTMzIiBzdFJlZjpkb2N1bWVudElEPSJ4bXAuZGlkOkQ3MDY5OEI2MDcyMDY4MTE5OTRDODM3ODY1NEU0QUZFIi8+IDwvcmRmOkRlc2NyaXB0aW9uPiA8L3JkZjpSREY+IDwveDp4bXBtZXRhPiA8P3hwYWNrZXQgZW5kPSJyIj8+TGD0YAAAAi1JREFUeNrcV98rQ2EYxka5mZUUW/kTpITEFa2UNSluVq7UypWSuSSuhBtXSu3KJW1ZFrW4UpJW1v4DGmorP3K10jxfPavvfM5P50R56+ntnH3neb73/X6875rr9XrTb1tL0x+Y386gid3bNrgIEAMGgG4gDJSBZ6AAZIH8xcpgzYqv2Sy9EPPBLQAbFLIyMYF1IAXxT8eiEOyFOwH6+epSREI8M8owJxMhxjn2DpiG8L1tUQiKFJ6S8BrYBw71CEAsfzcPtwiMcGJR/F6w3Ej4UMz+jIIZYNJIUGcChxyf4fdn5DOOlBvmhik9BuZsCBktzxHcLFM9LG8wNdIlCoqUJlyejAR5+sn7Pb2YWTvcMh+3gBc3iojshTzCkuT/FukU1yHPM6dnVaKPz6MgqwoYCGfJ10V+XVFhOZMAOolWPrdJ74wsp/BrRAek82hldcWbWZ5+SE+0l/7B46v2kT6sJ9pB/+qlItb1VeHXiL7RB70UxSYLKvwa0TJ9yOP0hhR+jWjjjox4LDqu8GtEs+rWNjGfg3ocU4+iXzlPFalY610QRfoPadMVTdYzRr6KzKde+Em4beCKEb+7uPADDGQMWMW4HaMLfw8ocWDK5VqmyFMir349ZfmJMh2iLKWBgMMjEgDS/L7CQl4zLeJsMaKs/DPAORC3KRjn+Bmpc7j3qkcSV9sT0MNz6L5HUrpBUYzXHHSDm8DBj7pBi7630QU2ukLv+t5/9bfiS4ABAKQh1Ar2teP/AAAAAElFTkSuQmCC); 0px 0px; float:left; width: 30px; height: 27px;        }"+" .peer5_settings_container { float:left } "+" .peer5_settings { background: no-repeat url(//api.peer5.com/downloader/buttons/setting_b.png) 0px 0px; width: 35px; height: 27px;                }"+" .peer5_pauseplay { }"+" .peer5_eta { float:left; padding: 0 0 4px 2px !important; font-size:16px; } "+" .peer5_progress { border-color: #555; border-width: 5px; border-bottom-style: solid;  overflow:hidden; height:15px; width:20px   } "+" .peer5_percentage { padding-left:1px !important; float:right; font-size: 14px; font-weight: bold; color: #555; }"+" .peer5_downloaded {  padding-left: 3px !important; float:left; font-size: 12px; }"+" .peer5_total { float: left; font-size: 12px; } "+" .peer5_rate_container * { font-size:16px; float: right; padding-left: 4px !important; text-align: right; } "+" .peer5_rate_speedup { font-size:11px; font-weight:bold; color:green; } "+" .peer5-dl-left { display: table-cell; } "+" .peer5-dl-left * { fill:"+e+" }"+" .peer5-dl-right { display:table-cell; vertical-align:top; width:100% } "+" .peer5-dl-metrics { padding-left: 1px !important; line-height: 30px !important; } "+" .peer5-control { color: #555; float: right; margin-left: 5px !important; font-size:12px !important; font-weight: bold !important; } "+" .peer5-options { font-weight: bold; font-size: 22px; cursor: hand; padding-left:20px !important; } "+" .peer5-dl button { color: #555; background-color: transparent; border: 0; }"+" .peer5_close_button { position:relative; font-size: 12px !important; font-weight: bold !important; line-height: 100% !important; vertical-align: top !important; cursor: pointer !important; }"+" .peer5-dl-feedback-button {display: inline-block;position: absolute; bottom: 0; left: 45.5%; margin: 0; float: none; padding: 2px 5px; border-radius: 6px 6px 0 0; background-color: #428BCA; color: #FFF; font-size: 13px; }"+" .peer5-dl-feedback-form {padding: 10px; border-top: 1px groove #eee;}"+" .peer5-dl-feedback-form textarea {width: 100%; height: 5em;}"+" .peer5-dl-feedback-form p {font-weight: bold;}"+" .peer5-dl-feedback-form ul {list-style: none;}"+" .peer5-dl-feedback-form li {display: inline-block; width: 30px; text-align: center}"+" .peer5-dl-feedback-form li label {display: block; position: relative; width: 26px; height: 30px; margin: 0 auto; cursor: pointer;}"+" .peer5-dl-feedback-form li label:before {position: absolute; content: '\\2605'; display: block; top: 0; line-height: 100%; font-size: 28px; color: #bbb;}"+" .peer5-dl-feedback-form li label:after {position: absolute; content: '\\2605'; display: none; top: 0; line-height: 100%; font-size: 28px;}"+" .peer5-dl-feedback-form ul.peer5-dl-checked li label:before {color: "+e+";}"+" .peer5-dl-feedback-form ul.peer5-dl-checked.peer5-dl-checked-show li label:after {display: none;}"+" .peer5-dl-feedback-form li.peer5-dl-checked ~ li label:before {color: #bbb;}"+" .peer5-dl-feedback-form ul:hover label:after {display: block;}"+" .peer5-dl-feedback-form ul:hover label:before {display: none;}"+" .peer5-dl-feedback-form ul.peer5-dl-checked-show:hover label:before {display: block;}"+" .peer5-dl-feedback-form ul li:hover ~ li label:after {display: none;}"+" .peer5-dl-feedback-form ul li:hover ~ li label:before {display: block;}"+" .peer5-dl-feedback-form li input {visibility: hidden;}"+" .peer5-dl-feedback-form .submit {text-align: left;}"+" .peer5-overlay-help {display: "+this.helpDisplay+"; z-index: 1338; background-color: rgba(0,0,0,0.85); width: 100%; height: 100%; position: fixed; top: 0; left:0;background-image: url(//api.peer5.com/downloader/help-overlay.png); background-size: 75% auto; background-position: center center; background-repeat: no-repeat; }"+" .peer5-dl-feedback-button {display: inline-block;position: absolute; bottom: 0; left: 45.5%; margin: 0; float: none; padding: 2px 5px; border-radius: 6px 6px 0 0; background-color: #428BCA; color: #FFF; font-size: 13px; }",this.container.appendChild(n),this.mainDiv=document.createElement("div"),this.mainDiv.className="peer5-dl peer5-dl-main"+this.peer5_dl_float,this.mainDiv.innerHTML=this.div_left+'<div class="peer5-dl peer5_stat_area peer5-dl-right stat_area stat_font">'+'<div class="peer5-dl peer5_header">'+'<div class="peer5-dl peer5_filename">Loading...</div>'+this.buttonsdiv+'<div class="peer5-dl peer5_help_button"><a class="peer5-dl" href="javascript:void(0)" onclick="document.querySelector(\'.peer5-overlay-help\').style.display=\'block\'">help</a></div>'+'<div class="peer5-dl peer5_share"><a class="peer5-dl" target="_blank" href="http://twitter.com/peer5">share</a></div>'+'<div class="peer5-dl peer5_logo"><a class="peer5-dl" target="_blank" href="http://peer5.com/downloader/land.html?o=d"><img class="peer5-dl" src="//api.peer5.com/downloader/peer5_logo.png" style="width: 45px;vertical-align: -3px;"></a></div>'+"</div>"+'<div class="peer5-dl peer5_progress">'+'<div class="peer5-dl peer5_percentage" >0%</div>'+'<div class="peer5-dl peer5_downloaded" ></div>'+'<div class="peer5-dl peer5_total"></div>'+"</div>"+'<div class="peer5-dl"><canvas title="Chunks map" class="peer5-dl peer5_stats_canvas" ></canvas></div>'+'<div class="peer5-dl peer5-dl-metrics">'+'<div class="peer5-dl peer5_pauseplay"></div>'+'<div class="peer5-dl peer5_settings_container">'+"</div>"+'<div class="peer5-dl peer5_eta" >Initializing...</div>'+'<div class="peer5-dl peer5_rate_container">'+'<div class="peer5-dl peer5_info">'+'<button class="peer5-dl peer5_info_button"></button>'+"</div>"+'<div title="Current download speed" class="peer5_rate" ></div>'+'<div title="The downloader speedup estimation" class="peer5_rate_speedup" ></div>'+'<div class="peer5_metric"> </div>'+"</div>"+"</div>"+"</div>"+'<div class="peer5-dl peer5_stats"></div>'+'<div class="peer5-dl peer5-overlay-help" onclick="this.style.display=\'none\'" ></div>'+'<div class="peer5-dl-feedback-button">Feedback</div>'+'<div class="peer5-dl-feedback-container">'+"</div>"+'<div class="peer5-dl" style="clear: both"></div>',this.getElement("peer5_help_button").addEventListener("click",function(){radio("helpClicked").broadcast()
  6. }),this.getElement("peer5_share").addEventListener("click",function(){radio("shareClicked").broadcast()}),this.getElement("peer5_logo").addEventListener("click",function(){radio("logoClicked").broadcast()}),this.getElement("peer5-overlay-help").addEventListener("click",function(){radio("helpExited").broadcast()}),this.mainDiv.url=this.url,this.container.appendChild(this.mainDiv),this.feedback_button=this.getElement("peer5-dl-feedback-button"),this.fileName_label=this.getElement("peer5_filename"),this.rateDiv_label=this.getElement("peer5_rate"),this.rateDiv_speedup_label=this.getElement("peer5_rate_speedup"),this.metric_label=this.getElement("peer5_metric"),this.downloaded_label=this.getElement("peer5_downloaded"),this.progress_label=this.getElement("peer5_progress"),this.percentage_label=this.getElement("peer5_percentage"),this.total_label=this.getElement("peer5_total"),this.eta_label=this.getElement("peer5_eta"),this.canvas=this.getElement("peer5_stats_canvas"),this.pauseplay=this.getElement("peer5_pauseplay"),this.settings_label=this.getElement("peer5_settings"),this.statsarea=this.getElement("peer5_stats"),this.canvas_width=parseInt(document.defaultView.getComputedStyle(this.canvas.parentElement).width.replace("px","")),this.fileName_label.textContent=i,this.fileName_label.style.width=this.canvas_width-170+"px",this.feedback_button.addEventListener("click",this.createFeedbackForm.bind(this),!1),this.initCanvas()},getElement:function(e){return this.mainDiv.querySelector("."+e)},updateAvgs:function(e){if(this.mainDiv&&!this.paused){this.size||(this.size=t(e.size),this.sizeType=this.size.substring(this.size.length-2)),this.Total_Avg_Download=e.Total_Avg_Download;var n=e.Avg_Recv_P2P+e.Avg_Recv_HTTP,o=e.Total_Recv_No_Waste;this.newDispSpeed=0==this.dispSpeed?n:.9*this.dispSpeed+.1*n,this.dispSpeed=Math.floor(this.newDispSpeed),10>this.dispSpeed&&(this.dispSpeed=0);var s=Math.floor((e.size-o)/this.dispSpeed);null==this.eta||this.eta>86400||s+1==this.eta||this.eta_off>10?(this.eta_off=0,this.eta=s):(this.eta_off++,this.eta--);var a=i(this.eta),c=this.dispSpeed>1048576?2:0;if(this.rateDiv_label.textContent=t(Math.floor(1.1*this.dispSpeed),c),this.rateDiv_label.textContent+="/s ",this.rateDiv_speedup_label.textContent="",e.Total_Recv_HTTP>0&&e.Total_Recv_P2P>0){var l=(e.Total_Recv_HTTP+e.Total_Recv_P2P)/e.Total_Recv_HTTP;l=Math.round(100*(l-1)),l=Math.min(l,999),l>0&&(this.rateDiv_speedup_label.textContent="+"+l+"%")}var d=t(o,1)+"";if(this.downloaded_label.textContent=d,this.total_label.textContent="/"+this.size,e.size>o){var u=Math.round(100*(o/e.size));this.percentage_label.textContent=u+"%";var h=this.percentage_label.clientWidth;this.progress_label.style.width=Math.max(h,this.canvas_width*(o/e.size))+"px"}else r.warn("FileUI trimmed the percentage to 100%"),this.percentage_label.textContent="100%",this.progress_label.style.width=this.canvas_width+"px";if(this.eta_label.textContent=""+a,this.container.className.indexOf("analytics")>-1){var f=e.Total_Recv_P2P+e.Total_Recv_HTTP,p=0==f?0:Math.floor(100*(e.Total_Recv_P2P/f));this.statsarea.innerHTML="",this.statsarea.innerHTML+="Connected to "+this.numOfPeers+"<br>",this.statsarea.innerHTML+="<b>"+p+"%</b> downloaded from peers"+"<br>",this.statsarea.innerHTML+="P2P: "+e.Total_Recv_P2P+" ",this.statsarea.innerHTML+="HTTP: "+e.Total_Recv_HTTP+" ",this.statsarea.innerHTML+="Cache: "+e.Total_loaded_FS+" "}}},updateAnalyticsDiv:function(e){console.log("p2p: "+e.Total_Recv_P2P),console.log("http: "+e.Total_Recv_HTTP),console.log("cache: "+e.Total_loaded_FS)},changeNumOfsources:function(e){this.numOfPeers=e},displayCompleted:function(){this.rateDiv_label.textContent=" ",this.metric_label.textContent="",this.downloaded_label.textContent="Download completed -  "+this.size,this.total_label.textContent="",this.eta_label.textContent="",this.pauseplay.innerHTML="",this.percentage_label.textContent="100%",this.progress_label.style.width=this.canvas_width+"px",this.updateAvgs=function(){}},displayVerifying:function(){this.rateDiv_label.textContent=" ",this.metric_label.textContent="",this.downloaded_label.textContent="The file is being verified -  "+this.size,this.total_label.textContent="",this.eta_label.textContent="",this.pauseplay.innerHTML="",this.percentage_label.textContent="100%",this.progress_label.style.width=this.canvas_width+"px",this.updateAvgs=function(){}},showError:function(){this.rateDiv_label.textContent=" ",this.metric_label.textContent="",this.total_label.textContent="",this.eta_label.textContent="",this.pauseplay.innerHTML="",this.progress_label.style.width=this.canvas_width+"px",this.updateAvgs=function(){},this.eta_label.textContent="Oops! Something went wrong with your download. Trying something else..."},removeUI:function(){this.mainDiv&&(this.removeFeedbackForm(),this.mainDiv.parentNode.removeChild(this.mainDiv),this.mainDiv=null)},serializeFeedbackForm:function(e){var t=new FormData(e),i=window.location,n=i.href.replace(i.protocol+"//"+i.hostname,""),r=i.port;return r&&(n=n.replace(":"+r,"")),t.append("user_agent",window.navigator.userAgent),t.append("domain",i.hostname),t.append("path",n),t.append("speed_avg",this.Total_Avg_Download||-1),t},appendFormHtml:function(e){var t=this.getElement("peer5-dl-feedback-container");t.innerHTML=e,this.feedback_form=t.firstChild,this.feedback_form.addEventListener("submit",function(e){e.preventDefault(),e.stopPropagation();var t=new XMLHttpRequest;t.open("POST","https://api.peer5.com/downloader-feedback"),t.send(this.serializeFeedbackForm(e.target)),this.removeFeedbackForm()}.bind(this),!1),this.feedback_form.addEventListener("change",function(e){var t,i,n=e.target,r="peer5-dl-checked",o="peer5-dl-checked-show";"rating"==n.name&&n.checked&&(i=n.parentNode.parentNode,t=i.parentNode,t.classList.add(r),t.classList.add(o),t.addEventListener("mousemove",function s(){t.classList.remove(o),t.removeEventListener("mousemove",s)},!1),[].slice.call(t.children).forEach(function(e){e.classList.remove(r)}),i.classList.add(r))})},createFeedbackForm:function(){var e;return function(t){if(e)this.appendFormHtml(e);else{var i=new XMLHttpRequest;i.open("GET","https://api.peer5.com/downloader-feedback"),i.onreadystatechange=function(){4==i.readyState&&200==i.status&&(e=i.responseText,this.appendFormHtml(e))}.bind(this),i.send()}t.target.parentNode.removeChild(t.target)}}(),removeFeedbackForm:function(){if(this.feedback_form){var e=document.createElement("span");e.appendChild(document.createTextNode("Thanks for your feedback!")),this.feedback_form.parentNode.replaceChild(e,this.feedback_form),this.feedback_form=null,setTimeout(function(){e.parentNode.removeChild(e),e=null},7e3)}}})}(),function(){(function(e,t,i,n,r,o,s){e.GoogleAnalyticsObject=r,e[r]=e[r]||function(){(e[r].q=e[r].q||[]).push(arguments)},e[r].l=1*new Date,o=t.createElement(i),s=t.getElementsByTagName(i)[0],o.async=1,o.src=n,s.parentNode.insertBefore(o,s)})(window,document,"script","//www.google-analytics.com/analytics.js","peer5_ga"),peer5_ga("create","UA-37859248-1"),peer5_ga("send","pageview"),r.gaManager=function(){this.registerEvents(),this.downloadStarted=!1,this.fallback=!1},r.gaManager.prototype={registerEvents:function(){radio("scriptLoaded").subscribe([function(){r.info("script loaded "+Date.now()),peer5_ga("send","event","script","loaded")},this]),radio("scriptValidated").subscribe([function(e){e?(r.info("script passed validated"),peer5_ga("send","event","script","browser passed validation")):(r.info("script failed validation"),peer5_ga("send","event","script","browser failed validation"))},this]),radio("requestSent").subscribe([function(){r.info("request sent "+Date.now()),peer5_ga("send","event","request","sent")},this]),radio("startedDownloading").subscribe([function(e){r.info("started downloading "+Date.now()),peer5_ga("send","event","transfer","downloadStarted","requestSize",e),this.downloadStarted=!0},this]),radio("resumeStarted").subscribe([function(){r.info("resume started "+Date.now()),peer5_ga("send","event","storage","resume started")},this]),radio("resumeEnded").subscribe([function(){r.info("resume ended "+Date.now()),peer5_ga("send","event","storage","resume ended")},this]),radio("requestedPersQuota").subscribe([function(){r.info("requested persistent quota event"),peer5_ga("send","event","user","prompt persistent quota")},this]),radio("persQuotaAnswer").subscribe([function(e){e?(r.info("user has approved using persistent quota"),peer5_ga("send","event","user","approved persistent quota")):(r.info("user has denied using persistent quota"),peer5_ga("send","event","user","denied persistent quota"))},this]),radio("persQuotaTimeout").subscribe([function(){peer5_ga("send","event","user","persistent quota timed out")},this]),radio("offlineStorageError").subscribe([function(e){peer5_ga("send","event","error","offline storage",e)},this]),radio("usingFileSystem").subscribe([function(e){peer5_ga("send","event","cacheMethod","filesystem","fileSize",e)},this]),radio("usingMemory").subscribe([function(e){peer5_ga("send","event","cacheMethod","memory","fileSize",e)},this]),radio("wsError").subscribe([function(e){peer5_ga("send","event","errors",e)},this]),radio("expireHttpRequest").subscribe([function(e){peer5_ga("send","event","errors","xhr manually expired","timeout duration",e)},this]),radio("unhandledError").subscribe([function(e,t,i){peer5_ga("send","event","unhandled errors",e,t,i)},this]),radio("outOfMemoryError").subscribe([function(e){peer5_ga("send","event","errors","out of memory","heap size",e)},this]),radio("peer5_b1_finished").subscribe([function(e){r.info("Got first block in "+e+" ms"),peer5_ga("send","event","transfer","received first block","time to first block",e)},this]),radio("peer5_p1_finished").subscribe([function(e){r.info("p1 completed"+Date.now()),e=Math.abs(Math.floor(e)),peer5_ga("send","event","transfer","downloaded 1%","average download speed",e)},this]),radio("peer5_p5_finished").subscribe([function(e){r.info("p5 completed"+Date.now()),e=Math.abs(Math.floor(e)),peer5_ga("send","event","transfer","downloaded 5%","average download speed",e)},this]),radio("peer5_p10_finished").subscribe([function(e){r.info("p10 completed"+Date.now()),e=Math.abs(Math.floor(e)),peer5_ga("send","event","transfer","downloaded 10%","average download speed",e)},this]),radio("peer5_q1_finished").subscribe(function(e){r.info("q1 completed"+Date.now()),e=Math.abs(Math.floor(e)),peer5_ga("send","event","transfer","downloaded 25%","average download speed",e)}),radio("peer5_q2_finished").subscribe(function(e){r.info("q2 completed"+Date.now()),e=Math.abs(Math.floor(e)),peer5_ga("send","event","transfer","downloaded 50%","average download speed",e)}),radio("peer5_q3_finished").subscribe(function(e){r.info("q3 completed"+Date.now()),e=Math.abs(Math.floor(e)),peer5_ga("send","event","transfer","downloaded 75%","average download speed",e)}),radio("peer5_q4_finished").subscribe(function(e){r.info("q4 completed"+Date.now()),e=Math.abs(Math.floor(e)),peer5_ga("send","event","transfer","downloaded 100%","average download speed",e)}),radio("downloadFinished").subscribe([function(e,t,i,n,r){peer5_ga("send","event","transfer","downloadFinished","fileSize",t),peer5_ga("send","event","transfer","downloadFinished","p2p bytes downloaded",i),peer5_ga("send","event","transfer","downloadFinished","http bytes downloaded",n),peer5_ga("send","event","transfer","downloadFinished","filesystem bytes resumed",r)},this]),radio("seeding").subscribe([function(e){switch(r.info("seeding for "+e+" miliseconds"),e){case 5e3:peer5_ga("send","event","user","seeding","5 seconds");break;case 3e4:peer5_ga("send","event","user","seeding","30 seconds");break;case 3e5:peer5_ga("send","event","user","seeding","5 minutes")}},this]),radio("exitDownload").subscribe([function(e){e?peer5_ga("send","event","user","exit download","download completed"):peer5_ga("send","event","user","exit download","download didnt complete")},this]),radio("exitPage").subscribe(function(e,t,i){t=Math.abs(Math.floor(t)),i=Math.abs(Math.floor(i)),this.downloadStarted?.25>e?peer5_ga("send","event","user","exit page","download in Q1",t):.5>e?peer5_ga("send","event","user","exit page","download in Q2",t):.75>e?peer5_ga("send","event","user","exit page","download in Q3",t):1>e?peer5_ga("send","event","user","exit page","download in Q4",t):peer5_ga("send","event","user","exit page","download finished",t):(peer5_ga("send","event","user","exit page","before download start"),this.fallback||peer5_ga("send","event","user","exit page","before download start and no fallback")),peer5_ga("send","event","user","exit page","average download speed",i)}),radio("fallback").subscribe([function(e){this.fallback=!0,r.info("fallback "+Date.now()),this.downloadStarted?peer5_ga("send","event","errors","fallback after download started",e):peer5_ga("send","event","errors","fallback before download started",e)},this]),radio("pauseClicked").subscribe([function(){peer5_ga("send","event","user","clicked paused")},this]),radio("playClicked").subscribe([function(){peer5_ga("send","event","user","clicked played")},this]),radio("helpClicked").subscribe([function(){peer5_ga("send","event","user","clicked help")},this]),radio("helpExited").subscribe([function(){peer5_ga("send","event","user","exited help")},this]),radio("sharedClicked").subscribe([function(){peer5_ga("send","event","user","clicked share")},this]),radio("logoClicked").subscribe([function(){peer5_ga("send","event","user","clicked logo")},this])}},r.gaManager=new r.gaManager}(),function(e){r.client.DownloadUploadManager=Object.subClass({name:"peer5.client.DownloadUploadManager",ctor:function(){if(this.clientId=r.core.util.generate_uuid(),this.registerEvents(),this.apiValidator=new r.core.apiValidators.ApiValidator({dataChannels:r.core.apiValidators.DataChannelsApiValidator,fileSystem:r.core.apiValidators.FileSystemApiValidator}),this.apiValidator.validate()){this.validated=!0,this.pendingWSMessages=[],this.chunkSize=r.config.CHUNK_SIZE;var e="wss://api.peer5.com";this.wsConnectionImpl=new r.core.transport.WsConnection(e,this.clientId),this.controller=new r.client.HybridController(this.clientId),this.resources={},this.statsCalculators={},this.lastReportTime=0,this.lastStatCalcTime=0,this.cron_interval_id=window.setInterval(this.cron,r.config.MONITOR_INTERVAL,this),radio("peer5_uuid").broadcast(this.clientId)}else this.validated=!1;radio("scriptLoaded").broadcast(),radio("scriptValidated").broadcast(this.validated)},getNumOfVerifiedBytes:function(e,t){var i,n=r.core.data.BlockCache.get(e);n&&(i=n.getNumOfVerifiedBytes()),t(i)},getBlobUrl:function(e,t){var i=r.core.data.BlockCache.get(e);i.getBlobUrl(t)},getBlob:function(e,t){var i=r.core.data.BlockCache.get(e);i.getBlob(t)},getResourceId:function(e,t){var i=r.core.data.BlockCache.get(e);i?t(i.resourceId):t()},getClientId:function(e){e(this.clientId)},isValidated:function(e){e(this.validated)},getSwarmId:function(e,t){var i=r.core.data.BlockCache.get(e);i&&i.getMetadata()&&t(swarmId=i.getMetadata().swarmId)},isFull:function(e,t){var i=r.core.data.BlockCache.get(e);t(i.isFull())},addResource:function(e,t){if(this.resources.hasOwnProperty(e)&&this.resources[e].state>1){this.resources[e].mod=t;var i=r.core.data.BlockCache.get(e);if(i)var n=i.getMetadata();if(n){var o=!0;return this.controller.init(n,o,this.resources[n.swarmId].mod),radio("fileInfoReceived").broadcast(n),radio("resourceReady").broadcast(n),void 0}return r.error("couldn't add resource already exists in unstable state"),void 0}if(this.resources[e]={state:0,mod:t},-1!=e.indexOf("http")){var s=new r.client.HTTPDownloader(e);s.head()}else this.joinSwarm(e)},removeResource:function(e){this.resources[e].state=4,this.controller.removeResource(e),r.core.data.BlockCache.remove(e),this.resources[e]&&this.resources[e].hash&&this.resources[this.resources[e].hash]&&delete this.resources[this.resources[e].hash],this.resources[e]&&this.resources[e].resourceId&&this.resources[this.resources[e].resourceId]&&delete this.resources[this.resources[e].resourceId],this.resources[e]&&delete this.resources[e]},stopResource:function(e){this.resources[e].state=4,this.controller.stopResource(e)},readBlobData:function(e,t){this.resources[e]={},this.resources[e].state=0,this.resources[e].origin=!0,this.resources[e].hashAlg=new r.core.util.MD5.ArrayBuffer,this.resources[e].chunkRead=0,this.resources[e].mod=2,this.resources[e].resourceId=e;var i=t.size;this.statsCalculators[e]=new r.core.stats.StatsCalculator(i,e,""),r.core.data.BlockCache.add(e,new r.core.dataStructures.BlockMap(i,e));var n=this;r.config.USE_FS?radio("filesystemInitiated"+e).subscribe([function(){this.readBlobInSlices(e,t)},this]):this.readBlobInSlices(e,t),radio("transferLoadedEvent").subscribe([function(t){t.url!==e||this.resources[e].uploaded||(this.resources[e].uploaded=!0,this.createAndUploadFileInfo(e))},n])},getLoadedStats:function(e,t){var i={},n=this.statsCalculators[e]||this.statsCalculators[this.resources[e].resourceId];i.loadedHTTP=n.Total_Recv_HTTP,i.loadedP2P=n.Total_Recv_P2P,i.loadedFS=n.Total_loaded_FS,t(i)},getUploadedStats:function(e,t){var i={},n=this.statsCalculators[e]||this.statsCalculators[this.resources[e].resourceId];i.uploaded=n.Total_Sent_P2P,t(i)},getCompatibilityStatus:function(e){var t=this.apiValidator.getStatus(),i=this.apiValidator.getBrowser();e(t,i)},createAndUploadFileInfo:function(e){this.resources[e].hash=this.resources[e].hashAlg.end(),this.changeResourceId(e,this.resources[e].hash);var t=r.core.data.BlockCache.get(e),i=new r.core.protocol.FileInfo(null,t.fileSize,this.resources[e].hash,null,null,"api",null,null,null);this.wsConnectionImpl.socketReadyToSend()?this.wsConnectionImpl.sendMessage(i):this.pendingWSMessages.push(i)},readBlobInSlices:function(e,t){if(!r.core.data.BlockCache.get(e).fs&&t.size>r.config.ALLOWED_FILE_SIZE)return radio("removeResource").broadcast(e,r.Request.FILE_SIZE_ERR,"file size too big"),void 0;var i=this;r.core.util.fileHandler.readFileInSlices(e,t,12e5,function(e,t,n){e&&t&&n?(r.log("adding chunks"),i.addChunks(e,t,n)):(!e||t||n)&&r.error("handle error")})},addChunks:function(e,t,i){r.log("slice"),this.resources[e].hashAlg.append(t);for(var n=r.core.data.BlockCache.get(e),o=Math.ceil(t.byteLength/r.config.CHUNK_SIZE),s=0;o>s;s++){var a=s*r.config.CHUNK_SIZE,c=new Uint8Array(t.slice(a,Math.min(a+r.config.CHUNK_SIZE,t.byteLength))),l=n.setChunk(this.resources[e].chunkRead,c);n.verifyBlock(l),radio("chunkAddedToBlockMap").broadcast(),this.resources[e].chunkRead++}this.resources[e].chunkRead==this.numOfChunksInFile&&(this.hasEntireFile=!0),n.fs?r.core.data.FSio.notifyFinishWrite(i):i()},cron:function(e){e.sendReport(),e.calculateStats(),radio("cron").broadcast();for(var t in e.statsCalculators)e.resources[t]&&1===e.resources[t].mod&&!r.core.data.BlockCache.get(t).isFull()&&(0===e.statsCalculators[t].Avg_Recv_HTTP?e.resources[t].httpIdle++:e.resources[t].httpIdle=0,e.resources[t].httpIdle>=r.config.HTTP_IDLE_RESET_DURATION/r.config.MONITOR_INTERVAL&&(e.controller.stopHttp(r.core.data.BlockCache.get(t).getMetadata().url),e.resources[t].httpIdle=0),e.controller.downloadPeriodicTest(r.core.data.BlockCache.get(t).getMetadata().url))},calculateStats:function(){var e=Date.now();if(!(e-this.lastStatCalcTime<r.config.STAT_CALC_INTERVAL)&&(this.lastStatCalcTime=e,this.statsCalculators))for(var t in this.statsCalculators)this.statsCalculators[t].calc_avg(!1)},sendReport:function(e){var t=this,i=Date.now();if(!(i-t.lastReportTime<r.config.REPORT_INTERVAL)){t.lastReportTime=i;var n=e?!0:null;r.core.data.BlockCache.forEach(function(e,i){if(i.init&&i.metadata&&i.metadata.swarmId&&i.availabilityMap&&t.statsCalculators&&t.statsCalculators[i.metadata.swarmId]){var o=t.statsCalculators[i.metadata.swarmId],s=new r.core.protocol.Report(i.metadata.swarmId,null,o.Total_Sent_P2P,o.Total_Recv_P2P,o.Total_Recv_HTTP,o.Total_Waste_P2P,o.Total_Waste_HTTP,null,null,t.getConnectionStats(),null,i.availabilityMap.serialize(),i.availabilityMap.numOfOnBits,i.fileSize,n);t.wsConnectionImpl.sendMessage(s)}})}},getConnectionStats:function(){return this.controller.getConnectionStats().p2p},handleFileInfo:function(e){this.statsCalculators[e.swarmId]=new r.core.stats.StatsCalculator(e.size,e.name,e.url,e.swarmId);var t=new r.core.dataStructures.BlockMap(e.size,e.swarmId,e.hash);r.core.data.BlockCache.add(e.swarmId,t),t.addMetadata(e),e.url&&this.changeResourceId(e.url,e.swarmId),this.resources[e.swarmId].state=1,radio("fileInfoReceived").broadcast(e),t.fs||radio("resourceInit").broadcast(e)},updateFileInfo:function(e){var t=this;this.changeResourceId(e.hash,e.swarmId,function(i){if(i){t.resources[e.swarmId].state=1;var n=r.core.data.BlockCache.get(e.swarmId);n.addMetadata(e),radio("resourceInit").broadcast(e)}else r.warn("couldn't change resource Id")}),radio("fileInfoReceived").broadcast(e)},joinSwarm:function(e){this.wsConnectionImpl.socketReadyToSend()?this.wsConnectionImpl.sendMessage(new r.core.protocol.Join(e)):this.pendingWSMessages.push(new r.core.protocol.Join(e))},registerEvents:function(){radio("stopResource").subscribe([function(e,t,i){radio("requestError").broadcast(e,t,i),this.stopResource(e)},this]),radio("removeResource").subscribe([function(e,t,i){r.warn("removing resource "+e),r.warn(t+": "+i),radio("requestError").broadcast(e,t,i),this.removeResource(e)},this]),radio("resourceInit").subscribe([function(e){this.resources[e.swarmId].state=2;var t=r.core.data.BlockCache.get(e.swarmId);if(!t.fs&&e.size>r.config.ALLOWED_FILE_SIZE)return 1==this.resources[e.swarmId].mod?radio("removeResource").broadcast(e.url,r.Request.FILE_SIZE_ERR,"file size too big"):2==this.resources[e.swarmId].mod&&radio("removeResource").broadcast(e.swarmId,r.Request.FILE_SIZE_ERR,"file size too big"),void 0;var i=!0;this.controller.init(e,i,this.resources[e.swarmId].mod),1==t.fs&&r.config.PREALLOCATE_FILE&&t.allocateFileSize(function(e){e||r.warn("Couldn't allocate space for file")}),radio("resourceReady").broadcast(e)},this]),radio("XHRMetaFetched").subscribe([function(e){var t=e.url;if(!t)return r.error("No URL given!"),void 0;if(t=t.split("#")[0],!e.fileSize)return radio("removeResource").broadcast(e.url,r.Request.FILE_SIZE_ERR,"file size undefined"),void 0;if(!r.config.USE_FS&&e.fileSize>r.config.ALLOWED_FILE_SIZE)return radio("removeResource").broadcast(e.url,r.Request.FILE_SIZE_ERR,"file size too big"),void 0;var i,n;if(this.resources[t].hash)i=this.resources[t].hash;else if(e.hash)i=e.hash+"!"+e.fileSize;else{var o=r.config.USE_QUERYSTRING_FOR_HASH?t:t.split("?")[0];i=o+"!"+e.fileSize}var s=r.CryptoJS.SHA1(i);n=""+s,n=n.substr(0,20),r.info("Hash is "+n);var a=new r.core.protocol.FileInfo(n,e.fileSize,n,null,12e5);a.url=t,this.resources[a.url].mediaType||(a.name=this.resources[a.url].name),this.joinSwarm(a.swarmId),this.handleFileInfo(a)},this]),radio("needByteRangeEvent").subscribe([function(e,t,i,n,o){var s=r.core.data.BlockCache.get(e),a=t?s.getBlockIndex(t):null,c=i?s.getBlockIndex(i):null;o&&r.warn("We don't support in pausing and resuming"),this.controller.download(e,a,c,n)},this]),radio("webSocketInit").subscribe([function(){for(var e=0;this.pendingWSMessages.length>e;++e)this.wsConnectionImpl.sendMessage(this.pendingWSMessages[e]);this.pendingWSMessages=[]},this]),radio("receivedFileInfo").subscribe([function(e){return this.resources[e.swarmId]||this.resources[e.hash]?(!this.resources[e.swarmId]&&this.resources[e.hash]&&this.resources[e.hash].origin?0==this.resources[e.hash].state&&this.updateFileInfo(e):this.resources[e.swarmId]&&0==this.resources[e.swarmId].state&&this.handleFileInfo(e),void 0):(r.warn("received fileInfo for a non existing swarm"),void 0)},this]),radio("browserUnsupported").subscribe([function(){r.warn("Unsupported browser for Peer5"),radio("browserUnsupported").unsubscribe(arguments.callee),this.validated=!1},this]),radio("swarmError").subscribe([function(e){var t;switch(e.error){case r.core.protocol.SWARM_NOT_FOUND:if(1==this.resources[e.swarmId].mod)return;if(2==this.resources[e.swarmId].mod){var t=r.Request.SWARMID_NOT_FOUND_ERR;break}case r.core.protocol.SWARM_ONLY_CHROME:var t=r.Request.CHROME_ONLY_SWARM_ERR;break;case r.core.protocol.SWARM_ONLY_FIREFOX:var t=r.Request.FIREFOX_ONLY_SWARM_ERR;break;case r.core.protocol.SWARM_NOT_COMPAT:var t=r.Request.BROWSER_SWARM_COMPAT_ERR}radio("requestError").broadcast(e.swarmId,t)},this])},changeResourceId:function(e,t,i){this.resources[e]&&(this.resources[t]=this.resources[e],this.resources[t].resourceId=t),this.statsCalculators[e]&&(this.statsCalculators[t]=this.statsCalculators[e],this.statsCalculators[t].resourceId=t),r.core.data.BlockCache.get(e)&&!r.core.data.BlockCache.get(t)?(r.core.data.BlockCache.alias(t,e),i&&r.core.data.BlockCache.get(e).changeResourceId(t,i)):!r.core.data.BlockCache.get(e)&&r.core.data.BlockCache.get(t)&&r.core.data.BlockCache.alias(e,t)}}),e.clientInstance=new r.client.DownloadUploadManager}("undefined"==typeof exports?r:exports);var o={};o.setLogLevel=r.setLogLevel,o.download=r.download,o.stopDownload=r.stopDownload,o.exitDownload=r.exitDownload,o.Request=r.Request,o.getCompatibilityStatus=r.getCompatibilityStatus,o.DATACHANNELS_ERROR=r.DATACHANNELS_ERROR,o.WEBSOCKETS_ERROR=r.WEBSOCKETS_ERROR,o.FILESYSTEM_ERROR=r.FILESYSTEM_ERROR,window.peer5=o})();
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!