New webhooks playStart, playStop, recordStart issue #4666

ant-media · Jan 17, 2023 · 60b0a20 · 60b0a20
1 parent 878221c
commit 60b0a20
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/src/main/java/io/antmedia/AntMediaApplicationAdapter.java b/src/main/java/io/antmedia/AntMediaApplicationAdapter.java
@@ -540,6 +540,9 @@ public void resetDASHStats(String streamId) {
 
 	public void sendStartPlayWebHook(final String streamId, final String viewerId){
 		final Broadcast broadcast = getDataStore().get(streamId);
+		if(broadcast == null){
+			return;
+		}
 		final String listenerHookURL = broadcast.getListenerHookURL();
 		if (listenerHookURL == null || listenerHookURL.isEmpty()) {
 			return;
@@ -553,6 +556,9 @@ public void sendStartPlayWebHook(final String streamId, final String viewerId){
 
 	public void sendStopPlayWebHook(final String streamId, final String viewerId){
 		final Broadcast broadcast = getDataStore().get(streamId);
+		if(broadcast == null){
+			return;
+		}
 		final String listenerHookURL = broadcast.getListenerHookURL();
 		if (listenerHookURL == null || listenerHookURL.isEmpty()) {
 			return;
@@ -566,6 +572,9 @@ public void sendStopPlayWebHook(final String streamId, final String viewerId){
 
 	public void sendStartRecordWebHook(final String streamId){
 		final Broadcast broadcast = getDataStore().get(streamId);
+		if(broadcast == null){
+			return;
+		}
 		final String listenerHookURL = broadcast.getListenerHookURL();
 		if (listenerHookURL == null || listenerHookURL.isEmpty()) {
 			return;

diff --git a/src/test/java/io/antmedia/test/AntMediaApplicationAdaptorUnitTest.java b/src/test/java/io/antmedia/test/AntMediaApplicationAdaptorUnitTest.java
@@ -1869,7 +1869,7 @@ public void testRtmpStreamPlayStop() throws Exception {
 
 		spyAdaptor.streamPlayItemPlay(stream, item, true);
 		verify(spyAdaptor, times(1)).sendStartPlayWebHook(anyString(), anyString());
-		Awaitility.await().atMost(2, TimeUnit.SECONDS).pollInterval(1, TimeUnit.SECONDS).until(
+		Awaitility.await().atMost(5, TimeUnit.SECONDS).pollInterval(1, TimeUnit.SECONDS).until(
 				()-> {
 					boolean called = false;
 					try{
@@ -1883,7 +1883,7 @@ public void testRtmpStreamPlayStop() throws Exception {
 
 		spyAdaptor.streamPlayItemStop(stream, item);
 		verify(spyAdaptor, times(1)).sendStopPlayWebHook(anyString(), anyString());
-		Awaitility.await().atMost(2, TimeUnit.SECONDS).pollInterval(1, TimeUnit.SECONDS).until(
+		Awaitility.await().atMost(5, TimeUnit.SECONDS).pollInterval(1, TimeUnit.SECONDS).until(
 				()-> {
 					boolean called = false;
 					try{