mirror of
https://github.com/mattermost/mattermost.git
synced 2025-02-25 18:55:24 -06:00
868bd76f40
* Add support for Kopano Webmeetings WebRTC server Add an option to select which WebRTC server to use and add support to use Kopano Webmeetings as backend instead of Janus. If the new configuration is not set, WebRTC assumes Janus is used as backend. * Fixup: remove redundant case. default to janus * Fixup: use GatewayAdminUrl as direct prefix to admin URL entry point * Fixup: consumeAndClose
132 lines
4.4 KiB
Go
132 lines
4.4 KiB
Go
// Copyright (c) 2017 Mattermost, Inc. All Rights Reserved.
|
|
// See License.txt for license information.
|
|
|
|
package app
|
|
|
|
import (
|
|
"crypto/hmac"
|
|
"crypto/sha1"
|
|
"encoding/base64"
|
|
"net/http"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/mattermost/mattermost-server/model"
|
|
"github.com/mattermost/mattermost-server/utils"
|
|
)
|
|
|
|
func GetWebrtcInfoForSession(sessionId string) (*model.WebrtcInfoResponse, *model.AppError) {
|
|
token, err := GetWebrtcToken(sessionId)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
result := &model.WebrtcInfoResponse{
|
|
Token: token,
|
|
GatewayUrl: *utils.Cfg.WebrtcSettings.GatewayWebsocketUrl,
|
|
GatewayType: *utils.Cfg.WebrtcSettings.GatewayType,
|
|
}
|
|
|
|
if len(*utils.Cfg.WebrtcSettings.StunURI) > 0 {
|
|
result.StunUri = *utils.Cfg.WebrtcSettings.StunURI
|
|
}
|
|
|
|
if len(*utils.Cfg.WebrtcSettings.TurnURI) > 0 {
|
|
timestamp := strconv.FormatInt(utils.EndOfDay(time.Now().AddDate(0, 0, 1)).Unix(), 10)
|
|
username := timestamp + ":" + *utils.Cfg.WebrtcSettings.TurnUsername
|
|
|
|
result.TurnUri = *utils.Cfg.WebrtcSettings.TurnURI
|
|
result.TurnPassword = GenerateTurnPassword(username, *utils.Cfg.WebrtcSettings.TurnSharedKey)
|
|
result.TurnUsername = username
|
|
}
|
|
|
|
return result, nil
|
|
}
|
|
|
|
func GetWebrtcToken(sessionId string) (string, *model.AppError) {
|
|
if !*utils.Cfg.WebrtcSettings.Enable {
|
|
return "", model.NewAppError("WebRTC.getWebrtcToken", "api.webrtc.disabled.app_error", nil, "", http.StatusNotImplemented)
|
|
}
|
|
|
|
switch strings.ToLower(*utils.Cfg.WebrtcSettings.GatewayType) {
|
|
case "kopano-webmeetings":
|
|
return GetKopanoWebmeetingsWebrtcToken(sessionId)
|
|
default:
|
|
// Default to Janus.
|
|
return GetJanusWebrtcToken(sessionId)
|
|
}
|
|
}
|
|
|
|
func GetJanusWebrtcToken(sessionId string) (string, *model.AppError) {
|
|
token := base64.StdEncoding.EncodeToString([]byte(sessionId))
|
|
|
|
data := make(map[string]string)
|
|
data["janus"] = "add_token"
|
|
data["token"] = token
|
|
data["transaction"] = model.NewId()
|
|
data["admin_secret"] = *utils.Cfg.WebrtcSettings.GatewayAdminSecret
|
|
|
|
rq, _ := http.NewRequest("POST", *utils.Cfg.WebrtcSettings.GatewayAdminUrl, strings.NewReader(model.MapToJson(data)))
|
|
rq.Header.Set("Content-Type", "application/json")
|
|
|
|
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 {
|
|
janusResponse := model.JanusGatewayResponseFromJson(rp.Body)
|
|
if janusResponse.Status != "success" {
|
|
return "", model.NewAppError("getWebrtcToken", "api.webrtc.register_token.app_error", nil, "", http.StatusInternalServerError)
|
|
}
|
|
}
|
|
|
|
return token, nil
|
|
}
|
|
|
|
func GetKopanoWebmeetingsWebrtcToken(sessionId string) (string, *model.AppError) {
|
|
data := make(map[string]string)
|
|
data["type"] = "Token"
|
|
data["id"] = sessionId
|
|
|
|
rq, _ := http.NewRequest("POST", *utils.Cfg.WebrtcSettings.GatewayAdminUrl+"/auth/tokens", strings.NewReader(model.MapToJson(data)))
|
|
rq.Header.Set("Content-Type", "application/json")
|
|
rq.Header.Set("Authorization", "Bearer "+*utils.Cfg.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)
|
|
h.Write([]byte(username))
|
|
return base64.StdEncoding.EncodeToString(h.Sum(nil))
|
|
}
|
|
|
|
func RevokeWebrtcToken(sessionId string) {
|
|
token := base64.StdEncoding.EncodeToString([]byte(sessionId))
|
|
data := make(map[string]string)
|
|
data["janus"] = "remove_token"
|
|
data["token"] = token
|
|
data["transaction"] = model.NewId()
|
|
data["admin_secret"] = *utils.Cfg.WebrtcSettings.GatewayAdminSecret
|
|
|
|
rq, _ := http.NewRequest("POST", *utils.Cfg.WebrtcSettings.GatewayAdminUrl, strings.NewReader(model.MapToJson(data)))
|
|
rq.Header.Set("Content-Type", "application/json")
|
|
|
|
// we do not care about the response
|
|
utils.HttpClient(true).Do(rq)
|
|
}
|