117 lines
3.2 KiB
Go
117 lines
3.2 KiB
Go
package chat
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/owncast/owncast/core/chat/events"
|
|
"github.com/owncast/owncast/core/data"
|
|
"github.com/owncast/owncast/core/user"
|
|
"github.com/owncast/owncast/core/webhooks"
|
|
log "github.com/sirupsen/logrus"
|
|
)
|
|
|
|
func (s *Server) userNameChanged(eventData chatClientEvent) {
|
|
var receivedEvent events.NameChangeEvent
|
|
if err := json.Unmarshal(eventData.data, &receivedEvent); err != nil {
|
|
log.Errorln("error unmarshalling to NameChangeEvent", err)
|
|
return
|
|
}
|
|
|
|
proposedUsername := receivedEvent.NewName
|
|
blocklist := data.GetForbiddenUsernameList()
|
|
|
|
for _, blockedName := range blocklist {
|
|
normalizedName := strings.TrimSpace(blockedName)
|
|
normalizedName = strings.ToLower(normalizedName)
|
|
if strings.Contains(normalizedName, proposedUsername) {
|
|
// Denied.
|
|
log.Debugln(eventData.client.User.DisplayName, "blocked from changing name to", proposedUsername, "due to blocked name", normalizedName)
|
|
message := fmt.Sprintf("You cannot change your name to **%s**.", proposedUsername)
|
|
s.sendActionToClient(eventData.client, message)
|
|
|
|
// Resend the client's user so their username is in sync.
|
|
eventData.client.sendConnectedClientInfo()
|
|
|
|
return
|
|
}
|
|
}
|
|
|
|
savedUser := user.GetUserByToken(eventData.client.accessToken)
|
|
oldName := savedUser.DisplayName
|
|
|
|
// Save the new name
|
|
user.ChangeUsername(eventData.client.User.ID, receivedEvent.NewName)
|
|
|
|
// Update the connected clients associated user with the new name
|
|
now := time.Now()
|
|
eventData.client.User = savedUser
|
|
eventData.client.User.NameChangedAt = &now
|
|
|
|
// Send chat event letting everyone about about the name change
|
|
savedUser.DisplayName = receivedEvent.NewName
|
|
|
|
broadcastEvent := events.NameChangeBroadcast{
|
|
Oldname: oldName,
|
|
}
|
|
broadcastEvent.User = savedUser
|
|
broadcastEvent.SetDefaults()
|
|
payload := broadcastEvent.GetBroadcastPayload()
|
|
if err := s.Broadcast(payload); err != nil {
|
|
log.Errorln("error broadcasting NameChangeEvent", err)
|
|
return
|
|
}
|
|
|
|
// Send chat user name changed webhook
|
|
receivedEvent.User = savedUser
|
|
receivedEvent.ClientID = eventData.client.id
|
|
webhooks.SendChatEventUsernameChanged(receivedEvent)
|
|
}
|
|
|
|
func (s *Server) userMessageSent(eventData chatClientEvent) {
|
|
var event events.UserMessageEvent
|
|
if err := json.Unmarshal(eventData.data, &event); err != nil {
|
|
log.Errorln("error unmarshalling to UserMessageEvent", err)
|
|
return
|
|
}
|
|
|
|
event.SetDefaults()
|
|
event.ClientID = eventData.client.id
|
|
|
|
// Ignore empty messages
|
|
if event.Empty() {
|
|
return
|
|
}
|
|
|
|
// Ignore if the stream has been offline
|
|
if !getStatus().Online && getStatus().LastDisconnectTime != nil {
|
|
disconnectedTime := getStatus().LastDisconnectTime.Time
|
|
if time.Since(disconnectedTime) > 5*time.Minute {
|
|
return
|
|
}
|
|
}
|
|
|
|
event.User = user.GetUserByToken(eventData.client.accessToken)
|
|
|
|
// Guard against nil users
|
|
if event.User == nil {
|
|
return
|
|
}
|
|
|
|
payload := event.GetBroadcastPayload()
|
|
if err := s.Broadcast(payload); err != nil {
|
|
log.Errorln("error broadcasting UserMessageEvent payload", err)
|
|
return
|
|
}
|
|
|
|
// Send chat message sent webhook
|
|
webhooks.SendChatEvent(&event)
|
|
|
|
SaveUserMessage(event)
|
|
|
|
eventData.client.MessageCount++
|
|
_lastSeenCache[event.User.ID] = time.Now()
|
|
}
|