Recording mixed file

Author: borbuevbeksultan

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

@@ -13,36 +13,38 @@ class CallMediaPipeline(kurento: KurentoClient, from: String, to: String?) {
     private val recorderCaller: RecorderEndpoint
     private val recorderCallee: RecorderEndpoint
 
+    val composite: Composite = Composite.Builder(pipeline).build()
+    val out = HubPort.Builder(composite).build()
+    val recorder: RecorderEndpoint = RecorderEndpoint.Builder(pipeline, RECORDING_PATH + "combined" + RECORDING_EXT)
+        .build()
+
     init {
         recorderCaller = RecorderEndpoint.Builder(pipeline, RECORDING_PATH + from + RECORDING_EXT)
             .build()
         recorderCallee = RecorderEndpoint.Builder(pipeline, RECORDING_PATH + to + RECORDING_EXT)
             .build()
 
         callerWebRtcEp.connect(calleeWebRtcEp)
+        callerWebRtcEp.connect(recorderCaller)
+
         calleeWebRtcEp.connect(callerWebRtcEp)
-        val composite: Composite = Composite.Builder(pipeline).build()
+        calleeWebRtcEp.connect(recorderCallee)
 
+        // mixing
         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)
+        out.connect(recorder)
     }
 
     fun record() {
         recorderCaller.record()
         recorderCallee.record()
+        recorder.record()
     }
 
     fun generateSdpAnswerForCaller(sdpOffer: String?): String {