You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
43 lines
1.1 KiB
43 lines
1.1 KiB
package rtc
|
|
|
|
import (
|
|
"Open_IM/pkg/common/log"
|
|
pbRtc "Open_IM/pkg/proto/rtc"
|
|
"Open_IM/pkg/utils"
|
|
"context"
|
|
"time"
|
|
|
|
"github.com/livekit/protocol/auth"
|
|
//lksdk "github.com/livekit/server-sdk-go"
|
|
)
|
|
|
|
type RtcService struct {
|
|
|
|
}
|
|
|
|
func (r *RtcService) GetJoinToken(_ context.Context, req *pbRtc.GetJoinTokenReq) (resp *pbRtc.GetJoinTokenResp, err error) {
|
|
log.NewInfo(req.OperationID, utils.GetSelfFuncName(), "req: ", req.String())
|
|
resp = &pbRtc.GetJoinTokenResp{}
|
|
canPublish := true
|
|
canSubscribe := true
|
|
at := auth.NewAccessToken(req.ApiKey, req.ApiSecret)
|
|
grant := &auth.VideoGrant{
|
|
RoomJoin: true,
|
|
Room: req.Room,
|
|
CanPublish: &canPublish,
|
|
CanSubscribe: &canSubscribe,
|
|
}
|
|
at.AddGrant(grant).
|
|
SetIdentity(req.Identity).
|
|
// optional
|
|
SetName("participant-name").
|
|
SetValidFor(time.Hour)
|
|
jwt, err := at.ToJWT()
|
|
if err != nil {
|
|
log.NewError(req.OperationID, utils.GetSelfFuncName(), "toJwt failed", err.Error(), "jwt: ", jwt)
|
|
}
|
|
resp.Jwt = jwt
|
|
resp.CommonResp = &pbRtc.CommonResp{}
|
|
log.NewInfo(req.OperationID, utils.GetSelfFuncName(), "resp: ", resp.String())
|
|
return resp, err
|
|
} |