PairDrop/app/elements/p2p-network/p2p-network.html

124 lines
4 KiB
HTML
Raw Normal View History

2015-12-19 01:18:02 +01:00
<script src="../../../bower_components/peerjs/peer.min.js"></script>
2015-12-18 17:43:46 +01:00
<dom-module id="p2p-network">
<template>
</template>
<script>
'use strict';
Polymer({
is: 'p2p-network',
properties: {
me: {
type: String,
notify: true,
}
},
attached: function() {
this._connectedPeers = {};
this._initCallbacks = [];
this._unsendMsgs = {};
window.onunload = window.onbeforeunload = function() {
if (!!this._peer && !this._peer.destroyed) {
this._peer.destroy();
}
}.bind(this);
2015-12-19 01:18:02 +01:00
this._initialize();
2015-12-18 17:43:46 +01:00
},
2015-12-19 01:18:02 +01:00
_initialize: function() {
var options = {
host: 'yawim.com',
port: 443,
path: 'peerjs',
secure: true
};
this._peer = new Peer(options);
this._peer.on('open', function(id) {
console.log('My peer ID is: ' + id);
this.set('me', id);
this._peerOpen = true;
this._initCallbacks.forEach(function(cb) {
cb();
});
}.bind(this));
this._peer.on('connection', this.connect.bind(this));
this._peer.on('error', function(err) {
console.error(err);
//ugly hack to find out error type
if (err.message.indexOf('Could not connect to peer') > -1) {
delete this._connectedPeers[this.peer];
this.set('peer', 'error');
return;
}
if (err.message.indexOf('Lost connection to server') > -1) {
this._peer.destroy();
this.set('me', this.me);
this._initialize();
return;
}
}.bind(this));
2015-12-18 17:43:46 +01:00
},
connect: function(c) {
var peer = c.peer;
if (c.label === 'file') {
c.on('data', function(data) {
console.log('received!', data);
this.fire('file-received', {
peer: peer,
2015-12-19 01:18:02 +01:00
dataURI: data.dataURI,
2015-12-18 17:43:46 +01:00
name: data.name,
});
}.bind(this));
}
},
connectToPeer: (function() {
2015-12-19 01:18:02 +01:00
function request(requestedPeer, callback) {
2015-12-18 17:43:46 +01:00
return function() {
var f = this._peer.connect(requestedPeer, {
label: 'file',
reliable: true
});
f.on('open', function() {
this.connect(f);
2015-12-19 01:18:02 +01:00
if (callback) {
callback();
}
2015-12-18 17:43:46 +01:00
}.bind(this));
f.on('error', function(err) {
console.log(err);
});
};
}
2015-12-19 01:18:02 +01:00
return function(requestedPeer, callback) {
if (this._peer.connections[requestedPeer]) {
2015-12-19 02:12:45 +01:00
callback();
2015-12-19 01:18:02 +01:00
return;
}
this.set('loading', true);
if (this._peerOpen) {
request(requestedPeer, callback).bind(this)();
} else {
this._initCallbacks.push(request(requestedPeer, callback).bind(this));
2015-12-18 17:43:46 +01:00
}
2015-12-19 01:18:02 +01:00
2015-12-18 17:43:46 +01:00
};
}()),
sendFile: function(peerId, file) {
var conns = this._peer.connections[peerId];
if (conns) {
2015-12-19 01:18:02 +01:00
conns.forEach(function(conn) {
2015-12-18 17:43:46 +01:00
if (conn.label === 'file') {
conn.send(file);
console.log('file send');
}
2015-12-19 01:18:02 +01:00
});
2015-12-18 17:43:46 +01:00
}
}
});
</script>
</dom-module>