-
Notifications
You must be signed in to change notification settings - Fork 3
/
Transaction.js
64 lines (53 loc) · 1.95 KB
/
Transaction.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
class Transaction{
constructor(message){
return new Promise(resolve => {
this.context = message.context;
this.message = message;
this.start().then(res => {
resolve(this);
})
})
}
send(message){
if(typeof message == "object"){
message = Builder.Build(message);
}
return new Promise(resolve => {
this.context.send(message);
resolve(this);
})
}
on(event, callback){
//have all matching logic here.
//if its a part of a dialog, then send it to the dialog.
//apparently transaction handle responses to requests.
//and dialogs handle requests to responses.
//so we need to check if the message is a response or a request.
//if its a response, then we need to check if its a part of a dialog.
//if its a request, then we need to check if its a part of a dialog.
this.context.Socket.on('message', (message) => {
console.log("TRANSACTION")
console.log(message)
message = message.toString();
var sipMessage = this.context.Message(message);
if((sipMessage.branchId == this.branchId) && Parser.getResponseType(message) == event){
var sipMessage = this.context.Message(parsedMessage);
callback(sipMessage);
};
})
}
start(){
return new Promise(resolve => {
this.branchId = Parser.getBranch(this.message.message);
this.context.dialogs[this.branchId] = this;
//send intial request to server through main SIP class socket.
this.context.send(this.message);
resolve(this)
})
}
kill(){
delete this.context.dialogs[this.branchId];
//here add logic to detect dialog type and send appropriate message to server.
}
}
module.exports = Transaction;