-
Notifications
You must be signed in to change notification settings - Fork 1
/
AbstractPeer.js
74 lines (74 loc) · 3.01 KB
/
AbstractPeer.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
"use strict";
/**
* React,React-native webrtc peer implementation...
*
* Copyright 2017 Ahoo Studio.co.th.
*/
Object.defineProperty(exports, "__esModule", { value: true });
var _1 = require("./");
var AbstractPeer;
(function (AbstractPeer) {
var BasePeer = (function () {
/**
* reture PeerConnection
* @param socket
* @param stream
* @param options
*/
function BasePeer(config) {
this.enableDataChannels = true;
this.logError = function (error) {
console.log(error);
};
if (!config.stream) {
throw new Error("Missing stream!!!");
}
this.debug = config.debug;
this.id = config.peer_id;
this.pcPeers = config.pcPeers;
this.parentsEmitter = config.emitter;
this.send_event = config.sendHandler;
this.offer = config.offer;
}
BasePeer.prototype.initPeerConnection = function (stream) { };
BasePeer.prototype.removeStream = function (stream) {
this.pc.removeStream(stream);
};
BasePeer.prototype.addStream = function (stream) {
this.pc.addStream(stream);
};
BasePeer.prototype.onSetSessionDescriptionError = function (error) {
console.warn('Failed to set session description: ' + error.toString());
};
BasePeer.prototype.onCreateSessionDescriptionError = function (error) {
console.warn('Failed to create session description: ' + error.toString());
};
BasePeer.prototype.createOffer = function () {
var self = this;
this.pc.createOffer(function (desc) {
if (self.debug)
console.log('createOffer Success');
self.pc.setLocalDescription(desc, function () {
if (self.debug)
console.log('setLocalDescription Success');
self.send_event(_1.AbstractPeerConnection.OFFER, self.pc.localDescription, { to: self.id });
}, self.onSetSessionDescriptionError);
}, self.onCreateSessionDescriptionError);
};
BasePeer.prototype.createAnswer = function (message) {
var self = this;
self.pc.createAnswer(function (desc) {
if (self.debug)
console.log('createAnswer Success');
self.pc.setLocalDescription(desc, function () {
if (self.debug)
console.log('setLocalDescription Success');
self.send_event(_1.AbstractPeerConnection.OFFER, self.pc.localDescription, { to: message.from });
}, self.onSetSessionDescriptionError);
}, self.onCreateSessionDescriptionError);
};
BasePeer.prototype.handleMessage = function (message) { };
return BasePeer;
}());
AbstractPeer.BasePeer = BasePeer;
})(AbstractPeer = exports.AbstractPeer || (exports.AbstractPeer = {}));