From de6a7e5d4487ef56e7e710ae35c4daf306cf0ac8 Mon Sep 17 00:00:00 2001
From: Donat Zenichev <dzenichev@sipwise.com>
Date: Tue, 1 Apr 2025 12:03:45 +0200
Subject: [PATCH] MT#62272 auto-daemon-tests-moh: add reflect MoH test

Just another test to make sure the reflection MoH
functionality works correct.

Change-Id: I68974060523a99f740269c9c2daf06e1af7ecb4d
---
 t/auto-daemon-tests-moh.pl | 138 +++++++++++++++++++++++++++++++++++++
 1 file changed, 138 insertions(+)

diff --git a/t/auto-daemon-tests-moh.pl b/t/auto-daemon-tests-moh.pl
index 0180b1878..b88b99d35 100644
--- a/t/auto-daemon-tests-moh.pl
+++ b/t/auto-daemon-tests-moh.pl
@@ -935,5 +935,143 @@ a=recvonly
 a=rtcp:PORT
 SDP
 
+# test MoH for answerer with reflect
+
+($sock_a, $sock_b) = new_call([qw(198.51.100.1 33068)], [qw(198.51.100.3 33070)]);
+
+# declare that offerer is capable of moh
+offer('Music on hold - answerer test, sendrecv, with reflect', { ICE => 'remove', DTLS => 'off', moh => { blob => $wav_file } }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio 33068 RTP/AVP 8
+c=IN IP4 198.51.100.1
+a=sendrecv
+----------------------------------
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 8
+c=IN IP4 203.0.113.1
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
+# declare that answerer is capable of moh (fake db-id)
+answer('Music on hold - answerer test, sendrecv, with reflect', { ICE => 'remove', moh => { 'db-id' => '123' } }, <<SDP);
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio 33070 RTP/AVP 8
+c=IN IP4 198.51.100.3
+a=sendrecv
+--------------------------------------
+v=0
+o=- 1545997027 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 8
+c=IN IP4 203.0.113.1
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
+reverse_tags();
+
+# answerer puts on hold, and uses capabilities of the originator
+offer('Music on hold - answerer test, MoH set by answerer, with reflect', { ICE => 'remove', moh => { mode => 'reflect' }, DTLS => 'off' }, <<SDP);
+v=0
+o=- 1545997028 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio 33070 RTP/AVP 8
+c=IN IP4 198.51.100.1
+a=sendonly
+----------------------------------
+v=0
+o=- 1545997028 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+a=rtpengine-hold
+m=audio PORT RTP/AVP 8
+c=IN IP4 203.0.113.1
+a=rtpmap:8 PCMA/8000
+a=sendonly
+a=rtcp:PORT
+SDP
+
+# test received packets on the originator's side
+(undef, undef, $seq, $ts, $ssrc) = rcv($sock_a, -1, rtpm(8 | 0x80, -1, -1, -1, $pcma_1));
+rcv($sock_a, -1, rtpm(8, $seq + 1, $ts + 160 * 1, $ssrc, $pcma_2));
+rcv($sock_a, -1, rtpm(8, $seq + 2, $ts + 160 * 2, $ssrc, $pcma_3));
+rcv($sock_a, -1, rtpm(8, $seq + 3, $ts + 160 * 3, $ssrc, $pcma_4));
+rcv($sock_a, -1, rtpm(8, $seq + 4, $ts + 160 * 4, $ssrc, $pcma_5));
+
+answer('Music on hold - answerer test, MoH set by answerer, with reflect', { ICE => 'remove' }, <<SDP);
+v=0
+o=- 1545997028 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio 33068 RTP/AVP 8
+c=IN IP4 198.51.100.3
+a=recvonly
+--------------------------------------
+v=0
+o=- 1545997028 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 8
+c=IN IP4 203.0.113.1
+a=rtpmap:8 PCMA/8000
+a=recvonly
+a=rtcp:PORT
+SDP
+
+# answerer puts off hold
+offer('Music on hold - answerer test, MoH put off by answerer, with reflect', { ICE => 'remove', DTLS => 'off' }, <<SDP);
+v=0
+o=- 1545997029 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio 33070 RTP/AVP 8
+c=IN IP4 198.51.100.1
+a=sendrecv
+----------------------------------
+v=0
+o=- 1545997029 1 IN IP4 198.51.100.1
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 8
+c=IN IP4 203.0.113.1
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
+answer('Music on hold - answerer test, MoH put off by answerer, with reflect', { ICE => 'remove' }, <<SDP);
+v=0
+o=- 1545997029 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio 33068 RTP/AVP 8
+c=IN IP4 198.51.100.3
+a=sendrecv
+--------------------------------------
+v=0
+o=- 1545997029 1 IN IP4 198.51.100.3
+s=tester
+t=0 0
+m=audio PORT RTP/AVP 8
+c=IN IP4 203.0.113.1
+a=rtpmap:8 PCMA/8000
+a=sendrecv
+a=rtcp:PORT
+SDP
+
 #done_testing;NGCP::Rtpengine::AutoTest::terminate('f00');exit;
 done_testing();