mirror of
https://github.com/mattermost/mattermost.git
synced 2025-02-25 18:55:24 -06:00
* Add mutex to model.Post to guard against race conditions on Post.Props * Rename mutex * Add GetProp() method to Post * Fix more tests * Fix flaky test Benchmarks: BenchmarkPostPropsGet_indirect BenchmarkPostPropsGet_indirect-2 85026746 13.0 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsGet_indirect-4 90273747 13.0 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsGet_indirect-8 88324293 13.0 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsGet_indirect-16 91427720 13.1 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsGet_direct BenchmarkPostPropsGet_direct-2 1000000000 0.242 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsGet_direct-4 1000000000 0.241 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsGet_direct-8 1000000000 0.240 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsGet_direct-16 1000000000 0.241 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsAdd_indirect BenchmarkPostPropsAdd_indirect-2 5602224 203 ns/op 336 B/op 2 allocs/op BenchmarkPostPropsAdd_indirect-4 5959496 206 ns/op 336 B/op 2 allocs/op BenchmarkPostPropsAdd_indirect-8 5833999 205 ns/op 336 B/op 2 allocs/op BenchmarkPostPropsAdd_indirect-16 5802493 225 ns/op 336 B/op 2 allocs/op BenchmarkPostPropsAdd_direct BenchmarkPostPropsAdd_direct-2 100000000 11.3 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsAdd_direct-4 100000000 11.3 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsAdd_direct-8 100000000 11.6 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsAdd_direct-16 99840794 11.4 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsDel_indirect BenchmarkPostPropsDel_indirect-2 18824002 61.9 ns/op 48 B/op 1 allocs/op BenchmarkPostPropsDel_indirect-4 19470736 63.8 ns/op 48 B/op 1 allocs/op BenchmarkPostPropsDel_indirect-8 17640460 65.3 ns/op 48 B/op 1 allocs/op BenchmarkPostPropsDel_indirect-16 18692962 65.4 ns/op 48 B/op 1 allocs/op BenchmarkPostPropsDel_direct BenchmarkPostPropsDel_direct-2 516257440 2.34 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsDel_direct-4 514865216 2.43 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsDel_direct-8 511330477 2.37 ns/op 0 B/op 0 allocs/op BenchmarkPostPropsDel_direct-16 499504010 2.38 ns/op 0 B/op 0 allocs/op
167 lines
2.9 KiB
Go
167 lines
2.9 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package model
|
|
|
|
import (
|
|
"encoding/json"
|
|
"io"
|
|
"sort"
|
|
)
|
|
|
|
type PostList struct {
|
|
Order []string `json:"order"`
|
|
Posts map[string]*Post `json:"posts"`
|
|
NextPostId string `json:"next_post_id"`
|
|
PrevPostId string `json:"prev_post_id"`
|
|
}
|
|
|
|
func NewPostList() *PostList {
|
|
return &PostList{
|
|
Order: make([]string, 0),
|
|
Posts: make(map[string]*Post),
|
|
NextPostId: "",
|
|
PrevPostId: "",
|
|
}
|
|
}
|
|
|
|
func (o *PostList) ToSlice() []*Post {
|
|
var posts []*Post
|
|
for _, id := range o.Order {
|
|
posts = append(posts, o.Posts[id])
|
|
}
|
|
return posts
|
|
}
|
|
|
|
func (o *PostList) WithRewrittenImageURLs(f func(string) string) *PostList {
|
|
copy := *o
|
|
copy.Posts = make(map[string]*Post)
|
|
for id, post := range o.Posts {
|
|
copy.Posts[id] = post.WithRewrittenImageURLs(f)
|
|
}
|
|
return ©
|
|
}
|
|
|
|
func (o *PostList) StripActionIntegrations() {
|
|
posts := o.Posts
|
|
o.Posts = make(map[string]*Post)
|
|
for id, post := range posts {
|
|
pcopy := post.Clone()
|
|
pcopy.StripActionIntegrations()
|
|
o.Posts[id] = pcopy
|
|
}
|
|
}
|
|
|
|
func (o *PostList) ToJson() string {
|
|
copy := *o
|
|
copy.StripActionIntegrations()
|
|
b, err := json.Marshal(©)
|
|
if err != nil {
|
|
return ""
|
|
} else {
|
|
return string(b)
|
|
}
|
|
}
|
|
|
|
func (o *PostList) MakeNonNil() {
|
|
if o.Order == nil {
|
|
o.Order = make([]string, 0)
|
|
}
|
|
|
|
if o.Posts == nil {
|
|
o.Posts = make(map[string]*Post)
|
|
}
|
|
|
|
for _, v := range o.Posts {
|
|
v.MakeNonNil()
|
|
}
|
|
}
|
|
|
|
func (o *PostList) AddOrder(id string) {
|
|
|
|
if o.Order == nil {
|
|
o.Order = make([]string, 0, 128)
|
|
}
|
|
|
|
o.Order = append(o.Order, id)
|
|
}
|
|
|
|
func (o *PostList) AddPost(post *Post) {
|
|
|
|
if o.Posts == nil {
|
|
o.Posts = make(map[string]*Post)
|
|
}
|
|
|
|
o.Posts[post.Id] = post
|
|
}
|
|
|
|
func (o *PostList) UniqueOrder() {
|
|
keys := make(map[string]bool)
|
|
order := []string{}
|
|
for _, postId := range o.Order {
|
|
if _, value := keys[postId]; !value {
|
|
keys[postId] = true
|
|
order = append(order, postId)
|
|
}
|
|
}
|
|
|
|
o.Order = order
|
|
}
|
|
|
|
func (o *PostList) Extend(other *PostList) {
|
|
for postId := range other.Posts {
|
|
o.AddPost(other.Posts[postId])
|
|
}
|
|
|
|
for _, postId := range other.Order {
|
|
o.AddOrder(postId)
|
|
}
|
|
|
|
o.UniqueOrder()
|
|
}
|
|
|
|
func (o *PostList) SortByCreateAt() {
|
|
sort.Slice(o.Order, func(i, j int) bool {
|
|
return o.Posts[o.Order[i]].CreateAt > o.Posts[o.Order[j]].CreateAt
|
|
})
|
|
}
|
|
|
|
func (o *PostList) Etag() string {
|
|
|
|
id := "0"
|
|
var t int64 = 0
|
|
|
|
for _, v := range o.Posts {
|
|
if v.UpdateAt > t {
|
|
t = v.UpdateAt
|
|
id = v.Id
|
|
} else if v.UpdateAt == t && v.Id > id {
|
|
t = v.UpdateAt
|
|
id = v.Id
|
|
}
|
|
}
|
|
|
|
orderId := ""
|
|
if len(o.Order) > 0 {
|
|
orderId = o.Order[0]
|
|
}
|
|
|
|
return Etag(orderId, id, t)
|
|
}
|
|
|
|
func (o *PostList) IsChannelId(channelId string) bool {
|
|
for _, v := range o.Posts {
|
|
if v.ChannelId != channelId {
|
|
return false
|
|
}
|
|
}
|
|
|
|
return true
|
|
}
|
|
|
|
func PostListFromJson(data io.Reader) *PostList {
|
|
var o *PostList
|
|
json.NewDecoder(data).Decode(&o)
|
|
return o
|
|
}
|