Provide facade to access the SignalingTypingHandler

Signed-off-by: Daniel Calviño Sánchez <[email protected]>

Author: danxuliu

src/services/participantsService.js

@@ -29,6 +29,7 @@ import { PARTICIPANT } from '../constants.js'
 import {
 	signalingJoinConversation,
 	signalingLeaveConversation,
+	signalingSetTyping,
 } from '../utils/webrtc/index.js'
 
 const PERMISSIONS = PARTICIPANT.PERMISSIONS
@@ -220,6 +221,15 @@ const setPermissions = async (token, attendeeId, permission) => {
 		})
 }
 
+/**
+ * Sets whether the current participant is typing or not.
+ *
+ * @param {boolean} typing whether the current participant is typing.
+ */
+const setTyping = (typing) => {
+	signalingSetTyping(typing)
+}
+
 export {
 	joinConversation,
 	rejoinConversation,

src/store/participantsStore.js

@@ -691,6 +691,14 @@ const actions = {
 		}
 		context.commit('updateParticipant', { token, attendeeId, updatedData })
 	},
+
+	async setTyping(context, { typing }) {
+		if (!context.getters.currentConversationIsJoined()) {
+			return
+		}
+
+		await setTyping(typing)
+	},
 }
 
 export default { state, mutations, getters, actions }

src/utils/webrtc/index.js

@@ -35,6 +35,10 @@ import './shims/MediaStream.js'
 import './shims/MediaStreamTrack.js'
 import initWebRtc from './webrtc.js'
 
+// This does not really belongs here, as it is unrelated to WebRTC, but it is
+// included here for the time being until signaling and WebRTC are split.
+import SignalingTypingHandler from '../SignalingTypingHandler.js'
+
 let webRtc = null
 const callParticipantCollection = new CallParticipantCollection()
 const localCallParticipantModel = new LocalCallParticipantModel()
@@ -43,6 +47,8 @@ const mediaDevicesManager = new MediaDevicesManager()
 let callAnalyzer = null
 let sentVideoQualityThrottler = null
 
+let signalingTypingHandler = new SignalingTypingHandler()
+
 let cancelFetchSignalingSettings = null
 let signaling = null
 let tokensInSignaling = {}
@@ -126,6 +132,7 @@ async function connectSignaling(token) {
 			signaling.settings = settings
 		})
 
+		signalingTypingHandler.setSignaling(signaling)
 	}
 
 	tokensInSignaling[token] = true
@@ -436,6 +443,15 @@ function signalingKill() {
 	}
 }
 
+/**
+ * Sets whether the current participant is typing.
+ *
+ * @param {boolean} typing whether the current participant is typing.
+ */
+function signalingSetTyping(typing) {
+	signalingTypingHandler.setTyping(typing)
+}
+
 export {
 	callParticipantCollection,
 	localCallParticipantModel,
@@ -452,4 +468,6 @@ export {
 	signalingLeaveCall,
 	signalingLeaveConversation,
 	signalingKill,
+
+	signalingSetTyping,
 }