refactor: [DIOS-6937] Use safer async wrapper with weak_ptr object li…

…fetimes (#49)

package.json

@@ -35,7 +35,7 @@
     "uuid": "^3.3.2"
   },
   "peerDependencies": {
-    "medooze-media-server-src": "^2.4.2"
+    "medooze-media-server-src": "^3.0.0"
   },
   "devDependencies": {
     "@types/node": "^20.8.6",

src/IncomingStreamBridge.i

@@ -8,10 +8,11 @@ class IncomingStreamBridge :
 private:
 	static constexpr size_t BaseVideoSSRC = 2;
 public:
+
 	IncomingStreamBridge(v8::Local<v8::Object> object, int maxLateOffset = 200, int maxBufferingTime = 400) :
-		audio(new MediaFrameListenerBridge(loop, 1, false, true)),
+		audio(MediaFrameListenerBridge::Create(loop, 1, false, true)),
 		videos({
-			{0, std::make_shared<MediaFrameListenerBridge>(loop, BaseVideoSSRC, false, true)}
+			{0, MediaFrameListenerBridge::Create(loop, BaseVideoSSRC, false, true)}
 		}),
 		mutex(true),
 		maxLateOffset(maxLateOffset),
@@ -23,7 +24,7 @@ public:
 		loop.Start(-1);
 
 		//Create dispatch timer
-		dispatch = loop.CreateTimer([this](std::chrono::milliseconds now){
+		dispatch = loop.CreateTimerUnsafe([this](std::chrono::milliseconds now){
 
 			//Iterate over the enqueued packets
 			for(auto it = queue.begin(); it!=queue.end(); it = queue.erase(it))
@@ -55,7 +56,6 @@ public:
 		});
 
 	}
-
 	virtual ~IncomingStreamBridge()
 	{
 		Log("IncomingStreamBridge::~IncomingStreamBridge()\n");
@@ -134,7 +134,7 @@ public:
 		frame->SetTime(now);
 
 		//Run on thread
-		loop.Async([=](...) {
+		loop.AsyncUnsafe([=](...) {
 			//Check if it is the first time we see the video track
 			if (frame->GetType() == MediaFrame::Video && videos.find(frame->GetSSRC())==videos.end())
 			{
@@ -144,7 +144,7 @@ public:
 				//Log
 				Error("-IncomingStreamBridge::Enqueue() | New multivideotrack received [id:%d,ssrc:%d]\n", id, ssrc);
 				//Add it
-				videos[id] = std::make_shared<MediaFrameListenerBridge>(loop, ssrc, false, true);
+				videos[id] = MediaFrameListenerBridge::Create(loop, ssrc, false, true);
 
 				//Fire event on main node thread
 				RTMPServerModule::Async([=,cloned=persistent](){

src/MediaFrameListenerBridge.i

@@ -16,7 +16,6 @@ struct MediaFrameListenerBridge :
 	public MediaFrameListener,
 	public MediaFrameProducer
 {
-	MediaFrameListenerBridge(TimeService& timeService, int ssrc);
 
 	QWORD numFrames;
 	QWORD numPackets;
@@ -80,7 +79,7 @@ SHARED_PTR_BEGIN(MediaFrameListenerBridge)
 {
 	MediaFrameListenerBridgeShared(TimeService& timeService, int ssrc)
 	{
-		return new std::shared_ptr<MediaFrameListenerBridge>(new MediaFrameListenerBridge(timeService, ssrc));
+		return new std::shared_ptr<MediaFrameListenerBridge>(MediaFrameListenerBridge::Create(timeService, ssrc));
 	}
 	SHARED_PTR_TO(RTPIncomingMediaStream)
 	SHARED_PTR_TO(RTPReceiver)