diff options
| author | Chris <ccbrown112@gmail.com> | 2018-03-02 10:49:18 -0600 |
|---|---|---|
| committer | Joram Wilander <jwawilander@gmail.com> | 2018-03-02 16:49:18 +0000 |
| commit | 4ebf9746905c845ee3874f87478d7450391680d8 (patch) | |
| tree | 03163cd0809b2ae8c11e774ea5fbec2dff9d4e59 /app/post.go | |
| parent | 2b3b6051d265edf131d006b2eb14f55284faf1e5 (diff) | |
| download | chat-4ebf9746905c845ee3874f87478d7450391680d8.tar.gz chat-4ebf9746905c845ee3874f87478d7450391680d8.tar.bz2 chat-4ebf9746905c845ee3874f87478d7450391680d8.zip | |
remove `go Publish(...)` idiom (#8373)
Diffstat (limited to 'app/post.go')
| -rw-r--r-- | app/post.go | 18 |
1 files changed, 4 insertions, 14 deletions
diff --git a/app/post.go b/app/post.go index a541797fa..5067777ab 100644 --- a/app/post.go +++ b/app/post.go @@ -84,9 +84,7 @@ func (a *App) CreatePostAsUser(post *model.Post) (*model.Post, *model.AppError) if *a.Config().ServiceSettings.EnableChannelViewedMessages { message := model.NewWebSocketEvent(model.WEBSOCKET_EVENT_CHANNEL_VIEWED, "", "", post.UserId, nil) message.Add("channel_id", post.ChannelId) - a.Go(func() { - a.Publish(message) - }) + a.Publish(message) } } @@ -314,10 +312,7 @@ func (a *App) SendEphemeralPost(userId string, post *model.Post) *model.Post { message := model.NewWebSocketEvent(model.WEBSOCKET_EVENT_EPHEMERAL_MESSAGE, "", post.ChannelId, userId, nil) message.Add("post", a.PostWithProxyAddedToImageURLs(post).ToJson()) - - a.Go(func() { - a.Publish(message) - }) + a.Publish(message) return post } @@ -424,10 +419,7 @@ func (a *App) PatchPost(postId string, patch *model.PostPatch) (*model.Post, *mo func (a *App) sendUpdatedPostEvent(post *model.Post) { message := model.NewWebSocketEvent(model.WEBSOCKET_EVENT_POST_EDITED, "", post.ChannelId, "", nil) message.Add("post", a.PostWithProxyAddedToImageURLs(post).ToJson()) - - a.Go(func() { - a.Publish(message) - }) + a.Publish(message) } func (a *App) GetPostsPage(channelId string, page int, perPage int) (*model.PostList, *model.AppError) { @@ -567,11 +559,9 @@ func (a *App) DeletePost(postId string) (*model.Post, *model.AppError) { message := model.NewWebSocketEvent(model.WEBSOCKET_EVENT_POST_DELETED, "", post.ChannelId, "", nil) message.Add("post", a.PostWithProxyAddedToImageURLs(post).ToJson()) + a.Publish(message) a.Go(func() { - a.Publish(message) - }) - a.Go(func() { a.DeletePostFiles(post) }) a.Go(func() { |