summaryrefslogtreecommitdiffstats
path: root/app/reaction.go
diff options
context:
space:
mode:
authorChris <ccbrown112@gmail.com>2017-09-06 17:12:54 -0500
committerGitHub <noreply@github.com>2017-09-06 17:12:54 -0500
commit1adfd0e9be69a93c7f63bb7afc742c9fafe31aa3 (patch)
tree2766bacc1f045fa685ca3d8310cd6174d0311d09 /app/reaction.go
parentb84bd21089d305333fa4114b95be70f5ad94ad1b (diff)
downloadchat-1adfd0e9be69a93c7f63bb7afc742c9fafe31aa3.tar.gz
chat-1adfd0e9be69a93c7f63bb7afc742c9fafe31aa3.tar.bz2
chat-1adfd0e9be69a93c7f63bb7afc742c9fafe31aa3.zip
app type transition (#7167)
Diffstat (limited to 'app/reaction.go')
-rw-r--r--app/reaction.go24
1 files changed, 12 insertions, 12 deletions
diff --git a/app/reaction.go b/app/reaction.go
index adb92476f..b6395745e 100644
--- a/app/reaction.go
+++ b/app/reaction.go
@@ -7,54 +7,54 @@ import (
"github.com/mattermost/platform/model"
)
-func SaveReactionForPost(reaction *model.Reaction) (*model.Reaction, *model.AppError) {
- post, err := GetSinglePost(reaction.PostId)
+func (a *App) SaveReactionForPost(reaction *model.Reaction) (*model.Reaction, *model.AppError) {
+ post, err := a.GetSinglePost(reaction.PostId)
if err != nil {
return nil, err
}
- if result := <-Srv.Store.Reaction().Save(reaction); result.Err != nil {
+ if result := <-a.Srv.Store.Reaction().Save(reaction); result.Err != nil {
return nil, result.Err
} else {
reaction = result.Data.(*model.Reaction)
- go sendReactionEvent(model.WEBSOCKET_EVENT_REACTION_ADDED, reaction, post)
+ go a.sendReactionEvent(model.WEBSOCKET_EVENT_REACTION_ADDED, reaction, post)
return reaction, nil
}
}
-func GetReactionsForPost(postId string) ([]*model.Reaction, *model.AppError) {
- if result := <-Srv.Store.Reaction().GetForPost(postId, true); result.Err != nil {
+func (a *App) GetReactionsForPost(postId string) ([]*model.Reaction, *model.AppError) {
+ if result := <-a.Srv.Store.Reaction().GetForPost(postId, true); result.Err != nil {
return nil, result.Err
} else {
return result.Data.([]*model.Reaction), nil
}
}
-func DeleteReactionForPost(reaction *model.Reaction) *model.AppError {
- post, err := GetSinglePost(reaction.PostId)
+func (a *App) DeleteReactionForPost(reaction *model.Reaction) *model.AppError {
+ post, err := a.GetSinglePost(reaction.PostId)
if err != nil {
return err
}
- if result := <-Srv.Store.Reaction().Delete(reaction); result.Err != nil {
+ if result := <-a.Srv.Store.Reaction().Delete(reaction); result.Err != nil {
return result.Err
} else {
- go sendReactionEvent(model.WEBSOCKET_EVENT_REACTION_REMOVED, reaction, post)
+ go a.sendReactionEvent(model.WEBSOCKET_EVENT_REACTION_REMOVED, reaction, post)
}
return nil
}
-func sendReactionEvent(event string, reaction *model.Reaction, post *model.Post) {
+func (a *App) sendReactionEvent(event string, reaction *model.Reaction, post *model.Post) {
// send out that a reaction has been added/removed
message := model.NewWebSocketEvent(event, "", post.ChannelId, "", nil)
message.Add("reaction", reaction.ToJson())
Publish(message)
// The post is always modified since the UpdateAt always changes
- InvalidateCacheForChannelPosts(post.ChannelId)
+ a.InvalidateCacheForChannelPosts(post.ChannelId)
post.HasReactions = true
post.UpdateAt = model.GetMillis()
umessage := model.NewWebSocketEvent(model.WEBSOCKET_EVENT_POST_EDITED, "", post.ChannelId, "", nil)