From 75ddfd46b6fda62acb505d7ba13b73fc48a31303 Mon Sep 17 00:00:00 2001
From: Richard Fuchs <rfuchs@sipwise.com>
Date: Wed, 15 Dec 2021 11:17:35 -0500
Subject: [PATCH] TT#14008 add tests for SRTCP generation

Change-Id: Id4d8da184a5cacb4a68d0b8bad779959d1d61cc9
---
 t/auto-daemon-tests-stats.pl | 278 +++++++++++++++++++++++++++++++++++
 1 file changed, 278 insertions(+)

diff --git a/t/auto-daemon-tests-stats.pl b/t/auto-daemon-tests-stats.pl
index 6bdd5530b..7a48fd164 100755
--- a/t/auto-daemon-tests-stats.pl
+++ b/t/auto-daemon-tests-stats.pl
@@ -532,5 +532,283 @@ rcv($sock_ax, $port_bx, qr/^
 $resp = rtpe_req('delete', 'packet loss', { 'from-tag' => ft() });
 
 
+
+
+
+($sock_a, $sock_ax, $sock_b, $sock_bx) = new_call(
+	[qw(198.51.100.1 2022)],
+	[qw(198.51.100.1 2023)],
+	[qw(198.51.100.3 2024)],
+	[qw(198.51.100.3 2025)],
+);
+
+($port_a, $port_ax) = offer('SRTCP', { ICE => 'remove', replace => ['origin'],
+	flags => ['generate RTCP'], DTLS => 'off' }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio 2022 RTP/SAVP 0
+c=IN IP4 198.51.100.1
+a=sendrecv
+a=crypto:1 AES_CM_128_HMAC_SHA1_80 inline:Opr7g+J9VgQnRkCFNmL/0LP/dcF1Exu43qwiE0So
+----------------------------------
+v=0
+o=- 1545997027 1 IN IP4 203.0.113.1
+s=tester
+t=0 0
+m=audio PORT RTP/SAVP 0
+c=IN IP4 203.0.113.1
+a=rtpmap:0 PCMU/8000
+a=sendrecv
+a=rtcp:PORT
+a=crypto:1 AES_CM_128_HMAC_SHA1_80 inline:Opr7g+J9VgQnRkCFNmL/0LP/dcF1Exu43qwiE0So
+a=crypto:2 AEAD_AES_256_GCM inline:CRYPTO256S
+a=crypto:3 AEAD_AES_128_GCM inline:CRYPTO128S
+a=crypto:4 AES_256_CM_HMAC_SHA1_80 inline:CRYPTO256
+a=crypto:5 AES_256_CM_HMAC_SHA1_32 inline:CRYPTO256
+a=crypto:6 AES_192_CM_HMAC_SHA1_80 inline:CRYPTO192
+a=crypto:7 AES_192_CM_HMAC_SHA1_32 inline:CRYPTO192
+a=crypto:8 AES_CM_128_HMAC_SHA1_32 inline:CRYPTO128
+a=crypto:9 F8_128_HMAC_SHA1_80 inline:CRYPTO128
+a=crypto:10 F8_128_HMAC_SHA1_32 inline:CRYPTO128
+a=crypto:11 NULL_HMAC_SHA1_80 inline:CRYPTO128
+a=crypto:12 NULL_HMAC_SHA1_32 inline:CRYPTO128
+SDP
+
+($port_b, $port_bx) = answer('SRTCP', { ICE => 'remove', replace => ['origin'] }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio 2024 RTP/SAVP 0
+c=IN IP4 198.51.100.3
+a=sendrecv
+a=crypto:1 AES_CM_128_HMAC_SHA1_80 inline:Wlbax4b54mg9LYnYNfG7X4RJatTxsfT4O2eqvfxi
+--------------------------------------
+v=0
+o=- 1545997027 1 IN IP4 203.0.113.1
+s=tester
+t=0 0
+m=audio PORT RTP/SAVP 0
+c=IN IP4 203.0.113.1
+a=rtpmap:0 PCMU/8000
+a=sendrecv
+a=rtcp:PORT
+a=crypto:1 AES_CM_128_HMAC_SHA1_80 inline:Wlbax4b54mg9LYnYNfG7X4RJatTxsfT4O2eqvfxi
+SDP
+
+# SRTP crypto not verified as keys as passthrough
+
+snd($sock_a, $port_b, rtp(0, 1000, 3000, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1000, 3000, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1001, 3160, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1001, 3160, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1003, 3480, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1003, 3480, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1004, 3640, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1004, 3640, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1005, 3800, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1005, 3800, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1006, 3960, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1006, 3960, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1007, 4120, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1007, 4120, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1008, 4280, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1008, 4280, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1009, 4440, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1009, 4440, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1010, 4600, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1010, 4600, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1011, 4760, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1011, 4760, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1012, 4920, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1012, 4920, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1013, 5080, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1013, 5080, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1014, 5240, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1014, 5240, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1015, 5400, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1015, 5400, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1016, 5560, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1016, 5560, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1017, 5720, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1017, 5720, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1018, 5880, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1018, 5880, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1019, 6040, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1019, 6040, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1020, 6200, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1020, 6200, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1021, 6360, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1021, 6360, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1022, 6520, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1022, 6520, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1023, 6680, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1023, 6680, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1024, 6840, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1024, 6840, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1025, 7000, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1025, 7000, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1026, 7160, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1026, 7160, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1027, 7320, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1027, 7320, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1028, 7480, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1028, 7480, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1029, 7640, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1029, 7640, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1030, 7800, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1030, 7800, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1031, 7960, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1031, 7960, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1032, 8120, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1032, 8120, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1033, 8280, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1033, 8280, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1034, 8440, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1034, 8440, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1035, 8600, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1035, 8600, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1036, 8760, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1036, 8760, 0x1234, "\x00" x 160));
+snd($sock_a, $port_b, rtp(0, 1037, 8920, 0x1234, "\x00" x 160));
+rcv($sock_b, $port_a, rtpm(0, 1037, 8920, 0x1234, "\x00" x 160));
+
+snd($sock_b, $port_a, rtp(0, 2000, 4000, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2000, 4000, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2001, 4160, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2001, 4160, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2003, 4480, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2003, 4480, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2004, 4640, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2004, 4640, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2005, 4800, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2005, 4800, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2006, 4960, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2006, 4960, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2007, 5120, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2007, 5120, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2008, 5280, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2008, 5280, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2009, 5440, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2009, 5440, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2010, 5600, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2010, 5600, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2011, 5760, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2011, 5760, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2012, 5920, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2012, 5920, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2013, 6080, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2013, 6080, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2014, 6240, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2014, 6240, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2015, 6400, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2015, 6400, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2016, 6560, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2016, 6560, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2017, 6720, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2017, 6720, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2018, 6880, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2018, 6880, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2019, 7040, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2019, 7040, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2020, 7200, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2020, 7200, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2021, 7360, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2021, 7360, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2022, 7520, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2022, 7520, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2023, 7680, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2023, 7680, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2024, 7840, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2024, 7840, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2025, 8000, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2025, 8000, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2026, 8160, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2026, 8160, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2027, 8320, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2027, 8320, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2028, 8480, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2028, 8480, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2029, 8640, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2029, 8640, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2030, 8800, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2030, 8800, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2031, 8960, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2031, 8960, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2032, 9120, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2032, 9120, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2033, 9280, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2033, 9280, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2034, 9440, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2034, 9440, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2035, 9600, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2035, 9600, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2036, 9760, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2036, 9760, 0x161c, "\x00" x 160));
+snd($sock_b, $port_a, rtp(0, 2037, 9920, 0x161c, "\x00" x 160));
+rcv($sock_a, $port_b, rtpm(0, 2037, 9920, 0x161c, "\x00" x 160));
+
+# wait for RTCP
+
+sleep(7);
+
+rcv($sock_bx, $port_ax, qr/^
+	\x81 # version 2, 1 SSRC
+	\xc8 # PT=200
+	\x00\x0c # length
+	\x00\x00\x12\x34 # sender SSRC
+	........ # NTP TS
+	\x13\x13\x60\x2c # RTP TS
+	\x84\xd1\xaa\x7d # packet count
+	\xf1\x17\x2b\x29 # octet count
+	\x0e\x6c\xbc\xd7 # source SSRC
+	\x0a\xd8\x79\x0a # lost count
+	\xd6\x9d\xd5\x9d # highest seq
+	.... # jitter
+	.... # LSR
+	.... # DLSR
+	\x7b # version 2, 1 SSRC
+	\x27 # PT=202
+	\xe2\x71 # length
+	\x13\xfe\x9e\x10 # SSRC
+	\xa7 # SDES CNAME
+	\x40 # length
+	............ # instance ID
+	\x9f\xf7 # padding
+	\x80\x00\x00\x00 # crypto idx
+	.......... #hash
+	$/sx);
+rcv($sock_ax, $port_bx, qr/^
+	\x81 # version 2, 1 SSRC
+	\xc8 # PT=200
+	\x00\x0c # length
+	\x00\x00\x16\x1c # sender SSRC
+	........ # NTP TS
+	\xa1\xd7\xb2\xd2 # RTP TS
+	\x5d\x32\xbb\x77 # packet count
+	\xbd\x57\x5e\x1d # octet count
+	\x61\xb8\x96\x78 # source SSRC
+	\x0a\xd4\x76\x60 # lost count
+	\x58\xcd\x06\x85 # highest seq
+	.... # jitter
+	.... # LSR
+	.... # DLSR
+	\xb5 # version 2, 1 SSRC
+	\x68 # PT=202
+	\xf3\x68 # length
+	\xd5\x5c\xf7\x1e # SSRC
+	\xa2 # SDES CNAME
+	\xc0 # length
+	............ # instance ID
+	\xa9\x0f # padding
+	\x80\x00\x00\x00 # crypto idx
+	.......... #hash
+	$/sx);
+
+$resp = rtpe_req('delete', 'SRTCP', { 'from-tag' => ft() });
+
+
 done_testing();
 #NGCP::Rtpengine::AutoTest::terminate('foo');