Apply video policy on proxy

callconfig.go

@@ -12,6 +12,7 @@ import (
 
 type callConfig struct {
 	iceServers []webrtc.ICEServer
+	allowVideo bool
 }
 
 // This configuration is intialized as soon as
@@ -28,4 +29,7 @@ func setCallConfig(data map[string]interface{}) {
 			URLs: []string{server.(string)},
 		})
 	}
+
+	// Update allow video status
+	callConf.allowVideo = data["allowVideo"].(bool)
 }

relay.go

@@ -261,11 +261,13 @@ func newCall(mainOffer receivedSignal, r *activeRelay) {
 	})
 
 	// Allow us to receive 1 audio & 1 video track
-	if _, err = mainPeerConnection.AddTransceiverFromKind(webrtc.RTPCodecTypeVideo,
+	if callConf.allowVideo {
-		webrtc.RtpTransceiverInit{Direction: webrtc.RTPTransceiverDirectionRecvonly}); err != nil {
+		if _, err = mainPeerConnection.AddTransceiverFromKind(webrtc.RTPCodecTypeVideo,
-		log.Println("Error: could not prepare to receive video track!", err)
+			webrtc.RtpTransceiverInit{Direction: webrtc.RTPTransceiverDirectionRecvonly}); err != nil {
-		askForClose(r)
+			log.Println("Error: could not prepare to receive video track!", err)
-		return
+			askForClose(r)
+			return
+		}
 	}
 
 	if _, err = mainPeerConnection.AddTransceiverFromKind(webrtc.RTPCodecTypeAudio,
@@ -304,6 +306,13 @@ func newCall(mainOffer receivedSignal, r *activeRelay) {
 		trackID := "audio"
 		trackLabel := "pion" // We need only one track label
 		if remoteTrack.Kind() == webrtc.RTPCodecTypeVideo {
+
+			// Check if video calls are allowed
+			if !callConf.allowVideo {
+				log.Printf("Blocked a video stream! Call hash: %s", r.callHash)
+				return
+			}
+
 			trackID = "video" // We need two different track ids
 		}
 

ws.go

@@ -6,6 +6,7 @@ package main
 
 import (
 	"encoding/json"
+	"fmt"
 	"log"
 	"os"
 	"os/signal"
@@ -76,6 +77,7 @@ func openWs(conf *Config) {
 		case "config":
 			println("Got call configuration")
 			setCallConfig(msg.Data.(map[string]interface{}))
+			fmt.Println("Enable video calls:", callConf.allowVideo)
 			break
 
 		// Remote signal