LinqpadNotes/SipsorceryListen.linq at main · OurDotNetOrganization/LinqpadNotes · GitHub

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
<Query Kind="Statements">
  <NuGetReference>SIPSorcery</NuGetReference>
  <Namespace>System.Net</Namespace>
  <Namespace>SIPSorcery.SIP</Namespace>
  <Namespace>SIPSorcery.Media</Namespace>
  <Namespace>System.Threading.Tasks</Namespace>
</Query>

Console.InputEncoding = System.Text.UTF8Encoding.UTF8;
CancellationTokenSource source = new CancellationTokenSource();
// 被叫方監聽 5060
var sipTransport = new SIPSorcery.SIP.SIPTransport();
sipTransport.AddSIPChannel(new SIPSorcery.SIP.SIPUDPChannel(new System.Net.IPEndPoint(IPAddress.Loopback, 5061)));
var userAgent = new SIPSorcery.SIP.App.SIPUserAgent(sipTransport, null);
sipTransport.SIPTransportRequestReceived += async (lep, rep, req) =>
{
	lep.Dump();
	rep.Dump();
	req.Dump();
};
sipTransport.SIPTransportResponseReceived += async (lep, rep, req) =>
{
	lep.Dump();
	rep.Dump();
	req.Dump();
};
userAgent.OnIncomingCall += async (ua, req) =>
{
	VoIPMediaSession voipMediaSession = new VoIPMediaSession();
	voipMediaSession.OnRtpPacketReceived += (rep, media, rtpPkt) =>
	{
		(rtpPkt.Header.Timestamp, rtpPkt.Header.MarkerBit, rtpPkt.Header.PayloadType).Dump();
	};
	var uas = ua.AcceptCall(req);
	await ua.Answer(uas, voipMediaSession);
};
userAgent.OnCallHungup += (sIPDialogue) =>
{
	$"📞 Call hung up with {sIPDialogue.CallId}".Dump();
	source.Cancel();
};

Console.WriteLine("等待來電中...");
Task<string> callTask = Util.ReadLineAsync(cancelToken: source.Token);
try
{
	await callTask;
	userAgent.Hangup();
	Console.WriteLine("關閉");
	sipTransport.Shutdown();
	return;
}
catch (OperationCanceledException)
{
	userAgent.Hangup();
	Console.WriteLine("關閉");
	sipTransport.Shutdown();
	return;
}