diff options
author | Harrison Healey <harrisonmhealey@gmail.com> | 2016-11-30 13:55:49 -0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2016-11-30 13:55:49 -0500 |
commit | 165ad0d4f791f8ae2109472d8a626d911fa368e0 (patch) | |
tree | 29001baf676d7d4ef4cd9462e9f2c6766ed6333a /api/reaction.go | |
parent | 2bf0342d130b3a77c5ed02e98e0857f28a5787f0 (diff) | |
download | chat-165ad0d4f791f8ae2109472d8a626d911fa368e0.tar.gz chat-165ad0d4f791f8ae2109472d8a626d911fa368e0.tar.bz2 chat-165ad0d4f791f8ae2109472d8a626d911fa368e0.zip |
PLT-1378 Initial version of emoji reactions (#4520)
* Refactored emoji.json to support multiple aliases and emoji categories
* Added custom category to emoji.jsx and stabilized all fields
* Removed conflicting aliases for :mattermost: and :ca:
* fixup after store changes
* Added emoji reactions
* Removed reactions for an emoji when that emoji is deleted
* Fixed incorrect test case
* Renamed ReactionList to ReactionListView
* Fixed :+1: and :-1: not showing up as possible reactions
* Removed text emoticons from emoji reaction autocomplete
* Changed emoji reactions to be sorted by the order that they were first created
* Set a maximum number of listeners for the ReactionStore
* Removed unused code from Textbox component
* Fixed reaction permissions
* Changed error code when trying to modify reactions for another user
* Fixed merge conflicts
* Properly applied theme colours to reactions
* Fixed ESLint and gofmt errors
* Fixed ReactionListContainer to properly update when its post prop changes
* Removed unnecessary escape characters from reaction regexes
* Shared reaction message pattern between CreatePost and CreateComment
* Removed an unnecessary select query when saving a reaction
* Changed reactions route to be under /reactions
* Fixed copyright dates on newly added files
* Removed debug code that prevented all unit tests from being ran
* Cleaned up unnecessary code for reactions
* Renamed ReactionStore.List to ReactionStore.GetForPost
Diffstat (limited to 'api/reaction.go')
-rw-r--r-- | api/reaction.go | 203 |
1 files changed, 203 insertions, 0 deletions
diff --git a/api/reaction.go b/api/reaction.go new file mode 100644 index 000000000..5acf09f9e --- /dev/null +++ b/api/reaction.go @@ -0,0 +1,203 @@ +// Copyright (c) 2016 Mattermost, Inc. All Rights Reserved. +// See License.txt for license information. + +package api + +import ( + l4g "github.com/alecthomas/log4go" + "github.com/gorilla/mux" + "github.com/mattermost/platform/model" + "github.com/mattermost/platform/utils" + "net/http" +) + +func InitReaction() { + l4g.Debug(utils.T("api.reaction.init.debug")) + + BaseRoutes.NeedPost.Handle("/reactions/save", ApiUserRequired(saveReaction)).Methods("POST") + BaseRoutes.NeedPost.Handle("/reactions/delete", ApiUserRequired(deleteReaction)).Methods("POST") + BaseRoutes.NeedPost.Handle("/reactions", ApiUserRequired(listReactions)).Methods("GET") +} + +func saveReaction(c *Context, w http.ResponseWriter, r *http.Request) { + reaction := model.ReactionFromJson(r.Body) + if reaction == nil { + c.SetInvalidParam("saveReaction", "reaction") + return + } + + if reaction.UserId != c.Session.UserId { + c.Err = model.NewLocAppError("saveReaction", "api.reaction.save_reaction.user_id.app_error", nil, "") + c.Err.StatusCode = http.StatusForbidden + return + } + + params := mux.Vars(r) + + channelId := params["channel_id"] + if len(channelId) != 26 { + c.SetInvalidParam("saveReaction", "channelId") + return + } + + if !HasPermissionToChannelContext(c, channelId, model.PERMISSION_READ_CHANNEL) { + return + } + + postId := params["post_id"] + if len(postId) != 26 || postId != reaction.PostId { + c.SetInvalidParam("saveReaction", "postId") + return + } + + pchan := Srv.Store.Post().Get(reaction.PostId) + + var postHadReactions bool + if result := <-pchan; result.Err != nil { + c.Err = result.Err + return + } else if post := result.Data.(*model.PostList).Posts[postId]; post.ChannelId != channelId { + c.Err = model.NewLocAppError("saveReaction", "api.reaction.save_reaction.mismatched_channel_id.app_error", + nil, "channelId="+channelId+", post.ChannelId="+post.ChannelId+", postId="+postId) + c.Err.StatusCode = http.StatusBadRequest + return + } else { + postHadReactions = post.HasReactions + } + + if result := <-Srv.Store.Reaction().Save(reaction); result.Err != nil { + c.Err = result.Err + return + } else { + go sendReactionEvent(model.WEBSOCKET_EVENT_REACTION_ADDED, channelId, reaction, postHadReactions) + + reaction := result.Data.(*model.Reaction) + + w.Write([]byte(reaction.ToJson())) + } +} + +func deleteReaction(c *Context, w http.ResponseWriter, r *http.Request) { + reaction := model.ReactionFromJson(r.Body) + if reaction == nil { + c.SetInvalidParam("deleteReaction", "reaction") + return + } + + if reaction.UserId != c.Session.UserId { + c.Err = model.NewLocAppError("deleteReaction", "api.reaction.delete_reaction.user_id.app_error", nil, "") + c.Err.StatusCode = http.StatusForbidden + return + } + + params := mux.Vars(r) + + channelId := params["channel_id"] + if len(channelId) != 26 { + c.SetInvalidParam("deleteReaction", "channelId") + return + } + + if !HasPermissionToChannelContext(c, channelId, model.PERMISSION_READ_CHANNEL) { + return + } + + postId := params["post_id"] + if len(postId) != 26 || postId != reaction.PostId { + c.SetInvalidParam("deleteReaction", "postId") + return + } + + pchan := Srv.Store.Post().Get(reaction.PostId) + + var postHadReactions bool + if result := <-pchan; result.Err != nil { + c.Err = result.Err + return + } else if post := result.Data.(*model.PostList).Posts[postId]; post.ChannelId != channelId { + c.Err = model.NewLocAppError("deleteReaction", "api.reaction.delete_reaction.mismatched_channel_id.app_error", + nil, "channelId="+channelId+", post.ChannelId="+post.ChannelId+", postId="+postId) + c.Err.StatusCode = http.StatusBadRequest + return + } else { + postHadReactions = post.HasReactions + } + + if result := <-Srv.Store.Reaction().Delete(reaction); result.Err != nil { + c.Err = result.Err + return + } else { + go sendReactionEvent(model.WEBSOCKET_EVENT_REACTION_REMOVED, channelId, reaction, postHadReactions) + + ReturnStatusOK(w) + } +} + +func sendReactionEvent(event string, channelId string, reaction *model.Reaction, postHadReactions bool) { + // send out that a reaction has been added/removed + go func() { + message := model.NewWebSocketEvent(event, "", channelId, "", nil) + message.Add("reaction", reaction.ToJson()) + + Publish(message) + }() + + // send out that a post was updated if post.HasReactions has changed + go func() { + var post *model.Post + if result := <-Srv.Store.Post().Get(reaction.PostId); result.Err != nil { + l4g.Warn(utils.T("api.reaction.send_reaction_event.post.app_error")) + return + } else { + post = result.Data.(*model.PostList).Posts[reaction.PostId] + } + + if post.HasReactions != postHadReactions { + message := model.NewWebSocketEvent(model.WEBSOCKET_EVENT_POST_EDITED, "", channelId, "", nil) + message.Add("post", post.ToJson()) + + Publish(message) + } + }() +} + +func listReactions(c *Context, w http.ResponseWriter, r *http.Request) { + params := mux.Vars(r) + + channelId := params["channel_id"] + if len(channelId) != 26 { + c.SetInvalidParam("deletePost", "channelId") + return + } + + postId := params["post_id"] + if len(postId) != 26 { + c.SetInvalidParam("listReactions", "postId") + return + } + + pchan := Srv.Store.Post().Get(postId) + + if !HasPermissionToChannelContext(c, channelId, model.PERMISSION_READ_CHANNEL) { + return + } + + if result := <-pchan; result.Err != nil { + c.Err = result.Err + return + } else if post := result.Data.(*model.PostList).Posts[postId]; post.ChannelId != channelId { + c.Err = model.NewLocAppError("listReactions", "api.reaction.list_reactions.mismatched_channel_id.app_error", + nil, "channelId="+channelId+", post.ChannelId="+post.ChannelId+", postId="+postId) + c.Err.StatusCode = http.StatusBadRequest + return + } + + if result := <-Srv.Store.Reaction().GetForPost(postId); result.Err != nil { + c.Err = result.Err + return + } else { + reactions := result.Data.([]*model.Reaction) + + w.Write([]byte(model.ReactionsToJson(reactions))) + } +} |