From 14ba5049074040b918b963d0bfb060c2366aa9a7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?H=C3=A5var=20Aamb=C3=B8=20Fosstveit?= <havar@fosstveit.net>
Date: Fri, 23 Nov 2018 23:18:50 +0100
Subject: [PATCH] Added support for requesting keyframe

---
 server/lib/Room.js | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git a/server/lib/Room.js b/server/lib/Room.js
index f306ccb..5e7530b 100644
--- a/server/lib/Room.js
+++ b/server/lib/Room.js
@@ -346,6 +346,25 @@ class Room extends EventEmitter
 			);
 		});
 
+		signalingPeer.socket.on('request-consumer-keyframe', (request, cb) =>
+		{
+			cb(null);
+
+			const { consumerId } = request;
+			const mediaPeer  = this._mediaRoom.getPeerByName(signalingPeer.peerName);
+			const consumer = mediaPeer.consumers
+				.find((_consumer) => _consumer.id === consumerId);
+			
+			if (!consumer)
+			{
+				logger.warn('consumer with id "%s" not found', consumerId);
+				
+				return;
+			}
+			
+			consumer.requestKeyFrame();
+		});
+
 		signalingPeer.socket.on('disconnect', () =>
 		{
 			logger.debug('Peer "close" event [peer:"%s"]', signalingPeer.peerName);