2024-04-06 09:08:01 +00:00
|
|
|
package services
|
|
|
|
|
|
|
|
import (
|
2024-04-26 16:04:01 +00:00
|
|
|
"context"
|
2024-04-06 09:08:01 +00:00
|
|
|
"errors"
|
|
|
|
"fmt"
|
|
|
|
"git.solsynth.dev/hydrogen/messaging/pkg/database"
|
|
|
|
"git.solsynth.dev/hydrogen/messaging/pkg/models"
|
2024-04-27 14:20:48 +00:00
|
|
|
jsoniter "github.com/json-iterator/go"
|
2024-04-26 16:04:01 +00:00
|
|
|
"github.com/livekit/protocol/auth"
|
|
|
|
"github.com/livekit/protocol/livekit"
|
2024-04-06 09:08:01 +00:00
|
|
|
"github.com/rs/zerolog/log"
|
|
|
|
"github.com/samber/lo"
|
|
|
|
"github.com/spf13/viper"
|
|
|
|
"gorm.io/gorm"
|
|
|
|
"time"
|
|
|
|
)
|
|
|
|
|
|
|
|
func ListCall(channel models.Channel, take, offset int) ([]models.Call, error) {
|
|
|
|
var calls []models.Call
|
|
|
|
if err := database.C.
|
|
|
|
Where(models.Call{ChannelID: channel.ID}).
|
|
|
|
Limit(take).
|
|
|
|
Offset(offset).
|
|
|
|
Preload("Founder").
|
|
|
|
Preload("Founder.Account").
|
|
|
|
Preload("Channel").
|
|
|
|
Order("created_at DESC").
|
|
|
|
Find(&calls).Error; err != nil {
|
|
|
|
return calls, err
|
|
|
|
} else {
|
|
|
|
return calls, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func GetCall(channel models.Channel, id uint) (models.Call, error) {
|
|
|
|
var call models.Call
|
|
|
|
if err := database.C.
|
|
|
|
Where(models.Call{
|
|
|
|
BaseModel: models.BaseModel{ID: id},
|
|
|
|
ChannelID: channel.ID,
|
|
|
|
}).
|
|
|
|
Preload("Founder").
|
|
|
|
Preload("Founder.Account").
|
|
|
|
Preload("Channel").
|
|
|
|
Order("created_at DESC").
|
|
|
|
First(&call).Error; err != nil {
|
|
|
|
return call, err
|
|
|
|
} else {
|
|
|
|
return call, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func GetOngoingCall(channel models.Channel) (models.Call, error) {
|
|
|
|
var call models.Call
|
|
|
|
if err := database.C.
|
|
|
|
Where(models.Call{ChannelID: channel.ID}).
|
|
|
|
Where("ended_at IS NULL").
|
|
|
|
Preload("Founder").
|
|
|
|
Preload("Channel").
|
|
|
|
Order("created_at DESC").
|
|
|
|
First(&call).Error; err != nil {
|
|
|
|
return call, err
|
|
|
|
} else {
|
|
|
|
return call, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func NewCall(channel models.Channel, founder models.ChannelMember) (models.Call, error) {
|
|
|
|
call := models.Call{
|
2024-04-26 16:04:01 +00:00
|
|
|
ExternalID: channel.Alias,
|
2024-04-06 09:08:01 +00:00
|
|
|
FounderID: founder.ID,
|
|
|
|
ChannelID: channel.ID,
|
|
|
|
Founder: founder,
|
|
|
|
Channel: channel,
|
|
|
|
}
|
|
|
|
|
|
|
|
if _, err := GetOngoingCall(channel); err == nil || !errors.Is(err, gorm.ErrRecordNotFound) {
|
|
|
|
return call, fmt.Errorf("this channel already has an ongoing call")
|
|
|
|
}
|
|
|
|
|
2024-06-08 12:38:03 +00:00
|
|
|
_, err := Lk.CreateRoom(context.Background(), &livekit.CreateRoomRequest{
|
2024-04-26 16:04:01 +00:00
|
|
|
Name: call.ExternalID,
|
|
|
|
EmptyTimeout: viper.GetUint32("calling.empty_timeout_duration"),
|
|
|
|
MaxParticipants: viper.GetUint32("calling.max_participants"),
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return call, fmt.Errorf("remote livekit error: %v", err)
|
|
|
|
}
|
|
|
|
|
2024-04-06 09:08:01 +00:00
|
|
|
var members []models.ChannelMember
|
|
|
|
if err := database.C.Save(&call).Error; err != nil {
|
|
|
|
return call, err
|
|
|
|
} else if err = database.C.Where(models.ChannelMember{
|
|
|
|
ChannelID: call.ChannelID,
|
|
|
|
}).Preload("Account").Find(&members).Error; err == nil {
|
2024-04-06 15:04:53 +00:00
|
|
|
channel := call.Channel
|
2024-04-06 09:08:01 +00:00
|
|
|
call, _ = GetCall(call.Channel, call.ID)
|
|
|
|
for _, member := range members {
|
|
|
|
if member.ID != call.Founder.ID {
|
2024-06-08 04:49:26 +00:00
|
|
|
err = NotifyAccountMessager(member.Account,
|
2024-06-08 08:34:14 +00:00
|
|
|
"incomingCall",
|
2024-06-08 04:49:26 +00:00
|
|
|
fmt.Sprintf("Call in #%s", channel.Alias),
|
|
|
|
fmt.Sprintf("%s started a new call", call.Founder.Account.Name),
|
|
|
|
false,
|
|
|
|
true,
|
|
|
|
)
|
|
|
|
if err != nil {
|
|
|
|
log.Warn().Err(err).Msg("An error occurred when trying notify user.")
|
2024-04-06 09:08:01 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
PushCommand(member.AccountID, models.UnifiedCommand{
|
|
|
|
Action: "calls.new",
|
|
|
|
Payload: call,
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return call, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func EndCall(call models.Call) (models.Call, error) {
|
|
|
|
call.EndedAt = lo.ToPtr(time.Now())
|
|
|
|
|
2024-06-08 12:38:03 +00:00
|
|
|
if _, err := Lk.DeleteRoom(context.Background(), &livekit.DeleteRoomRequest{
|
2024-04-26 16:04:01 +00:00
|
|
|
Room: call.ExternalID,
|
|
|
|
}); err != nil {
|
|
|
|
log.Error().Err(err).Msg("Unable to delete room at livekit side")
|
|
|
|
}
|
|
|
|
|
2024-04-06 09:08:01 +00:00
|
|
|
var members []models.ChannelMember
|
|
|
|
if err := database.C.Save(&call).Error; err != nil {
|
|
|
|
return call, err
|
|
|
|
} else if err = database.C.Where(models.ChannelMember{
|
|
|
|
ChannelID: call.ChannelID,
|
|
|
|
}).Preload("Account").Find(&members).Error; err == nil {
|
|
|
|
call, _ = GetCall(call.Channel, call.ID)
|
|
|
|
for _, member := range members {
|
|
|
|
PushCommand(member.AccountID, models.UnifiedCommand{
|
|
|
|
Action: "calls.end",
|
|
|
|
Payload: call,
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return call, nil
|
|
|
|
}
|
|
|
|
|
2024-04-26 16:04:01 +00:00
|
|
|
func EncodeCallToken(user models.Account, call models.Call) (string, error) {
|
|
|
|
isAdmin := false
|
|
|
|
if user.ID == call.FounderID || user.ID == call.Channel.AccountID {
|
|
|
|
isAdmin = true
|
|
|
|
}
|
|
|
|
|
|
|
|
grant := &auth.VideoGrant{
|
|
|
|
Room: call.ExternalID,
|
|
|
|
RoomJoin: true,
|
|
|
|
RoomAdmin: isAdmin,
|
|
|
|
}
|
|
|
|
|
2024-04-27 14:20:48 +00:00
|
|
|
metadata, _ := jsoniter.Marshal(user)
|
|
|
|
|
2024-04-26 16:04:01 +00:00
|
|
|
duration := time.Second * time.Duration(viper.GetInt("calling.token_duration"))
|
|
|
|
tk := auth.NewAccessToken(viper.GetString("calling.api_key"), viper.GetString("calling.api_secret"))
|
2024-04-27 14:20:48 +00:00
|
|
|
tk.AddGrant(grant).
|
|
|
|
SetIdentity(user.Name).
|
|
|
|
SetName(user.Nick).
|
|
|
|
SetMetadata(string(metadata)).
|
|
|
|
SetValidFor(duration)
|
2024-04-06 09:08:01 +00:00
|
|
|
|
2024-04-26 16:04:01 +00:00
|
|
|
return tk.ToJWT()
|
2024-04-06 09:08:01 +00:00
|
|
|
}
|