One to one call

Author: borbuevbeksultan

src/main/kotlin/io/openfuture/openmessenger/kurento/KurentoWebsocketConfigurer.kt

@@ -2,7 +2,6 @@ package io.openfuture.openmessenger.kurento
 
 import io.openfuture.openmessenger.kurento.groupcall.CallHandler
 import io.openfuture.openmessenger.kurento.groupcall.RoomManager
-import io.openfuture.openmessenger.kurento.groupcall.UserRegistry
 import org.kurento.client.KurentoClient
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.context.annotation.Bean
@@ -11,6 +10,7 @@ import org.springframework.web.socket.config.annotation.EnableWebSocket
 import org.springframework.web.socket.config.annotation.WebSocketConfigurer
 import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry
 import org.springframework.web.socket.server.standard.ServletServerContainerFactoryBean
+import io.openfuture.openmessenger.kurento.recording.RecordingCallHandler as RecordingCallHandler
 
 @Configuration
 @EnableWebSocket
@@ -38,12 +38,19 @@ class KurentoWebsocketConfigurer(
     override fun registerWebSocketHandlers(registry: WebSocketHandlerRegistry) {
         registry.addHandler(groupCallHandler(), "/groupcall").setAllowedOriginPatterns("*")
         registry.addHandler(handler(), "/helloworld").setAllowedOriginPatterns("*")
+        registry.addHandler(callHandler(), "/call").setAllowedOrigins("*")
     }
+
     @Bean
     fun registry(): UserRegistry {
         return UserRegistry()
     }
 
+    @Bean
+    fun recordingUserRegistry(): io.openfuture.openmessenger.kurento.recording.UserRegistry {
+        return io.openfuture.openmessenger.kurento.recording.UserRegistry()
+    }
+
     @Bean
     fun roomManager(): RoomManager {
         return RoomManager()
@@ -54,5 +61,10 @@ class KurentoWebsocketConfigurer(
         return CallHandler()
     }
 
+    @Bean
+    fun callHandler(): RecordingCallHandler {
+        return RecordingCallHandler(kurentoClient(), recordingUserRegistry())
+    }
+
 }
 

…senger/kurento/groupcall/UserRegistry.kt …re/openmessenger/kurento/UserRegistry.ktsrc/main/kotlin/io/openfuture/openmessenger/kurento/groupcall/UserRegistry.kt renamed to src/main/kotlin/io/openfuture/openmessenger/kurento/UserRegistry.kt src/main/kotlin/io/openfuture/openmessenger/kurento/groupcall/UserRegistry.kt renamed to src/main/kotlin/io/openfuture/openmessenger/kurento/UserRegistry.kt

@@ -1,5 +1,6 @@
-package io.openfuture.openmessenger.kurento.groupcall
+package io.openfuture.openmessenger.kurento
 
+import io.openfuture.openmessenger.kurento.groupcall.UserSession
 import org.springframework.web.socket.WebSocketSession
 import java.util.concurrent.ConcurrentHashMap
 

src/main/kotlin/io/openfuture/openmessenger/kurento/groupcall/CallHandler.kt

@@ -3,6 +3,7 @@ package io.openfuture.openmessenger.kurento.groupcall
 import com.google.gson.Gson
 import com.google.gson.GsonBuilder
 import com.google.gson.JsonObject
+import io.openfuture.openmessenger.kurento.UserRegistry
 import org.kurento.client.IceCandidate
 import org.slf4j.Logger
 import org.slf4j.LoggerFactory

src/main/kotlin/io/openfuture/openmessenger/kurento/recording/CallMediaPipeline.kt

@@ -0,0 +1,61 @@
+package io.openfuture.openmessenger.kurento.recording
+
+import org.kurento.client.*
+import java.text.SimpleDateFormat
+import java.util.*
+
+
+class CallMediaPipeline(kurento: KurentoClient, from: String, to: String?) {
+    val pipeline: MediaPipeline = kurento.createMediaPipeline()
+
+    val callerWebRtcEp: WebRtcEndpoint = WebRtcEndpoint.Builder(pipeline).build()
+    val calleeWebRtcEp: WebRtcEndpoint = WebRtcEndpoint.Builder(pipeline).build()
+    private val recorderCaller: RecorderEndpoint
+    private val recorderCallee: RecorderEndpoint
+
+    init {
+        recorderCaller = RecorderEndpoint.Builder(pipeline, RECORDING_PATH + from + RECORDING_EXT)
+            .build()
+        recorderCallee = RecorderEndpoint.Builder(pipeline, RECORDING_PATH + to + RECORDING_EXT)
+            .build()
+
+        callerWebRtcEp.connect(calleeWebRtcEp)
+        calleeWebRtcEp.connect(callerWebRtcEp)
+        val composite: Composite = Composite.Builder(pipeline).build()
+
+        val callerPort: HubPort = HubPort.Builder(composite).build()
+        val calleePort: HubPort = HubPort.Builder(composite).build()
+        val out = HubPort.Builder(composite).build()
+
+        callerWebRtcEp.connect(callerPort)
+        calleeWebRtcEp.connect(calleePort)
+
+        out.connect(recorderCallee)
+
+        // Connections
+        callerWebRtcEp.connect(calleeWebRtcEp)
+        callerWebRtcEp.connect(recorderCaller)
+
+        calleeWebRtcEp.connect(callerWebRtcEp)
+        calleeWebRtcEp.connect(recorderCallee)
+    }
+
+    fun record() {
+        recorderCaller.record()
+        recorderCallee.record()
+    }
+
+    fun generateSdpAnswerForCaller(sdpOffer: String?): String {
+        return callerWebRtcEp.processOffer(sdpOffer)
+    }
+
+    fun generateSdpAnswerForCallee(sdpOffer: String?): String {
+        return calleeWebRtcEp.processOffer(sdpOffer)
+    }
+
+    companion object {
+        private val df = SimpleDateFormat("yyyy-MM-dd_HH-mm-ss-S")
+        val RECORDING_PATH: String = "file:///tmp/" + df.format(Date()) + "-"
+        const val RECORDING_EXT: String = ".webm"
+    }
+}

src/main/kotlin/io/openfuture/openmessenger/kurento/recording/PlayMediaPipeline.kt

@@ -0,0 +1,59 @@
+package io.openfuture.openmessenger.kurento.recording
+
+import com.google.gson.JsonObject
+import io.openfuture.openmessenger.kurento.recording.CallMediaPipeline.Companion.RECORDING_EXT
+import io.openfuture.openmessenger.kurento.recording.CallMediaPipeline.Companion.RECORDING_PATH
+import org.kurento.client.KurentoClient
+import org.kurento.client.MediaPipeline
+import org.kurento.client.PlayerEndpoint
+import org.kurento.client.WebRtcEndpoint
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
+import org.springframework.web.socket.TextMessage
+import org.springframework.web.socket.WebSocketSession
+import java.io.IOException
+
+class PlayMediaPipeline(kurento: KurentoClient, user: String, session: WebSocketSession) {
+    val pipeline: MediaPipeline = kurento.createMediaPipeline()
+    var webRtc: WebRtcEndpoint?
+    val player: PlayerEndpoint
+
+    init {
+        webRtc = WebRtcEndpoint.Builder(pipeline).build()
+        player = PlayerEndpoint.Builder(pipeline, RECORDING_PATH + user + RECORDING_EXT).build()
+
+        player.connect(webRtc)
+
+        player.addErrorListener { event ->
+            log.info("ErrorEvent: {}", event.description)
+            sendPlayEnd(session)
+        }
+    }
+
+    fun sendPlayEnd(session: WebSocketSession) {
+        try {
+            val response: JsonObject = JsonObject()
+            response.addProperty("id", "playEnd")
+            session.sendMessage(TextMessage(response.toString()))
+        } catch (e: IOException) {
+            log.error("Error sending playEndOfStream message", e)
+        }
+
+        // Release pipeline
+        pipeline.release()
+        this.webRtc = null
+    }
+
+    fun play() {
+        player.play()
+    }
+
+    fun generateSdpAnswer(sdpOffer: String?): String {
+        val processOffer: String? = webRtc?.processOffer(sdpOffer)
+        return processOffer!!
+    }
+
+    companion object {
+        private val log: Logger = LoggerFactory.getLogger(PlayMediaPipeline::class.java)
+    }
+}