summaryrefslogtreecommitdiffstats
path: root/app/webrtc.go
diff options
context:
space:
mode:
authorJason Blais <jason@spinpunch.com>2017-11-06 13:23:15 -0500
committerChristopher Speller <crspeller@gmail.com>2017-11-06 10:23:15 -0800
commit4731057e5063c2d50ede9f4b621414881b520daf (patch)
tree9c1b4e0b388c30b470de5b50799a76f930ce5eea /app/webrtc.go
parent1af182c198c67e0ea068308992772d4867cb0d40 (diff)
downloadchat-4731057e5063c2d50ede9f4b621414881b520daf.tar.gz
chat-4731057e5063c2d50ede9f4b621414881b520daf.tar.bz2
chat-4731057e5063c2d50ede9f4b621414881b520daf.zip
Revert PLT-7809 (#7793)
* Update webrtc_test.go * Update webrtc.go * Update config.go * Update webrtc.go
Diffstat (limited to 'app/webrtc.go')
-rw-r--r--app/webrtc.go40
1 files changed, 3 insertions, 37 deletions
diff --git a/app/webrtc.go b/app/webrtc.go
index 28c754622..b8b0a2827 100644
--- a/app/webrtc.go
+++ b/app/webrtc.go
@@ -23,9 +23,8 @@ func (a *App) GetWebrtcInfoForSession(sessionId string) (*model.WebrtcInfoRespon
}
result := &model.WebrtcInfoResponse{
- Token: token,
- GatewayUrl: *a.Config().WebrtcSettings.GatewayWebsocketUrl,
- GatewayType: *a.Config().WebrtcSettings.GatewayType,
+ Token: token,
+ GatewayUrl: *a.Config().WebrtcSettings.GatewayWebsocketUrl,
}
if len(*a.Config().WebrtcSettings.StunURI) > 0 {
@@ -49,16 +48,6 @@ func (a *App) GetWebrtcToken(sessionId string) (string, *model.AppError) {
return "", model.NewAppError("WebRTC.getWebrtcToken", "api.webrtc.disabled.app_error", nil, "", http.StatusNotImplemented)
}
- switch strings.ToLower(*a.Config().WebrtcSettings.GatewayType) {
- case "kopano-webmeetings":
- return a.GetKopanoWebmeetingsWebrtcToken(sessionId)
- default:
- // Default to Janus.
- return a.GetJanusWebrtcToken(sessionId)
- }
-}
-
-func (a *App) GetJanusWebrtcToken(sessionId string) (string, *model.AppError) {
token := base64.StdEncoding.EncodeToString([]byte(sessionId))
data := make(map[string]string)
@@ -76,7 +65,7 @@ func (a *App) GetJanusWebrtcToken(sessionId string) (string, *model.AppError) {
defer consumeAndClose(rp)
return "", model.AppErrorFromJson(rp.Body)
} else {
- janusResponse := model.JanusGatewayResponseFromJson(rp.Body)
+ janusResponse := model.GatewayResponseFromJson(rp.Body)
if janusResponse.Status != "success" {
return "", model.NewAppError("getWebrtcToken", "api.webrtc.register_token.app_error", nil, "", http.StatusInternalServerError)
}
@@ -85,29 +74,6 @@ func (a *App) GetJanusWebrtcToken(sessionId string) (string, *model.AppError) {
return token, nil
}
-func (a *App) GetKopanoWebmeetingsWebrtcToken(sessionId string) (string, *model.AppError) {
- data := make(map[string]string)
- data["type"] = "Token"
- data["id"] = sessionId
-
- rq, _ := http.NewRequest("POST", *a.Config().WebrtcSettings.GatewayAdminUrl+"/auth/tokens", strings.NewReader(model.MapToJson(data)))
- rq.Header.Set("Content-Type", "application/json")
- rq.Header.Set("Authorization", "Bearer "+*a.Config().WebrtcSettings.GatewayAdminSecret)
-
- if rp, err := utils.HttpClient(true).Do(rq); err != nil {
- return "", model.NewAppError("WebRTC.Token", "model.client.connecting.app_error", nil, err.Error(), http.StatusInternalServerError)
- } else if rp.StatusCode >= 300 {
- defer consumeAndClose(rp)
- return "", model.AppErrorFromJson(rp.Body)
- } else {
- kwmResponse := model.KopanoWebmeetingsResponseFromJson(rp.Body)
- if kwmResponse.Value == "" {
- return "", model.NewAppError("getWebrtcToken", "api.webrtc.register_token.app_error", nil, "", http.StatusInternalServerError)
- }
- return kwmResponse.Value, nil
- }
-}
-
func GenerateTurnPassword(username string, secret string) string {
key := []byte(secret)
h := hmac.New(sha1.New, key)