early webhook fix along with test fixes according to changes

ant-media · Apr 3, 2021 · a5c4453 · a5c4453
1 parent 84344a0
commit a5c4453
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 15 deletions.
diff --git a/src/main/java/io/antmedia/AntMediaApplicationAdapter.java b/src/main/java/io/antmedia/AntMediaApplicationAdapter.java
@@ -434,18 +434,6 @@ public void streamSubscriberClose(ISubscriberStream stream) {
 		vertx.setTimer(1, l -> getDataStore().updateRtmpViewerCount(stream.getBroadcastStreamPublishName(), false));
 	}
 
-	public void streamPublishStart(final IBroadcastStream stream) {
-		String streamName = stream.getPublishedName();
-		logger.info("stream name in streamPublishStart: {}", streamName );
-		long absoluteStartTimeMs = 0;
-		if (stream instanceof ClientBroadcastStream) {
-			absoluteStartTimeMs = ((ClientBroadcastStream) stream).getAbsoluteStartTimeMs();
-		}
-		startPublish(streamName, absoluteStartTimeMs);
-
-
-	}
-
 	public void startPublish(String streamName, long absoluteStartTimeMs) {
 		vertx.executeBlocking( handler -> {
 			try {

diff --git a/src/test/java/io/antmedia/test/Application.java b/src/test/java/io/antmedia/test/Application.java
@@ -169,5 +169,5 @@ public boolean isServerShuttingDown() {
 		return false;
 	}
 
-
+	public void startPublish(String streamName, long absoluteStartTimeMs){getAppAdaptor().startPublish(streamName, absoluteStartTimeMs);}
 }
diff --git a/src/test/java/io/antmedia/test/MuxerUnitTest.java b/src/test/java/io/antmedia/test/MuxerUnitTest.java
@@ -961,7 +961,7 @@ public void testAbsoluteStartTimeMs()
 		Mockito.when(stream.getPublishedName()).thenReturn(streamId);
 
 		doReturn(stream).when(spyAdaptor).getBroadcastStream(Mockito.any(), Mockito.any());
-		spyAdaptor.streamPublishStart(stream);
+		spyAdaptor.startPublish(streamId,0);
 
 
 		long absoluteTimeMS = System.currentTimeMillis();
@@ -1004,7 +1004,7 @@ public void testPublishAndUnpublishSocialEndpoints() {
 
 		appAdaptor.getDataStore().addEndpoint(broadcast.getStreamId(), endpoint);
 
-		appAdaptor.streamPublishStart(stream);
+		appAdaptor.startPublish(stream.getPublishedName(),broadcast.getAbsoluteStartTimeMs());
 
 		Awaitility.await().atMost(5, TimeUnit.SECONDS).pollInterval(1, TimeUnit.SECONDS) 
 		.until(() ->