tsk-16: Permitting identical messages by a user (#21)
Closes #16 Reviewed-on: phoenix/textsender-api#21 Co-authored-by: phoenix <kundeng00@pm.me> Co-committed-by: phoenix <kundeng00@pm.me>
This commit is contained in:
@@ -45,23 +45,13 @@ func (m *MessageHandler) AddMessage(w http.ResponseWriter, r *http.Request) {
|
|||||||
}
|
}
|
||||||
defer r.Body.Close()
|
defer r.Body.Close()
|
||||||
|
|
||||||
newMessage := message.Message{Content: req.Content, UserId: req.UserId}
|
|
||||||
|
|
||||||
var statusCode int
|
var statusCode int
|
||||||
var resp AddMessageResponse
|
var resp AddMessageResponse
|
||||||
|
newMessage := message.Message{Content: req.Content, UserId: req.UserId}
|
||||||
|
|
||||||
ctx := r.Context()
|
ctx := r.Context()
|
||||||
|
|
||||||
if exists, err := m.MessageStore.MessageExists(ctx, &newMessage); err != nil {
|
if err := m.MessageStore.CreateMessage(ctx, &newMessage); err != nil {
|
||||||
fmt.Println("Error: ", err)
|
|
||||||
statusCode = http.StatusInternalServerError
|
|
||||||
resp.Message = err.Error()
|
|
||||||
} else {
|
|
||||||
if exists {
|
|
||||||
statusCode = http.StatusBadRequest
|
|
||||||
resp.Message = "Cannot create message"
|
|
||||||
} else {
|
|
||||||
if err = m.MessageStore.CreateMessage(ctx, &newMessage); err != nil {
|
|
||||||
fmt.Println("Error:", err)
|
fmt.Println("Error:", err)
|
||||||
statusCode = http.StatusInternalServerError
|
statusCode = http.StatusInternalServerError
|
||||||
resp.Message = err.Error()
|
resp.Message = err.Error()
|
||||||
@@ -70,8 +60,6 @@ func (m *MessageHandler) AddMessage(w http.ResponseWriter, r *http.Request) {
|
|||||||
resp.Message = "Message created"
|
resp.Message = "Message created"
|
||||||
resp.Data = append(resp.Data, newMessage)
|
resp.Data = append(resp.Data, newMessage)
|
||||||
}
|
}
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
RespondWithJSON(w, statusCode, &resp)
|
RespondWithJSON(w, statusCode, &resp)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user