Skip to content

Commit

Permalink
fix : refactor go-lint code
Browse files Browse the repository at this point in the history
  • Loading branch information
JoeCP17 committed Jan 19, 2025
1 parent d95152e commit be42d04
Show file tree
Hide file tree
Showing 2 changed files with 17 additions and 2 deletions.
4 changes: 3 additions & 1 deletion internal/service/chat_service.go
Original file line number Diff line number Diff line change
Expand Up @@ -414,7 +414,9 @@ func (s *ChatService) SaveChatMessage(
return nil, databaseGenError
}

tx.Commit()
if err := tx.Commit(); err != nil {
return nil, err
}

return chat.ToChatRoomMessage(row), nil
}
15 changes: 14 additions & 1 deletion internal/wschat/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -125,14 +125,27 @@ func (s *WSServer) LoopOverClientMessages() {
var msg MessageResponse
switch msgReq.MessageType {
case "plain":
s.chatService.SaveChatMessage(
saveChatMessage, err := s.chatService.SaveChatMessage(
ctx,
msgReq.Sender.ID,
msgReq.Room.ID,
msgReq.MessageType,
msgReq.Message,
)
if err != nil {
log.Error().Err(err).Msg("Failed to save chat message")
msg = NewErrorMessageResponse(
msgReq.MessageID,
msgReq.Sender,
msgReq.Room,
"Failed to save chat message",
time.Now(),
)

break
}

log.Info().Msg("Save chat message: " + saveChatMessage.ID.String())
msg = NewPlainMessageResponse(
msgReq.MessageID,
msgReq.Sender,
Expand Down

0 comments on commit be42d04

Please sign in to comment.