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 // Check if name is on the blocklist 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 } } // Check if the name is not already assigned to a registered user. if available, err := user.IsDisplayNameAvailable(proposedUsername); err != nil { log.Errorln("error checking if name is available", err) return } else if !available { message := fmt.Sprintf("The name **%s** has been already registered. If this is your name, please authenticate.", 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 if err := user.ChangeUsername(eventData.client.User.ID, receivedEvent.NewName); err != nil { log.Errorln("error changing username", err) } // 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) chatMessagesSentCounter.Inc() SaveUserMessage(event) eventData.client.MessageCount++ _lastSeenCache[event.User.ID] = time.Now() }